106 lines
2.5 KiB
JavaScript
106 lines
2.5 KiB
JavaScript
'use strict';
|
|
|
|
var util = require('util');
|
|
var EventEmitter = require('events').EventEmitter;
|
|
var bitcore = require('bitcore-lib-btcp');
|
|
var spawn = require('child_process').spawn;
|
|
|
|
function SatoshiFireAlarm(options) {
|
|
EventEmitter.call(this, options);
|
|
this.node = options.node;
|
|
|
|
this.alarmActivated = false;
|
|
this.child = false;
|
|
this.interestingAddresses = [
|
|
//'1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa', //this is the address that the genesis paid its coinbase to. Can't be spent due to a bug in the code.
|
|
//'12c6DSiU4Rq3P4ZxziKxzrL5LmMBrzjrJX', //Block 1
|
|
//'1HLoD9E4SDFFPDiYfNYnkBLQ85Y51J3Zb1' //Block 2
|
|
'b1RXUJgnuxtzHyJ5UTWerh4pNBWcVikESZe'
|
|
];
|
|
this.node.services.bitcoind.on('tx', this.transactionHandler.bind(this));
|
|
}
|
|
|
|
/*
|
|
* We are going to need bitcoind because we will be setting event listeners (subscribers)
|
|
* on Blocks and such
|
|
*/
|
|
SatoshiFireAlarm.dependencies = ['bitcoind'];
|
|
|
|
/*
|
|
* inherits the serivce base class so we get some stuff for free
|
|
*/
|
|
util.inherits(SatoshiFireAlarm, EventEmitter);
|
|
|
|
/*
|
|
* start: REQUIRED!! Ours just calls the callback
|
|
*/
|
|
SatoshiFireAlarm.prototype.start = function(callback) {
|
|
callback();
|
|
};
|
|
|
|
/*
|
|
* stop: REQUIRED!! Ours just calls the callback
|
|
*/
|
|
SatoshiFireAlarm.prototype.stop = function(callback) {
|
|
callback();
|
|
};
|
|
|
|
SatoshiFireAlarm.prototype.getAPIMethods = function() {
|
|
return [];
|
|
};
|
|
|
|
SatoshiFireAlarm.prototype.getPublishEvents = function() {
|
|
return [];
|
|
};
|
|
|
|
/*
|
|
* transactionHandler: this is the delegate when a transaction is received by your node
|
|
*/
|
|
SatoshiFireAlarm.prototype.transactionHandler = function(txBuffer) {
|
|
var self = this;
|
|
|
|
var tx = bitcore.Transaction().fromBuffer(txBuffer);
|
|
|
|
for (var i = 0; i < tx.inputs.length; i++) {
|
|
self.transactionInputHandler(tx.inputs[i]);
|
|
}
|
|
|
|
};
|
|
|
|
/*
|
|
* transactionInputHandler: helper for transactionHandler
|
|
*/
|
|
SatoshiFireAlarm.prototype.transactionInputHandler = function(input) {
|
|
if (!input.script) {
|
|
return;
|
|
}
|
|
var address = input.script.toAddress(this.node.network);
|
|
if (address && this.interestingAddresses.indexOf(address.toString()) != -1) {
|
|
this.soundAlarm();
|
|
}
|
|
};
|
|
|
|
/*
|
|
* soundAlarm: will launch a separate alarm program (not provided)
|
|
*/
|
|
SatoshiFireAlarm.prototype.soundAlarm = function() {
|
|
if (this.alarmActivated) {
|
|
return;
|
|
}
|
|
|
|
this.alarmActivated = true;
|
|
console.log('ALARM TRIGGERED!');
|
|
this.child = spawn('alarm', []);
|
|
};
|
|
|
|
SatoshiFireAlarm.prototype.resetAlarm = function() {
|
|
if (this.child) {
|
|
this.child.kill();
|
|
}
|
|
this.alarmActivated = false;
|
|
console.log('ALARM OFF!');
|
|
};
|
|
|
|
module.exports = SatoshiFireAlarm;
|
|
|