var spec = [
     { "method": "coinbase", "params": null, "returns" : "" },
	{ "method": "isListening", "params": null, "returns" : false },
	{ "method": "isMining", "params": null, "returns" : false },
	{ "method": "gasPrice", "params": null, "returns" : "" },
	{ "method": "key", "params": null, "returns" : "" },
	{ "method": "keys", "params": null, "returns" : [""] },
	{ "method": "peerCount", "params": null, "returns" : 0 },
    { "method": "balanceAt", "params": { "a": "" }, "order": ["a"], "returns" : "" },
    { "method": "storageAt", "params": { "a": "", "x": "" }, "order": ["a", "x"], "returns" : "" },
    { "method": "txCountAt", "params": { "a": "" }, "order": ["a"], "returns" : "" },
    { "method": "isContractAt", "params": { "a": "" }, "order": ["a"], "returns" : false },
    { "method": "create", "params": { "sec": "", "xEndowment": "", "bCode": "", "xGas": "", "xGasPrice": "" }, "order": ["sec", "xEndowment", "bCode", "xGas", "xGasPrice"] },
    { "method": "transact", "params": { "sec": "", "xValue": "", "aDest": "", "bData": "", "xGas": "", "xGasPrice": "" }, "order": ["sec", "xValue", "aDest", "bData", "xGas", "xGasPrice"] },
    { "method": "secretToAddress", "params": { "a": "" }, "order": ["a"], "returns" : "" }
];

var eth = (function ethScope() {
	var m_reqId = 0
	var ret = {}
	function reqSync(m, p) {
		var req = { "jsonrpc": "2.0", "method": m, "params": p, "id": m_reqId }
		m_reqId++
		var request = new XMLHttpRequest();	
		request.open("POST", "http://localhost:8080", false);
//		console.log("Sending " + JSON.stringify(req))
		request.send(JSON.stringify(req));
		return JSON.parse(request.responseText).result;
	}
	function reqAsync(m, p, f) {
		var req = { "jsonrpc": "2.0", "method": m, "params": p, "id": m_reqId }
		m_reqId++
		var request = new XMLHttpRequest();	
		request.open("POST", "http://localhost:8080", true);
		request.send(JSON.stringify(req));
		request.onreadystatechange = function() {
			if (request.readyState === 4)
	        	f(JSON.parse(request.responseText).result)
	    };
	}
	function isEmpty(obj) {
		for (var prop in obj)
		    if (obj.hasOwnProperty(prop))
		        return false
		return true
	}

	var m_watching = {};
	
	for (si in spec) (function(s) {
		var m = s.method;
		var am = "get" + m.slice(0, 1).toUpperCase() + m.slice(1);
		var getParams = function(a) {
			var p = s.params ? {} : null
			for (j in s.order)
				p[s.order[j]] = a[j]
			return p
		};
		ret[am] = function() { return reqAsync(m, getParams(arguments), arguments[s.order.length]) }
		ret[m] = function() { return reqSync(m, getParams(arguments)) }
	})(spec[si]);

	ret.check = function(force) {
		if (!force && isEmpty(m_watching))
			return
		var watching = [];
		for (var w in m_watching)
			watching.push(w)
		var changed = reqSync("check", { "a": watching } );
		console.log("Got " + JSON.stringify(changed));
		for (var c in changed)
			m_watching[changed[c]]()
		var that = this;
		setTimeout(function() { that.check() }, 5000)
	}

	ret.watch = function(a, fx, f) {
		var old = isEmpty(m_watching)
		if (f)
			m_watching[a + fx] = f
		else
			m_watching[a] = fx
		(f ? f : fx)()
		if (isEmpty(m_watching) != old)
			this.check()
	}
	ret.unwatch = function(f, fx) {
		delete m_watching[fx ? f + fx : f];
	}
	ret.newBlock = function(f) {
		var old = isEmpty(m_watching)
		m_watching[""] = f
		f()
		if (isEmpty(m_watching) != old)
			this.check()
	}
	return ret;
}());