// ClassicalSharp copyright 2014-2016 UnknownShadow200 | Licensed under MIT
using System;
using System.Collections.Generic;
using System.Net;
using System.Threading;
using JsonObject = System.Collections.Generic.Dictionary<string, object>;

namespace Launcher.Web {
	
	public sealed class ClassicubeSession : IWebTask {
		
		const string classicubeNetUri = "https://www.classicube.net/",
		loginUri = "https://www.classicube.net/api/login/",
		publicServersUri = "https://www.classicube.net/api/servers",
		playUri = "https://www.classicube.net/api/server/";
		const string wrongCredentialsMessage = "Login failed";
		const string loggedInAs = @"<a href=""/acc"" class=""button"">";
		
		public List<ServerListEntry> Servers = new List<ServerListEntry>();
		
		public void LoginAsync(string user, string password) {
			Username = user;
			Working = true;
			Done = false;
			Exception = null;
			Status = "&eSigning in..";
			Servers = new List<ServerListEntry>();
			
			Thread thread = new Thread(LoginWorker, 256 * 1024);
			thread.Name = "Launcher.CCLoginAsync";
			thread.Start(password);
		}
		
		void LoginWorker(object password) {
			// Sign in to classicube.net
			try {
				Login(Username, (string)password);
			} catch (WebException ex) {
				Finish(false, ex, "sign in"); return;
			} catch (InvalidOperationException ex) {
				Finish(false, null, "&c" + ex.Message); return;
			}
			
			// Retrieve list of public servers
			Status = "&eRetrieving public servers list..";
			try {
				Servers = GetPublicServers();
			} catch (WebException ex) {
				Servers = new List<ServerListEntry>();
				Finish(false, ex, "retrieving servers list"); return;
			}
			Finish(true, null, "&eSigned in");
		}
		
		void Login(string user, string password) {
			Username = user;
			// Step 1: GET csrf token from login page.
			var swGet = System.Diagnostics.Stopwatch.StartNew();
			string getResponse = GetHtmlAll(loginUri, classicubeNetUri);
			int index = 0; bool success = true;
			JsonObject data = (JsonObject)Json.ParseValue(getResponse, ref index, ref success);
			string token = (string)data["token"];
			
			// Step 2: POST to login page with csrf token.
			string loginData = String.Format(
				"username={0}&password={1}&token={2}",
				Uri.EscapeDataString(user),
				Uri.EscapeDataString(password),
				Uri.EscapeDataString(token)
			);
			Log("cc login took " + swGet.ElapsedMilliseconds);
			
			var sw = System.Diagnostics.Stopwatch.StartNew();
			string response = PostHtmlAll(loginUri, loginUri, loginData);
			index = 0; success = true;
			data = (JsonObject)Json.ParseValue(response, ref index, ref success);
			
			List<object> errors = (List<object>)data["errors"];
			if (errors.Count > 0 || (data.ContainsKey("username") && data["username"] == null))
				throw new InvalidOperationException("Wrong username or password.");
			
			Username = (string)data["username"];
			Log("cc login took " + sw.ElapsedMilliseconds);
			sw.Stop();
		}
		
		public ClientStartData GetConnectInfo(string hash) {
			string uri = playUri + hash;
			string response = GetHtmlAll(uri, classicubeNetUri);
			
			int index = 0; bool success = true;
			JsonObject root = (JsonObject)Json.ParseValue(response, ref index, ref success);
			List<object> list = (List<object>)root["servers"];
			
			JsonObject obj = (JsonObject)list[0];
			return new ClientStartData(Username, (string)obj["mppass"], 
			                           (string)obj["ip"], (string)obj["port"]);
		}
		
		public List<ServerListEntry> GetPublicServers() {
			var sw = System.Diagnostics.Stopwatch.StartNew();
			List<ServerListEntry> servers = new List<ServerListEntry>();
			string response = GetHtmlAll(publicServersUri, classicubeNetUri);
			int index = 0; bool success = true;
			JsonObject root = (JsonObject)Json.ParseValue(response, ref index, ref success);
			List<object> list = (List<object>)root["servers"];
			
			foreach (object server in list) {
				JsonObject obj = (JsonObject)server;
				servers.Add(new ServerListEntry(
					(string)obj["hash"], (string)obj["name"],
					(string)obj["players"], (string)obj["maxplayers"],
					(string)obj["uptime"], (string)obj["mppass"],
					(string)obj["ip"], (string)obj["port"],
					(string)obj["software"]));
			}
			Log("cc servers took " + sw.ElapsedMilliseconds);
			sw.Stop();
			return servers;
		}
	}
}