namespace Oculus.Platform.Samples.NetChat
{
	using UnityEngine;
	using UnityEngine.UI;
	using System;
	using System.IO;
	using System.Collections.Generic;
	using Oculus.Platform;
	using Oculus.Platform.Models;

	enum states
	{
		NOT_INIT = 0,
		IDLE,
		REQUEST_FIND,
		FINDING_ROOM,
		REQUEST_CREATE,
		REQUEST_JOIN,
		REQUEST_LEAVE,
		IN_EMPTY_ROOM,
		IN_FULL_ROOM
	}

	// Pools are defined on the Oculus developer portal
	//
	// For this test we have a pool created with the pool key set as 'filter_pool'
	// Mode is set to 'Room'
	// Skill Pool is set to 'None'
	// We are not considering Round Trip Time
	// The following Data Settings are set:
	//  key: map_name, Type: STRING, String options: Small_Map, Big_Map, Really_Big_Map
	//  key: game_type, Type: STRING, String Options: deathmatch, CTF
	//
	// We also have the following two queries defined:
	//  Query Key: map
	//  Template: Set (String)
	//  Key: map_name
	//  Wildcards: map_param_1, map_param_2
	//
	//  Query Key: game_type
	//  Template: Set (String)
	//  Key: game_type_name
	//  Wildcards: game_type_param
	//
	// For this test we have a pool created with the pool key set as 'bout_pool'
	// Mode is set to 'Bout'
	// Skill Pool is set to 'None'
	// We are not considering Round Trip Time
	// No Data Settings are set:
	//

	public static class Constants
	{
		public const int BUFFER_SIZE = 512;
		public const string BOUT_POOL = "bout_pool";
		public const string FILTER_POOL = "filter_pool";
	}

	public class chatPacket
	{
		public int packetID { get; set; }
		public string textString { get; set;  }

		public byte[] Serialize()
		{
			using (MemoryStream m = new MemoryStream())
			{
				using (BinaryWriter writer = new BinaryWriter(m))
				{
					// Limit our string to BUFFER_SIZE
					if (textString.Length > Constants.BUFFER_SIZE)
					{
						textString = textString.Substring(0, Constants.BUFFER_SIZE-1);
					}
					writer.Write(packetID);
					writer.Write(textString.ToCharArray());
					writer.Write('\0');
				}
				return m.ToArray();
			}
		}

		public static chatPacket Deserialize(byte[] data)
		{
			chatPacket result = new chatPacket();
			using (MemoryStream m = new MemoryStream(data))
			{
				using (BinaryReader reader = new BinaryReader(m))
				{
					result.packetID = reader.ReadInt32();
					result.textString = System.Text.Encoding.Default.GetString(reader.ReadBytes(Constants.BUFFER_SIZE));
				}
			}
			return result;
		}
	}

	public class DataEntry : MonoBehaviour {

		public Text dataOutput;

		states currentState;
		User localUser;
		User remoteUser;
		Room currentRoom;
		int lastPacketID;
		bool ratedMatchStarted;

		// Use this for initialization
		void Start () {
			currentState = states.NOT_INIT;
			localUser = null;
			remoteUser = null;
			currentRoom = null;
			lastPacketID = 0;
			ratedMatchStarted = false;

			Core.Initialize();

			// Setup our room update handler
			Rooms.SetUpdateNotificationCallback(updateRoom);
			// Setup our match found handler
			Matchmaking.SetMatchFoundNotificationCallback(foundMatch);

			checkEntitlement();

		}

		// Update is called once per frame
		void Update()
		{
			string currentText = GetComponent<InputField>().text;

			if (Input.GetKey(KeyCode.Return))
			{
				if (currentText != "")
				{
					SubmitCommand(currentText);
				}

				GetComponent<InputField>().text = "";
			}

			processNetPackets();
			// Handle all messages being returned
			Request.RunCallbacks();
		}

