cista/api.py

@@ -6,7 +6,7 @@ from sanic import Blueprint
 
 from cista import watching
 from cista.fileio import FileServer
-from cista.protocol import ControlTypes, FileRange, StatusMsg
+from cista.protocol import ControlBase, FileRange, StatusMsg
 from cista.util.apphelpers import asend, websocket_wrapper
 
 bp = Blueprint("api", url_prefix="/api")
@@ -76,8 +76,7 @@ async def download(req, ws):
 @bp.websocket("control")
 @websocket_wrapper
 async def control(req, ws):
-    while True:
+    cmd = msgspec.json.decode(await ws.recv(), type=ControlBase)
-        cmd = msgspec.json.decode(await ws.recv(), type=ControlTypes)
     await asyncio.to_thread(cmd)
     await asend(ws, StatusMsg(status="ack", req=cmd))
 

cista/app.py

@@ -2,13 +2,12 @@ import mimetypes
 from importlib.resources import files
 from urllib.parse import unquote
 
-import asyncio
-import brotli
 from sanic import Blueprint, Sanic, raw
 from sanic.exceptions import Forbidden, NotFound
 
 from cista import auth, config, session, watching
 from cista.api import bp
+from cista.util import filename
 from cista.util.apphelpers import handle_sanic_exception
 
 app = Sanic("cista", strict_slashes=True)
@@ -59,54 +58,15 @@ def http_fileserver(app, _):
     app.blueprint(bp)
 
 
-www = {}
-
-
-@app.before_server_start
-def load_wwwroot(app):
-    global www
-    wwwnew = {}
-    base = files("cista") / "wwwroot"
-    paths = ["."]
-    while paths:
-        path = paths.pop(0)
-        current = base / path
-        for p in current.iterdir():
-            if p.is_dir():
-                paths.append(current / p.parts[-1])
-                continue
-            name = p.relative_to(base).as_posix()
-            mime = mimetypes.guess_type(name)[0] or "application/octet-stream"
-            data = p.read_bytes()
-            # Use old data if not changed
-            if name in www and www[name][0] == data:
-                wwwnew[name] = www[name]
-                continue
-            # Precompress with Brotli
-            br = brotli.compress(data)
-            if len(br) >= len(data):
-                br = False
-            wwwnew[name] = data, br, mime
-    www = wwwnew
-
-
-@app.add_task
-async def refresh_wwwroot():
-    while app.debug:
-        await asyncio.sleep(0.5)
-        load_wwwroot(app)
-
-
 @app.get("/<path:path>", static=True)
 async def wwwroot(req, path=""):
     """Frontend files only"""
-    name = unquote(path) or "index.html"
+    name = filename.sanitize(unquote(path)) if path else "index.html"
-    if name not in www:
+    try:
-        raise NotFound(f"File not found: /{path}", extra={"name": name})
+        index = files("cista").joinpath("wwwroot", name).read_bytes()
-    data, br, mime = www[name]
+    except OSError as e:
-    headers = {}
+        raise NotFound(
-    # Brotli compressed?
+            f"File not found: /{path}", extra={"name": name, "exception": repr(e)}
-    if br and "br" in req.headers.accept_encoding.split(", "):
+        )
-        headers["content-encoding"] = "br"
+    mime = mimetypes.guess_type(name)[0] or "application/octet-stream"
-        data = br
+    return raw(index, content_type=mime)
-    return raw(data, content_type=mime, headers=headers)

cista/protocol.py

@@ -78,9 +78,6 @@ class Cp(ControlBase):
             )
 
 
-ControlTypes = MkDir | Rename | Rm | Mv | Cp
-
-
 ## File uploads and downloads
 
 

pyproject.toml

@@ -15,7 +15,6 @@ classifiers = [
 ]
 dependencies = [
     "argon2-cffi",
-    "brotli",
     "docopt",
     "inotify",
     "msgspec",