fix closing of connections

hackbg · Nov 21, 2024 · 1ab7423 · 1ab7423
1 parent c19f81a
commit 1ab7423
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/control_node.js b/control_node.js
@@ -22,7 +22,7 @@ function main () {
   const service = new NamadaService(NAMADA, CHAIN_ID)
   service.events.addEventListener('request-pause', async () => {
     let canConnect = true
-    while (!(canConnect === false)) {
+    while (canConnect) {
       console.log('🟠 Requesting pause until indexer catches up.')
       const response = await fetch(`${NODE_OUT}/pause`)
       const responseJson = await response.json()

diff --git a/control_out_proxy.js b/control_out_proxy.js
@@ -47,23 +47,23 @@ async function run (localHost, controlPort, proxyConfig) {
       if (canConnect) {
         console.log('🟠 Disabling new connections')
         canConnect = false
-        if (connectionsJustClosed > 0) {
-          console.log('Closing', connectionsJustClosed, 'open connection(s)')
-          for (const connection of connections) {
-            try {
-              connection.close()
-              console.log('Closed:', connection.localAddr, '<->', connection.remoteAddr)
-              connectionsJustClosed++
-            } catch (e) {
-              if (e.name === 'BadResource') {
-                console.log('Already closed:', connection.localAddr, '<->', connection.remoteAddr)
-                connectionsAlreadyClosed++
-              } else {
-                throw e
-              }
+      }
+      if (connections.size > 0) {
+        console.log('Closing', connectionsJustClosed, 'open connection(s)')
+        for (const connection of connections) {
+          try {
+            connection.close()
+            console.log('Closed:', connection.localAddr, '<->', connection.remoteAddr)
+            connectionsJustClosed++
+          } catch (e) {
+            if (e.name === 'BadResource') {
+              console.log('Already closed:', connection.localAddr, '<->', connection.remoteAddr)
+              connectionsAlreadyClosed++
+            } else {
+              throw e
             }
-            connections.delete(connection)
           }
+          connections.delete(connection)
         }
       }
       return respond(200, {