turtlesoup

Minimal Event Sourcing helper for RethinkDB & node.js

install

npm install turtlesoup --save

usage

/*
// first create a db and table
var r = require('rethinkdb');
r.connect(function (err, conn) {
    r.create('demo').tableCreate('bucket').run(conn, function (){});
});
*/
var _turtlesoup = require('turtlesoup');
var turtlesoup = new _turtlesoup('demo', 'bucket'
 
setInterval(function () {
 
    turtlesoup.add({ demo: Math.random() * 11, timestamp: new Date() });
 
}, 1000);
 
pull(
    turtlesoup.get_all_latest(),
    pull.log()
)
 

methods

add

turtlesoup.add({ demo: true, timestamp: new Date().toISOString() });

Add a new JSON object with mandatory timestamp field which needs to be a Javascript Date object.

get_all

turtlesoup.get_all(function (results) {
    console.log(results);
});
 
// or
 
turtlesoup.get_latest(function({ demo: true }, function (results) {
        console.log(results, 'filtered on demo property');
});
 

Returns an array of all items in the table.

get_all_latest

turtlesoup.get_all_latest(function (results) {
        console.log(results);
});
 
// or
 
turtlesoup.get_all_latest(function({ demo: true }, function (results) {
    console.log(results, 'filtered on demo property');
});
 

Returns an array of all the items in the table with the latest first.

pull_all

pull(
    turtlesoup.pull_all(),
    pull.log()
)
 
// or
 
    turtlesoup.pull_all({ demo: true }) // filter on demo === true
 

Get each data item from a pull stream source.

pull_all_latest

pull(
    turtlesoup.pull_all_latest(),
    pull.log()
)
 
//
 
    turtlesoup.pull_all_latest({ demo: true }) // filter on demo === true
 

Get each item from a pull stream source with the latest coming first.