const Watcher = require('postgres-watcher')
const watcher = Watcher({
  db: 'postgres://foo@localhost:5432/db',
  channel: 'table_update', // optional
  
  // optional filter function.
  // only payloads which return a truthy value 
  // will later emit a 'change' event
  filter: function (payload) { return payload.id >= 42 }
})
 
// listen for changes
watcher.on('change', function (change) {
  console.log(change) // { id: 1, type: 'INSERT', table: 'foo', ... }
})
 
watcher.on('error', console.error.bind(console))
 
// start watching, callback is optional
watcher.start(function(err) {
  if (err) throw err
  console.log(watcher.running) // true
})
 
// insert, update, delete rows in your db...
 
// stop watching, callback is optional
watcher.stop(function () {})