From 07d456ab77b911fee806568ee55b0edd97c20616 Mon Sep 17 00:00:00 2001 From: Eric Xanderson Date: Thu, 7 Sep 2017 17:34:31 -0500 Subject: [PATCH] Rough outline of switching to the reconnect changefeed --- src/db-driver.js | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/src/db-driver.js b/src/db-driver.js index 62463cd..2e30609 100755 --- a/src/db-driver.js +++ b/src/db-driver.js @@ -1,12 +1,20 @@ const logger = require('./logger')(module) -const rethinkdbdash = require('rethinkdbdash') +// const rethinkdbdash = require('rethinkdbdash') +const rethinkdbdash = require('rethinkdb-changefeed-reconnect') const is = require('./is') const enums = require('./enums') module.exports = function dbDriver (cxn) { logger('dbDriver', cxn) cxn = cxn !== undefined ? cxn : {} - const cxnCopy = Object.assign({}, cxn) + let reconnectOptions = { + changefeedName: cxn._name || // not sure what + maxAttempts: 10, + attemptDelay: 10000, + silent: false, + logger: global.console, + } + const cxnCopy = Object.assign({}, reconnectOptions, cxn) if (Object.keys(cxn).length < 1 || cxn.host != null ||