From 7ca0e79023dbf7cafb32591eb2fbcce1594d904e Mon Sep 17 00:00:00 2001
From: Adhidarma Hadiwinoto <adhisimon@gmail.com>
Date: Mon, 14 Feb 2022 16:06:40 +0700
Subject: [PATCH] Create initServer
---
server.js | 26 ++++++++++++++++----------
1 file changed, 16 insertions(+), 10 deletions(-)
diff --git a/server.js b/server.js
index f5af61a..bff0453 100644
--- a/server.js
+++ b/server.js
@@ -28,16 +28,9 @@ exports.setPartner = (partnerFromCaller) => {
const wsListenPort = config.push_trx_server
&& (config.push_trx_server.port || config.push_trx_server.listen_port);
-if (!wsListenPort) {
- logger.info(`${MODULE_NAME} 58ACCE20: Disabling PUSH_TRX_SERVER`, {
- config: {
- push_trx_server: !!config && !!config.push_trx_server && {
- port: !!config.push_trx_server.port,
- listen_port: !!config.push_trx_server.listen_port,
- },
- },
- });
-} else {
+const initServer = () => {
+ logger.verbose(`${MODULE_NAME} 70D208B2: Initializing`);
+
const wss = new WebSocketServer({ noServer: true, perMessageDeflate: true });
wss.on('connection', (ws, req, client) => {
@@ -211,4 +204,17 @@ if (!wsListenPort) {
logger.verbose(`${MODULE_NAME} E973112F: WebSocketServer closed`);
// clearInterval(heatbeatPingInterval);
});
+};
+
+if (!wsListenPort) {
+ logger.info(`${MODULE_NAME} 58ACCE20: Disabling PUSH_TRX_SERVER`, {
+ config: {
+ push_trx_server: !!config && !!config.push_trx_server && {
+ port: !!config.push_trx_server.port,
+ listen_port: !!config.push_trx_server.listen_port,
+ },
+ },
+ });
+} else {
+ initServer();
}
--
1.9.0