From 77625084e9ac13b34d4461d698bcb97c7cbbd9ed Mon Sep 17 00:00:00 2001
From: KubaPro010 <kuba.pro010@gmail.com>
Date: Wed, 29 Apr 2026 14:45:19 +0200
Subject: [PATCH] fsdb

---
 modules/web.py        |  42 ++++++++-
 modules/web/fsdb.html | 213 ++++++++++++++++++++++++++++++++++++++++++
 rds_codec.py          |   8 +-
 3 files changed, 254 insertions(+), 9 deletions(-)
 create mode 100644 modules/web/fsdb.html

diff --git a/modules/web.py b/modules/web.py
index b35bc77..0df2ace 100644
--- a/modules/web.py
+++ b/modules/web.py
@@ -6,13 +6,11 @@ import asyncio
 import websockets
 from websockets import ServerConnection, Request, Response, Headers
 import mimetypes
+import shutil
 
 def get_content_type(filename: str) -> str:
-    # Fallback to Python's mimetypes
     mime_type, _ = mimetypes.guess_type(filename)
-
-    if mime_type:
-        return mime_type
+    if mime_type: return mime_type
 
     # Final fallback
     return "application/octet-stream"
@@ -92,6 +90,40 @@ async def ws_handler(websocket: ServerConnection, shared_data: dict, imc_q: mult
                 payload = {"files": [i.name for i in list(dir.iterdir()) if i.is_file()], "base": str(dir), "dir": dir.name}
             except Exception: payload = {}
             await websocket.send(json.dumps({"event": "request_dir", "data": payload}))
+        elif action == "fsdb_add":
+            name: str | None = msg.get("name")
+            try:
+                if not name: raise Exception("name not defined")
+                path = Path(MAIN_PATH_DIR, ".playlist", msg.get("playlist", ""), name)
+                path.touch(exist_ok=True)
+                await websocket.send(json.dumps({"event": "fsdb_add", "ok": True}))
+            except Exception as e: await websocket.send(json.dumps({"event": "fsdb_add", "error": str(e)}))
+        elif action == "fsdb_add_dir":
+            name: str | None = msg.get("name")
+            try:
+                if not name: raise Exception("name not defined")
+                path = Path(MAIN_PATH_DIR, ".playlist", msg.get("playlist", ""), name)
+                path.mkdir(parents=True, exist_ok=True)
+                await websocket.send(json.dumps({"event": "fsdb_add_dir", "ok_dir": True}))
+            except Exception as e: await websocket.send(json.dumps({"event": "fsdb_add_dir", "error": str(e)}))
+        elif action == "fsdb_remove":
+            name: str | None = msg.get("name")
+            try:
+                if not name: raise Exception("name not defined")
+                path = Path(MAIN_PATH_DIR, ".playlist", msg.get("playlist", ""), name)
+                if path.is_dir(): shutil.rmtree(path)
+                else: path.unlink(missing_ok=True)
+                await websocket.send(json.dumps({"event": "fsdb_remove", "ok": True}))
+            except Exception as e: await websocket.send(json.dumps({"event": "fsdb_remove", "error": str(e)}))
+        elif action == "fsdb_list":
+            try:
+                p = Path(MAIN_PATH_DIR, ".playlist", msg.get("playlist", ""))
+                payload = {
+                    "files": [i.name for i in p.iterdir() if i.is_file()],
+                    "dirs": [i.name for i in p.iterdir() if i.is_dir()]
+                }
+                await websocket.send(json.dumps({"event": "fsdb_list", "data": payload}))
+            except Exception: await websocket.send(json.dumps({"event": "fsdb_list", "data": {}}))
         else: await websocket.send(json.dumps({"event": "error", "error": "unknown action"}))
 
 async def broadcast_worker(ws_q: multiprocessing.Queue, clients: set):
@@ -117,7 +149,7 @@ def websocket_server_process(shared_data: dict, imc_q: multiprocessing.Queue, ws
 
         async def handler_wrapper(websocket: ServerConnection):
             clients.add(websocket)
-            await asyncio.get_event_loop().run_in_executor(None, ws_q.put, {"data": len(clients), "event": "users"})
+            await asyncio.get_event_loop().run_in_executor(None, ws_q.put, {"event": "users", "data": len(clients)})
             try: await ws_handler(websocket, shared_data, imc_q, ws_q)
             finally:
                 await websocket.close(1001, "")
diff --git a/modules/web/fsdb.html b/modules/web/fsdb.html
new file mode 100644
index 0000000..8488873
--- /dev/null
+++ b/modules/web/fsdb.html
@@ -0,0 +1,213 @@
+<!DOCTYPE html>
+
+<html lang="en">
+<head>
+<meta charset="utf-8">
+<title>FSDB Editor</title>
+<style>
+    body {
+        margin: 0;
+        font-family: sans-serif;
+        background: #111;
+        color: #eee;
+    }
+
+.container {
+    display: flex;
+    height: 100vh;
+}
+
+.panel {
+    flex: 1;
+    padding: 10px;
+    box-sizing: border-box;
+    overflow-y: auto;
+    border-right: 1px solid #333;
+}
+
+.panel:last-child {
+    border-right: none;
+}
+
+h2 {
+    margin-top: 0;
+    font-size: 16px;
+    color: #aaa;
+}
+
+.item {
+    padding: 6px;
+    margin: 2px 0;
+    cursor: pointer;
+    border-radius: 4px;
+}
+
+.item:hover {
+    background: #222;
+}
+
+.dir {
+    color: #6cf;
+}
+
+.file {
+    color: #ccc;
+}
+
+.controls {
+    padding: 5px;
+    border-bottom: 1px solid #333;
+}
+
+button {
+    margin-right: 5px;
+    background: #222;
+    color: #eee;
+    border: 1px solid #444;
+    padding: 5px 8px;
+    cursor: pointer;
+}
+
+button:hover {
+    background: #333;
+}
+
+input {
+    background: #222;
+    color: #eee;
+    border: 1px solid #444;
+    padding: 4px;
+}
+
+</style>
+</head>
+<body>
+
+<div class="controls">
+    Playlist:
+    <input id="playlist" value="default">
+    <button onclick="refreshPlaylist()">Refresh</button>
+</div>
+
+<div class="container">
+    <div class="panel">
+        <h2>Ref Dir</h2>
+        <div id="ref"></div>
+    </div>
+
+```
+<div class="panel">
+    <h2>Playlist</h2>
+    <div id="playlistView"></div>
+</div>
+```
+
+</div>
+
+<script>
+const ws = new WebSocket("ws://" + location.host + "/ws");
+
+let currentPlaylist = "default";
+
+ws.onopen = () => {
+    console.log("WS connected");
+};
+
+ws.onmessage = (ev) => {
+    const msg = JSON.parse(ev.data);
+
+    if (msg.event === "state") {
+        renderRef(msg.data.dirs);
+    }
+
+    if (msg.event === "fsdb_list") {
+        renderPlaylist(msg.data);
+    }
+};
+
+function getPlaylistName() {
+    currentPlaylist = document.getElementById("playlist").value || "";
+    return currentPlaylist;
+}
+
+function renderRef(data) {
+    const el = document.getElementById("ref");
+    el.innerHTML = "";
+
+    data.dirs.forEach(d => {
+        const div = document.createElement("div");
+        div.className = "item dir";
+        div.textContent = d + "/";
+        div.onclick = () => addDir(d);
+        el.appendChild(div);
+    });
+
+    data.files.forEach(f => {
+        const div = document.createElement("div");
+        div.className = "item file";
+        div.textContent = f;
+        div.onclick = () => addFile(f);
+        el.appendChild(div);
+    });
+}
+
+function renderPlaylist(data) {
+    const el = document.getElementById("playlistView");
+    el.innerHTML = "";
+
+    data.dirs.forEach(d => {
+        const div = document.createElement("div");
+        div.className = "item dir";
+        div.textContent = d + "/";
+        div.onclick = () => removeEntry(d);
+        el.appendChild(div);
+    });
+
+    data.files.forEach(f => {
+        const div = document.createElement("div");
+        div.className = "item file";
+        div.textContent = f;
+        div.onclick = () => removeEntry(f);
+        el.appendChild(div);
+    });
+}
+
+function addFile(name) {
+    ws.send(JSON.stringify({
+        action: "fsdb_add",
+        name: name,
+        playlist: getPlaylistName()
+    }));
+    setTimeout(refreshPlaylist, 100);
+}
+
+function addDir(name) {
+    ws.send(JSON.stringify({
+        action: "fsdb_add_dir",
+        name: name,
+        playlist: getPlaylistName()
+    }));
+    setTimeout(refreshPlaylist, 100);
+}
+
+function removeEntry(name) {
+    if (!confirm("Remove " + name + "?")) return;
+
+    ws.send(JSON.stringify({
+        action: "fsdb_remove",
+        name: name,
+        playlist: getPlaylistName()
+    }));
+    setTimeout(refreshPlaylist, 100);
+}
+
+function refreshPlaylist() {
+    ws.send(JSON.stringify({
+        action: "fsdb_list",
+        playlist: getPlaylistName()
+    }));
+}
+</script>
+
+</body>
+</html>
diff --git a/rds_codec.py b/rds_codec.py
index c28427f..2844490 100644
--- a/rds_codec.py
+++ b/rds_codec.py
@@ -5,14 +5,14 @@ Usage:
     import rds_codec  # registers the codec
 
     # Decode RDS bytes to str
-    text = b'\\x48\\x65\\x8A\\x6C\\x6F'.decode('rp-rds')
+    text = b'\\x48\\x65\\x8A\\x6C\\x6F'.decode('radiodatasystem')
 
     # Encode str to RDS bytes
-    data = 'Héllo'.encode('rp-rds')
+    data = 'Héllo'.encode('radiodatasystem')
 
     # With error handlers
-    text = rds_bytes.decode('rp-rds', errors='replace')
-    text = rds_bytes.decode('rp-rds', errors='ignore')
+    text = rds_bytes.decode('radiodatasystem', errors='replace')
+    text = rds_bytes.decode('radiodatasystem', errors='ignore')
 """
 
 import codecs