connection.js

var q = require('q');
var r = require('rethinkdbdash')();

var Connection = (function () {
    function Connection(options) {
        this.options = options;
        this.dbname = options.db;
        this.db = r.db(options.db);
    }
    Connection.prototype.run = function (exp) {
        var def = q.defer();
        exp.run(this.conn, function (err, stuff) {
            if (err)
                def.reject(err);
            else if (stuff && stuff.toArray) {
                stuff.toArray(function (err, items) {
                    if (err)
                        def.reject(err);
                    else
                        def.resolve(items);
                });
            } else
                def.resolve(stuff);
        }).error(function (err) {
            return def.reject(err);
        });
        return def.promise;
    };

    Connection.prototype.connect = function () {
        var _this = this;
        console.log("rethinkdb://" + this.options.host + ":" + this.options.port + "/" + this.options.db);
        var def = q.defer();
        r.connect(this.options, function (err, c) {
            if (err)
                def.reject(err);
            _this.conn = c;
            r.dbCreate(_this.options.db).run(_this.conn, function (err, result) {
                // ignore error (It's probably an already created error)
                _this.conn.use(_this.options.db);
                def.resolve(_this.conn);
            });
        });
        return def.promise;
    };
    return Connection;
})();
exports.Connection = Connection;