a10e2b4a43
/api/messages/verify accepts three parameters either via JSON POST data or GET query parameters, pipes them to the bitcoin RPCs verifymessage command, and returns the result for the user.
124 lines
3.1 KiB
JavaScript
124 lines
3.1 KiB
JavaScript
'use strict';
|
|
|
|
var imports = require('soop').imports();
|
|
|
|
var bitcore = require('bitcore'),
|
|
RpcClient = bitcore.RpcClient,
|
|
BitcoreBlock = bitcore.Block,
|
|
util = require('util'),
|
|
config = require('../config/config');
|
|
|
|
var bitcoreRpc = imports.bitcoreRpc || new RpcClient(config.bitcoind);
|
|
|
|
function Rpc() {
|
|
}
|
|
|
|
Rpc._parseTxResult = function(info) {
|
|
var b = new Buffer(info.hex,'hex');
|
|
|
|
// remove fields we dont need, to speed and adapt the information
|
|
delete info.hex;
|
|
|
|
// Inputs => add index + coinBase flag
|
|
var n =0;
|
|
info.vin.forEach(function(i) {
|
|
i.n = n++;
|
|
if (i.coinbase) info.isCoinBase = true;
|
|
if (i.scriptSig) delete i.scriptSig.hex;
|
|
});
|
|
|
|
// Outputs => add total
|
|
var valueOutSat = 0;
|
|
info.vout.forEach( function(o) {
|
|
o.value = o.value.toFixed(8);
|
|
valueOutSat += o.value * bitcore.util.COIN;
|
|
delete o.scriptPubKey.hex;
|
|
});
|
|
info.valueOut = valueOutSat.toFixed(0) / bitcore.util.COIN;
|
|
info.size = b.length;
|
|
|
|
return info;
|
|
};
|
|
|
|
|
|
Rpc.errMsg = function(err) {
|
|
var e = err;
|
|
e.message += util.format(' [Host: %s:%d User:%s Using password:%s]',
|
|
bitcoreRpc.host,
|
|
bitcoreRpc.port,
|
|
bitcoreRpc.user,
|
|
bitcoreRpc.pass?'yes':'no'
|
|
);
|
|
return e;
|
|
};
|
|
|
|
Rpc.getTxInfo = function(txid, doNotParse, cb) {
|
|
var self = this;
|
|
|
|
if (typeof doNotParse === 'function') {
|
|
cb = doNotParse;
|
|
doNotParse = false;
|
|
}
|
|
|
|
bitcoreRpc.getRawTransaction(txid, 1, function(err, txInfo) {
|
|
// Not found?
|
|
if (err && err.code === -5) return cb();
|
|
if (err) return cb(self.errMsg(err));
|
|
|
|
var info = doNotParse ? txInfo.result : self._parseTxResult(txInfo.result);
|
|
return cb(null,info);
|
|
});
|
|
};
|
|
|
|
|
|
Rpc.blockIndex = function(height, cb) {
|
|
var self = this;
|
|
|
|
bitcoreRpc.getBlockHash(height, function(err, bh){
|
|
if (err) return cb(self.errMsg(err));
|
|
cb(null, { blockHash: bh.result });
|
|
});
|
|
};
|
|
|
|
Rpc.getBlock = function(hash, cb) {
|
|
var self = this;
|
|
|
|
bitcoreRpc.getBlock(hash, function(err,info) {
|
|
// Not found?
|
|
if (err && err.code === -5) return cb();
|
|
if (err) return cb(self.errMsg(err));
|
|
|
|
|
|
if (info.result.height)
|
|
info.result.reward = BitcoreBlock.getBlockValue(info.result.height) / bitcore.util.COIN ;
|
|
|
|
return cb(err,info.result);
|
|
});
|
|
};
|
|
|
|
Rpc.sendRawTransaction = function(rawtx, cb) {
|
|
var self = this;
|
|
bitcoreRpc.sendRawTransaction(rawtx, function(err, txid) {
|
|
if (err && err.code === -5) return cb(err); // transaction already in block chain
|
|
if (err) return cb(self.errMsg(err));
|
|
|
|
return cb(err, txid.result);
|
|
});
|
|
};
|
|
|
|
Rpc.verifyMessage = function(address, signature, message, cb) {
|
|
var self = this;
|
|
bitcoreRpc.verifyMessage(address, signature, message, function(err, message) {
|
|
if (err && (err.code === -3 || err.code === -5))
|
|
return cb(err); // -3 = invalid address, -5 = malformed base64 / etc.
|
|
if (err)
|
|
return cb(self.errMsg(err));
|
|
|
|
return cb(err, message.result);
|
|
});
|
|
};
|
|
|
|
module.exports = require('soop')(Rpc);
|
|
|
|
|