121 lines
2.8 KiB
JavaScript
121 lines
2.8 KiB
JavaScript
/**
|
|
* Cryptonote Node.JS Pool
|
|
* https://github.com/dvandal/cryptonote-nodejs-pool
|
|
*
|
|
* Handle communications to APIs
|
|
**/
|
|
|
|
// Load required modules
|
|
var http = require('http');
|
|
var https = require('https');
|
|
|
|
function jsonHttpRequest (host, port, data, callback, path) {
|
|
path = path || '/json_rpc';
|
|
callback = callback || function () {};
|
|
var options = {
|
|
hostname: host,
|
|
port: port,
|
|
path: path,
|
|
method: data ? 'POST' : 'GET',
|
|
headers: {
|
|
'Content-Length': data.length,
|
|
'Content-Type': 'application/json',
|
|
'Accept': 'application/json'
|
|
}
|
|
};
|
|
var req = (port === 443 ? https : http)
|
|
.request(options, function (res) {
|
|
var replyData = '';
|
|
res.setEncoding('utf8');
|
|
res.on('data', function (chunk) {
|
|
replyData += chunk;
|
|
});
|
|
res.on('end', function () {
|
|
var replyJson;
|
|
try {
|
|
replyJson = replyData ? JSON.parse(replyData) : {};
|
|
} catch (e) {
|
|
callback(e, {});
|
|
return;
|
|
}
|
|
callback(null, replyJson);
|
|
});
|
|
});
|
|
|
|
req.on('error', function (e) {
|
|
callback(e, {});
|
|
});
|
|
|
|
req.end(data);
|
|
}
|
|
|
|
/**
|
|
* Send RPC request
|
|
**/
|
|
function rpc (host, port, method, params, callback) {
|
|
var data = JSON.stringify({
|
|
id: "0",
|
|
jsonrpc: "2.0",
|
|
method: method,
|
|
params: params
|
|
});
|
|
jsonHttpRequest(host, port, data, function (error, replyJson) {
|
|
if (error) {
|
|
callback(error, {});
|
|
return;
|
|
}
|
|
callback(replyJson.error, replyJson.result)
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Send RPC requests in batch mode
|
|
**/
|
|
function batchRpc (host, port, array, callback) {
|
|
var rpcArray = [];
|
|
for (var i = 0; i < array.length; i++) {
|
|
rpcArray.push({
|
|
id: i.toString(),
|
|
jsonrpc: "2.0",
|
|
method: array[i][0],
|
|
params: array[i][1]
|
|
});
|
|
}
|
|
var data = JSON.stringify(rpcArray);
|
|
jsonHttpRequest(host, port, data, callback);
|
|
}
|
|
|
|
/**
|
|
* Send RPC request to pool API
|
|
**/
|
|
function poolRpc (host, port, path, callback) {
|
|
jsonHttpRequest(host, port, '', callback, path);
|
|
}
|
|
|
|
/**
|
|
* Exports API interfaces functions
|
|
**/
|
|
module.exports = function (daemonConfig, walletConfig, poolApiConfig) {
|
|
return {
|
|
batchRpcDaemon: function (batchArray, callback) {
|
|
batchRpc(daemonConfig.host, daemonConfig.port, batchArray, callback);
|
|
},
|
|
rpcDaemon: function (method, params, callback, serverConfig) {
|
|
if (serverConfig) {
|
|
rpc(serverConfig.host, serverConfig.port, method, params, callback);
|
|
} else {
|
|
rpc(daemonConfig.host, daemonConfig.port, method, params, callback);
|
|
}
|
|
},
|
|
rpcWallet: function (method, params, callback) {
|
|
rpc(walletConfig.host, walletConfig.port, method, params, callback);
|
|
},
|
|
pool: function (path, callback) {
|
|
var bindIp = config.api.bindIp ? config.api.bindIp : "0.0.0.0";
|
|
var poolApi = (bindIp !== "0.0.0.0" ? poolApiConfig.bindIp : "127.0.0.1");
|
|
poolRpc(poolApi, poolApiConfig.port, path, callback);
|
|
},
|
|
jsonHttpRequest: jsonHttpRequest
|
|
}
|
|
};
|