resend-report

Adhidarma Hadiwinoto
1 parent 543431fe9c
Showing 3 changed files with 49 additions and 1 deletions Side-by-side Diff
aaa-report-sender.js
index.js
package.json
@@ -0,0 +1,41 @@
+var request = require('request');
+var moment = require('moment');
+
+var config;
+var monitorUtil;
+
+function init(options) {
+    config = options.config;
+    monitorUtil = options.monitorUtil;
+}
+
+function _resend(requestId, cb) {
+    monitorUtil.getTrx(requestId, function(err, trx) {
+
+        if (err) {
+            cb(err);
+            return;
+        }
+
+        var options = {
+            url: config.aaa_url + '/topup',
+            qs: {
+                trans_id: requestId,
+                trans_date: moment().format('YYYYMMDDHHmmss'),
+                resp_code: trx.rc,
+                ussd_msg: trx.supplier + '$' + trx.lastResponse.parsed.MESSAGE
+            }
+        };
+
+        cb(null);
+    });
+}
+
+function resend(req, res, next) {
+    _resend(req.params.id, function(err) {
+        res.redirect("/trx/view/" + req.params.id);
+    });
+}
+
+exports.init = init;
+exports.resend = resend;
@@ -36,12 +36,16 @@ monitorUtil.init({
 })
  
 var controllerOptions = {
-    config: config
+    config: config,
+    monitorUtil: monitorUtil
 }
  
 var UsersController = require("./usersController");
 var usersController = new UsersController(config);
  
+var aaaReportSender = require("./aaa-report-sender");
+aaaReportSender.init(controllerOptions);
+
 var app = express();
  
 app.use(morgan('combined', {stream: accessLogStream}));
@@ -347,6 +351,7 @@ app.get(&#39;/logout&#39;, logout);
 app.get('/runtime-info', authNeeded, adminNeeded, pageRuntimeInfo);
  
 app.get('/trx/view/:id', authNeeded, pageTrxView);
+app.get('/trx/resend-report/:id', authNeeded, adminNeeded, aaaReportSender.resend);
  
 app.get('/users', authNeeded, adminNeeded, usersController.index);
 app.get('/users/view/:id', authNeeded, adminNeeded, usersController.view);
@@ -27,9 +27,11 @@
     "express-session": "^1.13.0",
     "file-stream-rotator": "0.0.6",
     "lru-cache": "^4.0.1",
+    "moment": "^2.15.1",
     "mongodb": "^2.1.18",
     "morgan": "^1.7.0",
     "nunjucks": "^2.4.2",
+    "request": "^2.75.0",
     "strftime": "^0.9.2",
     "winston": "^2.2.0"
   },
...	...	@@ -0,0 +1,41 @@
	1	+var request = require('request');
	2	+var moment = require('moment');
	3	+
	4	+var config;
	5	+var monitorUtil;
	6	+
	7	+function init(options) {
	8	+ config = options.config;
	9	+ monitorUtil = options.monitorUtil;
	10	+}
	11	+
	12	+function _resend(requestId, cb) {
	13	+ monitorUtil.getTrx(requestId, function(err, trx) {
	14	+
	15	+ if (err) {
	16	+ cb(err);
	17	+ return;
	18	+ }
	19	+
	20	+ var options = {
	21	+ url: config.aaa_url + '/topup',
	22	+ qs: {
	23	+ trans_id: requestId,
	24	+ trans_date: moment().format('YYYYMMDDHHmmss'),
	25	+ resp_code: trx.rc,
	26	+ ussd_msg: trx.supplier + '$' + trx.lastResponse.parsed.MESSAGE
	27	+ }
	28	+ };
	29	+
	30	+ cb(null);
	31	+ });
	32	+}
	33	+
	34	+function resend(req, res, next) {
	35	+ _resend(req.params.id, function(err) {
	36	+ res.redirect("/trx/view/" + req.params.id);
	37	+ });
	38	+}
	39	+
	40	+exports.init = init;
	41	+exports.resend = resend;
...	...	@@ -36,12 +36,16 @@ monitorUtil.init({
36	36	})
37	37
38	38	var controllerOptions = {
39		- config: config
	39	+ config: config,
	40	+ monitorUtil: monitorUtil
40	41	}
41	42
42	43	var UsersController = require("./usersController");
43	44	var usersController = new UsersController(config);
44	45
	46	+var aaaReportSender = require("./aaa-report-sender");
	47	+aaaReportSender.init(controllerOptions);
	48	+
45	49	var app = express();
46	50
47	51	app.use(morgan('combined', {stream: accessLogStream}));
...	...	@@ -347,6 +351,7 @@ app.get('/logout', logout);
347	351	app.get('/runtime-info', authNeeded, adminNeeded, pageRuntimeInfo);
348	352
349	353	app.get('/trx/view/:id', authNeeded, pageTrxView);
	354	+app.get('/trx/resend-report/:id', authNeeded, adminNeeded, aaaReportSender.resend);
350	355
351	356	app.get('/users', authNeeded, adminNeeded, usersController.index);
352	357	app.get('/users/view/:id', authNeeded, adminNeeded, usersController.view);
...	...	@@ -27,9 +27,11 @@
27	27	"express-session": "^1.13.0",
28	28	"file-stream-rotator": "0.0.6",
29	29	"lru-cache": "^4.0.1",
	30	+ "moment": "^2.15.1",
30	31	"mongodb": "^2.1.18",
31	32	"morgan": "^1.7.0",
32	33	"nunjucks": "^2.4.2",
	34	+ "request": "^2.75.0",
33	35	"strftime": "^0.9.2",
34	36	"winston": "^2.2.0"
35	37	},