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;
		}
	}
}