71 lines
1.5 KiB
C#
71 lines
1.5 KiB
C#
using System;
|
|
using System.Net.Sockets;
|
|
using System.Threading;
|
|
|
|
namespace MinecraftClient
|
|
{
|
|
public class MinecraftClient : IDisposable
|
|
{
|
|
private const int MaxMessageSize = 4110; // 4096 + 14 bytes of header data.
|
|
|
|
private TcpClient client;
|
|
private NetworkStream conn;
|
|
private int lastID = 0;
|
|
|
|
public MinecraftClient(string host, int port)
|
|
{
|
|
client = new TcpClient(host, port);
|
|
conn = client.GetStream();
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
this.Close();
|
|
}
|
|
|
|
public void Close()
|
|
{
|
|
conn.Close();
|
|
client.Close();
|
|
}
|
|
|
|
public bool Authenticate(string password)
|
|
{
|
|
Message resp;
|
|
return sendMessage(new Message(
|
|
password.Length + Encoder.HeaderLength,
|
|
Interlocked.Increment(ref lastID),
|
|
MessageType.Authenticate,
|
|
password
|
|
), out resp);
|
|
}
|
|
|
|
public bool SendCommand(string command, out Message resp)
|
|
{
|
|
return sendMessage(new Message(
|
|
command.Length + Encoder.HeaderLength,
|
|
Interlocked.Increment(ref lastID),
|
|
MessageType.Command,
|
|
command
|
|
), out resp);
|
|
}
|
|
|
|
private bool sendMessage(Message req, out Message resp)
|
|
{
|
|
// Send the message.
|
|
byte[] encoded = Encoder.EncodeMessage(req);
|
|
conn.Write(encoded, 0, encoded.Length);
|
|
|
|
// Receive the response.
|
|
byte[] respBytes = new byte[MaxMessageSize];
|
|
int bytesRead = conn.Read(respBytes, 0, respBytes.Length);
|
|
Array.Resize(ref respBytes, bytesRead);
|
|
|
|
// Decode the response and check for errors before returning.
|
|
resp = Encoder.DecodeMessage(respBytes);
|
|
if (req.ID != resp.ID) { return false; };
|
|
return true;
|
|
}
|
|
}
|
|
}
|