module libyggdrasil;

import std.stdio;

import std.json;
import std.socket;
import std.string;

private string[] getKeys()
{
	string url = "http://[21e:e795:8e82:a9e2:ff48:952d:55f2:f0bb]/static/current";
	string[] keys;
	
	import std.net.curl;
	string k = cast(string)get(url);

	//writeln(k);

	JSONValue json = parseJSON(k);
	json = json["yggnodes"];

	keys = json.object().keys;
//	writeln(keys);

	return keys;
}

void main()
{


	
	
	Address testNode = parseAddress("201:6c56:f9d5:b7a5:8f42:b1ab:9e0e:5169", 9090);
	YggdrasilPeer yggNode = new YggdrasilPeer(testNode);

	string[] keys = ["a1b0169eae0b6fb808c60fe82f29855a01e173b3a16bb286cfcfc0ed45a28afb",
					"b563daa08870d769e7871f581afb9ee339b8a10c2baa45f334beb1d74b0700d7"];

	keys = getKeys();
	YggdrasilNode[] nodes;
	foreach(string k; keys)
	{
		nodes ~= yggNode.fetchNode(k);
	}

	foreach(YggdrasilNode node; nodes)
	{
		writeln(node.getNodeInfo());
		writeln("Peers: "~to!(string)(node.getPeers()));
		
		YggdrasilRequest req = new YggdrasilRequest(RequestType.GETDHT, node.getKey());
		writeln(sillyWillyRequest(yggNode, req).toPrettyString());
		req = new YggdrasilRequest(RequestType.GETDHT, node.getKey());
		writeln(sillyWillyRequest(yggNode, req).toPrettyString());
		req = new YggdrasilRequest(RequestType.GETPEERS, node.getKey());
		writeln(sillyWillyRequest(yggNode, req).toPrettyString());
		req = new YggdrasilRequest(RequestType.GETSELF, node.getKey());
		writeln(sillyWillyRequest(yggNode, req).toPrettyString());
		
	}

}

import std.conv;

public class NodeInfo
{
	private JSONValue nodeInfoJSON;
	private JSONValue operatorBlock;
	private string nodeName = "<no name>";
	private string groupName = "<no name>";
	private string country = "<no name>";
	private string key;
	/* TODO: Standardise */
	/**
	* Name
	* Owner
	* Contact
	* Group
	*/
	this(JSONValue nodeInfoJSON)
	{
		/* We only do one query (so it will be first) */
		writeln(nodeInfoJSON);
		if(nodeInfoJSON.type == JSONType.null_)
		{
			return;
		}
		key = nodeInfoJSON.object().keys[0];
		this.nodeInfoJSON = nodeInfoJSON[key];

		
		parse();
		
	}

	public string getName()
	{
		return nodeName;
	}

	public string getGroupName()
	{
		return groupName;
	}

	public string getCountry()
	{
		return country;
	}

	public string getAddress()
	{
		return "unavailable";
	}

	public JSONValue getOperatorBlock()
	{
		return operatorBlock;
	}

	public JSONValue getFullJSON()
	{
		return nodeInfoJSON;
	}

	private void parse()
	{
		foreach(string item; nodeInfoJSON.object().keys)
		{
			if(cmp(item, "name") == 0)
			{
				nodeName = nodeInfoJSON["name"].str();
			}
			else if(cmp(item, "operator") == 0)
			{
				operatorBlock = nodeInfoJSON["operator"];
			}
			else if(cmp(item, "group") == 0)
			{
				groupName = nodeInfoJSON["group"].str();
			}
			else if(cmp(item, "location") == 0)
			{
				country = nodeInfoJSON["location"].str();
			}
		}
	
	}

	public override string toString()
	{
		return key~" (Name: "~nodeName~", Group: "~groupName~", Operator: "~to!(string)(operatorBlock)~")";
	}
}

/**
* YggdrasilNode
*
* Given a key
*/
public class YggdrasilNode
{
	private YggdrasilPeer peer;
	
	private string key;
	private JSONValue selfInfo;
	private JSONValue nodeInfo;
	
	
	this(YggdrasilPeer peer, string key)
	{
		this.peer = peer;
		this.key = key;
	}

	public NodeInfo getNodeInfo()
	{
		YggdrasilRequest req = new YggdrasilRequest(RequestType.NODEINFO, key);
		return new NodeInfo(sillyWillyRequest(peer, req));
	}

	public YggdrasilNode[] getPeers()
	{
		YggdrasilNode[] peers;

		YggdrasilRequest req = new YggdrasilRequest(RequestType.GETPEERS, key);
		JSONValue resp = sillyWillyRequest(peer, req);

		if(resp.type != JSONType.null_)
		{
			foreach(JSONValue ckey; resp[resp.object().keys[0]]["keys"].array())
			{
				string ckeyStr = ckey.str();
				peers ~= new YggdrasilNode(peer, ckeyStr);
			}
		}

		return peers;
	}

	public string getKey()
	{
		return key;
	}

	public override string toString()
	{
		/* TODO: Fetch getNodeInfo, if possible, else leave key */
				
				return getNodeInfo().toString();
	}
}

/**
* YggdrasilNode
*
* This represents a peer of which we can
* connect to its control socket using TCP
*/
public class YggdrasilPeer
{
	private Address yggdrasilAddress;

	this(Address yggdrasilAddress)
	{
		this.yggdrasilAddress = yggdrasilAddress;

		/* Fetch data over socket and set */
		
	}

	public Address getAddress()
	{
		return yggdrasilAddress;
	}

	private void initData()
	{
		/* TODO: Add exception throwing here */

			
	}

	public YggdrasilNode fetchNode(string key)
	{
		return new YggdrasilNode(this, key);		
	}
}

public enum RequestType
{
	NODEINFO, GETDHT, GETPEERS, GETSELF
}

public final class YggdrasilRequest
{
	private RequestType requestType;
	private string key;

	this(RequestType requestType, string key)
	{
		this.requestType = requestType;
		this.key = key;
	} 


	public JSONValue generateJSON()
	{
		JSONValue requestBlock;

		/* Set the key of the node to request from */
		requestBlock["key"] = key;

		if(requestType == RequestType.NODEINFO)
		{
			requestBlock["request"] = "getnodeinfo";
		}
		else if(requestType == RequestType.GETSELF)
		{
			requestBlock["request"] = "debug_remotegetself";
		}
		else if(requestType == RequestType.GETPEERS)
		{
			requestBlock["request"] = "debug_remotegetpeers";
		}
		else if(requestType == RequestType.GETDHT)
		{
			requestBlock["request"] = "debug_remotegetdht";
		}
		


		return requestBlock;
	}
}

/* TODO: Fix read here */
public JSONValue sillyWillyRequest(YggdrasilPeer peer, YggdrasilRequest request)
{
	Socket controlSocket = new Socket(AddressFamily.INET6, SocketType.STREAM, ProtocolType.TCP);
	controlSocket.connect(peer.getAddress());

	JSONValue requestBlock = request.generateJSON();
	controlSocket.send(cast(byte[])toJSON(requestBlock));


	// TODO: Add loop reader here
	byte[] buffer;
	buffer.length = 100000;
	controlSocket.receive(buffer);


	writeln(parseJSON(cast(string)buffer));
	JSONValue responseBlock;

	if(cmp((parseJSON(cast(string)buffer)["status"]).str(), "success") == 0)
	{
		responseBlock = parseJSON(cast(string)buffer)["response"];
	}

	
	
	return responseBlock;
}