collection

// Modules
const EventsEmitter = require('events');

// Libs
const _ = require('lodash');
const Winston = require('winston');
const Pluralize = require('pluralize');
const Promise = require('bluebird');

const bookshelf = require('./pg');

function Collection(dbSettings) {
  const defaults = {
    tableName: 'default'
  };
  this.settings = Object.assign({}, defaults, dbSettings);
  this.tableName = this.settings.tableName;
  this.model = null;

  delete this.settings.tableName;

  this.orm = bookshelf(this.settings);
}

const proto = {
  setModel: function(name, model) {
    const defaults = {
      tableName: this.tableName,
    };
    const modelData = Object.assign({}, defaults, model);
    const baseModel = this.orm.Model.extend.call(this.orm.Model, modelData);
    this.model = this.orm.model(name, baseModel);
  },

  create(record, options) {
  },

  read(record, options) {
  },

  update(search, updateValues, options) {
  },

  delete(record, options) {
  },
};

Collection.prototype = proto;

module.exports = Collection;

rest

const Winston = require('winston');
const _ = require('lodash');

const Collection = require('./collection');

class Rest {
  constructor(server, pgSettings) {
    this.server = server;
    this.db = new Collection(pgSettings);
    this.route = {};
    this.route.before = [];
    this.route.after = [];
  }
}

module.exports = Rest;

test

const connection = {
  tableName: 'user',
  connection: {
    host: '192.168.99.100',
    port: 5432,
    user: 'pgUser',
    password: 'password',
    database: 'local'
  }
};
const User = new Rest({}, connection);

connection.tableName = 'comments';
const Comments = new Rest({}, connection);

Comments.db.setModel('Comments', {
  user: function() {
    return this.belongsTo('User');
  }
});

User.db.setModel({
  firstName: function() {
    return this.get('first') + ' ' + this.get('last');
  },
  comments: function() {
    return this.hasMany('Comments');
  }
});

User.db.model.forge().fetch({ withRelated: ['comments']}).then((user) => {
  console.log('user comments', user.related('comments'));
});