The aipgcoin Service is a Node.js interface to aipgcoin for querying information about the aipgcoin block chain. It will manage starting and stopping aipgd
or connect to several running aipgd
processes. It uses a branch of a branch of aipgcoin with additional indexes for querying information about addresses and blocks. Results are cached for performance and there are several additional API methods added for common queries.
The default configuration will include a "spawn" configuration in "aipgd". This defines the location of the block chain database and the location of the aipgd
daemon executable. The below configuration points to a local clone of aipgcoin
, and will start aipgd
automatically with your Node.js application.
"servicesConfig": {
"aipgd": {
"spawn": {
"datadir": "/home/aipgcore/.aipg",
"exec": "/home/aipgcore/aipgcoin/src/aipgd"
}
}
}
It's also possible to connect to separately managed aipgd
processes with round-robin quering, for example:
"servicesConfig": {
"aipgd": {
"connect": [
{
"rpchost": "127.0.0.1",
"rpcport": 30521,
"rpcuser": "aipgcoin",
"rpcpassword": "local321",
"zmqpubrawtx": "tcp://127.0.0.1:30611"
},
{
"rpchost": "127.0.0.1",
"rpcport": 30522,
"rpcuser": "aipgcoin",
"rpcpassword": "local321",
"zmqpubrawtx": "tcp://127.0.0.1:30622"
},
{
"rpchost": "127.0.0.1",
"rpcport": 30523,
"rpcuser": "aipgcoin",
"rpcpassword": "local321",
"zmqpubrawtx": "tcp://127.0.0.1:30633"
}
]
}
}
Note: For detailed example configuration see regtest/cluster.js
Methods are available by directly interfacing with the service:
node.services.aipgd.<methodName>
Getting Latest Blocks
// gives the block hashes sorted from low to high within a range of timestamps
var high = 1460393372; // Mon Apr 11 2016 12:49:25 GMT-0400 (EDT)
var low = 1460306965; // Mon Apr 10 2016 12:49:25 GMT-0400 (EDT)
node.services.aipgd.getBlockHashesByTimestamp(high, low, function(err, blockHashes) {
//...
});
// get the current tip of the chain
node.services.aipgd.getBestBlockHash(function(err, blockHash) {
//...
})
Getting Synchronization and Node Status
// gives a boolean if the daemon is fully synced (not the initial block download)
node.services.aipgd.isSynced(function(err, synced) {
//...
})
// gives the current estimate of blockchain download as a percentage
node.services.aipgd.syncPercentage(function(err, percent) {
//...
});
// gives information about the chain including total number of blocks
node.services.aipgd.getInfo(function(err, info) {
//...
});
Generate Blocks
// will generate a block for the "regtest" network (development purposes)
var numberOfBlocks = 10;
node.services.aipgd.generateBlock(numberOfBlocks, function(err, blockHashes) {
//...
});
Getting Block Information
It's possible to query blocks by both block hash and by height. Blocks are given as Node.js Buffers and can be parsed via aipgcore:
var blockHeight = 0;
node.services.aipgd.getRawBlock(blockHeight, function(err, blockBuffer) {
if (err) {
throw err;
}
var block = aipgcore.Block.fromBuffer(blockBuffer);
console.log(block);
};
// get a aipgcore object of the block (as above)
node.services.aipgd.getBlock(blockHash, function(err, block) {
//...
};
// get only the block header and index (including chain work, height, and previous hash)
node.services.aipgd.getBlockHeader(blockHeight, function(err, blockHeader) {
//...
});
// get the block with a list of txids
node.services.aipgd.getBlockOverview(blockHash, function(err, blockOverview) {
//...
};
Retrieving and Sending Transactions
Get a transaction asynchronously by reading it from disk:
var txid = '7426c707d0e9705bdd8158e60983e37d0f5d63529086d6672b07d9238d5aa623';
node.services.aipgd.getRawTransaction(txid, function(err, transactionBuffer) {
if (err) {
throw err;
}
var transaction = aipgcore.Transaction().fromBuffer(transactionBuffer);
});
// get a aipgcore object of the transaction (as above)
node.services.aipgd.getTransaction(txid, function(err, transaction) {
//...
});
// retrieve the transaction with input values, fees, spent and block info
node.services.aipgd.getDetailedTransaction(txid, function(err, transaction) {
//...
});
Send a transaction to the network:
var numberOfBlocks = 3;
node.services.aipgd.estimateFee(numberOfBlocks, function(err, feesPerKilobyte) {
//...
});
node.services.aipgd.sendTransaction(transaction.serialize(), function(err, hash) {
//...
});
Get Unspent Outputs
One of the most common uses will be to retrieve unspent outputs necessary to create a transaction, here is how to get the unspent outputs for an address:
var address = 'mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW';
node.services.aipgd.getAddressUnspentOutputs(address, options, function(err, unspentOutputs) {
// see below
});
The unspentOutputs
will have the format:
[
{
address: 'mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW',
txid: '9d956c5d324a1c2b12133f3242deff264a9b9f61be701311373998681b8c1769',
outputIndex: 1,
height: 150,
satoshis: 1000000000,
script: '76a9140b2f0a0c31bfe0406b0ccc1381fdbe311946dadc88ac',
confirmations: 3
}
]
View Balances
var address = 'mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW';
node.services.aipgd.getAddressBalance(address, options, function(err, balance) {
// balance will be in satoshis with "received" and "balance"
});
View Address History
This method will give history of an address limited by a range of block heights by using the "start" and "end" arguments. The "start" value is the more recent, and greater, block height. The "end" value is the older, and lesser, block height. This feature is most useful for synchronization as previous history can be omitted. Furthermore for large ranges of block heights, results can be paginated by using the "from" and "to" arguments.
If "queryMempool" is set as true (it is true by default), it will show unconfirmed transactions from the aipgcoin mempool. However, if you specify "start" and "end", "queryMempool" is ignored and is always false.
If "queryMempoolOnly" is set as true (it is false by default), it will show only unconfirmed transactions from mempool.
var addresses = ['mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW'];
var options = {
start: 345000,
end: 344000,
queryMempool: true // since we presented range, queryMempool will be ignored
};
node.services.aipgd.getAddressHistory(addresses, options, function(err, history) {
// see below
});
The history format will be:
{
totalCount: 1, // The total number of items within "start" and "end"
items: [
{
addresses: {
'mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW': {
inputIndexes: [],
outputIndexes: [0]
}
},
satoshis: 1000000000,
tx: <detailed_transaction> // the same format as getDetailedTransaction
}
]
}
View Address Summary
var address = 'mgY65WSfEmsyYaYPQaXhmXMeBhwp4EcsQW';
var options = {
noTxList: false
};
node.services.aipgd.getAddressSummary(address, options, function(err, summary) {
// see below
});
The summary
will have the format (values are in satoshis):
{
totalReceived: 1000000000,
totalSpent: 0,
balance: 1000000000,
unconfirmedBalance: 1000000000,
appearances: 1,
unconfirmedAppearances: 0,
txids: [
'3f7d13efe12e82f873f4d41f7e63bb64708fc4c942eb8c6822fa5bd7606adb00'
]
}
Notes:
totalReceived
does not exclude change (the amount of satoshis originating from the same address)unconfirmedBalance
is the delta that the unconfirmed transactions have on the total balance (can be both positive and negative)unconfirmedAppearances
is the total number of unconfirmed transactionsappearances
is the total confirmed transactionstxids
Are sorted in block order with the most recent at the beginning. A maximum of 1000 (default) will be returned, thefrom
andto
options can be used to get further values.
The aipgcoin Service exposes two events via the Bus, and there are a few events that can be directly registered:
node.services.aipgd.on('tip', function(blockHash) {
// a new block tip has been added, if there is a rapid update (with a second) this will not emit every tip update
});
node.services.aipgd.on('tx', function(transactionBuffer) {
// a new transaction has entered the mempool
});
node.services.aipgd.on('block', function(blockHash) {
// a new block has been added
});
For details on instantiating a bus for a node, see the Bus Documentation.
- Name:
aipgd/rawtransaction
- Name:
aipgd/hashblock
- Name:
aipgd/addresstxid
, Arguments: [address, address...]
Examples:
bus.subscribe('aipgd/rawtransaction');
bus.subscribe('aipgd/hashblock');
bus.subscribe('aipgd/addresstxid', ['13FMwCYz3hUhwPcaWuD2M1U2KzfTtvLM89']);
bus.on('aipgd/rawtransaction', function(transactionHex) {
//...
});
bus.on('aipgd/hashblock', function(blockhashHex) {
//...
});
bus.on('aipgd/addresstxid', function(data) {
// data.address;
// data.txid;
});