Compare commits
16 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5dd208a100 | ||
| 18b7e10631 | |||
| 07106f1816 | |||
|
115deaab4b
|
|||
|
8d2b8f9519
|
|||
|
f365139e9f
|
|||
|
cc6b650f5c
|
|||
|
faf1f4eeee
|
|||
|
61a607c20e
|
|||
|
fe7d78c1c8
|
|||
|
cee30251dd
|
|||
|
721ab87e71
|
|||
|
1211ca2029
|
|||
|
5024862165
|
|||
|
6f5fa33a12
|
|||
|
f0eeeb79a1
|
30
CHANGELOG.md
30
CHANGELOG.md
@@ -2,6 +2,36 @@
|
||||
|
||||
All notable changes to this project will be documented in this file.
|
||||
|
||||
## [0.4.0] - 2025-11-30
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
- [`115deaa`](https://github.com/pufereq/template-repo/commit/115deaab4b0aaa9f0d3577be56e64fa3bb03f76b) **backend_server.py**: use unused `packet_size` argument to `_receive_inbound()`
|
||||
- [`cc6b650`](https://github.com/pufereq/template-repo/commit/cc6b650f5cd1f3889c251fbe7b36c681be48b2a0) **backend_server.py**: import Any from typing
|
||||
- [`5024862`](https://github.com/pufereq/template-repo/commit/50248621650590c17fcf96c0cec9618a2b0dd07c) **backend_server.py**: add 1ms sleep to prevent 100% CPU usage in `_loop()`
|
||||
- [`f0eeeb7`](https://github.com/pufereq/template-repo/commit/f0eeeb79a188548c3f306f4bc875bacc6fd89588) **backend_server.py**: handle unregister exceptions
|
||||
|
||||
### Features
|
||||
|
||||
- [`6f5fa33`](https://github.com/pufereq/template-repo/commit/6f5fa33a122e9ebdf9df91628be67721cfc031e3) **backend_server.py**: handle all other client Exceptions in `_handle_connection()`
|
||||
|
||||
### Refactor
|
||||
|
||||
- [`8d2b8f9`](https://github.com/pufereq/template-repo/commit/8d2b8f9519bb809df45ba79ea53f12775c3097d4) **backend_server.py**: change log levels
|
||||
- [`faf1f4e`](https://github.com/pufereq/template-repo/commit/faf1f4eeee341f5f8d234dc7d93ae5c86e276217) **backend_server.py**: remove unused argument in `BackendServer._send_outbound()`
|
||||
- [`61a607c`](https://github.com/pufereq/template-repo/commit/61a607c20e205c18e60a9b26f6fb3c37a47d6a55) wip
|
||||
|
||||
### Styling
|
||||
|
||||
- [`f365139`](https://github.com/pufereq/template-repo/commit/f365139e9f064de309f655296b99868833ba7dce) **backend_server.py**: ignore type error in `_handle_connection()`
|
||||
|
||||
### Build
|
||||
|
||||
- [`fe7d78c`](https://github.com/pufereq/template-repo/commit/fe7d78c1c8cd1d0e13276ce82549ee97b896aff0) **uv.lock**: update judas_protocol to 0.5.0
|
||||
- [`cee3025`](https://github.com/pufereq/template-repo/commit/cee30251ddb87b1f3ca84d0f3c8cf40fb37debcc) **uv.lock**: update judas_protocol to 0.4.3
|
||||
- [`721ab87`](https://github.com/pufereq/template-repo/commit/721ab87e7156045703f55ecefc6ed3e15ffa36aa) **uv.lock**: update judas_protocol to 0.3.0
|
||||
- [`1211ca2`](https://github.com/pufereq/template-repo/commit/1211ca20294dcc3907dbadfee4b294cf7e24a8f9) **uv.lock**: update judas_protocol to 0.2.0
|
||||
|
||||
## [0.3.0] - 2025-09-19
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
@@ -4,7 +4,7 @@ build-backend = "uv_build"
|
||||
|
||||
[project]
|
||||
name = "judas_server"
|
||||
version = "0.3.0"
|
||||
version = "0.4.0"
|
||||
description = "The backbone of the remote PC fleet management system."
|
||||
readme = "README.md"
|
||||
authors = []
|
||||
|
||||
@@ -7,7 +7,9 @@ import socket
|
||||
import threading
|
||||
import time
|
||||
|
||||
from judas_protocol import Message
|
||||
from typing import Any
|
||||
|
||||
from judas_protocol import Category, ControlAction, Message
|
||||
|
||||
from judas_server.backend.client import Client
|
||||
|
||||
@@ -60,14 +62,15 @@ class BackendServer:
|
||||
)
|
||||
time.sleep(1)
|
||||
|
||||
def _send_ack(self, client: Client) -> None:
|
||||
def _send_ack(self, client: Client, target_id: str) -> None:
|
||||
"""Send an ACK message to a client.
|
||||
|
||||
Args:
|
||||
client (Client): The client to send the ACK to.
|
||||
target_id (str): The id of the ACK'd message.
|
||||
"""
|
||||
ack: bytes = Message.ack().to_bytes()
|
||||
self.logger.debug(f"[>] Sending ACK to {client}")
|
||||
ack: bytes = Message.ack(target_id=target_id).to_bytes()
|
||||
self.logger.info(f"[>] Sending ACK to {client}")
|
||||
client.outbound += ack
|
||||
|
||||
def _accept_connection(self, sock: socket.socket) -> None:
|
||||
@@ -78,43 +81,13 @@ class BackendServer:
|
||||
"""
|
||||
conn, addr = sock.accept()
|
||||
self.logger.info(f"[+] Accepted connection from {addr}")
|
||||
conn.setblocking(False)
|
||||
|
||||
# wait for hello message to get mac_id
|
||||
|
||||
conn.settimeout(5)
|
||||
try:
|
||||
message = conn.recv(1024)
|
||||
if not message:
|
||||
self.logger.error(f"[-] No data received from {addr}")
|
||||
conn.close()
|
||||
return
|
||||
except socket.timeout:
|
||||
self.logger.error(f"[-] Timeout waiting for hello from {addr}")
|
||||
conn.close()
|
||||
return
|
||||
conn.settimeout(None)
|
||||
|
||||
message = message.split(b"\n")[0] # get first line only
|
||||
message = Message.from_bytes(message)
|
||||
|
||||
mac_id = message.payload.get("mac", None)
|
||||
if mac_id is None:
|
||||
self.logger.error(
|
||||
f"[-] No mac_id provided by {addr}, closing connection"
|
||||
)
|
||||
conn.close()
|
||||
return
|
||||
|
||||
client = Client(id_=mac_id, addr=addr, socket=conn)
|
||||
self.clients[mac_id] = client
|
||||
|
||||
self._send_ack(client)
|
||||
client = Client(mac_id=None, addr=addr, socket=conn)
|
||||
|
||||
events = selectors.EVENT_READ | selectors.EVENT_WRITE
|
||||
self.selector.register(conn, events, data=client)
|
||||
|
||||
self.logger.info(f"[+] Registered client {client}")
|
||||
self.logger.info(f"[+] Registered client {client}, HELLO pending...")
|
||||
|
||||
def _disconnect(self, client: Client) -> None:
|
||||
"""Disconnect a client and clean up resources.
|
||||
@@ -122,10 +95,51 @@ class BackendServer:
|
||||
Args:
|
||||
sock (socket.socket): The client socket to disconnect.
|
||||
"""
|
||||
self.logger.info(f"[-] Disconnecting {client}")
|
||||
self.selector.unregister(client.socket)
|
||||
self.logger.info(f"[-] Disconnecting {client}...")
|
||||
self.logger.debug("[*] Sending DNR message...")
|
||||
|
||||
try:
|
||||
self.selector.unregister(client.socket)
|
||||
except Exception as e:
|
||||
self.logger.error(f"Error unregistering client {client}: {e}")
|
||||
|
||||
client.disconnect()
|
||||
|
||||
def _send_outbound(self, sock: socket.socket, client: Client) -> None:
|
||||
"""Queue data to be sent to a client.
|
||||
|
||||
Args:
|
||||
client (Client): The client to send data to.
|
||||
"""
|
||||
self.logger.debug(f"[>] Sending data to {client}: {client.outbound!r}")
|
||||
sent = sock.send(client.outbound)
|
||||
|
||||
client.outbound = client.outbound[sent:]
|
||||
|
||||
def _receive_inbound(
|
||||
self, sock: socket.socket, client: Client, packet_size: int = 4096
|
||||
) -> None:
|
||||
"""Receive data from a client socket.
|
||||
|
||||
Args:
|
||||
sock (socket.socket): The client socket to receive data from.
|
||||
client (Client): The client object.
|
||||
packet_size (int): The maximum amount of data to be received at once.
|
||||
Returns:
|
||||
bytes: The received data.
|
||||
"""
|
||||
recv_data = sock.recv(packet_size)
|
||||
if recv_data:
|
||||
self.logger.debug(
|
||||
f"[<] Received data from {client}: {recv_data!r}"
|
||||
)
|
||||
client.inbound += recv_data
|
||||
|
||||
# set last seen
|
||||
client.last_seen = time.time()
|
||||
else:
|
||||
self._disconnect(client)
|
||||
|
||||
def _handle_connection(
|
||||
self, key: selectors.SelectorKey, mask: int
|
||||
) -> None:
|
||||
@@ -135,42 +149,84 @@ class BackendServer:
|
||||
key (selectors.SelectorKey): The selector key for the client.
|
||||
mask (int): The event mask.
|
||||
"""
|
||||
sock: socket.socket = key.fileobj
|
||||
sock: socket.socket = key.fileobj # type: ignore
|
||||
client = key.data
|
||||
|
||||
try:
|
||||
if mask & selectors.EVENT_READ:
|
||||
recv_data = sock.recv(1024)
|
||||
if recv_data:
|
||||
self.logger.debug(
|
||||
f"[<] Received data from {client}: {recv_data!r}"
|
||||
)
|
||||
client.inbound += recv_data
|
||||
self._receive_inbound(sock, client)
|
||||
if client.inbound:
|
||||
if client.mac_id is None:
|
||||
# expect HELLO message
|
||||
try:
|
||||
msg = Message.from_bytes(client.inbound)
|
||||
if (
|
||||
msg.category == Category.CONTROL
|
||||
and msg.action == ControlAction.HELLO
|
||||
and msg.payload.get("mac") is not None
|
||||
):
|
||||
client.mac_id = msg.payload["mac"]
|
||||
if (
|
||||
client.mac_id in self.clients
|
||||
and self.clients[client.mac_id].status
|
||||
== "connected"
|
||||
):
|
||||
old_client: Client = self.clients[
|
||||
client.mac_id
|
||||
]
|
||||
self.logger.warning(
|
||||
f"Client {client.mac_id} is already connected from {old_client.addr}, disconnecting old client..."
|
||||
)
|
||||
self._disconnect(old_client)
|
||||
# TODO: tell client not to reconnect
|
||||
self.clients[client.mac_id] = client
|
||||
self.logger.info(
|
||||
f"[+] Registered new client {client}"
|
||||
)
|
||||
else:
|
||||
self.logger.error(
|
||||
f"Expected HELLO message from {client}, got {msg}"
|
||||
)
|
||||
self._disconnect(client)
|
||||
return
|
||||
except Exception as e:
|
||||
self.logger.error(
|
||||
f"Failed to parse HELLO message from {client}: {e}"
|
||||
)
|
||||
self._disconnect(client)
|
||||
return
|
||||
|
||||
while b"\n" in client.inbound:
|
||||
line, client.inbound = client.inbound.split(b"\n", 1)
|
||||
self.logger.info(
|
||||
self.logger.debug(
|
||||
f"[<] Complete message from {client}: {line!r}"
|
||||
)
|
||||
try:
|
||||
msg = Message.from_bytes(line)
|
||||
self.logger.info(f"[.] Parsed message {msg.id}")
|
||||
if msg.ack_required:
|
||||
self._send_ack(client, target_id=msg.id)
|
||||
|
||||
self._send_ack(client)
|
||||
except Exception as e:
|
||||
self.logger.error(
|
||||
f"Failed to parse message from {client}: {e}"
|
||||
)
|
||||
self._disconnect(client)
|
||||
return
|
||||
|
||||
# set last seen
|
||||
client.last_seen = time.time()
|
||||
else:
|
||||
self._disconnect(client)
|
||||
|
||||
if mask & selectors.EVENT_WRITE:
|
||||
if client.outbound:
|
||||
self.logger.debug(
|
||||
f"[>] Sending data to {client}: {client.outbound!r}"
|
||||
)
|
||||
sent = sock.send(client.outbound)
|
||||
self._send_outbound(sock, client)
|
||||
|
||||
client.outbound = client.outbound[sent:]
|
||||
# TODO: wait for ACK from client
|
||||
except ConnectionResetError as e:
|
||||
self.logger.error(f"Connection reset by {client}, disconnect: {e}")
|
||||
self._disconnect(client)
|
||||
except Exception as e:
|
||||
self.logger.error(f"Connection error for {client}: {e}")
|
||||
self._disconnect(client)
|
||||
|
||||
def run(self) -> None:
|
||||
"""Start the backend server."""
|
||||
@@ -187,9 +243,11 @@ class BackendServer:
|
||||
events = self.selector.select(timeout=1)
|
||||
for key, mask in events:
|
||||
if key.data is None:
|
||||
self._accept_connection(key.fileobj)
|
||||
self._accept_connection(key.fileobj) # type: ignore
|
||||
else:
|
||||
self._handle_connection(key, mask)
|
||||
time.sleep(0.001) # prevent 100% CPU usage
|
||||
|
||||
except Exception as e:
|
||||
self.logger.error(f"Server error: {e}")
|
||||
raise e
|
||||
@@ -204,7 +262,7 @@ class BackendServer:
|
||||
self.logger.warning(f"Client {client_id} not found")
|
||||
return None
|
||||
return {
|
||||
"id": client.id,
|
||||
"id": client.mac_id,
|
||||
"addr": client.addr,
|
||||
"last_seen": client.last_seen,
|
||||
"status": client.status,
|
||||
|
||||
@@ -17,12 +17,13 @@ class Client:
|
||||
"""Represents a client."""
|
||||
|
||||
def __init__(
|
||||
self, id_: str, addr: tuple[str, int], socket: socket.socket
|
||||
self, mac_id: str | None, addr: tuple[str, int], socket: socket.socket
|
||||
) -> None:
|
||||
"""Initialize the client.
|
||||
|
||||
Args:
|
||||
id_ (str): The unique identifier for the client.
|
||||
mac_id (str | None): The unique identifier for the client.
|
||||
Can be None if not yet assigned.
|
||||
addr (tuple[str, int]): The (IP, port) address of the client.
|
||||
socket (socket.socket): The socket object for communication.
|
||||
"""
|
||||
@@ -31,7 +32,7 @@ class Client:
|
||||
)
|
||||
self.logger.debug(f"Initializing Client {addr}...")
|
||||
|
||||
self.id: str = id_
|
||||
self.mac_id: str | None = mac_id
|
||||
self.last_seen: float = 0.0 # unix timestanp of last inbound message
|
||||
self.status: ClientStatus = ClientStatus.CONNECTED
|
||||
|
||||
@@ -41,10 +42,10 @@ class Client:
|
||||
self.outbound: bytes = b""
|
||||
|
||||
def __str__(self) -> str:
|
||||
return f"Client({self.id} ({self.addr[0]}:{self.addr[1]}))"
|
||||
return f"Client({self.mac_id} ({self.addr[0]}:{self.addr[1]}))"
|
||||
|
||||
def __repr__(self) -> str:
|
||||
return f"Client({self.id}, {self.addr})"
|
||||
return f"Client({self.mac_id}, {self.addr})"
|
||||
|
||||
def disconnect(self) -> None:
|
||||
"""Disconnect the client and close the socket."""
|
||||
|
||||
6
uv.lock
generated
6
uv.lock
generated
@@ -319,12 +319,12 @@ wheels = [
|
||||
|
||||
[[package]]
|
||||
name = "judas-protocol"
|
||||
version = "0.1.0"
|
||||
source = { git = "https://gitea.pufereq.pl/judas/judas_protocol.git#fd070b176347a0f7b81f937b189d8f50736f3514" }
|
||||
version = "0.5.0"
|
||||
source = { git = "https://gitea.pufereq.pl/judas/judas_protocol.git#c48b69ecee16f5824ffd8bce8921341d5fa326b7" }
|
||||
|
||||
[[package]]
|
||||
name = "judas-server"
|
||||
version = "0.3.0"
|
||||
version = "0.4.0"
|
||||
source = { editable = "." }
|
||||
dependencies = [
|
||||
{ name = "flask" },
|
||||
|
||||
Reference in New Issue
Block a user