var overwatch = require('overwatch');
 
var watcher = overwatch({
  //
  // For each couch that is not the hub, it has an optional `pullOnly` property
  // if you do not need to ensure bi-directional replication.
  // Also, the set of dbs for replication will be pulled from the `hub` couch
  // by default if they are not specified directly
  //
  couches: [
    { url: 'http://username:password@myDB.iriscouch.com', hub: true },
    { url: 'http://localhost:5984' }
  ],
  //
  // Fulfillment timeout.
  //
  timeout: 5000,
  //
  // Database filter function if you want to ignore replication for a particular databases
  //
  filter: function (db) { return !/somethingIDontCareAbout/.test(db) },
 
  //
  // `follow` options for the underlying `follow` instances
  //
  follow: {
    inactivity_ms: 1800000
  }
});
 
//
// Listen on some events with your own functions
//
watcher.on('error', function (err) {
  //
  // Remark: this error is probably from `follow` and we should crash as its
  // probably an unresponsive couch and we have bigger problems.
  // This is tweaked through setting the `inactivity_ms` in the follow options object.
  //
  console.error(err);
  process.exit(1);
});
 
//
// We are now listening on live changes for all feeds for this database
//
watcher.on('live', function (db) {
  console.log('Watching on live changes for ' + db);
});
 
//
// Log some events when we process each change for each couch and database
//
watcher.on('processChange', function (change) {
  console.log('processing change');
  console.log('couch url ' + change.couch)
  console.log('database ' + change.db);
  console.log('revision ' + change.rev);
  console.log('doc id ' + change.id);
  console.log('update seq ' + change.seq);
});
 
//
// Oh gosh couch failed to fulfill its promise to replicate :'(.
// Bad couchdb
//
watcher.on('unfulfilled', function (unfulfilled) {
  var source = unfulfilled.source,
      target = unfulfilled.target,
      error = unfulfilled.error,
      db    = unfulfilled.db;
 
  console.error(error);
  console.log('We failed to replicate from '
    + source + ' to ' + target + ' for database ' + db);
  console.log('We should probably take some action');
});
 
//
// Emits when we are listening on live changes for a particular couch and
// database. It is a proxy of `follow`s catchup event and is just a signal of
// progress in the initialization. We may still be buffering events if this is
// not the last database to catchup
//
watcher.on('catchUp', function(feed) {
  console.log('Feed for ' + feed.db ' on couch url' + feed.couch
    + ' is caught up with sequence id ' + feed.seq);
});
 

var Overwatch = require('overwatch');
 
//
// Remark: subtle note that we support calling with or without `new`
//
var watcher = new Overwatch({
  couches: [
    { url: 'http://username:password@myCouch.iriscouch.com', hub: true },
    { url: 'http://localhost:5984' }
  ],
  dbs: ['foo', 'bar', 'baz']
});
 
watcher.on('unfulfilled', function (unfulfilled) {
  //
  // Same as above example
  //
});