rebroadcast to incoming peers even if there is an error broadcasting …

…to outgoing peer.
RunOnFlux · Jan 7, 2024 · b24ab9b · b24ab9b
1 parent a6281de
commit b24ab9b
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/ZelBack/src/services/fluxCommunication.js b/ZelBack/src/services/fluxCommunication.js
@@ -81,7 +81,9 @@ async function handleAppMessages(message, fromIP, port) {
           wsListOut.push(client);
         }
       });
-      fluxCommunicationMessagesSender.sendToAllPeers(messageString, wsListOut);
+      fluxCommunicationMessagesSender.sendToAllPeers(messageString, wsListOut).catch((error) => {
+        log.error(error);
+      });
       await serviceHelper.delay(500);
       const wsList = [];
       incomingConnections.forEach((client) => {
@@ -124,7 +126,9 @@ async function handleAppRunningMessage(message, fromIP, port) {
           wsListOut.push(client);
         }
       });
-      fluxCommunicationMessagesSender.sendToAllPeers(messageString, wsListOut);
+      fluxCommunicationMessagesSender.sendToAllPeers(messageString, wsListOut).catch((error) => {
+        log.error(error);
+      });
       await serviceHelper.delay(500);
       const wsList = [];
       incomingConnections.forEach((client) => {
@@ -449,7 +453,9 @@ function connectedPeersInfo(req, res) {
  */
 function keepConnectionsAlive() {
   setInterval(() => {
-    fluxCommunicationMessagesSender.sendToAllPeers(); // perform ping
+    fluxCommunicationMessagesSender.sendToAllPeers().catch((error) => {
+      log.error(error);
+    }); // perform ping
     fluxCommunicationMessagesSender.sendToAllIncomingConnections(); // perform ping
   }, 15 * 1000);
 }