transaction-queue-test.js

var assert = require('assert');
var utils = require('./testutils');
var Transaction = utils.load_module('transaction').Transaction;
var TransactionQueue = utils.load_module('transactionqueue').TransactionQueue;

describe('Transaction queue', function() {
  it('Push transaction', function() {
    var queue = new TransactionQueue();
    var tx = new Transaction();

    queue.push(tx);

    assert.strictEqual(queue.length(), 1);
  });

  it('Remove transaction', function() {
    var queue = new TransactionQueue();
    var tx = new Transaction();

    queue.push(tx);
    queue.remove(tx);

    assert.strictEqual(queue.length(), 0);
  });

  it('Remove transaction by ID', function() {
    var queue = new TransactionQueue();
    var tx = new Transaction();

    queue.push(tx);

    tx.submittedIDs = [
      '1A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B',
      '2A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'
    ];

    queue.remove('3A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B');

    assert.strictEqual(queue.length(), 1);

    queue.remove('2A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B');

    assert.strictEqual(queue.length(), 0);
  });

  it('Add sequence', function() {
    var queue = new TransactionQueue();
    queue.addReceivedSequence(1);
    assert(queue.hasSequence(1));
  });

  it('Add ID', function() {
    var queue = new TransactionQueue();
    var tx = new Transaction();
    queue.addReceivedId('1A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B', tx);
    assert.strictEqual(queue.getReceived('2A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'), void(0));
    assert.strictEqual(queue.getReceived('1A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'), tx);
  });

  it('Get submission', function() {
    var queue = new TransactionQueue();
    var tx = new Transaction();

    queue.push(tx);

    tx.submittedIDs = [
      '1A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B',
      '2A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'
    ];

    assert.strictEqual(queue.getSubmission('1A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'), tx);
    assert.strictEqual(queue.getSubmission('2A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'), tx);
    assert.strictEqual(queue.getSubmission('3A4DEBF37496464145AA301F0AA77712E3A2BFE3480D24C3584663F800B85B5B'), void(0));
  });

  it('Iterate over queue', function() {
    var queue = new TransactionQueue();
    var count = 10;

    for (var i=0; i<count; i++) {
      queue.push(new Transaction());
    }

    queue.forEach(function(tx) {
      assert(tx instanceof Transaction);
      --count;
    });

    assert.strictEqual(count, 0);
  });
});