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

chore(release): 0.1.0 #1

Merged
pufereq merged 12 commits from release/0.1.0 into main 2025-08-28 22:44:31 +00:00
Conversation 0 Commits 12 Files Changed 5 +214 -1
5 changed files with 214 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 4496fc60aa - Show all commits

7
src/judas_client/connector.py
View File

@@ -130,6 +130,12 @@ class Connector:
self.socket.close() self.socket.close()
self.logger.info("Connection closed.") self.logger.info("Connection closed.")
def reconnect(self) -> None:
self.logger.debug("Reconnecting...")
self.close()
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.connect()
def send_hello(self) -> None: def send_hello(self) -> None:
self.logger.debug("[.] Sending hello message...") self.logger.debug("[.] Sending hello message...")
hello_message: Message = Message.hello(self.mac_address) hello_message: Message = Message.hello(self.mac_address)
@@ -141,6 +147,7 @@ class Connector:
time.sleep(1) time.sleep(1)
data: bytes = self.receive() data: bytes = self.receive()
if not data: if not data:
self.reconnect()
continue continue
message = Message.from_bytes(data.strip()) message = Message.from_bytes(data.strip())
self.logger.info(f"[<] Message received: {message}") self.logger.info(f"[<] Message received: {message}")