dbot/database.js

var databank = require('databank'),
    Databank = databank.Databank,
    DatabankObject = databank.DatabankObject,
    _ = require('underscore')._;

/**
 * Multiplex databank objects
 */
var DatabaseDriver = function(config) {
    this.config = config;
    this.databanks = {};
};

/**
 * Connect to or create a new DataBank
 */
DatabaseDriver.prototype.createDB = function(name, driver, schema, callback) {
    if(!_.has(this.databanks, name)) {
        var params = { 'schema': schema };

        if(driver == 'redis' && _.has(this.config, 'redisPort')) params.port = this.config.redisPort;
        if(driver == 'disk') params.dir = 'db';

        this.databanks[name] = Databank.get(driver, params);
        this.databanks[name].connect({}, function(err) {
            if(err) {
                console.log('Didn\'t manage to connect to the data source - ' + err);
            } else {
                callback(this.databanks[name]);
            }
        }.bind(this));
    } else {
        callback(this.databanks[name]);
    }
};

exports.DatabaseDriver = DatabaseDriver;