Compare View
Commits (2)
Changes
Showing 2 changed files Side-by-side Diff
center/messaging/trx-center.js
... | ... | @@ -63,17 +63,18 @@ function executePriceCheck(paramsFromTransport) { |
63 | 63 | requestToCore(requestOptions); |
64 | 64 | } |
65 | 65 | |
66 | -function parseBalanceResponse(body) { | |
67 | - let result; | |
66 | +function parseCoreMessage(body) { | |
67 | + let coreRes; | |
68 | 68 | |
69 | 69 | try { |
70 | - result = JSON.parse(body); | |
70 | + coreRes = JSON.parse(body) | |
71 | 71 | } |
72 | - catch(e) { | |
73 | - logger.warn('Error JSON parsing', {module_name: module_name, method_name: 'parseBalanceResponse', body: body}) | |
74 | - result = null; | |
72 | + catch(err) { | |
73 | + logger.warn('Exception on parsing CORE response as JSON', {body: body, err: err}); | |
74 | + coreRes = null; | |
75 | 75 | } |
76 | - return result; | |
76 | + | |
77 | + return coreRes; | |
77 | 78 | } |
78 | 79 | |
79 | 80 | function generateRequestId(req) { |
... | ... | @@ -119,7 +120,7 @@ function requestToCore(requestOptions, partner) { |
119 | 120 | return; |
120 | 121 | } |
121 | 122 | |
122 | - let result = parseBalanceResponse(body); | |
123 | + let result = parseCoreMessage(body); | |
123 | 124 | if (!result || !result.message) { |
124 | 125 | transport.send(requestOptions.qs.terminal_name, 'INTERNAL ERROR'); |
125 | 126 | return; |
... | ... | @@ -129,20 +130,6 @@ function requestToCore(requestOptions, partner) { |
129 | 130 | }) |
130 | 131 | } |
131 | 132 | |
132 | -function parseCoreMessage(body) { | |
133 | - let coreRes; | |
134 | - | |
135 | - try { | |
136 | - coreRes = JSON.parse(body) | |
137 | - } | |
138 | - catch(err) { | |
139 | - logger.warn('Exception on parsing CORE response as JSON', {body: body, err: err}); | |
140 | - coreRes = null; | |
141 | - } | |
142 | - | |
143 | - return coreRes; | |
144 | -} | |
145 | - | |
146 | 133 | function setTransport(_transport) { |
147 | 134 | transport = _transport; |
148 | 135 | httpResponseServer.setTransport(transport); |