mirror of
https://github.com/openmhz/trunk-server.git
synced 2026-11-10 07:47:29 -05:00
39 lines
1.0 KiB
JavaScript
39 lines
1.0 KiB
JavaScript
var MongoClient = require('mongodb').MongoClient;
|
|
|
|
|
|
var host = process.env['MONGO_NODE_DRIVER_HOST'] != null ? process.env['MONGO_NODE_DRIVER_HOST'] : 'localhost';
|
|
var port = process.env['MONGO_NODE_DRIVER_PORT'] != null ? process.env['MONGO_NODE_DRIVER_PORT'] : 27017;
|
|
var dbUser = process.env['MONGO_TRUNK_FRONTEND_USER'] != null ? process.env['MONGO_TRUNK_FRONTEND_USER'] : null;
|
|
var dbPass = process.env['MONGO_TRUNK_FRONTEND_PASS'] != null ? process.env['MONGO_TRUNK_FRONTEND_PASS'] : null;
|
|
|
|
var state = {
|
|
db: null,
|
|
}
|
|
|
|
exports.connect = function(done) {
|
|
if (state.db) return done()
|
|
|
|
var url = 'mongodb://' + host + ':' + port;
|
|
|
|
MongoClient.connect(url, function(err, client) {
|
|
if (err) return done(err)
|
|
|
|
//test.equal(true, result);
|
|
state.db = client.db('scanner');
|
|
done();
|
|
})
|
|
}
|
|
|
|
exports.get = function() {
|
|
return state.db
|
|
}
|
|
|
|
exports.close = function(done) {
|
|
if (state.db) {
|
|
state.db.close(function(err, result) {
|
|
state.db = null
|
|
state.mode = null
|
|
done(err)
|
|
})
|
|
}
|
|
} |