		void SubmitCommand(string command)
		{
			string[] commandParams = command.Split('!');

			if (commandParams.Length > 0)
			{
				switch (commandParams[0])
				{
					case "c":
						requestCreateRoom();
						break;
					case "d":
						requestCreateFilterRoom();
						break;
					case "f":
						requestFindMatch();
						break;
					case "g":
						requestFindRoom();
						break;
					case "i":
						requestFindFilteredRoom();
						break;
					case "s":
						if (commandParams.Length > 1)
						{
							sendChat(commandParams[1]);
						}
						break;
					case "l":
						requestLeaveRoom();
						break;
					case "1":
						requestStartRatedMatch();
						break;
					case "2":
						requestReportResults();
						break;
					default:
						printOutputLine("Invalid Command");
						break;
				}
			}
		}

		void printOutputLine(String newLine)
		{
			dataOutput.text = "> " + newLine + System.Environment.NewLine + dataOutput.text;
		}

		void checkEntitlement()
		{
			Entitlements.IsUserEntitledToApplication().OnComplete(getEntitlementCallback);
		}

		void getEntitlementCallback(Message msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("You are entitled to use this app.");
				Users.GetLoggedInUser().OnComplete(init);
			}
			else
			{
				printOutputLine("You are NOT entitled to use this app.");
			}
		}

