Compare View
Commits (2)
Changes
Showing 2 changed files Side-by-side Diff
center/messaging/trx-center.js
... | ... | @@ -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; |