From 5ff7a921977a1732a153d5817851a334ffcafba8 Mon Sep 17 00:00:00 2001 From: Ben Gotow Date: Thu, 1 Dec 2016 18:54:26 -0800 Subject: [PATCH] [*] fix(deltas): 0 as first cursor, deltas from redis are already JSON --- packages/isomorphic-core/src/delta-stream-builder.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/isomorphic-core/src/delta-stream-builder.js b/packages/isomorphic-core/src/delta-stream-builder.js index edbd5dce0..5b9b91491 100644 --- a/packages/isomorphic-core/src/delta-stream-builder.js +++ b/packages/isomorphic-core/src/delta-stream-builder.js @@ -3,7 +3,7 @@ const Rx = require('rx') const stream = require('stream'); function stringifyTransactions(db, transactions = []) { - const transactionJSONs = transactions.map((t) => t.toJSON()) + const transactionJSONs = transactions.map((t) => (t.toJSON ? t.toJSON() : t)) transactionJSONs.forEach((t) => { t.cursor = t.id }); const byModel = _.groupBy(transactionJSONs, "object"); @@ -57,7 +57,7 @@ module.exports = { buildCursor({databasePromise}) { return databasePromise.then(({Transaction}) => { return Transaction.findOne({order: [['id', 'DESC']]}).then((t) => { - return (t || {}).id; + return t ? t.id : 0; }); }); },