mirror of
https://github.com/openstf/stf
synced 2025-10-04 18:29:17 +02:00
26 lines
626 B
JavaScript
26 lines
626 B
JavaScript
var r = require('rethinkdb')
|
|
var re = require('rethinkdb/errors')
|
|
var Promise = require('bluebird')
|
|
|
|
module.exports.errors = re
|
|
|
|
module.exports.connect = function(options) {
|
|
var resolver = Promise.defer()
|
|
r.connect(options, resolver.callback)
|
|
return resolver.promise
|
|
}
|
|
|
|
module.exports.close = function(conn, options) {
|
|
var resolver = Promise.defer()
|
|
if (!options) {
|
|
options = {}
|
|
}
|
|
conn.close(options, resolver.callback)
|
|
return resolver.promise
|
|
}
|
|
|
|
module.exports.run = function(conn, q, options) {
|
|
var resolver = Promise.defer()
|
|
q.run(conn, options || {}, resolver.callback)
|
|
return resolver.promise
|
|
}
|