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 +201 -1
5 changed files with 201 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 43e61e7e68 - Show all commits

3
src/judas_client/connector.py
View File

@@ -83,6 +83,7 @@ class Connector:
self.socket.connect((self.host, self.port)) self.socket.connect((self.host, self.port))
self.socket.settimeout(self.socket_timeout) self.socket.settimeout(self.socket_timeout)
self.logger.info(f"[+] Connected to {self.host}:{self.port}") self.logger.info(f"[+] Connected to {self.host}:{self.port}")
self.send_hello()
except ( except (
socket.timeout, socket.timeout,
ConnectionRefusedError, ConnectionRefusedError,
@@ -131,6 +132,7 @@ class Connector:
def _loop(self) -> None: def _loop(self) -> None:
self.logger.debug("Starting main loop...") self.logger.debug("Starting main loop...")
while True: while True:
time.sleep(1)
data: bytes = self.receive() data: bytes = self.receive()
if not data: if not data:
continue continue
@@ -140,7 +142,6 @@ class Connector:
# self.logger.debug("[.] ACK verified") # self.logger.debug("[.] ACK verified")
# else: # else:
# self.logger.error("[!] ACK verification failed") # self.logger.error("[!] ACK verification failed")
time.sleep(1)
def run(self) -> None: def run(self) -> None:
self.logger.debug("Running Connector...") self.logger.debug("Running Connector...")