index.js

var mongodb = require('mongodb');
var mysql = require('mysql');
var redis = require("redis");
var pg = require('pg');

function has (obj, key) {
  return Object.prototype.hasOwnProperty.call(obj, key);
}


var Stackato = function(opts){

    this.isStackato = (process.env.STACKATO_APP_NAME) ? true : false;

    this.port = (process.env.PORT) ? parseInt(process.env.PORT,10) : null;
    this.host = (process.env.VCAP_APP_HOST) ? process.env.VCAP_APP_HOST : null;

    if (process.env.VCAP_APPLICATION){
        this.app = JSON.parse(process.env.VCAP_APPLICATION);
        this.instance = JSON.parse(process.env.VMC_APP_INSTANCE);
        this.services = JSON.parse(process.env.VCAP_SERVICES);
    }

    if (this.instance){
        this.sudo = this.instance.sudo;
        this.instanceID = this.instance.instance_id;
        this.uris = this.instance.uris;
    }

    this.hasMongoDB = (process.env.MONGODB_URL) ? true : false;
    this.hasRedis = (process.env.REDIS_URL) ? true : false;
    this.hasMySQL = (process.env.MYSQL_URL) ? true : false;
    this.hasPostgreSQL = (process.env.POSTGRESQL_URL) ? true : false;
    this.hasHarbor = (process.env.STACKATO_HARBOR) ? true : false;
    if(this.hasHarbor) this.harborPort = parseInt(process.env.STACKATO_HARBOR, 10);

    if(process.env.STACKATO_FILESYSTEM) {
        this.hasFileSystem = true;
        this.fileSystemPath = process.env.STACKATO_FILESYSTEM;
    }

    if (process.env.STACKATO_SERVICES){

        this.services = JSON.parse(process.env.STACKATO_SERVICES);

        if(this.services){

            for(service in this.services){

                if(service == 'mongodb') this.hasMongoDB = true;
                if(service == 'redis') this.hasRedis = true;
                if(service == 'mysql') this.hasMySQL = true;
                if(service == 'postgresql') this.hasPostgreSQL = true;
                if(service == 'filesystem') this.hasFileSystem = true;
                if(service == 'harbor') this.hasHarbor = true;

            }
        }
    }

};

Stackato.prototype.getService = function(serviceName, cb){
    if(has(this.services, serviceName)){
        return cb(null, this.services[serviceName]);
    }else{
        return cb(null, null);
    }
}

Stackato.prototype.connectMongoDB = function(serviceName, opts, cb) {
    var self = this;

    if(opts instanceof Function) {
        cb = opts;
        opts = {safe:false};
    }
    if(!cb){
        return new Error('Last argument must be callback function')
    }
    if(!serviceName){
        return cb(new Error('Service name not specified'));
    }
    if (has(this.services, serviceName)){
        var service = self.services[serviceName];
        var server = new mongodb.Server(service.host, service.port, opts);
        new mongodb.Db(service.db, server, opts).open(function (err, client) {
          if(err) return cb(err, null);
          client.authenticate(service.username, service.password, function(err, status) {
                  cb(err, client);
          });
        });

    }else{
        cb(new Error('Cannot find a service named: ' + serviceName));
    }
};

Stackato.prototype.connectRedis = function(serviceName, opts, cb) {

    if(opts instanceof Function) {
        cb = opts;
        opts = {};
    }
    if(!cb){
        return new Error('Last argument must be callback function')
    }
    if(!serviceName){
        return cb(new Error('Service name not specified'));
    }
    if (has(this.services, serviceName)){
        var client = redis.createClient(this.services[serviceName].port, this.services[serviceName].host, opts);
        client.on('error', function(err){
            cb(err);
        });
        client.auth(this.services[serviceName].password, function(){
            return cb(null, client);
        });
    }else{
        cb(new Error('Cannot find a service named: ' + serviceName));
    }
};

Stackato.prototype.connectPostgreSQL = function(serviceName, opts, cb) {

    if(opts instanceof Function) {
        cb = opts;
        opts = {};
    }
    if(!cb){
        return new Error('Last argument must be callback function')
    }
    if(!serviceName){
        return cb(new Error('Service name not specified'));
    }
    if (has(this.services, serviceName)){

        pg.defaults.host = this.services[serviceName].host;
        pg.defaults.port = this.services[serviceName].port;
        pg.defaults.user = this.services[serviceName].user;
        pg.defaults.password = this.services[serviceName].password;
        pg.defaults.database = this.services[serviceName].name;

        pg.connect(function(err, client){
            cb(err, client, pg);
        });

    }else{
        cb(new Error('Cannot find a service named: ' + serviceName));
    }
};

Stackato.prototype.connectMySQL = function(serviceName, opts, cb) {

    if(opts instanceof Function) {
        cb = opts;
        opts = {};
    }
    if(!cb){
        return new Error('Last argument must be callback function')
    }
    if(!serviceName){
        return cb(new Error('Service name not specified'));
    }
    if (has(this.services, serviceName)){

        var connection = mysql.createConnection({
          host     : this.services[serviceName].host,
          port     : this.services[serviceName].port,
          user     : this.services[serviceName].user,
          password : this.services[serviceName].password,
          database : this.services[serviceName].name
        });

        connection.connect();

        cb(null, connection);

    }else{
        cb(new Error('Cannot find a service named: ' + serviceName));
    }
};

module.exports = new Stackato()