FIX add docstrings

Author: eleniv3d

src/gh/components/DF_http_listener/code.py

@@ -36,7 +36,7 @@ def RunScript(self,
         sc.sticky.setdefault(f'{prefix}_prev_load', False)  # previous state of toggle
         sc.sticky.setdefault(f'{prefix}_thread_running', False)  # is a background thread running?
 
-        def _import_job(url: str):
+        def _import_job(url: str) -> None:
 
             """
             Downloads and imports a .ply file from a given URL in a background thread.

src/gh/components/DF_tcp_listener/code.py

@@ -45,7 +45,7 @@ def RunScript(self,
         sc.sticky.setdefault(f'{prefix}_prev_load', False)
 
         # Client handler
-        def handle_client(conn):
+        def handle_client(conn: socket.socket) -> None:
             """
             Reads the incoming bytes from a single TCP client socket and stores valid data in a shared buffer.
 
@@ -76,7 +76,7 @@ def handle_client(conn):
                     time.sleep(0.05)  # sleep briefly to prevent CPU spin
 
         # thread to accept incoming connections
-        def server_loop(sock):
+        def server_loop(sock: socket.socket) -> None:
             """
             Accepts a single client connection and starts a background thread to handle it.
 
@@ -92,7 +92,7 @@ def server_loop(sock):
                 pass
 
         # Start TCP server
-        def start_server():
+        def start_server() -> None:
             """
             creates and binds a TCP socket on the given host/port, marks the server as started and then starts the accept_loop in a background thread
 
@@ -108,7 +108,7 @@ def start_server():
             # Only accept one connection to keep it long-lived
             threading.Thread(target=server_loop, args=(sock,), daemon=True).start()
 
-        def stop_server():
+        def stop_server() -> None:
             """
             Stops the running TCP server by closing the listening socket and resetting internal state.
 

src/gh/components/DF_websocket_listener/code.py

@@ -66,7 +66,7 @@ def RunScript(self,
         # START server
         if i_start and not sc.sticky[f'{prefix}_thread_started']:
 
-            async def echo(ws, path):
+            async def echo(ws, path: str) -> None:
                 """
                 Handles a single WebSocket client connection and reads messages containing point cloud data.
 
@@ -92,7 +92,7 @@ async def echo(ws, path):
                 except Exception as outer:
                     logs.append(f"Handler crashed: {outer}")
 
-            async def server_coro():
+            async def server_coro() -> None:
                 """
                 Coroutine that starts the WebSocket server and waits for it to be closed.
 
@@ -109,7 +109,7 @@ async def server_coro():
                 await server.wait_closed()
                 logs.append("Server coroutine exited")
 
-            def run_server():
+            def run_server() -> None:
                 """
                 Blocking function that runs the WebSocket server coroutine in this thread.