flatsoup

event sourcing (append only log) to a flat file

install

npm install flatsoup

example

 
var pull     = require('pull-stream');
var test     = require('tape');
var flatsoup = require('flatsoup');
 
var database = 'demo';
var table    = 'event_bucket';
 
var demo = new flatsoup(database, table);
 
demo.clear();
 
test('add events and listen as pull streams', function (t) {
    
    t.plan(7);	
 
    demo.add({demo:true, order: 0}, function () {
        t.ok(true, 'add handles callback')
    });
    
    demo.add({demo:false, order: 1});
 
    var counter = 0;
    var counter_latest = 1; 
 
    pull(
        demo.pull_all(),
        pull.drain(function (item) {
            t.ok(item.value.order === counter, 'can pull event');
            counter += 1;	
        })
    );
 
    pull(
        	demo.pull_all_latest(),
        	pull.drain(function (item) {
            t.ok(item.value.order === counter_latest, 'can pull latest event');
            counter_latest -= 1;
        	})
    );
 
 
    demo.get_all(function (results) {
        t.ok(results[0].value.order < results[1].value.order, 'can get all with callback');
    });
 
    demo.get_all_latest(function (results) {
        	t.ok(results[0].value.order > results[1].value.order, 'can get latest with callback');
    });
 
    pull(
        	demo.pull_all_latest(),
        	pull.drain(function (item) {
            console.log('[events found]', item)
        	})
    )
});