node-eventstore-client/test/readStreamEventsForward_test.js

var uuid = require('uuid');
var client = require('../lib/dist');
var Long = require('long');

const streamSize = 100;

var NOSTREAM_VERSION = Long.fromNumber(client.expectedVersion.noStream);

module.exports = {
  setUp: function(cb) {
    this.eventsData = [];
    for(var i = 0; i < streamSize; i++)
      this.eventsData.push(client.createJsonEventData(uuid.v4(), {a: uuid.v4(), b: Math.random()}, null, 'anEvent'));
    this.conn.appendToStream(this.testStreamName, NOSTREAM_VERSION, this.eventsData)
        .then(function() {
          cb();
        })
        .catch(cb);
  },
  'Read Stream Events Forward Happy Path': function(test) {
    test.expect(7 + (streamSize * 11));
    var self = this;
    this.conn.readStreamEventsForward(this.testStreamName, Long.fromNumber(0), streamSize)
        .then(function(slice) {
          test.areEqual('slice.status', slice.status, client.eventReadStatus.Success);
          test.areEqual('slice.stream', slice.stream, self.testStreamName);
          test.areEqual('slice.fromEventNumber', slice.fromEventNumber, Long.fromNumber(0));
          test.areEqual('slice.readDirection', slice.readDirection, 'forward');
          test.areEqual('slice.nextEventNumber', slice.nextEventNumber, Long.fromNumber(streamSize));
          test.areEqual('slice.lastEventNumber', slice.lastEventNumber, Long.fromNumber(streamSize-1));
          test.areEqual('slice.isEndOfStream', slice.isEndOfStream, true);
          for(var i = 0; i < streamSize; i++) {
            test.eventEqualEventData('slice.events[' + i + ']', slice.events[i], self.eventsData[i]);
            test.testReadEvent('slice.events[' + i + ']', slice.events[i], i);
          }
          test.done();
        })
        .catch(function(err) {
          test.done(err);
        })
  },
  'Read Stream Events Forward With Non-Existing Stream': function(test) {
    test.expect(4);
    var anotherStream = 'test' + uuid.v4();
    this.conn.readStreamEventsForward(anotherStream, Long.fromNumber(0), streamSize)
        .then(function(slice) {
          test.areEqual('slice.status', slice.status, client.sliceReadStatus.StreamNotFound);
          test.areEqual('slice.stream', slice.stream, anotherStream);
          test.areEqual('slice.fromEventNumber', slice.fromEventNumber, Long.fromNumber(0));
          test.areEqual('slice.events.length', slice.events.length, 0);
          test.done();
        })
        .catch(function(err) {
          test.done(err);
        });
  },
  'Read Stream Events Forward With Deleted Stream': function(test) {
    test.expect(4);
    var self = this;
    this.conn.deleteStream(this.testStreamName, Long.fromNumber(streamSize-1), true)
        .then(function() {
          return self.conn.readStreamEventsForward(self.testStreamName, Long.fromNumber(0), streamSize)
        })
        .then(function(slice) {
          test.areEqual('slice.status', slice.status, client.eventReadStatus.StreamDeleted);
          test.areEqual('slice.stream', slice.stream, self.testStreamName);
          test.areEqual('slice.fromEventNumber', slice.fromEventNumber, Long.fromNumber(0));
          test.areEqual('slice.events.length', slice.events.length, 0);
          test.done();
        })
        .catch(function(err) {
          test.done(err);
        });
  },
  'Read Stream Events Forward With Inexisting Version': function(test) {
    test.expect(4);
    var self = this;
    return self.conn.readStreamEventsForward(self.testStreamName, Long.fromNumber(streamSize * 2), streamSize)
        .then(function(slice) {
          test.areEqual('slice.status', slice.status, client.eventReadStatus.Success);
          test.areEqual('slice.stream', slice.stream, self.testStreamName);
          test.areEqual('slice.fromEventNumber', slice.fromEventNumber, Long.fromNumber(streamSize*2));
          test.areEqual('slice.events.length', slice.events.length, 0);
          test.done();
        })
        .catch(function(err) {
          test.done(err);
        });
  },
  'Read Stream Events Forward With No Access': function(test) {
    test.expect(1);
    var self = this;
    var metadata = {$acl: {$r: '$admins'}};
    this.conn.setStreamMetadataRaw(self.testStreamName, NOSTREAM_VERSION, metadata)
        .then(function(){
          return self.conn.readStreamEventsForward(self.testStreamName, Long.fromNumber(0), streamSize);
        })
        .then(function(slice) {
          test.fail("readStreamEventsForward succeeded but should have failed.");
          test.done();
        })
        .catch(function(err) {
          var isAccessDenied = err instanceof client.AccessDeniedError;
          test.ok(isAccessDenied, "readStreamEventsForward should have failed with AccessDeniedError, got " + err.constructor.name);
          if (isAccessDenied) return test.done();
          test.done(err);
        });
  }
};

require('./common/base_test').init(module.exports);