src/judas_server/backend/backend_server.py

@@ -171,9 +171,13 @@ class BackendServer:
 
                     client.outbound = client.outbound[sent:]
                     # TODO: wait for ACK from client
+
         except ConnectionResetError as e:
             self.logger.error(f"Connection reset by {client}, disconnect: {e}")
             self._disconnect(client)
+        except Exception as e:
+            self.logger.error(f"Connection error for {client}: {e}")
+            self._disconnect(client)
 
     def run(self) -> None:
         """Start the backend server."""