Commit 2507b4aed4c8c0e70f3b7edfb3f53adb59f667c2

Authored by Adhidarma Hadiwinoto
1 parent 891017834b
Exists in master

Filter connectAll only on gateway with ws protocol url

Showing 1 changed file with 4 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 && gateway.url && gateway.name); 15 .filter((gateway) => !gateway.disabled
16 && gateway.name
17 && gateway.url
18 && ((new URL(gateway.url) || {}).protocol === 'ws:'));
16 19
17 if (debugAllGatewaysFromConfig) { 20 if (debugAllGatewaysFromConfig) {
18 logger.verbose(`${MODULE_NAME} 80C7AAD6: Dumping config.gateways`, { 21 logger.verbose(`${MODULE_NAME} 80C7AAD6: Dumping config.gateways`, {
19 xid, 22 xid,
20 gateways: config.gateways, 23 gateways: config.gateways,
21 }); 24 });
22 } 25 }
23 26
24 logger.verbose(`${MODULE_NAME} 79B5FEB5: Connecting to all gateways`, { 27 logger.verbose(`${MODULE_NAME} 79B5FEB5: Connecting to all gateways`, {
25 xid, 28 xid,
26 gatewayNames: gateways.map((gateway) => gateway.name), 29 gatewayNames: gateways.map((gateway) => gateway.name),
27 }); 30 });
28 31
29 gateways.forEach((gateway) => { 32 gateways.forEach((gateway) => {
30 connect(xid, gateway); 33 connect(xid, gateway);
31 }); 34 });
32 }; 35 };
33 36
34 connectAll(); 37 connectAll();
35 38