pgservice.js

import dbmon from 'dbmon';
import EventEmitter from 'events';

export default function(name, schema) {
  return {
    setup(app) {
      this.db = app.db;
      this.model = this.db.define(name, schema, { freezeTableName: true });
      this.model.sync();

      let emitter = new EventEmitter;
      let channel = dbmon.channel({
        driver: 'postgresql',
        driverOpts: {
          // postgresql: { cli: app.pgcli }
          postgresql: { connStr: 'tcp://127.0.0.1:5432/lbtest' }
        },
        table: name,
        monitor: 'all',
        keyfld: { name: 'id', type: 'integer' },
        transports: 'console,eventemitter',
        transportsOpts: {
          eventEmitter: { eventEmitter: emitter}
        }
      });
      emitter.on('insert', (row) => {
        console.log('insert', row);
        this.model.findOne({where: {id: row.k}}).then((obj) => {
          console.log('created', JSON.stringify(obj));
          this.emit('created', obj);
        })
      });
    },

    find(params, callback) {
      this.model.findAll().then((models) => {
        callback(null, models);
      }).error(callback);
    },

    create(data, params, callback) {
      this.model.create(data).then((model) => {
        callback(null, model);
      }).error(callback);
    },

    get(id, params, callback) {
      this.model.findOne({id}).then((model) => {
        callback(null, model);
      }).error(callback);
    },

    update(id, data, params, callback) {
      this.model.findOne({id}).then((model) => {
        model.update(data).then((model) => {
          callback(null, model);
        }).error(callback);
      }).error(callback);
    },

    patch(id, data, params, callback) {
      this.update(id, data, params, callback);
    },

    remove(id, params, callback) {
      this.model.findOne({id}).then((model) => {
        model.destroy().then(() => {
          callback(null, model);
        }).error(callback);
      }).error(callback);
    }
  };
};