judas/judas_server
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 5 Wiki Activity

refactor: improve backend server #11

Merged
pufereq merged 8 commits from refactor/improve-backend-server into develop 2025-11-30 17:34:14 +00:00
Conversation 0 Commits 8 Files Changed 3 +114 -64
3 changed files with 114 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 8d2b8f9519 - Show all commits

5
src/judas_server/backend/backend_server.py
View File

@@ -70,7 +70,7 @@ class BackendServer:
target_id (str): The id of the ACK'd message. target_id (str): The id of the ACK'd message.
""" """
ack: bytes = Message.ack(target_id=target_id).to_bytes() ack: bytes = Message.ack(target_id=target_id).to_bytes()
self.logger.debug(f"[>] Sending ACK to {client}") self.logger.info(f"[>] Sending ACK to {client}")
client.outbound += ack client.outbound += ack
def _accept_connection(self, sock: socket.socket) -> None: def _accept_connection(self, sock: socket.socket) -> None:
@@ -195,9 +195,10 @@ class BackendServer:
) )
self._disconnect(client) self._disconnect(client)
return return
while b"\n" in client.inbound: while b"\n" in client.inbound:
line, client.inbound = client.inbound.split(b"\n", 1) line, client.inbound = client.inbound.split(b"\n", 1)
self.logger.info( self.logger.debug(
f"[<] Complete message from {client}: {line!r}" f"[<] Complete message from {client}: {line!r}"
) )
try: try: