Merge pull request #91 from SomeoneWeird/master

Clean up & fix examples
This commit is contained in:
Ryan X. Charles 2014-02-25 17:36:05 -05:00
commit c1f82d16ce
5 changed files with 208 additions and 122 deletions

164
README.md
View File

@ -28,58 +28,84 @@ Some examples are provided at the [examples](/examples) path. Here are some snip
## Validating an address ## Validating an address
Validating a Bitcoin address: Validating a Bitcoin address:
``` ```js
var Address = require('bitcore/Address').class(); var Address = require('bitcore/Address').class();
var addr = new Address("1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa");
try { var addrStrings = [
addr.validate(); "1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa",
console.log("Address is valid."); "1A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx",
} catch(e) { "A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx",
console.log(addr.data + " is not a valid address. " + e); "1600 Pennsylvania Ave NW",
} ].map(function(addr) {
return new Address(addr);
});
addrStrings.forEach(function(addr) {
try {
addr.validate();
console.log(addr.data + ": is valid");
} catch(e) {
console.log(addr.data + ": is not a valid address. " + e);
}
});
``` ```
## Monitoring Blocks and Transactions ## Monitoring Blocks and Transactions
``` ```js
var networks = require('bitcore/networks'); var util = require('util');
var Peer = require('bitcore/Peer').class(); var networks = require('bitcore/networks');
var Peer = require('bitcore/Peer').class();
var PeerManager = require('bitcore/PeerManager').createClass({ var PeerManager = require('bitcore/PeerManager').createClass({
network: networks.testnet network: networks.testnet
}); });
var util= require('util');
var handleBlock = function(info) {
console.log('** Block Received **');
console.log(info.message);
var handleBlock = function(b) {
console.log('block received:', util.inspect(b.message,{depth:null}));
}; };
var handleTx = function(b) { var handleTx = function(info) {
var tx = info.message.tx.getStandardizedObject(); var tx = info.message.tx.getStandardizedObject();
console.log('block tx:', util.inspect(tx,{depth:null}));
console.log('** Block TX **');
console.log(tx);
}; };
var handleInv = function(b) { var handleInv = function(info) {
console.log('block inv:', util.inspect(info.message,{depth:null}));
console.log('** Block Inv **');
console.log(info.message);
var invs = info.message.invs; var invs = info.message.invs;
info.conn.sendGetData(invs); info.conn.sendGetData(invs);
}; };
var peerman = new PeerManager(); var peerman = new PeerManager();
peerman.addPeer( new Peer('127.0.0.1',18333) );
peerman.addPeer( new Peer('127.0.0.1', 18333) );
peerman.on('connection', function(conn) { peerman.on('connection', function(conn) {
conn.on('inv', handleInv); conn.on('inv', handleInv);
conn.on('block', handleBlock); conn.on('block', handleBlock);
conn.on('tx', handleTx); conn.on('tx', handleTx);
}); });
peerman.start(); peerman.start();
``` ```
PeerManager will emit the following events: 'version', 'verack', 'addr', 'getaddr', 'error' 'disconnect'; and will relay events like: 'tx', 'block', 'inv'. Please see [PeerManager.js](PeerManager.js), [Peer.js](Peer.js) and [Connection.js](Connection.js) PeerManager will emit the following events: 'version', 'verack', 'addr', 'getaddr', 'error' 'disconnect'; and will relay events like: 'tx', 'block', 'inv'. Please see [PeerManager.js](PeerManager.js), [Peer.js](Peer.js) and [Connection.js](Connection.js)
## Creating and sending a Transaction through P2P ## Creating and sending a Transaction through P2P
``` ```js
var networks = require('bitcore/networks'); var networks = require('bitcore/networks');
var Peer = require('bitcore/Peer').class(); var Peer = require('bitcore/Peer').class();
var Transaction = require('bitcore/Transaction').class(); var Transaction = require('bitcore/Transaction').class();
@ -91,31 +117,37 @@ var PeerManager = require('bitcore/PeerManager').createClass({
}); });
var createTx = function() { var createTx = function() {
var TXIN='d05f35e0bbc495f6dcab03e599c8f5e32a07cdb4bc76964de201d06a2a7d8265';
var TXIN_N=0;
var ADDR='muHct3YZ9Nd5Pq7uLYYhXRAxeW4EnpcaLz';
var VAL='1.234';
var txobj = {};
txobj.version = 1;
txobj.lock_time = 0;
txobj.ins = [];
txobj.outs = [];
var txin = {};
txin.s = coinUtil.EMPTY_BUFFER; //Add signature
txin.q = 0xffffffff;
var hash = new Buffer(TXIN, 'hex'); var TXIN = 'd05f35e0bbc495f6dcab03e599c8f5e32a07cdb4bc76964de201d06a2a7d8265';
hash.reverse(); var TXIN_N = 0;
var vout = parseInt(TXIN_N); var ADDR = 'muHct3YZ9Nd5Pq7uLYYhXRAxeW4EnpcaLz';
var VAL = '1.234';
var txobj = {
version: 1,
lock_time: 0,
ins: [],
outs: []
}
var txin = {
s: coinUtil.EMPTY_BUFFER, // Add signature
q: 0xffffffff
};
var hash = new Buffer(TXIN.split('').reverse(), 'hex');
var vout = parseInt(TXIN_N);
var voutBuf = new Buffer(4); var voutBuf = new Buffer(4);
voutBuf.writeUInt32LE(vout, 0); voutBuf.writeUInt32LE(vout, 0);
txin.o = Buffer.concat([hash, voutBuf]); txin.o = Buffer.concat([hash, voutBuf]);
txobj.ins.push(txin); txobj.ins.push(txin);
var addr = new Address(ADDR); var addr = new Address(ADDR);
var script = Script.createPubKeyHashOut(addr.payload()); var script = Script.createPubKeyHashOut(addr.payload());
var valueNum = coinUtil.parseValue(VAL); var valueNum = coinUtil.parseValue(VAL);
var value = coinUtil.bigIntToValue(valueNum); var value = coinUtil.bigIntToValue(valueNum);
var txout = { var txout = {
v: value, v: value,
@ -124,33 +156,55 @@ var createTx = function() {
txobj.outs.push(txout); txobj.outs.push(txout);
return new Transaction(txobj); return new Transaction(txobj);
}; };
var peerman = new PeerManager(); var peerman = new PeerManager();
peerman.addPeer( new Peer('127.0.0.1',18333) ); peerman.addPeer(new Peer('127.0.0.1', 18333));
peerman.on('connect', function(conn) { peerman.on('connect', function(conn) {
var conn = peerman.getActiveConnection(); var conn = peerman.getActiveConnection();
if (conn)
if (conn) {
conn.sendTx(createTx()); conn.sendTx(createTx());
conn.on('reject', function () { console.log('Transaction Rejected'); } ); }
conn.on('reject', function () {
console.log('Transaction Rejected');
});
}); });
peerman.start(); peerman.start();
``` ```
## Consuming bitcoind RPC ## Consuming bitcoind RPC
``` ```js
var RpcClient = require('../RpcClient').class(); var util = require('util');
var config = { var RpcClient = require('bitcore/RpcClient').class();
protocol: 'http', var hash = process.argv[2] || '0000000000b6288775bbd326bedf324ca8717a15191da58391535408205aada4';
user: 'user',
pass: 'pass', var config = {
host: '127.0.0.1', protocol: 'http',
port: '18332', user: 'user',
pass: 'pass',
host: '127.0.0.1',
port: '18332',
}; };
var rpc = new RpcClient(config); var rpc = new RpcClient(config);
rpc.getBlock( hash, function(err, ret) {
console.log(err); rpc.getBlock(hash, function(err, ret) {
console.log(util.inspect(ret, { depth: 10} ));
if(err) {
console.error("An error occured fetching block", hash);
console.error(err);
return;
}
console.log(ret);
}); });
``` ```
Check the list of all supported RPC call at [RpcClient.js](RpcClient.js) Check the list of all supported RPC call at [RpcClient.js](RpcClient.js)

View File

@ -1,7 +1,7 @@
'use strict';
// Replace '..' with 'bitcore' if you plan on using this code elsewhere.
// Replace path '..' to 'bitcore' if you are using this example
// in a different project
var Address = require('../Address').class(); var Address = require('../Address').class();
var addrStrings = [ var addrStrings = [
@ -9,10 +9,11 @@ var addrStrings = [
"1A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx", "1A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx",
"A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx", "A1zP1eP5QGefi2DMPTfTL5SLmv7Dixxxx",
"1600 Pennsylvania Ave NW", "1600 Pennsylvania Ave NW",
]; ].map(function(addr) {
return new Address(addr);
});
addrStrings.forEach(function(addrStr){ addrStrings.forEach(function(addr) {
var addr = new Address(addrStr);
try { try {
addr.validate(); addr.validate();
@ -20,4 +21,5 @@ addrStrings.forEach(function(addrStr){
} catch(e) { } catch(e) {
console.log(addr.data + ": is not a valid address. " + e); console.log(addr.data + ": is not a valid address. " + e);
} }
}); });

View File

@ -1,38 +1,48 @@
'use strict'; 'use strict';
// Replace path '..' to 'bitcore' if you are using this example // Replace '..' with 'bitcore' if you plan on using this code elsewhere.
// in a different project
var networks = require('../networks'); var util = require('util');
var Peer = require('../Peer').class(); var networks = require('../networks');
var Peer = require('../Peer').class();
var PeerManager = require('../PeerManager').createClass({ var PeerManager = require('../PeerManager').createClass({
network: networks.testnet network: networks.testnet
}); });
var util= require('util'); var handleBlock = function(info) {
console.log('** Block Received **');
console.log(info.message);
var handleBlock = function(b) {
console.log('block received:', util.inspect(b.message,{depth:null}));
}; };
var handleTx = function(info) { var handleTx = function(info) {
var tx = info.message.tx.getStandardizedObject(); var tx = info.message.tx.getStandardizedObject();
console.log('block tx:', util.inspect(tx,{depth:null}));
console.log('** Block TX **');
console.log(tx);
}; };
var handleInv = function(info) { var handleInv = function(info) {
console.log('block inv:', util.inspect(info.message,{depth:null}));
console.log('** Block Inv **');
console.log(info.message);
var invs = info.message.invs; var invs = info.message.invs;
info.conn.sendGetData(invs); info.conn.sendGetData(invs);
}; };
var peerman = new PeerManager(); var peerman = new PeerManager();
peerman.addPeer( new Peer('127.0.0.1',18333) );
peerman.on('connection', function(conn) {
conn.on('inv', handleInv);
conn.on('block', handleBlock);
conn.on('tx', handleTx);
});
peerman.start();
peerman.addPeer( new Peer('127.0.0.1', 18333) );
peerman.on('connection', function(conn) {
conn.on('inv', handleInv);
conn.on('block', handleBlock);
conn.on('tx', handleTx);
});
peerman.start();

View File

@ -1,23 +1,29 @@
'use strict';
var util = require('util'); // Replace '..' with 'bitcore' if you plan on using this code elsewhere.
// Replace path '..' to 'bitcore' if you are using this example var util = require('util');
// in a different project
var RpcClient = require('../RpcClient').class(); var RpcClient = require('../RpcClient').class();
var hash = process.argv[2] var hash = process.argv[2] || '0000000000b6288775bbd326bedf324ca8717a15191da58391535408205aada4';
|| '0000000000b6288775bbd326bedf324ca8717a15191da58391535408205aada4';
var config = { var config = {
protocol: 'http', protocol: 'http',
user: 'user', user: 'user',
pass: 'pass', pass: 'pass',
host: '127.0.0.1', host: '127.0.0.1',
port: '18332', port: '18332',
}; };
var rpc = new RpcClient(config); var rpc = new RpcClient(config);
rpc.getBlock( hash, function(err, ret) {
console.log(err); rpc.getBlock(hash, function(err, ret) {
console.log(util.inspect(ret, { depth: 10} ));
if(err) {
console.error("An error occured fetching block", hash);
console.error(err);
return;
}
console.log(ret);
}); });

View File

@ -1,42 +1,48 @@
// Replace path '..' to 'bitcore' if you are using this example
// in a different project // Replace '..' with 'bitcore' if you plan on using this code elsewhere.
var networks = require('../networks');
var Peer = require('../Peer').class(); var networks = require('../networks');
var Peer = require('../Peer').class();
var Transaction = require('../Transaction').class(); var Transaction = require('../Transaction').class();
var Address = require('../Address').class(); var Address = require('../Address').class();
var Script = require('../Script').class(); var Script = require('../Script').class();
var coinUtil = require('../util/util');
var PeerManager = require('../PeerManager').createClass({ var PeerManager = require('../PeerManager').createClass({
network: networks.testnet network: networks.testnet
}); });
var coinUtil = require('../util/util');
var createTx = function() { var createTx = function() {
var TXIN='d05f35e0bbc495f6dcab03e599c8f5e32a07cdb4bc76964de201d06a2a7d8265';
var TXIN_N=0;
var ADDR='muHct3YZ9Nd5Pq7uLYYhXRAxeW4EnpcaLz';
var VAL='1.234';
var txobj = {};
txobj.version = 1;
txobj.lock_time = 0;
txobj.ins = [];
txobj.outs = [];
var txin = {};
txin.s = coinUtil.EMPTY_BUFFER; //Add signature
txin.q = 0xffffffff;
var hash = new Buffer(TXIN, 'hex'); var TXIN = 'd05f35e0bbc495f6dcab03e599c8f5e32a07cdb4bc76964de201d06a2a7d8265';
hash.reverse(); var TXIN_N = 0;
var vout = parseInt(TXIN_N); var ADDR = 'muHct3YZ9Nd5Pq7uLYYhXRAxeW4EnpcaLz';
var VAL = '1.234';
var txobj = {
version: 1,
lock_time: 0,
ins: [],
outs: []
}
var txin = {
s: coinUtil.EMPTY_BUFFER, // Add signature
q: 0xffffffff
};
var hash = new Buffer(TXIN.split('').reverse(), 'hex');
var vout = parseInt(TXIN_N);
var voutBuf = new Buffer(4); var voutBuf = new Buffer(4);
voutBuf.writeUInt32LE(vout, 0); voutBuf.writeUInt32LE(vout, 0);
txin.o = Buffer.concat([hash, voutBuf]); txin.o = Buffer.concat([hash, voutBuf]);
txobj.ins.push(txin); txobj.ins.push(txin);
var addr = new Address(ADDR); var addr = new Address(ADDR);
var script = Script.createPubKeyHashOut(addr.payload()); var script = Script.createPubKeyHashOut(addr.payload());
var valueNum = coinUtil.parseValue(VAL); var valueNum = coinUtil.parseValue(VAL);
var value = coinUtil.bigIntToValue(valueNum); var value = coinUtil.bigIntToValue(valueNum);
var txout = { var txout = {
v: value, v: value,
@ -45,16 +51,24 @@ var createTx = function() {
txobj.outs.push(txout); txobj.outs.push(txout);
return new Transaction(txobj); return new Transaction(txobj);
}; };
var peerman = new PeerManager(); var peerman = new PeerManager();
peerman.addPeer( new Peer('127.0.0.1',18333) ); peerman.addPeer(new Peer('127.0.0.1', 18333));
peerman.on('connect', function(conn) { peerman.on('connect', function(conn) {
var conn = peerman.getActiveConnection(); var conn = peerman.getActiveConnection();
if (conn)
if (conn) {
conn.sendTx(createTx()); conn.sendTx(createTx());
conn.on('reject', function () { console.log('Transaction Rejected'); } ); }
conn.on('reject', function () {
console.log('Transaction Rejected');
});
}); });
peerman.start(); peerman.start();