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

feat(connector.py): add Connector.send() method

Browse Source
This commit is contained in:
Artur Borecki
2025-11-19 21:53:08 +01:00
parent 99e94e2f5a
commit 5458281186
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/judas_client/connector.py
View File

@@ -89,6 +89,17 @@ class Connector:
self.logger.error(f"[!] Socket error: {e}") self.logger.error(f"[!] Socket error: {e}")
self.reconnect() self.reconnect()
def send(self, message: Message) -> None:
"""Send a message to the server.
Args:
message (Message): The message to send.
"""
self.logger.debug(f"[>] Queueing message to send: {message}")
if message.ack_required:
self.pending_acks[message.id] = (message, time.time())
self.outbound_buffer += message.to_bytes()
def send_hello(self) -> None: def send_hello(self) -> None:
"""Send a HELLO message to the server.""" """Send a HELLO message to the server."""
self.logger.debug("[*] Sending HELLO message...") self.logger.debug("[*] Sending HELLO message...")