diff --git a/partner-sc.js b/partner-sc.js index f2e6880..0de49a7 100644 --- a/partner-sc.js +++ b/partner-sc.js @@ -8,6 +8,8 @@ var strftime = require('strftime'); var math = require('mathjs'); var winston = require('winston'); var cekstatus = require('./cekstatus.js'); +var mongoClient = require('mongodb').MongoClient; +var mongodb; var config; var httpServer; @@ -21,6 +23,29 @@ var sleep_before_retry = 30000; var logTag = __filename.split('/').reverse()[0]; +unction initMongoClient() { + if (!config.mongodb || !config.mongodb.url) { + return; + } + + try { + var url = config.mongodb.url; + + mongoClient.connect(url, function(err, db) { + if (err) { + logger.warn('Failed to connect to mongodb', {err: err}); + return; + } + mongodb = db; + logger.info('MongoDB connected'); + }); + } + catch(err) { + logger.warn('Exception when connecting to mongodb', {err: err, url: url}); + } + +} + function topupRequest(task) { var ts = strftime('%Y%m%d%H%M%S', new Date());