httpResponseServer diinisiasi oleh trx-center

Adhidarma Hadiwinoto
1 parent a2e812c335
Showing 1 changed file with 8 additions and 4 deletions Side-by-side Diff
center/messaging/trx-center.js
@@ -9,6 +9,7 @@ const request = require(&#39;request&#39;);
 const strftime = require('strftime');
 const config = require('../../config');
 const logger = require('../../logger');
+const httpResponseServer = require('../http-response-server');
  
 const module_name = path.basename(__filename);
  
@@ -128,6 +129,7 @@ function requestToCore(requestOptions, partner) {
  
 function parseCoreMessage(body) {
     let coreRes;
+
     try {
         coreRes = JSON.parse(body)
     }
@@ -135,17 +137,19 @@ function parseCoreMessage(body) {
         logger.warn('Exception on parsing CORE response as JSON', {body: body, err: err});
         coreRes = null;
     }
+
     return coreRes;
 }
  
+function setTransport(_transport) {
+    transport = _transport;
+    httpResponseServer.setTransport(transport);
+}
+
 const callback = {
     onOnline: onOnline,
     onIncomingMessage: onIncomingMessage
 }
  
-function setTransport(_transport) {
-    transport = _transport;
-}
-
 exports.callback = callback;
 exports.setTransport = setTransport;
...	...	@@ -9,6 +9,7 @@ const request = require('request');
9	9	const strftime = require('strftime');
10	10	const config = require('../../config');
11	11	const logger = require('../../logger');
	12	+const httpResponseServer = require('../http-response-server');
12	13
13	14	const module_name = path.basename(__filename);
14	15
...	...	@@ -128,6 +129,7 @@ function requestToCore(requestOptions, partner) {
128	129
129	130	function parseCoreMessage(body) {
130	131	let coreRes;
	132	+
131	133	try {
132	134	coreRes = JSON.parse(body)
133	135	}
...	...	@@ -135,17 +137,19 @@ function parseCoreMessage(body) {
135	137	logger.warn('Exception on parsing CORE response as JSON', {body: body, err: err});
136	138	coreRes = null;
137	139	}
	140	+
138	141	return coreRes;
139	142	}
140	143
	144	+function setTransport(_transport) {
	145	+ transport = _transport;
	146	+ httpResponseServer.setTransport(transport);
	147	+}
	148	+
141	149	const callback = {
142	150	onOnline: onOnline,
143	151	onIncomingMessage: onIncomingMessage
144	152	}
145	153
146		-function setTransport(_transport) {
147		- transport = _transport;
148		-}
149		-
150	154	exports.callback = callback;
151	155	exports.setTransport = setTransport;