From 9ab0922b3027e212c0f60f25d495fd1a4eb22b8e Mon Sep 17 00:00:00 2001 From: Patrick Titzler Date: Wed, 7 Sep 2016 13:26:44 -0700 Subject: [PATCH] i10: enhance status output --- lib/replicate.js | 21 ++++++++++++++++++++- package.json | 2 +- 2 files changed, 21 insertions(+), 2 deletions(-) diff --git a/lib/replicate.js b/lib/replicate.js index 95c5482..f213716 100644 --- a/lib/replicate.js +++ b/lib/replicate.js @@ -56,7 +56,12 @@ function Replicator(sourceCredentials, filtered: 0, // documents that were not copied because the filter condition was met last_change_received: null, // timestamp for last change notification that was received from the source database last_change_applied: null, // timestamp for last write operation in the target database - last_update_seq: 0 // CouchDB update_seq number for the last change that was written to the target database + last_update_seq: 0, // CouchDB update_seq number for the last change that was written to the target database + filter: { + server: null, + client: null + }, + transformer: null }; } // constructor @@ -213,6 +218,11 @@ Replicator.prototype.init = function(initCallback) { return initCallback(err); } + this.stats.transformer = { + name : transformer.getName(), + definition : transformer.getRoutineDefinition() + }; + // load filters, if configured require('./filter.js').getFilter(sourceDb, function(err, filter) { @@ -220,6 +230,15 @@ Replicator.prototype.init = function(initCallback) { return initCallback(err); } + this.stats.filter.server = { + name : filter.getServerFilterName(), + definition : filter.getServerFilterDefinition() + }; + this.stats.filter.client = { + name : filter.getClientFilterName(), + definition : filter.getClientFilterDefinition() + }; + console.log('Replicator ready. Starting to listen for changes in database "' + this.sourceCredentials.dbname + '". Changes will be applied to database "' + this.targetCredentials.dbname + '".'); diff --git a/package.json b/package.json index 590dfcc..3887c7d 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "couchdb-db-transform", - "version": "0.0.2", + "version": "0.0.3", "description": "Fetches documents from one couchdb database, optionally transforms them and inserts them into target database", "main": "app.js", "scripts": {