Komodo / komodo-sdk-push-trx

Download as
Browse Code ยป

Commit 817328fa7799d047ac808655d36bf3e00068665d

Authored by Adhidarma Hadiwinoto
1 parent db4dc1afc5
Exists in master

Fix gateway url verification

Showing 1 changed file with 1 additions and 1 deletions Inline Diff

1 const MODULE_NAME = 'KOMODO_SDK-PUSH-TRX.CLIENT'; 1 const MODULE_NAME = 'KOMODO_SDK-PUSH-TRX.CLIENT';
2 2
3 const config = require('komodo-sdk/config'); 3 const config = require('komodo-sdk/config');
4 const logger = require('tektrans-logger'); 4 const logger = require('tektrans-logger');
5 const uniqid = require('uniqid'); 5 const uniqid = require('uniqid');
6 const connect = require('./connect'); 6 const connect = require('./connect');
7 7
8 const debugAllGatewaysFromConfig = global.SDK_PUSH_TRX_DEBUG_ALL_GATEWAYS_FROM_CONFIG 8 const debugAllGatewaysFromConfig = global.SDK_PUSH_TRX_DEBUG_ALL_GATEWAYS_FROM_CONFIG
9 || false; 9 || false;
10 10
11 const connectAll = (xidFromCaller) => { 11 const connectAll = (xidFromCaller) => {
12 const xid = xidFromCaller || uniqid(); 12 const xid = xidFromCaller || uniqid();
13 13
14 const gateways = config.gateways 14 const gateways = config.gateways
15 .filter((gateway) => !gateway.disabled 15 .filter((gateway) => !gateway.disabled
16 && gateway.name 16 && gateway.name
17 && gateway.url 17 && gateway.url
18 && (gateway.url.indexOf('ws://') === 0) 18 && (gateway.url.indexOf('ws://') !== 0)
19 && ((new URL(gateway.url) || {}).protocol === 'ws:')); 19 && ((new URL(gateway.url) || {}).protocol === 'ws:'));
20 20
21 if (debugAllGatewaysFromConfig) { 21 if (debugAllGatewaysFromConfig) {
22 logger.verbose(`${MODULE_NAME} 80C7AAD6: Dumping config.gateways`, { 22 logger.verbose(`${MODULE_NAME} 80C7AAD6: Dumping config.gateways`, {
23 xid, 23 xid,
24 gateways: config.gateways, 24 gateways: config.gateways,
25 }); 25 });
26 } 26 }
27 27
28 logger.verbose(`${MODULE_NAME} 79B5FEB5: Connecting to all gateways`, { 28 logger.verbose(`${MODULE_NAME} 79B5FEB5: Connecting to all gateways`, {
29 xid, 29 xid,
30 gatewayNames: gateways.map((gateway) => gateway.name), 30 gatewayNames: gateways.map((gateway) => gateway.name),
31 }); 31 });
32 32
33 gateways.forEach((gateway) => { 33 gateways.forEach((gateway) => {
34 connect(xid, gateway); 34 connect(xid, gateway);
35 }); 35 });
36 }; 36 };
37 37
38 connectAll(); 38 connectAll();
39 39