From a54a7e3e6488bfa87904911ffb778d94bbcd7760 Mon Sep 17 00:00:00 2001 From: AW Date: Sat, 29 Oct 2022 11:58:12 +0200 Subject: [PATCH 1/2] on 'websocket close' event-handler parameter added --- lib/websockets.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/websockets.js b/lib/websockets.js index 7e79d6c..a4390e7 100644 --- a/lib/websockets.js +++ b/lib/websockets.js @@ -48,7 +48,7 @@ getSocketEndpoint = async function(type, baseURL, environment, sign) { } eventHanlder = function */ -Sockets.initSocket = async function(params, eventHandler) { +Sockets.initSocket = async function(params, eventHandler, onCloseEventHandler) { try { if ( !params.sign ) params.sign = false; if ( !params.endpoint ) params.endpoint = false; @@ -72,6 +72,7 @@ Sockets.initSocket = async function(params, eventHandler) { ws.on('close', () => { clearInterval(Sockets.ws[topic].heartbeat) console.log(topic + ' websocket closed...') + onCloseEventHandler() }) } catch (err) { console.log(err) From 7a17718bc73f130edbb8b7b60670ba838a44f226 Mon Sep 17 00:00:00 2001 From: AW Date: Sat, 29 Oct 2022 13:30:27 +0200 Subject: [PATCH 2/2] if condition added to optional parameter call --- lib/websockets.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lib/websockets.js b/lib/websockets.js index a4390e7..61b2f69 100644 --- a/lib/websockets.js +++ b/lib/websockets.js @@ -72,7 +72,9 @@ Sockets.initSocket = async function(params, eventHandler, onCloseEventHandler) { ws.on('close', () => { clearInterval(Sockets.ws[topic].heartbeat) console.log(topic + ' websocket closed...') - onCloseEventHandler() + if (onCloseEventHandler) { + onCloseEventHandler() + } }) } catch (err) { console.log(err)