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

Compare commits

base: judas:1e38be5ec5d55a30fd715a650ea7402b9fb4c546
Branches Tags
judas:main judas:develop judas:build/migrate-to-uv
judas:0.7.0-dev.1 judas:0.6.0 judas:0.5.0 judas:0.4.0 judas:0.3.0 judas:0.2.0 judas:0.1.1 judas:0.1.0
...
compare: judas:f01eaecba346715dd0c50eb4b253656df5c89ad8
Branches Tags
judas:develop judas:main judas:build/migrate-to-uv
judas:0.7.0-dev.1 judas:0.6.0 judas:0.5.0 judas:0.4.0 judas:0.3.0 judas:0.2.0 judas:0.1.1 judas:0.1.0

2 Commits
1e38be5ec5 ... f01eaecba3

Author SHA1 Message Date
Artur Borecki
f01eaecba3 build(uv.lock): update judas_protocol to 0.6.0 2026-02-28 20:58:09 +01:00
Artur Borecki
a5e1ba88ae refactor: adapt for client.id 2026-02-28 20:57:59 +01:00
4 changed files with 15 additions and 16 deletions
Expand all files Collapse all files

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

@@ -92,7 +92,7 @@ class BackendServer:
conn, addr = sock.accept() conn, addr = sock.accept()
self.logger.info(f"[+] Accepted connection from {addr}") self.logger.info(f"[+] Accepted connection from {addr}")
client = Client(mac_id=None, addr=addr, socket=conn) client = Client(id=None, addr=addr, socket=conn)
events = selectors.EVENT_READ | selectors.EVENT_WRITE events = selectors.EVENT_READ | selectors.EVENT_WRITE
self.selector.register(conn, events, data=client) self.selector.register(conn, events, data=client)
@@ -168,7 +168,7 @@ class BackendServer:
self._disconnect(client) self._disconnect(client)
return return
if client.mac_id is None: if client.id is None:
# expect HELLO message # expect HELLO message
try: try:
msg = Message.from_bytes(client.inbound) msg = Message.from_bytes(client.inbound)
@@ -182,22 +182,21 @@ class BackendServer:
if ( if (
msg.category == Category.CONTROL msg.category == Category.CONTROL
and msg.action == ControlAction.HELLO and msg.action == ControlAction.HELLO
and msg.payload.get("mac") is not None and msg.payload.get("id") is not None
): ):
client.mac_id = msg.payload["mac"] client.id = msg.payload["id"]
if ( if (
client.mac_id in self.clients client.id in self.clients
and self.clients[client.mac_id].status and self.clients[client.id].status == "connected"
== "connected"
): ):
old_client: Client = self.clients[client.mac_id] old_client: Client = self.clients[client.id]
self.logger.warning( self.logger.warning(
f"Client {client.mac_id} is already connected from {old_client.addr}, disconnecting old client..." f"Client {client.id} is already connected from {old_client.addr}, disconnecting old client..."
) )
self.send_close(old_client) self.send_close(old_client)
# self._disconnect(old_client) # self._disconnect(old_client)
# TODO: tell client not to reconnect # TODO: tell client not to reconnect
self.clients[client.mac_id] = client self.clients[client.id] = client
self.logger.info(f"[+] Registered new client {client}") self.logger.info(f"[+] Registered new client {client}")
else: else:
self.logger.error( self.logger.error(

6
src/judas_server/backend/client.py
View File

@@ -17,12 +17,12 @@ class Client:
"""Represents a client.""" """Represents a client."""
def __init__( def __init__(
self, mac_id: str | None, addr: tuple[str, int], socket: socket.socket self, id: str | None, addr: tuple[str, int], socket: socket.socket
) -> None: ) -> None:
"""Initialize the client. """Initialize the client.
Args: Args:
mac_id (str | None): The unique identifier for the client. id (str | None): The unique identifier for the client.
Can be None if not yet assigned. Can be None if not yet assigned.
addr (tuple[str, int]): The (IP, port) address of the client. addr (tuple[str, int]): The (IP, port) address of the client.
socket (socket.socket): The socket object for communication. socket (socket.socket): The socket object for communication.
@@ -32,7 +32,7 @@ class Client:
) )
self.logger.debug(f"Initializing Client {addr}...") self.logger.debug(f"Initializing Client {addr}...")
self.id: str | None = mac_id self.id: str | None = id
self.last_seen: float = 0.0 # unix timestanp of last inbound message self.last_seen: float = 0.0 # unix timestanp of last inbound message
self.status: ClientStatus = ClientStatus.CONNECTED self.status: ClientStatus = ClientStatus.CONNECTED

2
src/judas_server/web/templates/client_details.html
View File

@@ -3,7 +3,7 @@
<head> <head>
<meta charset="UTF-8" /> <meta charset="UTF-8" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" />
<title>Details for client {{ client.id }}</title> <title>Details for client {{ client.mac_id }}</title>
</head> </head>
<body></body> <body></body>
</html> </html>

4
uv.lock generated
View File

@@ -358,8 +358,8 @@ wheels = [
[[package]] [[package]]
name = "judas-protocol" name = "judas-protocol"
version = "0.5.0" version = "0.6.0"
source = { git = "https://gitea.pufereq.pl/judas/judas_protocol.git#c48b69ecee16f5824ffd8bce8921341d5fa326b7" } source = { git = "https://gitea.pufereq.pl/judas/judas_protocol.git#d16c1914ba343aed300f1c5fae0201370c3274de" }
[[package]] [[package]]
name = "judas-server" name = "judas-server"