Compare View

switch
from
...
to
 
Commits (3)

Changes

Showing 3 changed files Side-by-side Diff

center/http-response-server.js
... ... @@ -16,7 +16,6 @@ const logger = require('../logger');
16 16 let transport;
17 17  
18 18 function onRequest(request, response) {
19   - console.log('CEKIDOT');
20 19 response.end('OK');
21 20  
22 21 const qs = url.parse(request.url, true).query;
center/messaging/trx-center.js
... ... @@ -117,22 +117,33 @@ function requestToCore(requestOptions, cb) {
117 117 request(requestOptions, function(err, res, body) {
118 118 if (err || res.statusCode != 200) {
119 119 logger.warn('Error requesting to CORE', {module_name: module_name, method_name: 'requestToCore', requestOptions: requestOptions, err: err});
120   - transport.send(requestOptions.qs.terminal_name, 'INTERNAL ERROR');
121   - if (cb) { cb(null, {msg: 'INTERNAL ERROR'}); }
  120 + if (cb) {
  121 + cb(null, {msg: 'INTERNAL ERROR'});
  122 + }
  123 + else if (transport.send) {
  124 + transport.send(requestOptions.qs.terminal_name, 'INTERNAL ERROR');
  125 + }
122 126 return;
123 127 }
124 128  
125 129 let result = parseCoreMessage(body);
126 130 if (!result || !result.message) {
127   - transport.send(requestOptions.qs.terminal_name, 'INTERNAL ERROR');
128   - if (cb) { cb(null, {msg: 'INTERNAL ERROR'}); }
  131 + if (cb) {
  132 + cb(null, {msg: 'INTERNAL ERROR'});
  133 + }
  134 + else if (transport.send) {
  135 + transport.send(requestOptions.qs.terminal_name, 'INTERNAL ERROR');
  136 + }
129 137 return;
130 138 }
131 139  
132   - transport.send(requestOptions.qs.terminal_name, result.message);
133 140 if (cb) {
134 141 cb(null, result);
135 142 }
  143 + else if (transport.send) {
  144 + transport.send(requestOptions.qs.terminal_name, result.message);
  145 +
  146 + }
136 147 })
137 148 }
138 149  
1 1 {
2 2 "name": "komodo-sdk",
3   - "version": "1.4.14",
  3 + "version": "1.4.15",
4 4 "description": "SDK for Komodo",
5 5 "main": "index.js",
6 6 "scripts": {