		void init(Message<User> msg)
		{
			if (!msg.IsError)
			{
				User user = msg.Data;
				localUser = user;

				currentState = states.IDLE;
			}
			else
			{
				printOutputLine("Received get current user error");
				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);

				// Retry getting the current user
				Users.GetLoggedInUser().OnComplete(init);
				currentState = states.NOT_INIT;
			}
		}

		void requestCreateRoom()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;
				case states.IDLE:
					printOutputLine("Trying to create a matchmaking room");
					Matchmaking.CreateAndEnqueueRoom(Constants.FILTER_POOL, 8, true, null).OnComplete(createRoomResponse);
					currentState = states.REQUEST_CREATE;
					break;
				case states.REQUEST_FIND:
					printOutputLine("You have already made a request to find a room.  Please wait for that request to complete.");
					break;
				case states.FINDING_ROOM:
					printOutputLine("You have already currently looking for a room.  Please wait for the match to be made.");
					break;
				case states.REQUEST_JOIN:
					printOutputLine("We are currently trying to join a room.  Please wait to see if we can join it.");
					break;            
				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.");
					break;
				case states.REQUEST_CREATE:
					printOutputLine("You have already requested a matchmaking room to be created.  Please wait for the room to be made.");
					break;
				case states.IN_EMPTY_ROOM:
					printOutputLine("You have already in a matchmaking room.  Please wait for an opponent to join.");
					break;
				case states.IN_FULL_ROOM:
					printOutputLine("You have already in a match.");
					break;
				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void createRoomResponse(Message<MatchmakingEnqueueResultAndRoom> msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Received create matchmaking room success");
				Room room = msg.Data.Room;
				currentRoom = room;

				printOutputLine("RoomID: " + room.ID.ToString());
				currentState = states.IN_EMPTY_ROOM;
			}
			else
			{
				printOutputLine("Received create matchmaking room Error");
				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
				printOutputLine("You can only create a matchmaking room for pools of mode Room.  Make sure you have an appropriate pool setup on the Developer portal.\n");
				currentState = states.IDLE;
			}
		}

		void requestCreateFilterRoom()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.\n");
					break;

				case states.IDLE:
					printOutputLine("Trying to create a matchmaking room");

					// We're going to create a room that has the following values set:
					// game_type_name = "CTF"
					// map_name = "Really_Big_Map"
					//

					Matchmaking.CustomQuery roomCustomQuery = new Matchmaking.CustomQuery();

					roomCustomQuery.criteria = null;
					roomCustomQuery.data = new Dictionary<string, object>();

					roomCustomQuery.data.Add("game_type_name", "CTF");
					roomCustomQuery.data.Add("map_name", "Really_Big_Map");

					Matchmaking.CreateAndEnqueueRoom(Constants.FILTER_POOL, 8, true, roomCustomQuery).OnComplete(createRoomResponse);
					currentState = states.REQUEST_CREATE;
					break;

				case states.REQUEST_FIND:
					printOutputLine("You have already made a request to find a room.  Please wait for that request to complete.\n");
					break;
				case states.FINDING_ROOM:
					printOutputLine("You have already currently looking for a room.  Please wait for the match to be made.\n");
					break;
				case states.REQUEST_JOIN:
					printOutputLine("We are currently trying to join a room.  Please wait to see if we can join it.\n");
					break;
				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.\n");
					break;
				case states.REQUEST_CREATE:
					printOutputLine("You have already requested a matchmaking room to be created.  Please wait for the room to be made.\n");
					break;
				case states.IN_EMPTY_ROOM:
					printOutputLine("You have already in a matchmaking room.  Please wait for an opponent to join.\n");
					break;
				case states.IN_FULL_ROOM:
					printOutputLine("You have already in a match.\n");
					break;
				default:
					printOutputLine("You have hit an unknown state.\n");
					break;
			}
		}

		void requestFindRoom()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
					printOutputLine("\nTrying to find a matchmaking room\n");

					Matchmaking.Enqueue(Constants.FILTER_POOL, null).OnComplete(searchingStarted);
					currentState = states.REQUEST_FIND;
					break;

				case states.REQUEST_FIND:
					printOutputLine("You have already made a request to find a room.  Please wait for that request to complete.");
					break;

				case states.FINDING_ROOM:
					printOutputLine("You have already currently looking for a room.  Please wait for the match to be made.");
					break;

				case states.REQUEST_JOIN:
					printOutputLine("We are currently trying to join a room.  Please wait to see if we can join it.");
					break;

				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.");
					break;

				case states.REQUEST_CREATE:
					printOutputLine("You have already requested a matchmaking room to be created.  Please wait for the room to be made.");
					break;

				case states.IN_EMPTY_ROOM:
					printOutputLine("You have already in a matchmaking room.  Please wait for an opponent to join.");
					break;

				case states.IN_FULL_ROOM:
					printOutputLine("You have already in a match.");
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void requestFindFilteredRoom()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
					printOutputLine("Trying to find a matchmaking room");

					// Our search filter criterion
					//
					// We're filtering using two different queries setup on the developer portal
					//
					// map - query to filter by map.  The query allows you to filter with up to two different maps using keys called 'map_1' and 'map_2'
					// game_type - query to filter by game type.  The query allows you to filter with up to two different game types using keys called 'type_1' and 'type_2'
					//
					// In the example below we are filtering for matches that are of type CTF and on either Big_Map or Really_Big_Map.
					//

					Matchmaking.CustomQuery roomCustomQuery = new Matchmaking.CustomQuery();
					Matchmaking.CustomQuery.Criterion[] queries = new Matchmaking.CustomQuery.Criterion[2];

					queries[0].key = "map";
					queries[0].importance = MatchmakingCriterionImportance.Required;
					queries[0].parameters = new Dictionary<string, object>();
					queries[0].parameters.Add("map_param_1","Really_Big_Map");
					queries[0].parameters.Add("map_param_2", "Big_Map");

					queries[1].key = "game_type";
					queries[1].importance = MatchmakingCriterionImportance.Required;
					queries[1].parameters = new Dictionary<string, object>();
					queries[1].parameters.Add("game_type_param", "CTF");

					roomCustomQuery.criteria = queries;
					roomCustomQuery.data = null;

					Matchmaking.Enqueue(Constants.FILTER_POOL, roomCustomQuery);
					currentState = states.REQUEST_FIND;
					break;

				case states.REQUEST_FIND:
					printOutputLine("You have already made a request to find a room.  Please wait for that request to complete.");
					break;

				case states.FINDING_ROOM:
					printOutputLine("You have already currently looking for a room.  Please wait for the match to be made.");
					break;

				case states.REQUEST_JOIN:
					printOutputLine("We are currently trying to join a room.  Please wait to see if we can join it.");
					break;

				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.");
					break;

				case states.REQUEST_CREATE:
					printOutputLine("You have already requested a matchmaking room to be created.  Please wait for the room to be made.");
					break;

				case states.IN_EMPTY_ROOM:
					printOutputLine("You have already in a matchmaking room.  Please wait for an opponent to join.");
					break;

				case states.IN_FULL_ROOM:
					printOutputLine("You have already in a match.");
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void foundMatch(Message<Room> msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Received find match success. We are now going to request to join the room.");
				Room room = msg.Data;

				Rooms.Join(room.ID, true).OnComplete(joinRoomResponse);
				currentState = states.REQUEST_JOIN;
			}
			else
			{
				printOutputLine("Received find match error");
				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
				currentState = states.IDLE;
			}
		}

		void joinRoomResponse(Message<Room> msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Received join room success.");
				currentRoom = msg.Data;

				currentState = states.IN_EMPTY_ROOM;

				// Try to pull out remote user's ID if they have already joined
				if (currentRoom.UsersOptional != null)
				{
					foreach (User element in currentRoom.UsersOptional)
					{
						if (element.ID != localUser.ID)
						{
							remoteUser = element;
							currentState = states.IN_FULL_ROOM;
						}
					}
				}
			}
			else
			{
				printOutputLine("Received join room error");
				printOutputLine("It's possible the room filled up before you could join it.");

				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
				currentState = states.IDLE;
			}
		}

		void requestFindMatch()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;
				case states.IDLE:
					printOutputLine("Trying to find a matchmaking room");
					Matchmaking.Enqueue(Constants.BOUT_POOL, null).OnComplete(searchingStarted);
					currentState = states.REQUEST_FIND;
					break;
				case states.REQUEST_FIND:
					printOutputLine("You have already made a request to find a room.  Please wait for that request to complete.");
					break;
				case states.FINDING_ROOM:
					printOutputLine("You have already currently looking for a room.  Please wait for the match to be made.");
					break;
				case states.REQUEST_JOIN:
					printOutputLine("We are currently trying to join a room.  Please wait to see if we can join it.");
					break;
				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.");
					break;
				case states.REQUEST_CREATE:
					printOutputLine("You have already requested a matchmaking room to be created.  Please wait for the room to be made.");
					break;
				case states.IN_EMPTY_ROOM:
					printOutputLine("You have already in a matchmaking room.  Please wait for an opponent to join.");
					break;
				case states.IN_FULL_ROOM:
					printOutputLine("You have already in a match.");
					break;
				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void searchingStarted(Message msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Searching for a match successfully started");
				currentState = states.REQUEST_FIND;
			}
			else
			{
				printOutputLine("Searching for a match error");

				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
			}
		}

		void updateRoom(Message<Room> msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Received room update notification");
				Room room = msg.Data;

				if (currentState == states.IN_EMPTY_ROOM)
				{
					// Check to see if this update is another user joining
					if (room.UsersOptional != null)
					{
						foreach (User element in room.UsersOptional)
						{
							if (element.ID != localUser.ID)
							{
								remoteUser = element;
								currentState = states.IN_FULL_ROOM;
							}
						}
					}
				}
				else
				{
					// Check to see if this update is another user leaving
					if (room.UsersOptional != null && room.UsersOptional.Count == 1)
					{
						printOutputLine("User ID: " + remoteUser.ID.ToString() + "has left");
						remoteUser = null;
						currentState = states.IN_EMPTY_ROOM;
					}
				}
			}
			else
			{
				printOutputLine("Received room update error");

				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
			}
		}

		void sendChat(string chatMessage)
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
				case states.REQUEST_FIND:
				case states.FINDING_ROOM:
				case states.REQUEST_JOIN:
				case states.REQUEST_CREATE:
				case states.REQUEST_LEAVE:
				case states.IN_EMPTY_ROOM:
					printOutputLine("You need to be in a room with another player to send a message.");
					break;

				case states.IN_FULL_ROOM:
					{
						chatPacket newMessage = new chatPacket();

						// Create a packet to send with the packet ID and string payload
						lastPacketID++;
						newMessage.packetID = lastPacketID;
						newMessage.textString = chatMessage;

						Oculus.Platform.Net.SendPacket(remoteUser.ID, newMessage.Serialize(), SendPolicy.Reliable);
					}
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void processNetPackets()
		{
			Packet incomingPacket = Net.ReadPacket();

			while (incomingPacket != null)
			{
				byte[] rawBits = new byte[incomingPacket.Size];
				incomingPacket.ReadBytes(rawBits);

				chatPacket newMessage = chatPacket.Deserialize(rawBits);

				printOutputLine("Chat Text: " + newMessage.textString.ToString());
				printOutputLine("Received Packet from UserID: " + incomingPacket.SenderID.ToString());
				printOutputLine("Received Packet ID: " + newMessage.packetID.ToString());

				// Look to see if there's another packet waiting
				incomingPacket = Net.ReadPacket();
			}
		}

		void requestLeaveRoom()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
				case states.REQUEST_FIND:
				case states.FINDING_ROOM:
				case states.REQUEST_JOIN:
				case states.REQUEST_CREATE:
					printOutputLine("You are currently not in a room to leave.");
					break;

				case states.REQUEST_LEAVE:
					printOutputLine("We are currently trying to leave a room.  Please wait to see if we can leave it.");
					break;

				case states.IN_EMPTY_ROOM:
				case states.IN_FULL_ROOM:
					printOutputLine("Trying to leave room.");
					Rooms.Leave(currentRoom.ID).OnComplete(leaveRoomResponse);
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void leaveRoomResponse(Message<Room> msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("We were able to leave the room");
				currentRoom = null;
				remoteUser = null;
				currentState = states.IDLE;
			}
			else
			{
				printOutputLine("Leave room error");

				Error error = msg.GetError();
				printOutputLine("Error: " + error.Message);
			}

		}

		void requestStartRatedMatch()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
				case states.REQUEST_FIND:
				case states.FINDING_ROOM:
				case states.REQUEST_JOIN:
				case states.REQUEST_CREATE:
				case states.REQUEST_LEAVE:
				case states.IN_EMPTY_ROOM:
					printOutputLine("You need to be in a room with another player to start a rated match.");
					break;

				case states.IN_FULL_ROOM:
					printOutputLine("Trying to start a rated match.  This call should be made once a rated match begins so we will be able to submit results after the game is done.");

					Matchmaking.StartMatch(currentRoom.ID).OnComplete(startRatedMatchResponse);
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void startRatedMatchResponse(Message msg)
		{
			if(!msg.IsError)
			{
				printOutputLine("Started a rated match");
				ratedMatchStarted = true;
			}
			else
			{
				Error error = msg.GetError();
				printOutputLine("Received starting rated match failure: " + error.Message);
				printOutputLine("Your matchmaking pool needs to have a skill pool associated with it to play rated matches");
			}
		}

		void requestReportResults()
		{
			switch (currentState)
			{
				case states.NOT_INIT:
					printOutputLine("The app has not initialized properly and we don't know your userID.");
					break;

				case states.IDLE:
				case states.REQUEST_FIND:
				case states.FINDING_ROOM:
				case states.REQUEST_JOIN:
				case states.REQUEST_CREATE:
				case states.REQUEST_LEAVE:
					printOutputLine("You need to be in a room with another player to report results on a rated match.");
					break;

				case states.IN_EMPTY_ROOM:
				case states.IN_FULL_ROOM:
					if (ratedMatchStarted)
					{
						printOutputLine("Submitting rated match results.");

						Dictionary <string, int> results = new Dictionary<string, int>();
						results.Add(localUser.ID.ToString(), 1);
						results.Add(remoteUser.ID.ToString(), 2);

						Matchmaking.ReportResultsInsecure(currentRoom.ID, results).OnComplete(reportResultsResponse);
					}
					else
					{
						printOutputLine("You can't report results unless you've already started a rated match");
					}
					break;

				default:
					printOutputLine("You have hit an unknown state.");
					break;
			}
		}

		void reportResultsResponse(Message msg)
		{
			if (!msg.IsError)
			{
				printOutputLine("Rated match results reported. Now attempting to leave room.");
				ratedMatchStarted = false;
				requestLeaveRoom();
			}
			else
			{
				Error error = msg.GetError();
				printOutputLine("Received reporting rated match failure: " + error.Message);
			}
		}
	}
}