ethminer/eth/eth.js

if (typeof(window.eth) === "undefined")
{
if (typeof(require) !== "undefined")
	require( ['ethString'], function() {} )
else if (typeof(String.prototype.pad) === "undefined")
{
	var scriptTag = document.getElementsByTagName('script');
	scriptTag = scriptTag[scriptTag.length - 1]; 
	var scriptPath = scriptTag.src; 
	var path = scriptPath.substr(0, scriptPath.lastIndexOf( '/' ));
	var start = '<script src="' + path + '/';
	var slash = '"><'+'/script>';
	document.write(start + 'BigInteger.js' + slash);
	document.write(start + 'ethString.js' + slash);
}

var spec = [
            { "method": "procedures", "params": null, "order": [], "returns": [] },
            { "method": "coinbase", "params": null, "order": [], "returns" : "" },
            { "method": "isListening", "params": null, "order": [], "returns" : false },
            { "method": "isMining", "params": null, "order": [], "returns" : false },
            { "method": "gasPrice", "params": null, "order": [], "returns" : "" },
            { "method": "key", "params": null, "order": [], "returns" : "" },
            { "method": "keys", "params": null, "order": [], "returns" : [] },
            { "method": "peerCount", "params": null, "order": [], "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"] , "returns": "" },
            { "method": "transact", "params": { "sec": "", "xValue": "", "aDest": "", "bData": "", "xGas": "", "xGasPrice": "" }, "order": ["sec", "xValue", "aDest", "bData", "xGas", "xGasPrice"], "returns": {} },
            { "method": "secretToAddress", "params": { "a": "" }, "order": ["a"], "returns" : "" },
            { "method": "lll", "params": { "s": "" }, "order": ["s"], "returns" : "" }
];

window.eth = (function ethScope() {
	var m_reqId = 0
	var ret = {}
    function reformat(m, d) { return m == "lll" ? d.bin() : d; }
	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 reformat(m, 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(reformat(m, 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]] = (s.order[j][0] === "b") ? a[j].unbin() : a[j]
			return p
		};
        if (m == "create" || m == "transact")
            ret[m] = function() { return reqAsync(m, getParams(arguments), arguments[s.order.length]) }
		else
		{
			ret[am] = function() { return reqAsync(m, getParams(arguments), arguments[s.order.length]) }
			if (s.params)
				ret[m] = function() { return reqSync(m, getParams(arguments)) }
            else
				Object.defineProperty(ret, m, {
					get: function() { return reqSync(m, {}); },
					set: function(v) {}
			})
        }
	})(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;
}());

}