flocore-node/test/services/address/index.unit.js

'use strict';

var sinon = require('sinon');
var AddressService = require('../../../lib/services/address');
var Tx = require('bcoin').tx;
var expect = require('chai').expect;
var Encoding  = require('../../../lib/services/address/encoding');
var Readable = require('stream').Readable;
var EventEmitter = require('events').EventEmitter;
var bcoin = require('bcoin');

describe('Address Service', function() {

  var tx = Tx.fromRaw( '0100000004de9b4bb17f627096a9ee0b4528e4eae17df5b5c69edc29704c2e84a7371db29f010000006b483045022100f5b1a0d33b7be291c3953c25f8ae39d98601aa7099a8674daf638a08b86c7173022006ce372da5ad088a1cc6e5c49c2760a1b6f085eb1b51b502211b6bc9508661f9012102ec5e3731e54475dd2902326f43602a03ae3d62753324139163f81f20e787514cffffffff7a1d4e5fc2b8177ec738cd723a16cf2bf493791e55573445fc0df630fe5e2d64010000006b483045022100cf97f6cb8f126703e9768545dfb20ffb10ba78ae3d101aa46775f5a239b075fc02203150c4a89a11eaf5e404f4f96b62efa4455e9525765a025525c7105a7e47b6db012102c01e11b1d331f999bbdb83e8831de503cd52a01e3834a95ccafd615c67703d77ffffffff9e52447116415ca0d0567418a1a4ef8f27be3ff5a96bf87c922f3723d7db5d7c000000006b483045022100f6c117e536701be41a6b0b544d7c3b1091301e4e64a6265b6eb167b15d16959d022076916de4b115e700964194ce36a24cb9105f86482f4abbc63110c3f537cd5770012102ddf84cc7bee2d6a82ac09628a8ad4a26cd449fc528b81e7e6cc615707b8169dfffffffff5815d9750eb3572e30d6fd9df7afb4dbd76e042f3aa4988ac763b3fdf8397f80010000006a473044022028f4402b736066d93d2a32b28ccd3b7a21d84bb58fcd07fe392a611db94cdec5022018902ee0bf2c3c840c1b81ead4e6c87c88c48b2005bf5eea796464e561a620a8012102b6cdd1a6cd129ef796faeedb0b840fcd0ca00c57e16e38e46ee7028d59812ae7ffffffff0220a10700000000001976a914c342bcd1a7784d9842f7386b8b3b8a3d4171a06e88ac59611100000000001976a91449f8c749a9960dc29b5cbe7d2397cea7d26611bb88ac00000000', 'hex');
  var blocks = require('../../regtest/data/blocks.json');
  var addressService;
  var sandbox;

  beforeEach(function() {
    sandbox = sinon.sandbox.create();
    addressService = new AddressService({
      node: {
        getNetworkName: function() { return 'regtest'; },
        services: []
      }
    });
    addressService._encoding = new Encoding(new Buffer('0000', 'hex'));
  });

  afterEach(function() {
    sandbox.restore();
  });

  describe('#start', function() {

    it('should get prefix for database', function(done) {
      var getPrefix = sandbox.stub().callsArgWith(1, null, new Buffer('ffee', 'hex'));
      addressService._db = { getPrefix: getPrefix };
      addressService.start(function() {
        expect(getPrefix.calledOnce).to.be.true;
        done();
      });
    });

  });

  describe('#stop', function() {
    it('should stop the service', function(done) {
      addressService.stop(function() {
        done();
      });
    });
  });


  describe('#getAddressHistory', function() {
    it('should get the address history', function(done) {

      sandbox.stub(addressService, '_getAddressHistory').callsArgWith(2, null, {});
      addressService.getAddressHistory(['a', 'b', 'c'], { from: 12, to: 14 }, function(err, res) {

        if (err) {
          return done(err);
        }

        expect(res).to.be.deep.equal({
          totalCount: 3,
          items: [ {}, {}, {} ]
        });

        done();
      });
    });

  });

  describe('#_getAddressHistory', function() {
    it('should get the address history', function(done) {
      var encoding = new Encoding(new Buffer('0001', 'hex'));
      addressService._encoding = encoding;
      var getHeaderHash = sandbox.stub().callsArgWith(1, null, 'aa');
      addressService._header = { getHeaderHash: getHeaderHash };
      var address = 'a';
      var opts = { from: 12, to: 14 };
      var txid = '1c6ea4a55a3edaac0a05e93b52908f607376a8fdc5387c492042f8baa6c05085';
      var data = [ null, encoding.encodeAddressIndexKey(address, 123, txid, 1, 1) ];
      var getTransaction = sandbox.stub().callsArgWith(2, null, { __height: 123, outputs: [ { value: 1 } ], __inputValues: [ 1 ] });
      addressService._tx = { getTransaction: getTransaction };

      var txidStream = new Readable();

      txidStream._read = function() {
        txidStream.push(data.pop());
      };

      var createReadStream = sandbox.stub().returns(txidStream);
      addressService._db = { createKeyStream: createReadStream };

      addressService._getAddressHistory(address, opts, function(err, res) {
        if (err) {
          return done(err);
        }
        expect(getTransaction.calledOnce).to.be.true;
        expect(res).to.deep.equal([
            {
              __blockhash: 'aa',
              __height: 123,
              __inputSatoshis: 1,
              __inputValues: [
                1
              ],
              __outputSatoshis: 1,
              outputs: [
                {
                  value: 1
                }
              ]
            }
        ]);
        done();
      });
    });
  });

  describe('#AddressSummary', function() {

    it('should get the address summary', function(done) {
      var encoding = new Encoding(new Buffer('0001', 'hex'));
      addressService._encoding = encoding;
      var address = 'a';
      var txid = tx.txid();
      var data = [ null, encoding.encodeAddressIndexKey(address, 123, txid, 1, 0) ];
      var inputValues = [120, 0, 120, 120];
      tx.__inputValues = inputValues;
      var getTransaction = sandbox.stub().callsArgWith(2, null, tx);
      addressService._tx = { getTransaction: getTransaction };
      addressService._header = { getBestHeight: function() { return 150; } };

      var txidStream = new Readable();

      txidStream._read = function() {
        txidStream.push(data.pop());
      };

      var createReadStream = sandbox.stub().returns(txidStream);
      addressService._db = { createKeyStream: createReadStream };

      addressService.getAddressSummary(address, {}, function(err, res) {
        if (err) {
          return done(err);
        }
        expect(getTransaction.calledOnce).to.be.true;
        expect(res).to.deep.equal({ addrStr: 'a',
          balance: 0.01139033,
          balanceSat: 1139033,
          totalReceived: 0.01139033,
          totalReceivedSat: 1139033,
          totalSent: 0,
          totalSentSat: 0,
          unconfirmedBalance: 0,
          unconfirmedBalanceSat: 0,
          unconfirmedTxApperances: 0,
          txApperances: 1,
          transactions: [ '25e28f9fb0ada5353b7d98d85af5524b2f8df5b0b0e2d188f05968bceca603eb' ]
        });
        done();
      });

    });

  });
  describe('#getAddressUnspentOutputs', function() {
    it('should get address utxos', function(done) {

      var encoding = new Encoding(new Buffer('0001', 'hex'));
      addressService._encoding = encoding;

      var address = 'a';
      var txid = tx.txid();
      var ts = Math.floor(new Date('2019-01-01').getTime() / 1000);

      var data = {
        key: encoding.encodeUtxoIndexKey(address, txid, 1),
        value: encoding.encodeUtxoIndexValue(123, 120000, ts, tx.outputs[1].script.raw)
      };

      addressService._header = { getBestHeight: function() { return 150; } };

      var txidStream = new EventEmitter();

      var createReadStream = sandbox.stub().returns(txidStream);
      addressService._db = { createReadStream: createReadStream };

      addressService.getAddressUnspentOutputs(address, {}, function(err, res) {
        if (err) {
          return done(err);
        }
        expect(res[0]).to.deep.equal({
          address: 'a',
          amount: 0.0012,
          confirmations: 27,
          confirmationsFromCache: true,
          satoshis: 120000,
          scriptPubKey: '76a91449f8c749a9960dc29b5cbe7d2397cea7d26611bb88ac',
          ts: 1546300800,
          txid: '25e28f9fb0ada5353b7d98d85af5524b2f8df5b0b0e2d188f05968bceca603eb',
          vout: 1
        });
        done();
      });

      txidStream.emit('data', data);
      txidStream.emit('end');

    });

  });

  describe('#onReorg', function() {

    it('should reorg', function(done ) {

      var commonAncestorHeader = bcoin.block.fromRaw(blocks[5], 'hex').toHeaders().toJSON();
      var oldBlocks = [bcoin.block.fromRaw(blocks[6], 'hex')];

      addressService.onReorg([commonAncestorHeader, oldBlocks], function(err, ops) {

        expect(ops.length).to.equal(1);
        expect(ops[0].type).to.equal('del');

        done();


      });

    });

  });
});