Type checking, formatting and some more improvements

.gitignore

@@ -1,2 +1,3 @@
 *.mp3
+/cookies.txt
 __pycache__

.python-version

@@ -0,0 +1 @@
+3.12

.vscode/settings.json

@@ -0,0 +1,15 @@
+{
+	"[python]": {
+		"editor.defaultFormatter": "ms-python.black-formatter",
+		"editor.formatOnSave": true,
+		"editor.codeActionsOnSave": {
+			"source.organizeImports": "explicit"
+		},
+	},
+	"isort.args": [
+		"--profile",
+		"black"
+	],
+	"python.analysis.diagnosticsSource": "Pylance",
+	"python-envs.defaultEnvManager": "ms-python.python:venv"
+}

_types.py

@@ -0,0 +1,59 @@
+# pyright: strict
+
+from typing import Literal, TypeAlias
+
+import pydantic as pyd
+
+#############
+# Responses #
+#############
+
+
+class AddressResponse(pyd.BaseModel):
+    type: Literal["address"] = "address"
+    address: str | None
+
+
+class ListContentResponseEntry(pyd.BaseModel):
+    id: str
+    title: str
+    duration: float | None
+    nick: str | None
+    address: str | None
+    prio: int
+
+    model_config = {"extra": "ignore"}
+
+
+class ListContentResponse(pyd.BaseModel):
+    type: Literal["list"] = "list"
+    position: float
+    list: list[ListContentResponseEntry]
+
+
+class ListFallbackResponse(pyd.BaseModel):
+    type: Literal["fallback"] = "fallback"
+    description: str
+
+
+ListResponse: TypeAlias = ListContentResponse | ListFallbackResponse
+
+
+class ProgressResponse(pyd.BaseModel):
+    type: Literal["progress"] = "progress"
+    position: float
+
+
+Response: TypeAlias = AddressResponse | ListResponse | ProgressResponse
+
+############
+# Requests #
+############
+
+
+class CancelRequest(pyd.BaseModel):
+    type: Literal["cancel"] = "cancel"
+    id: str
+
+
+Request: TypeAlias = CancelRequest

connections.py

@@ -1,30 +1,39 @@
-from threading import Lock
-import json
+# pyright: strict
+
+import threading
+
+import tornado.ioloop
+import tornado.websocket
+
+import _types
+
 
 class Connections:
-    def __init__(self, ioloop):
-        self.lock = Lock()
+    def __init__(self, ioloop: tornado.ioloop.IOLoop):
+        self.lock = threading.Lock()
         self._ioloop = ioloop
-        self._clients = []
+        self._clients: list[tornado.websocket.WebSocketHandler] = []
 
-    def add_connection(self, handler):
+    def add_connection(self, handler: tornado.websocket.WebSocketHandler):
         self.lock.acquire()
         try:
             self._clients.append(handler)
         finally:
             self.lock.release()
 
-    def close_connection(self, handler):
+    def close_connection(self, handler: tornado.websocket.WebSocketHandler):
         self.lock.acquire()
         try:
             self._clients.remove(handler)
         finally:
             self.lock.release()
 
-    def message_clients(self, message):
+    def message_clients(self, message: _types.Response):
         self.lock.acquire()
         try:
             for client in self._clients:
-                self._ioloop.add_callback(client.write_message, json.dumps(message))
+                self._ioloop.add_callback(  # pyright: ignore[reportUnknownMemberType]
+                    client.write_message, message.model_dump_json()
+                )
         finally:
             self.lock.release()