Wrapper around node-postgres

pg.js

var BPromise = require('bluebird'),
  pg = require('pg');

function Postgres(opts) {
  this.host = opts.host;
}

Postgres.prototype.query = function(sql) {
  return new BPromise(function(resolve, reject){
    
    var opts = { host: this.host };
    
    pg.connect(opts, function(err, client, done) {
      var queryCallback = function(err, ret) {

        if (err) {
          reject(new Error(err));
        } else {
          done();
          resolve();
        }
        
      };
      if (err) {
        reject(new Error(err));
      } else {
        client.query(sql, queryCallback)
      }
    });
  })    
};

module.exports = Postgres;