using System;
using System.Collections.Generic;
using System.Threading;
using UnityEngine;

public class ConsoleOutputSeparator
{
	public struct AllocsTelnetCommand
	{
		public string command;
		public AllocsTelnetConnection client;

		public AllocsTelnetCommand (string _cmd, AllocsTelnetConnection _client)
		{
			command = _cmd;
			client = _client;
		}
	}

	private static List<AllocsTelnetCommand> telnetCommandQueue = new List<AllocsTelnetCommand> ();
	private static bool isCurrentCommandFromClient = false;
	private static AllocsTelnetConnection issuerOfCurrentTelnetCommand;

	public static void C_ExecuteCmdFromClient (ConsoleSdtd console, NetworkPlayer _networkPlayer, string _playerID, string _command)
	{
		Log.Out ("Executed command \"" + _command + "\" from player \"" + _playerID + "\"");

		object obj = telnetCommandQueue;
		Monitor.Enter (obj);
		try {
			isCurrentCommandFromClient = true;
			console.issuerOfCurrentClientCommand = _networkPlayer;
			console.ExecuteClientCmdInternal (_playerID, _command);
			isCurrentCommandFromClient = false;
		} finally {
			Monitor.Exit (obj);
		}

	}

	public static void C_SendResult (ConsoleSdtd console, string _line)
	{
		if (isCurrentCommandFromClient) {
			console.gameManager.GetRPCNetworkView ().RPC ("RPC_Console", console.issuerOfCurrentClientCommand, new object[]
			{
				_line,
				false
			}
			);
		} else {
			if (console.telnetServer != null && issuerOfCurrentTelnetCommand != null)
				AllocsNetTelnetServer.WriteToClient (_line, issuerOfCurrentTelnetCommand);
			else if (ControlPanel.IsStarted ())
				ControlPanel.AddTextToOutputBuffer (_line);
		}
	}

	public static void C_Run (ConsoleSdtd console)
	{
		if (telnetCommandQueue.Count > 0) {
			object obj = telnetCommandQueue;
			Monitor.Enter (obj);
			try {
				issuerOfCurrentTelnetCommand = telnetCommandQueue [0].client;
				console.ExecuteRemoteCmdInternal (telnetCommandQueue [0].command, false);
				telnetCommandQueue.RemoveAt (0);
				issuerOfCurrentTelnetCommand = null;
			} finally {
				Monitor.Exit (obj);
			}
		}
	}

	public static void QueueTelnetCommand (string _line, AllocsTelnetConnection _con)
	{
		object obj = telnetCommandQueue;
		Monitor.Enter (obj);
		try {
			telnetCommandQueue.Add (new AllocsTelnetCommand (_line, _con));
		} finally {
			Monitor.Exit (obj);
		}
	}
}