From 84ce4b9220d9f4df963447aeff64f9689922c336 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sat, 11 Nov 2023 10:48:33 +0000
Subject: [PATCH 01/19] Fix various typing errors in backend.

---
 cista/app.py  | 84 +++++++++++++++++++++++++++++++--------------------
 cista/auth.py |  4 +--
 2 files changed, 53 insertions(+), 35 deletions(-)

diff --git a/cista/app.py b/cista/app.py
index 2b8d80d..5672a17 100644
--- a/cista/app.py
+++ b/cista/app.py
@@ -4,7 +4,7 @@ import mimetypes
 from collections import deque
 from concurrent.futures import ThreadPoolExecutor
 from importlib.resources import files
-from pathlib import Path
+from pathlib import Path, PurePath
 from stat import S_IFDIR, S_IFREG
 from urllib.parse import unquote
 from wsgiref.handlers import format_date_time
@@ -14,13 +14,13 @@ import sanic.helpers
 from blake3 import blake3
 from natsort import natsorted, ns
 from sanic import Blueprint, Sanic, empty, raw
-from sanic.exceptions import Forbidden, NotFound
+from sanic.exceptions import Forbidden, NotFound, ServerError, ServiceUnavailable
 from sanic.log import logging
 from stream_zip import ZIP_AUTO, stream_zip
 
 from cista import auth, config, session, watching
 from cista.api import bp
-from cista.protocol import DirEntry
+from cista.protocol import DirEntry, DirList
 from cista.util.apphelpers import handle_sanic_exception
 
 # Workaround until Sanic PR #2824 is merged
@@ -36,7 +36,9 @@ app.exception(Exception)(handle_sanic_exception)
 async def main_start(app, loop):
     config.load_config()
     await watching.start(app, loop)
-    app.ctx.threadexec = ThreadPoolExecutor(max_workers=8)
+    app.ctx.threadexec = ThreadPoolExecutor(
+        max_workers=8, thread_name_prefix="cista-ioworker"
+    )
 
 
 @app.after_server_stop
@@ -49,8 +51,8 @@ async def main_stop(app, loop):
 async def use_session(req):
     req.ctx.session = session.get(req)
     try:
-        req.ctx.username = req.ctx.session["username"]
-        req.ctx.user = config.config.users[req.ctx.session["username"]]  # type: ignore
+        req.ctx.username = req.ctx.session["username"]  # type: ignore
+        req.ctx.user = config.config.users[req.ctx.username]
     except (AttributeError, KeyError, TypeError):
         req.ctx.username = None
         req.ctx.user = None
@@ -81,22 +83,16 @@ def http_fileserver(app, _):
 www = {}
 
 
-@app.before_server_start
-async def load_wwwroot(*_ignored):
-    global www
-    www = await asyncio.get_event_loop().run_in_executor(None, _load_wwwroot, www)
-
-
 def _load_wwwroot(www):
     wwwnew = {}
-    base = files("cista") / "wwwroot"
-    paths = ["."]
+    base = Path(__file__).with_name("wwwroot")
+    paths = [PurePath()]
     while paths:
         path = paths.pop(0)
         current = base / path
         for p in current.iterdir():
             if p.is_dir():
-                paths.append(current / p.parts[-1])
+                paths.append(p.relative_to(base))
                 continue
             name = p.relative_to(base).as_posix()
             mime = mimetypes.guess_type(name)[0] or "application/octet-stream"
@@ -127,15 +123,35 @@ def _load_wwwroot(www):
             if len(br) >= len(data):
                 br = False
             wwwnew[name] = data, br, headers
+    if not wwwnew:
+        raise ServerError(
+            "Web frontend missing. Did you forget npm run build?",
+            extra={"wwwroot": str(base)},
+            quiet=True,
+        )
     return wwwnew
 
 
-@app.add_task
+@app.before_server_start
+async def start(app):
+    await load_wwwroot(app)
+    if app.debug:
+        app.add_task(refresh_wwwroot())
+
+
+async def load_wwwroot(app):
+    global www
+    www = await asyncio.get_event_loop().run_in_executor(
+        app.ctx.threadexec, _load_wwwroot, www
+    )
+
+
 async def refresh_wwwroot():
     while True:
+        await asyncio.sleep(0.5)
         try:
             wwwold = www
-            await load_wwwroot()
+            await load_wwwroot(app)
             changes = ""
             for name in sorted(www):
                 attr = www[name]
@@ -151,7 +167,6 @@ async def refresh_wwwroot():
             print("Error loading wwwroot", e)
         if not app.debug:
             return
-        await asyncio.sleep(0.5)
 
 
 @app.route("/<path:path>", methods=["GET", "HEAD"])
@@ -166,21 +181,19 @@ async def wwwroot(req, path=""):
         return empty(304, headers=headers)
     # Brotli compressed?
     if br and "br" in req.headers.accept_encoding.split(", "):
-        headers = {
-            **headers,
-            "content-encoding": "br",
-        }
+        headers = {**headers, "content-encoding": "br"}
         data = br
     return raw(data, headers=headers)
 
 
-@app.get("/zip/<keys>/<zipfile:ext=zip>")
-async def zip_download(req, keys, zipfile, ext):
-    """Download a zip archive of the given keys"""
-    wanted = set(keys.split("+"))
+def get_files(wanted: set) -> list:
+    if not isinstance(watching.tree[""], DirEntry):
+        raise ServiceUnavailable(headers={"retry-after": 1})
+    root = Path(watching.rootpath)
     with watching.tree_lock:
-        q = deque([([], None, watching.tree[""].dir)])
-        files = []
+        q: deque[tuple[list[str], None | list[str], DirList]] = deque(
+            [([], None, watching.tree[""].dir)]
+        )
         while q:
             locpar, relpar, d = q.pop()
             for name, attr in d.items():
@@ -193,9 +206,16 @@ async def zip_download(req, keys, zipfile, ext):
                 if isdir:
                     q.append((loc, rel, attr.dir))
                 if rel:
-                    files.append(
-                        ("/".join(rel), Path(watching.rootpath.joinpath(*loc)))
-                    )
+                    files.append(("/".join(rel), root.joinpath(*loc)))
+    return natsorted(files, key=lambda f: "/".join(f[0]), alg=ns.IGNORECASE)
+
+
+@app.get("/zip/<keys>/<zipfile:ext=zip>")
+async def zip_download(req, keys, zipfile, ext):
+    """Download a zip archive of the given keys"""
+
+    wanted = set(keys.split("+"))
+    files = get_files(wanted)
 
     if not files:
         raise NotFound(
@@ -205,8 +225,6 @@ async def zip_download(req, keys, zipfile, ext):
     if wanted:
         raise NotFound("Files not found", context={"missing": wanted})
 
-    files = natsorted(files, key=lambda f: f[0], alg=ns.IGNORECASE)
-
     def local_files(files):
         for rel, p in files:
             s = p.stat()
diff --git a/cista/auth.py b/cista/auth.py
index b3d27d4..7efeb8c 100644
--- a/cista/auth.py
+++ b/cista/auth.py
@@ -68,10 +68,10 @@ def verify(request, *, privileged=False):
         if request.ctx.user:
             if request.ctx.user.privileged:
                 return
-            raise Forbidden("Access Forbidden: Only for privileged users")
+            raise Forbidden("Access Forbidden: Only for privileged users", quiet=True)
     elif config.config.public or request.ctx.user:
         return
-    raise Unauthorized("Login required", "cookie")
+    raise Unauthorized("Login required", "cookie", quiet=True)
 
 
 bp = Blueprint("auth")
-- 
2.45.2


From 5d32396127e506ff2a8e189c4f0ff3dbc601c0b7 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sat, 11 Nov 2023 14:49:46 +0000
Subject: [PATCH 02/19] Modified column needs more space

---
 cista-front/src/components/FileExplorer.vue | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cista-front/src/components/FileExplorer.vue b/cista-front/src/components/FileExplorer.vue
index a784ce6..5b7e8f8 100644
--- a/cista-front/src/components/FileExplorer.vue
+++ b/cista-front/src/components/FileExplorer.vue
@@ -400,7 +400,7 @@ table .selection {
   text-overflow: clip;
 }
 table .modified {
-  width: 8em;
+  width: 9em;
 }
 table .size {
   width: 5em;
-- 
2.45.2


From 82bc449bbc3bae40e78e816cdf7500d2ba5b6d39 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sat, 11 Nov 2023 14:54:30 +0000
Subject: [PATCH 03/19] Rename frontend dir, update README.

---
 README.md                                                   | 6 ++++--
 {cista-front => frontend}/.gitignore                        | 0
 {cista-front => frontend}/README.md                         | 0
 {cista-front => frontend}/env.d.ts                          | 0
 {cista-front => frontend}/index.html                        | 0
 {cista-front => frontend}/package.json                      | 2 +-
 {cista-front => frontend}/public/robots.txt                 | 0
 {cista-front => frontend}/src/App.vue                       | 0
 {cista-front => frontend}/src/assets/logo.svg               | 0
 {cista-front => frontend}/src/assets/main.css               | 0
 {cista-front => frontend}/src/assets/svg/add-file.svg       | 0
 {cista-front => frontend}/src/assets/svg/add-folder.svg     | 0
 {cista-front => frontend}/src/assets/svg/arrow.svg          | 0
 {cista-front => frontend}/src/assets/svg/arrows-h.svg       | 0
 {cista-front => frontend}/src/assets/svg/arrows-v.svg       | 0
 {cista-front => frontend}/src/assets/svg/check.svg          | 0
 {cista-front => frontend}/src/assets/svg/code.svg           | 0
 {cista-front => frontend}/src/assets/svg/cog.svg            | 0
 {cista-front => frontend}/src/assets/svg/copy.svg           | 0
 {cista-front => frontend}/src/assets/svg/create-file.svg    | 0
 {cista-front => frontend}/src/assets/svg/create-folder.svg  | 0
 {cista-front => frontend}/src/assets/svg/cross.svg          | 0
 {cista-front => frontend}/src/assets/svg/disk.svg           | 0
 {cista-front => frontend}/src/assets/svg/download.svg       | 0
 {cista-front => frontend}/src/assets/svg/exclamation.svg    | 0
 {cista-front => frontend}/src/assets/svg/eye.svg            | 0
 {cista-front => frontend}/src/assets/svg/find.svg           | 0
 {cista-front => frontend}/src/assets/svg/fullscreen.svg     | 0
 {cista-front => frontend}/src/assets/svg/github.svg         | 0
 {cista-front => frontend}/src/assets/svg/home.svg           | 0
 {cista-front => frontend}/src/assets/svg/info.svg           | 0
 {cista-front => frontend}/src/assets/svg/link.svg           | 0
 {cista-front => frontend}/src/assets/svg/logo.svg           | 0
 {cista-front => frontend}/src/assets/svg/loop.svg           | 0
 {cista-front => frontend}/src/assets/svg/menu.svg           | 0
 {cista-front => frontend}/src/assets/svg/next.svg           | 0
 {cista-front => frontend}/src/assets/svg/open.svg           | 0
 {cista-front => frontend}/src/assets/svg/paste.svg          | 0
 {cista-front => frontend}/src/assets/svg/pause.svg          | 0
 {cista-front => frontend}/src/assets/svg/pencil.svg         | 0
 {cista-front => frontend}/src/assets/svg/play.svg           | 0
 {cista-front => frontend}/src/assets/svg/plus.svg           | 0
 {cista-front => frontend}/src/assets/svg/previous.svg       | 0
 {cista-front => frontend}/src/assets/svg/reload.svg         | 0
 {cista-front => frontend}/src/assets/svg/rename.svg         | 0
 {cista-front => frontend}/src/assets/svg/scissors.svg       | 0
 {cista-front => frontend}/src/assets/svg/shuffle.svg        | 0
 {cista-front => frontend}/src/assets/svg/signin.svg         | 0
 {cista-front => frontend}/src/assets/svg/signout.svg        | 0
 {cista-front => frontend}/src/assets/svg/skip.svg           | 0
 {cista-front => frontend}/src/assets/svg/spinner.svg        | 0
 {cista-front => frontend}/src/assets/svg/stop.svg           | 0
 {cista-front => frontend}/src/assets/svg/trash.svg          | 0
 {cista-front => frontend}/src/assets/svg/triangle.svg       | 0
 {cista-front => frontend}/src/assets/svg/unfullscreen.svg   | 0
 {cista-front => frontend}/src/assets/svg/up-arrow.svg       | 0
 {cista-front => frontend}/src/assets/svg/upload-cloud.svg   | 0
 {cista-front => frontend}/src/assets/svg/user-cog.svg       | 0
 {cista-front => frontend}/src/assets/svg/user.svg           | 0
 {cista-front => frontend}/src/assets/svg/volume-high.svg    | 0
 {cista-front => frontend}/src/assets/svg/volume-low.svg     | 0
 {cista-front => frontend}/src/assets/svg/volume-medium.svg  | 0
 {cista-front => frontend}/src/assets/svg/volume-mute.svg    | 0
 {cista-front => frontend}/src/assets/svg/window-cross.svg   | 0
 {cista-front => frontend}/src/assets/svg/window.svg         | 0
 {cista-front => frontend}/src/assets/svg/wordwrap.svg       | 0
 {cista-front => frontend}/src/assets/svg/zoomin.svg         | 0
 {cista-front => frontend}/src/assets/svg/zoomout.svg        | 0
 {cista-front => frontend}/src/components/BreadCrumb.vue     | 0
 {cista-front => frontend}/src/components/FileExplorer.vue   | 0
 .../src/components/FileRenameInput.vue                      | 0
 {cista-front => frontend}/src/components/FileViewer.vue     | 0
 {cista-front => frontend}/src/components/HeaderMain.vue     | 0
 {cista-front => frontend}/src/components/HeaderSelected.vue | 0
 {cista-front => frontend}/src/components/LoginModal.vue     | 0
 {cista-front => frontend}/src/components/ModalDialog.vue    | 0
 .../src/components/NotificationLoading.vue                  | 0
 {cista-front => frontend}/src/components/SvgButton.vue      | 0
 {cista-front => frontend}/src/components/UploadButton.vue   | 0
 {cista-front => frontend}/src/main.ts                       | 0
 {cista-front => frontend}/src/repositories/Client.ts        | 0
 {cista-front => frontend}/src/repositories/Document.ts      | 0
 {cista-front => frontend}/src/repositories/User.ts          | 0
 {cista-front => frontend}/src/repositories/WS.ts            | 0
 {cista-front => frontend}/src/router/index.ts               | 0
 {cista-front => frontend}/src/stores/documents.ts           | 0
 {cista-front => frontend}/src/utils/index.ts                | 0
 {cista-front => frontend}/src/views/ExplorerView.vue        | 0
 {cista-front => frontend}/tsconfig.app.json                 | 0
 {cista-front => frontend}/tsconfig.json                     | 0
 {cista-front => frontend}/tsconfig.node.json                | 0
 {cista-front => frontend}/tsconfig.vitest.json              | 0
 {cista-front => frontend}/vite.config.ts                    | 0
 93 files changed, 5 insertions(+), 3 deletions(-)
 rename {cista-front => frontend}/.gitignore (100%)
 rename {cista-front => frontend}/README.md (100%)
 rename {cista-front => frontend}/env.d.ts (100%)
 rename {cista-front => frontend}/index.html (100%)
 rename {cista-front => frontend}/package.json (98%)
 rename {cista-front => frontend}/public/robots.txt (100%)
 rename {cista-front => frontend}/src/App.vue (100%)
 rename {cista-front => frontend}/src/assets/logo.svg (100%)
 rename {cista-front => frontend}/src/assets/main.css (100%)
 rename {cista-front => frontend}/src/assets/svg/add-file.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/add-folder.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/arrow.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/arrows-h.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/arrows-v.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/check.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/code.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/cog.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/copy.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/create-file.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/create-folder.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/cross.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/disk.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/download.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/exclamation.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/eye.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/find.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/fullscreen.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/github.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/home.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/info.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/link.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/logo.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/loop.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/menu.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/next.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/open.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/paste.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/pause.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/pencil.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/play.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/plus.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/previous.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/reload.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/rename.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/scissors.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/shuffle.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/signin.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/signout.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/skip.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/spinner.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/stop.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/trash.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/triangle.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/unfullscreen.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/up-arrow.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/upload-cloud.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/user-cog.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/user.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/volume-high.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/volume-low.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/volume-medium.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/volume-mute.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/window-cross.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/window.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/wordwrap.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/zoomin.svg (100%)
 rename {cista-front => frontend}/src/assets/svg/zoomout.svg (100%)
 rename {cista-front => frontend}/src/components/BreadCrumb.vue (100%)
 rename {cista-front => frontend}/src/components/FileExplorer.vue (100%)
 rename {cista-front => frontend}/src/components/FileRenameInput.vue (100%)
 rename {cista-front => frontend}/src/components/FileViewer.vue (100%)
 rename {cista-front => frontend}/src/components/HeaderMain.vue (100%)
 rename {cista-front => frontend}/src/components/HeaderSelected.vue (100%)
 rename {cista-front => frontend}/src/components/LoginModal.vue (100%)
 rename {cista-front => frontend}/src/components/ModalDialog.vue (100%)
 rename {cista-front => frontend}/src/components/NotificationLoading.vue (100%)
 rename {cista-front => frontend}/src/components/SvgButton.vue (100%)
 rename {cista-front => frontend}/src/components/UploadButton.vue (100%)
 rename {cista-front => frontend}/src/main.ts (100%)
 rename {cista-front => frontend}/src/repositories/Client.ts (100%)
 rename {cista-front => frontend}/src/repositories/Document.ts (100%)
 rename {cista-front => frontend}/src/repositories/User.ts (100%)
 rename {cista-front => frontend}/src/repositories/WS.ts (100%)
 rename {cista-front => frontend}/src/router/index.ts (100%)
 rename {cista-front => frontend}/src/stores/documents.ts (100%)
 rename {cista-front => frontend}/src/utils/index.ts (100%)
 rename {cista-front => frontend}/src/views/ExplorerView.vue (100%)
 rename {cista-front => frontend}/tsconfig.app.json (100%)
 rename {cista-front => frontend}/tsconfig.json (100%)
 rename {cista-front => frontend}/tsconfig.node.json (100%)
 rename {cista-front => frontend}/tsconfig.vitest.json (100%)
 rename {cista-front => frontend}/vite.config.ts (100%)

diff --git a/README.md b/README.md
index b2d5852..09f9e01 100644
--- a/README.md
+++ b/README.md
@@ -1,6 +1,7 @@
 # Web File Storage
 
 Run directly from repository with Hatch (or use pip install as usual):
+
 ```sh
 hatch run cista -l :3000 /path/to/files
 ```
@@ -8,16 +9,17 @@ hatch run cista -l :3000 /path/to/files
 Settings incl. these arguments are stored to config file on the first startup and later `hatch run cista` is sufficient. If the `cista` script is missing, consider `pip install -e .` (within `hatch shell`) or some other trickery (known issue with installs made prior to adding the startup script).
 
 Create your user account:
+
 ```sh
 hatch run cista --user admin --privileged
 ```
 
 ## Build frontend
 
-Prebuilt frontend is provided in repository but for any changes it will need to be manually rebuilt:
+Frontend needs to be built before using and after any frontend changes:
 
 ```sh
-cd cista-front
+cd frontend
 npm install
 npm run build
 ```
diff --git a/cista-front/.gitignore b/frontend/.gitignore
similarity index 100%
rename from cista-front/.gitignore
rename to frontend/.gitignore
diff --git a/cista-front/README.md b/frontend/README.md
similarity index 100%
rename from cista-front/README.md
rename to frontend/README.md
diff --git a/cista-front/env.d.ts b/frontend/env.d.ts
similarity index 100%
rename from cista-front/env.d.ts
rename to frontend/env.d.ts
diff --git a/cista-front/index.html b/frontend/index.html
similarity index 100%
rename from cista-front/index.html
rename to frontend/index.html
diff --git a/cista-front/package.json b/frontend/package.json
similarity index 98%
rename from cista-front/package.json
rename to frontend/package.json
index 7d7c3fa..4686e02 100644
--- a/cista-front/package.json
+++ b/frontend/package.json
@@ -1,5 +1,5 @@
 {
-  "name": "front",
+  "name": "cista-frontend",
   "version": "0.0.0",
   "private": true,
   "scripts": {
diff --git a/cista-front/public/robots.txt b/frontend/public/robots.txt
similarity index 100%
rename from cista-front/public/robots.txt
rename to frontend/public/robots.txt
diff --git a/cista-front/src/App.vue b/frontend/src/App.vue
similarity index 100%
rename from cista-front/src/App.vue
rename to frontend/src/App.vue
diff --git a/cista-front/src/assets/logo.svg b/frontend/src/assets/logo.svg
similarity index 100%
rename from cista-front/src/assets/logo.svg
rename to frontend/src/assets/logo.svg
diff --git a/cista-front/src/assets/main.css b/frontend/src/assets/main.css
similarity index 100%
rename from cista-front/src/assets/main.css
rename to frontend/src/assets/main.css
diff --git a/cista-front/src/assets/svg/add-file.svg b/frontend/src/assets/svg/add-file.svg
similarity index 100%
rename from cista-front/src/assets/svg/add-file.svg
rename to frontend/src/assets/svg/add-file.svg
diff --git a/cista-front/src/assets/svg/add-folder.svg b/frontend/src/assets/svg/add-folder.svg
similarity index 100%
rename from cista-front/src/assets/svg/add-folder.svg
rename to frontend/src/assets/svg/add-folder.svg
diff --git a/cista-front/src/assets/svg/arrow.svg b/frontend/src/assets/svg/arrow.svg
similarity index 100%
rename from cista-front/src/assets/svg/arrow.svg
rename to frontend/src/assets/svg/arrow.svg
diff --git a/cista-front/src/assets/svg/arrows-h.svg b/frontend/src/assets/svg/arrows-h.svg
similarity index 100%
rename from cista-front/src/assets/svg/arrows-h.svg
rename to frontend/src/assets/svg/arrows-h.svg
diff --git a/cista-front/src/assets/svg/arrows-v.svg b/frontend/src/assets/svg/arrows-v.svg
similarity index 100%
rename from cista-front/src/assets/svg/arrows-v.svg
rename to frontend/src/assets/svg/arrows-v.svg
diff --git a/cista-front/src/assets/svg/check.svg b/frontend/src/assets/svg/check.svg
similarity index 100%
rename from cista-front/src/assets/svg/check.svg
rename to frontend/src/assets/svg/check.svg
diff --git a/cista-front/src/assets/svg/code.svg b/frontend/src/assets/svg/code.svg
similarity index 100%
rename from cista-front/src/assets/svg/code.svg
rename to frontend/src/assets/svg/code.svg
diff --git a/cista-front/src/assets/svg/cog.svg b/frontend/src/assets/svg/cog.svg
similarity index 100%
rename from cista-front/src/assets/svg/cog.svg
rename to frontend/src/assets/svg/cog.svg
diff --git a/cista-front/src/assets/svg/copy.svg b/frontend/src/assets/svg/copy.svg
similarity index 100%
rename from cista-front/src/assets/svg/copy.svg
rename to frontend/src/assets/svg/copy.svg
diff --git a/cista-front/src/assets/svg/create-file.svg b/frontend/src/assets/svg/create-file.svg
similarity index 100%
rename from cista-front/src/assets/svg/create-file.svg
rename to frontend/src/assets/svg/create-file.svg
diff --git a/cista-front/src/assets/svg/create-folder.svg b/frontend/src/assets/svg/create-folder.svg
similarity index 100%
rename from cista-front/src/assets/svg/create-folder.svg
rename to frontend/src/assets/svg/create-folder.svg
diff --git a/cista-front/src/assets/svg/cross.svg b/frontend/src/assets/svg/cross.svg
similarity index 100%
rename from cista-front/src/assets/svg/cross.svg
rename to frontend/src/assets/svg/cross.svg
diff --git a/cista-front/src/assets/svg/disk.svg b/frontend/src/assets/svg/disk.svg
similarity index 100%
rename from cista-front/src/assets/svg/disk.svg
rename to frontend/src/assets/svg/disk.svg
diff --git a/cista-front/src/assets/svg/download.svg b/frontend/src/assets/svg/download.svg
similarity index 100%
rename from cista-front/src/assets/svg/download.svg
rename to frontend/src/assets/svg/download.svg
diff --git a/cista-front/src/assets/svg/exclamation.svg b/frontend/src/assets/svg/exclamation.svg
similarity index 100%
rename from cista-front/src/assets/svg/exclamation.svg
rename to frontend/src/assets/svg/exclamation.svg
diff --git a/cista-front/src/assets/svg/eye.svg b/frontend/src/assets/svg/eye.svg
similarity index 100%
rename from cista-front/src/assets/svg/eye.svg
rename to frontend/src/assets/svg/eye.svg
diff --git a/cista-front/src/assets/svg/find.svg b/frontend/src/assets/svg/find.svg
similarity index 100%
rename from cista-front/src/assets/svg/find.svg
rename to frontend/src/assets/svg/find.svg
diff --git a/cista-front/src/assets/svg/fullscreen.svg b/frontend/src/assets/svg/fullscreen.svg
similarity index 100%
rename from cista-front/src/assets/svg/fullscreen.svg
rename to frontend/src/assets/svg/fullscreen.svg
diff --git a/cista-front/src/assets/svg/github.svg b/frontend/src/assets/svg/github.svg
similarity index 100%
rename from cista-front/src/assets/svg/github.svg
rename to frontend/src/assets/svg/github.svg
diff --git a/cista-front/src/assets/svg/home.svg b/frontend/src/assets/svg/home.svg
similarity index 100%
rename from cista-front/src/assets/svg/home.svg
rename to frontend/src/assets/svg/home.svg
diff --git a/cista-front/src/assets/svg/info.svg b/frontend/src/assets/svg/info.svg
similarity index 100%
rename from cista-front/src/assets/svg/info.svg
rename to frontend/src/assets/svg/info.svg
diff --git a/cista-front/src/assets/svg/link.svg b/frontend/src/assets/svg/link.svg
similarity index 100%
rename from cista-front/src/assets/svg/link.svg
rename to frontend/src/assets/svg/link.svg
diff --git a/cista-front/src/assets/svg/logo.svg b/frontend/src/assets/svg/logo.svg
similarity index 100%
rename from cista-front/src/assets/svg/logo.svg
rename to frontend/src/assets/svg/logo.svg
diff --git a/cista-front/src/assets/svg/loop.svg b/frontend/src/assets/svg/loop.svg
similarity index 100%
rename from cista-front/src/assets/svg/loop.svg
rename to frontend/src/assets/svg/loop.svg
diff --git a/cista-front/src/assets/svg/menu.svg b/frontend/src/assets/svg/menu.svg
similarity index 100%
rename from cista-front/src/assets/svg/menu.svg
rename to frontend/src/assets/svg/menu.svg
diff --git a/cista-front/src/assets/svg/next.svg b/frontend/src/assets/svg/next.svg
similarity index 100%
rename from cista-front/src/assets/svg/next.svg
rename to frontend/src/assets/svg/next.svg
diff --git a/cista-front/src/assets/svg/open.svg b/frontend/src/assets/svg/open.svg
similarity index 100%
rename from cista-front/src/assets/svg/open.svg
rename to frontend/src/assets/svg/open.svg
diff --git a/cista-front/src/assets/svg/paste.svg b/frontend/src/assets/svg/paste.svg
similarity index 100%
rename from cista-front/src/assets/svg/paste.svg
rename to frontend/src/assets/svg/paste.svg
diff --git a/cista-front/src/assets/svg/pause.svg b/frontend/src/assets/svg/pause.svg
similarity index 100%
rename from cista-front/src/assets/svg/pause.svg
rename to frontend/src/assets/svg/pause.svg
diff --git a/cista-front/src/assets/svg/pencil.svg b/frontend/src/assets/svg/pencil.svg
similarity index 100%
rename from cista-front/src/assets/svg/pencil.svg
rename to frontend/src/assets/svg/pencil.svg
diff --git a/cista-front/src/assets/svg/play.svg b/frontend/src/assets/svg/play.svg
similarity index 100%
rename from cista-front/src/assets/svg/play.svg
rename to frontend/src/assets/svg/play.svg
diff --git a/cista-front/src/assets/svg/plus.svg b/frontend/src/assets/svg/plus.svg
similarity index 100%
rename from cista-front/src/assets/svg/plus.svg
rename to frontend/src/assets/svg/plus.svg
diff --git a/cista-front/src/assets/svg/previous.svg b/frontend/src/assets/svg/previous.svg
similarity index 100%
rename from cista-front/src/assets/svg/previous.svg
rename to frontend/src/assets/svg/previous.svg
diff --git a/cista-front/src/assets/svg/reload.svg b/frontend/src/assets/svg/reload.svg
similarity index 100%
rename from cista-front/src/assets/svg/reload.svg
rename to frontend/src/assets/svg/reload.svg
diff --git a/cista-front/src/assets/svg/rename.svg b/frontend/src/assets/svg/rename.svg
similarity index 100%
rename from cista-front/src/assets/svg/rename.svg
rename to frontend/src/assets/svg/rename.svg
diff --git a/cista-front/src/assets/svg/scissors.svg b/frontend/src/assets/svg/scissors.svg
similarity index 100%
rename from cista-front/src/assets/svg/scissors.svg
rename to frontend/src/assets/svg/scissors.svg
diff --git a/cista-front/src/assets/svg/shuffle.svg b/frontend/src/assets/svg/shuffle.svg
similarity index 100%
rename from cista-front/src/assets/svg/shuffle.svg
rename to frontend/src/assets/svg/shuffle.svg
diff --git a/cista-front/src/assets/svg/signin.svg b/frontend/src/assets/svg/signin.svg
similarity index 100%
rename from cista-front/src/assets/svg/signin.svg
rename to frontend/src/assets/svg/signin.svg
diff --git a/cista-front/src/assets/svg/signout.svg b/frontend/src/assets/svg/signout.svg
similarity index 100%
rename from cista-front/src/assets/svg/signout.svg
rename to frontend/src/assets/svg/signout.svg
diff --git a/cista-front/src/assets/svg/skip.svg b/frontend/src/assets/svg/skip.svg
similarity index 100%
rename from cista-front/src/assets/svg/skip.svg
rename to frontend/src/assets/svg/skip.svg
diff --git a/cista-front/src/assets/svg/spinner.svg b/frontend/src/assets/svg/spinner.svg
similarity index 100%
rename from cista-front/src/assets/svg/spinner.svg
rename to frontend/src/assets/svg/spinner.svg
diff --git a/cista-front/src/assets/svg/stop.svg b/frontend/src/assets/svg/stop.svg
similarity index 100%
rename from cista-front/src/assets/svg/stop.svg
rename to frontend/src/assets/svg/stop.svg
diff --git a/cista-front/src/assets/svg/trash.svg b/frontend/src/assets/svg/trash.svg
similarity index 100%
rename from cista-front/src/assets/svg/trash.svg
rename to frontend/src/assets/svg/trash.svg
diff --git a/cista-front/src/assets/svg/triangle.svg b/frontend/src/assets/svg/triangle.svg
similarity index 100%
rename from cista-front/src/assets/svg/triangle.svg
rename to frontend/src/assets/svg/triangle.svg
diff --git a/cista-front/src/assets/svg/unfullscreen.svg b/frontend/src/assets/svg/unfullscreen.svg
similarity index 100%
rename from cista-front/src/assets/svg/unfullscreen.svg
rename to frontend/src/assets/svg/unfullscreen.svg
diff --git a/cista-front/src/assets/svg/up-arrow.svg b/frontend/src/assets/svg/up-arrow.svg
similarity index 100%
rename from cista-front/src/assets/svg/up-arrow.svg
rename to frontend/src/assets/svg/up-arrow.svg
diff --git a/cista-front/src/assets/svg/upload-cloud.svg b/frontend/src/assets/svg/upload-cloud.svg
similarity index 100%
rename from cista-front/src/assets/svg/upload-cloud.svg
rename to frontend/src/assets/svg/upload-cloud.svg
diff --git a/cista-front/src/assets/svg/user-cog.svg b/frontend/src/assets/svg/user-cog.svg
similarity index 100%
rename from cista-front/src/assets/svg/user-cog.svg
rename to frontend/src/assets/svg/user-cog.svg
diff --git a/cista-front/src/assets/svg/user.svg b/frontend/src/assets/svg/user.svg
similarity index 100%
rename from cista-front/src/assets/svg/user.svg
rename to frontend/src/assets/svg/user.svg
diff --git a/cista-front/src/assets/svg/volume-high.svg b/frontend/src/assets/svg/volume-high.svg
similarity index 100%
rename from cista-front/src/assets/svg/volume-high.svg
rename to frontend/src/assets/svg/volume-high.svg
diff --git a/cista-front/src/assets/svg/volume-low.svg b/frontend/src/assets/svg/volume-low.svg
similarity index 100%
rename from cista-front/src/assets/svg/volume-low.svg
rename to frontend/src/assets/svg/volume-low.svg
diff --git a/cista-front/src/assets/svg/volume-medium.svg b/frontend/src/assets/svg/volume-medium.svg
similarity index 100%
rename from cista-front/src/assets/svg/volume-medium.svg
rename to frontend/src/assets/svg/volume-medium.svg
diff --git a/cista-front/src/assets/svg/volume-mute.svg b/frontend/src/assets/svg/volume-mute.svg
similarity index 100%
rename from cista-front/src/assets/svg/volume-mute.svg
rename to frontend/src/assets/svg/volume-mute.svg
diff --git a/cista-front/src/assets/svg/window-cross.svg b/frontend/src/assets/svg/window-cross.svg
similarity index 100%
rename from cista-front/src/assets/svg/window-cross.svg
rename to frontend/src/assets/svg/window-cross.svg
diff --git a/cista-front/src/assets/svg/window.svg b/frontend/src/assets/svg/window.svg
similarity index 100%
rename from cista-front/src/assets/svg/window.svg
rename to frontend/src/assets/svg/window.svg
diff --git a/cista-front/src/assets/svg/wordwrap.svg b/frontend/src/assets/svg/wordwrap.svg
similarity index 100%
rename from cista-front/src/assets/svg/wordwrap.svg
rename to frontend/src/assets/svg/wordwrap.svg
diff --git a/cista-front/src/assets/svg/zoomin.svg b/frontend/src/assets/svg/zoomin.svg
similarity index 100%
rename from cista-front/src/assets/svg/zoomin.svg
rename to frontend/src/assets/svg/zoomin.svg
diff --git a/cista-front/src/assets/svg/zoomout.svg b/frontend/src/assets/svg/zoomout.svg
similarity index 100%
rename from cista-front/src/assets/svg/zoomout.svg
rename to frontend/src/assets/svg/zoomout.svg
diff --git a/cista-front/src/components/BreadCrumb.vue b/frontend/src/components/BreadCrumb.vue
similarity index 100%
rename from cista-front/src/components/BreadCrumb.vue
rename to frontend/src/components/BreadCrumb.vue
diff --git a/cista-front/src/components/FileExplorer.vue b/frontend/src/components/FileExplorer.vue
similarity index 100%
rename from cista-front/src/components/FileExplorer.vue
rename to frontend/src/components/FileExplorer.vue
diff --git a/cista-front/src/components/FileRenameInput.vue b/frontend/src/components/FileRenameInput.vue
similarity index 100%
rename from cista-front/src/components/FileRenameInput.vue
rename to frontend/src/components/FileRenameInput.vue
diff --git a/cista-front/src/components/FileViewer.vue b/frontend/src/components/FileViewer.vue
similarity index 100%
rename from cista-front/src/components/FileViewer.vue
rename to frontend/src/components/FileViewer.vue
diff --git a/cista-front/src/components/HeaderMain.vue b/frontend/src/components/HeaderMain.vue
similarity index 100%
rename from cista-front/src/components/HeaderMain.vue
rename to frontend/src/components/HeaderMain.vue
diff --git a/cista-front/src/components/HeaderSelected.vue b/frontend/src/components/HeaderSelected.vue
similarity index 100%
rename from cista-front/src/components/HeaderSelected.vue
rename to frontend/src/components/HeaderSelected.vue
diff --git a/cista-front/src/components/LoginModal.vue b/frontend/src/components/LoginModal.vue
similarity index 100%
rename from cista-front/src/components/LoginModal.vue
rename to frontend/src/components/LoginModal.vue
diff --git a/cista-front/src/components/ModalDialog.vue b/frontend/src/components/ModalDialog.vue
similarity index 100%
rename from cista-front/src/components/ModalDialog.vue
rename to frontend/src/components/ModalDialog.vue
diff --git a/cista-front/src/components/NotificationLoading.vue b/frontend/src/components/NotificationLoading.vue
similarity index 100%
rename from cista-front/src/components/NotificationLoading.vue
rename to frontend/src/components/NotificationLoading.vue
diff --git a/cista-front/src/components/SvgButton.vue b/frontend/src/components/SvgButton.vue
similarity index 100%
rename from cista-front/src/components/SvgButton.vue
rename to frontend/src/components/SvgButton.vue
diff --git a/cista-front/src/components/UploadButton.vue b/frontend/src/components/UploadButton.vue
similarity index 100%
rename from cista-front/src/components/UploadButton.vue
rename to frontend/src/components/UploadButton.vue
diff --git a/cista-front/src/main.ts b/frontend/src/main.ts
similarity index 100%
rename from cista-front/src/main.ts
rename to frontend/src/main.ts
diff --git a/cista-front/src/repositories/Client.ts b/frontend/src/repositories/Client.ts
similarity index 100%
rename from cista-front/src/repositories/Client.ts
rename to frontend/src/repositories/Client.ts
diff --git a/cista-front/src/repositories/Document.ts b/frontend/src/repositories/Document.ts
similarity index 100%
rename from cista-front/src/repositories/Document.ts
rename to frontend/src/repositories/Document.ts
diff --git a/cista-front/src/repositories/User.ts b/frontend/src/repositories/User.ts
similarity index 100%
rename from cista-front/src/repositories/User.ts
rename to frontend/src/repositories/User.ts
diff --git a/cista-front/src/repositories/WS.ts b/frontend/src/repositories/WS.ts
similarity index 100%
rename from cista-front/src/repositories/WS.ts
rename to frontend/src/repositories/WS.ts
diff --git a/cista-front/src/router/index.ts b/frontend/src/router/index.ts
similarity index 100%
rename from cista-front/src/router/index.ts
rename to frontend/src/router/index.ts
diff --git a/cista-front/src/stores/documents.ts b/frontend/src/stores/documents.ts
similarity index 100%
rename from cista-front/src/stores/documents.ts
rename to frontend/src/stores/documents.ts
diff --git a/cista-front/src/utils/index.ts b/frontend/src/utils/index.ts
similarity index 100%
rename from cista-front/src/utils/index.ts
rename to frontend/src/utils/index.ts
diff --git a/cista-front/src/views/ExplorerView.vue b/frontend/src/views/ExplorerView.vue
similarity index 100%
rename from cista-front/src/views/ExplorerView.vue
rename to frontend/src/views/ExplorerView.vue
diff --git a/cista-front/tsconfig.app.json b/frontend/tsconfig.app.json
similarity index 100%
rename from cista-front/tsconfig.app.json
rename to frontend/tsconfig.app.json
diff --git a/cista-front/tsconfig.json b/frontend/tsconfig.json
similarity index 100%
rename from cista-front/tsconfig.json
rename to frontend/tsconfig.json
diff --git a/cista-front/tsconfig.node.json b/frontend/tsconfig.node.json
similarity index 100%
rename from cista-front/tsconfig.node.json
rename to frontend/tsconfig.node.json
diff --git a/cista-front/tsconfig.vitest.json b/frontend/tsconfig.vitest.json
similarity index 100%
rename from cista-front/tsconfig.vitest.json
rename to frontend/tsconfig.vitest.json
diff --git a/cista-front/vite.config.ts b/frontend/vite.config.ts
similarity index 100%
rename from cista-front/vite.config.ts
rename to frontend/vite.config.ts
-- 
2.45.2


From 535905780a2d8648cd043fdeaef3a8c9e8a6e343 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 11:55:28 +0000
Subject: [PATCH 04/19] Refactor file modified/size fields components, style
 different sizes

---
 frontend/src/components/FileExplorer.vue | 17 +++----------
 frontend/src/components/FileModified.vue | 22 ++++++++++++++++
 frontend/src/components/FileSize.vue     | 32 ++++++++++++++++++++++++
 3 files changed, 58 insertions(+), 13 deletions(-)
 create mode 100644 frontend/src/components/FileModified.vue
 create mode 100644 frontend/src/components/FileSize.vue

diff --git a/frontend/src/components/FileExplorer.vue b/frontend/src/components/FileExplorer.vue
index 5b7e8f8..a12586f 100644
--- a/frontend/src/components/FileExplorer.vue
+++ b/frontend/src/components/FileExplorer.vue
@@ -48,12 +48,8 @@
             "
           />
         </td>
-        <td class="modified right">
-          <time :datetime="new Date(editing.mtime).toISOString().replace('.000', '')">{{
-            editing.modified
-          }}</time>
-        </td>
-        <td class="size right">{{ editing.sizedisp }}</td>
+        <FileModified :doc=editing />
+        <FileSize :doc=editing />
         <td class="menu"></td>
       </tr>
       <template
@@ -111,13 +107,8 @@
               </button>
             </template>
           </td>
-          <td class="modified right">
-            <time
-              :data-tooltip="new Date(1000 * doc.mtime).toISOString().replace('T', '\n').replace('.000Z', ' UTC')"
-              >{{ doc.modified }}</time
-            >
-          </td>
-          <td class="size right">{{ doc.sizedisp }}</td>
+          <FileModified :doc=doc />
+          <FileSize :doc=doc />
           <td class="menu">
             <button
               tabindex="-1"
diff --git a/frontend/src/components/FileModified.vue b/frontend/src/components/FileModified.vue
new file mode 100644
index 0000000..b6950ae
--- /dev/null
+++ b/frontend/src/components/FileModified.vue
@@ -0,0 +1,22 @@
+<template>
+  <td class="modified right">
+    <time :data-tooltip=tooltip :datetime=datetime>{{ doc.modified }}</time>
+  </td>
+</template>
+
+<script setup lang="ts">
+import type { Document } from '@/repositories/Document'
+import { computed } from 'vue'
+
+const datetime = computed(() =>
+  new Date(1000 * props.doc.mtime).toISOString().replace('.000Z', 'Z')
+)
+
+const tooltip = computed(() =>
+  datetime.value.replace('T', '\n').replace('Z', ' UTC')
+)
+
+const props = defineProps<{
+    doc: Document
+}>()
+</script>
diff --git a/frontend/src/components/FileSize.vue b/frontend/src/components/FileSize.vue
new file mode 100644
index 0000000..fbc0bfe
--- /dev/null
+++ b/frontend/src/components/FileSize.vue
@@ -0,0 +1,32 @@
+<template>
+  <td class="size right" :class=sizeClass>{{ doc.sizedisp }}</td>
+</template>
+
+<script setup lang="ts">
+import type { Document } from '@/repositories/Document'
+import { computed } from 'vue'
+
+const sizeClass = computed(() => props.doc.sizedisp.split('\u202F').slice(-1)[0])
+
+const props = defineProps<{
+    doc: Document
+}>()
+</script>
+
+<style>
+.size.empty {
+  opacity: 50%;
+}
+.size.bytes {
+  opacity: 60%;
+}
+.size.kB {
+  opacity: 70%;
+}
+.size.MB {
+  opacity: 80%;
+}
+.size.GB {
+  opacity: 90%;
+}
+</style>
-- 
2.45.2


From a70549e6ec24eefacd1ba8d90b1f709e80f96023 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 12:08:31 +0000
Subject: [PATCH 05/19] Formatting

---
 frontend/src/components/FileExplorer.vue | 73 ++++--------------------
 1 file changed, 11 insertions(+), 62 deletions(-)

diff --git a/frontend/src/components/FileExplorer.vue b/frontend/src/components/FileExplorer.vue
index a12586f..e7636ef 100644
--- a/frontend/src/components/FileExplorer.vue
+++ b/frontend/src/components/FileExplorer.vue
@@ -3,34 +3,11 @@
     <thead>
       <tr>
         <th class="selection">
-          <input
-            type="checkbox"
-            tabindex="-1"
-            v-model="allSelected"
-            :indeterminate="selectionIndeterminate"
-          />
-        </th>
-        <th
-          class="sortcolumn"
-          :class="{ sortactive: sort === 'name' }"
-          @click="toggleSort('name')"
-        >
-          Name
-        </th>
-        <th
-          class="sortcolumn modified right"
-          :class="{ sortactive: sort === 'modified' }"
-          @click="toggleSort('modified')"
-        >
-          Modified
-        </th>
-        <th
-          class="sortcolumn size right"
-          :class="{ sortactive: sort === 'size' }"
-          @click="toggleSort('size')"
-        >
-          Size
+          <input type="checkbox" tabindex="-1" v-model="allSelected" :indeterminate="selectionIndeterminate">
         </th>
+        <th class="sortcolumn" :class="{ sortactive: sort === 'name' }" @click="toggleSort('name')">Name</th>
+        <th class="sortcolumn modified right" :class="{ sortactive: sort === 'modified' }" @click="toggleSort('modified')">Modified</th>
+        <th class="sortcolumn size right" :class="{ sortactive: sort === 'size' }" @click="toggleSort('size')">Size</th>
         <th class="menu"></th>
       </tr>
     </thead>
@@ -38,23 +15,13 @@
       <tr v-if="editing?.key === 'new'" class="folder">
         <td class="selection"></td>
         <td class="name">
-          <FileRenameInput
-            :doc="editing"
-            :rename="mkdir"
-            :exit="
-              () => {
-                editing = null
-              }
-            "
-          />
+          <FileRenameInput :doc="editing" :rename="mkdir" :exit="() => {editing = null}" />
         </td>
         <FileModified :doc=editing />
         <FileSize :doc=editing />
         <td class="menu"></td>
       </tr>
-      <template
-        v-for="(doc, index) in sortedDocuments"
-        :key="doc.key">
+      <template v-for="(doc, index) in sortedDocuments" :key="doc.key">
         <tr class="folder-change" v-if="showFolderBreadcrumb(index)">
           <th colspan="5"><BreadCrumb :path="doc.loc ? doc.loc.split('/') : []" /></th>
         </tr>
@@ -78,16 +45,9 @@
             />
           </td>
           <td class="name">
-            <template v-if="editing === doc"
-              ><FileRenameInput
-                :doc="doc"
-                :rename="rename"
-                :exit="
-                  () => {
-                    editing = null
-                  }
-                "
-            /></template>
+            <template v-if="editing === doc">
+              <FileRenameInput :doc="doc" :rename="rename" :exit="() => {editing = null}" />
+            </template>
             <template v-else>
               <a
                 :href="url_for(doc)"
@@ -98,24 +58,13 @@
                 @keyup.right.stop="ev => { if (doc.dir) (ev.target as HTMLElement).click() }"
                 >{{ doc.name }}</a
               >
-              <button
-                v-if="cursor == doc"
-                class="rename-button"
-                @click="() => (editing = doc)"
-              >
-                🖊️
-              </button>
+              <button v-if="cursor == doc" class="rename-button" @click="() => (editing = doc)">🖊️</button>
             </template>
           </td>
           <FileModified :doc=doc />
           <FileSize :doc=doc />
           <td class="menu">
-            <button
-              tabindex="-1"
-              @click.stop="contextMenu($event, doc)"
-            >
-              ⋮
-            </button>
+            <button tabindex="-1" @click.stop="contextMenu($event, doc)">⋮</button>
           </td>
         </tr>
       </template>
-- 
2.45.2


From ef5e37187d96813303103a14d4f5ec6f8d0359dd Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:35:20 +0000
Subject: [PATCH 06/19] Completely revamped file list format. Fixes to zip
 creation.

---
 cista/api.py      |   6 +-
 cista/app.py      |  74 +++++-----
 cista/protocol.py |  67 ++++-----
 cista/watching.py | 354 ++++++++++++++++++++++++++++++----------------
 4 files changed, 301 insertions(+), 200 deletions(-)

diff --git a/cista/api.py b/cista/api.py
index d08705f..55c760c 100644
--- a/cista/api.py
+++ b/cista/api.py
@@ -104,11 +104,11 @@ async def watch(req, ws):
     )
     uuid = token_bytes(16)
     try:
-        with watching.tree_lock:
+        with watching.state.lock:
             q = watching.pubsub[uuid] = asyncio.Queue()
             # Init with disk usage and full tree
-            await ws.send(watching.format_du())
-            await ws.send(watching.format_tree())
+            await ws.send(watching.format_du(watching.state.space))
+            await ws.send(watching.format_tree(watching.state.root))
         # Send updates
         while True:
             await ws.send(await q.get())
diff --git a/cista/app.py b/cista/app.py
index 5672a17..2bf7e93 100644
--- a/cista/app.py
+++ b/cista/app.py
@@ -1,10 +1,8 @@
 import asyncio
 import datetime
 import mimetypes
-from collections import deque
 from concurrent.futures import ThreadPoolExecutor
-from importlib.resources import files
-from pathlib import Path, PurePath
+from pathlib import Path, PurePath, PurePosixPath
 from stat import S_IFDIR, S_IFREG
 from urllib.parse import unquote
 from wsgiref.handlers import format_date_time
@@ -12,15 +10,13 @@ from wsgiref.handlers import format_date_time
 import brotli
 import sanic.helpers
 from blake3 import blake3
-from natsort import natsorted, ns
 from sanic import Blueprint, Sanic, empty, raw
-from sanic.exceptions import Forbidden, NotFound, ServerError, ServiceUnavailable
+from sanic.exceptions import Forbidden, NotFound, ServerError
 from sanic.log import logging
 from stream_zip import ZIP_AUTO, stream_zip
 
 from cista import auth, config, session, watching
 from cista.api import bp
-from cista.protocol import DirEntry, DirList
 from cista.util.apphelpers import handle_sanic_exception
 
 # Workaround until Sanic PR #2824 is merged
@@ -186,28 +182,26 @@ async def wwwroot(req, path=""):
     return raw(data, headers=headers)
 
 
-def get_files(wanted: set) -> list:
-    if not isinstance(watching.tree[""], DirEntry):
-        raise ServiceUnavailable(headers={"retry-after": 1})
-    root = Path(watching.rootpath)
-    with watching.tree_lock:
-        q: deque[tuple[list[str], None | list[str], DirList]] = deque(
-            [([], None, watching.tree[""].dir)]
-        )
-        while q:
-            locpar, relpar, d = q.pop()
-            for name, attr in d.items():
-                loc = [*locpar, name]
-                rel = None
-                if relpar or attr.key in wanted:
-                    rel = [*relpar, name] if relpar else [name]
-                    wanted.discard(attr.key)
-                isdir = isinstance(attr, DirEntry)
-                if isdir:
-                    q.append((loc, rel, attr.dir))
-                if rel:
-                    files.append(("/".join(rel), root.joinpath(*loc)))
-    return natsorted(files, key=lambda f: "/".join(f[0]), alg=ns.IGNORECASE)
+def get_files(wanted: set) -> list[tuple[PurePosixPath, Path]]:
+    loc = PurePosixPath()
+    idx = 0
+    ret = []
+    level: int | None = None
+    parent: PurePosixPath | None = None
+    with watching.state.lock:
+        root = watching.state.root
+        while idx < len(root):
+            f = root[idx]
+            loc = PurePosixPath(*loc.parts[: f.level - 1]) / f.name
+            if parent is not None and f.level <= level:
+                level = parent = None
+            if f.key in wanted:
+                level, parent = f.level, loc.parent
+            if parent is not None:
+                wanted.discard(f.key)
+                ret.append((loc.relative_to(parent), watching.rootpath / loc))
+            idx += 1
+    return ret
 
 
 @app.get("/zip/<keys>/<zipfile:ext=zip>")
@@ -220,7 +214,7 @@ async def zip_download(req, keys, zipfile, ext):
     if not files:
         raise NotFound(
             "No files found",
-            context={"keys": keys, "zipfile": zipfile, "wanted": wanted},
+            context={"keys": keys, "zipfile": f"{zipfile}.{ext}", "wanted": wanted},
         )
     if wanted:
         raise NotFound("Files not found", context={"missing": wanted})
@@ -230,20 +224,25 @@ async def zip_download(req, keys, zipfile, ext):
             s = p.stat()
             size = s.st_size
             modified = datetime.datetime.fromtimestamp(s.st_mtime, datetime.UTC)
+            name = rel.as_posix()
             if p.is_dir():
-                yield rel, modified, S_IFDIR | 0o755, ZIP_AUTO(size), b""
+                yield f"{name}/", modified, S_IFDIR | 0o755, ZIP_AUTO(size), iter(b"")
             else:
-                yield rel, modified, S_IFREG | 0o644, ZIP_AUTO(size), contents(p)
+                yield name, modified, S_IFREG | 0o644, ZIP_AUTO(size), contents(p, size)
 
-    def contents(name):
+    def contents(name, size):
         with name.open("rb") as f:
-            while chunk := f.read(65536):
+            while size > 0 and (chunk := f.read(min(size, 1 << 20))):
+                size -= len(chunk)
                 yield chunk
+        assert size == 0
 
     def worker():
         try:
-            for chunk in stream_zip(local_files(files)):
-                asyncio.run_coroutine_threadsafe(queue.put(chunk), loop)
+            with open("test2.zip", "wb") as f:
+                for chunk in stream_zip(local_files(files)):
+                    f.write(chunk)
+                    asyncio.run_coroutine_threadsafe(queue.put(chunk), loop).result()
         except Exception:
             logging.exception("Error streaming ZIP")
             raise
@@ -256,7 +255,10 @@ async def zip_download(req, keys, zipfile, ext):
     thread = loop.run_in_executor(app.ctx.threadexec, worker)
 
     # Stream the response
-    res = await req.respond(content_type="application/zip")
+    res = await req.respond(
+        content_type="application/zip",
+        headers={"cache-control": "no-store"},
+    )
     while chunk := await queue.get():
         await res.send(chunk)
 
diff --git a/cista/protocol.py b/cista/protocol.py
index a949d67..86617f6 100644
--- a/cista/protocol.py
+++ b/cista/protocol.py
@@ -112,47 +112,36 @@ class ErrorMsg(msgspec.Struct):
 ## Directory listings
 
 
-class FileEntry(msgspec.Struct):
-    key: str
-    size: int
-    mtime: int
-
-
-class DirEntry(msgspec.Struct):
-    key: str
-    size: int
-    mtime: int
-    dir: DirList
-
-    def __getitem__(self, name):
-        return self.dir[name]
-
-    def __setitem__(self, name, value):
-        self.dir[name] = value
-
-    def __contains__(self, name):
-        return name in self.dir
-
-    def __delitem__(self, name):
-        del self.dir[name]
-
-    @property
-    def props(self):
-        return {k: v for k, v in self.__struct_fields__ if k != "dir"}
-
-
-DirList = dict[str, FileEntry | DirEntry]
-
-
-class UpdateEntry(msgspec.Struct, omit_defaults=True):
-    """Updates the named entry in the tree. Fields that are set replace old values. A list of entries recurses directories."""
-
+class FileEntry(msgspec.Struct, array_like=True):
+    level: int
     name: str
     key: str
-    deleted: bool = False
-    size: int | None = None
-    mtime: int | None = None
-    dir: DirList | None = None
+    mtime: int
+    size: int
+    isfile: int
+
+
+class Update(msgspec.Struct, array_like=True):
+    ...
+
+
+class UpdKeep(Update, tag="k"):
+    count: int
+
+
+class UpdDel(Update, tag="d"):
+    count: int
+
+
+class UpdIns(Update, tag="i"):
+    items: list[FileEntry]
+
+
+class Space(msgspec.Struct):
+    disk: int
+    free: int
+    usage: int
+    storage: int
 
 
 def make_dir_data(root):
diff --git a/cista/watching.py b/cista/watching.py
index 978a056..aa704e5 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -1,20 +1,133 @@
 import asyncio
 import shutil
+import stat
 import sys
 import threading
 import time
+from os import stat_result
 from pathlib import Path, PurePosixPath
 
 import msgspec
+from natsort import humansorted, natsort_keygen, ns
 from sanic.log import logging
 
 from cista import config
 from cista.fileio import fuid
-from cista.protocol import DirEntry, FileEntry, UpdateEntry
+from cista.protocol import FileEntry, Space, UpdDel, UpdIns, UpdKeep
 
 pubsub = {}
-tree = {"": None}
-tree_lock = threading.Lock()
+sortkey = natsort_keygen(alg=ns.LOCALE)
+
+
+class State:
+    def __init__(self):
+        self.lock = threading.RLock()
+        self._space = Space(0, 0, 0, 0)
+        self._listing: list[FileEntry] = []
+
+    @property
+    def space(self):
+        with self.lock:
+            return self._space
+
+    @space.setter
+    def space(self, space):
+        with self.lock:
+            self._space = space
+
+    @property
+    def root(self) -> list[FileEntry]:
+        with self.lock:
+            return self._listing[:]
+
+    @root.setter
+    def root(self, listing: list[FileEntry]):
+        with self.lock:
+            self._listing = listing
+
+    def _slice(self, idx: PurePosixPath | tuple[PurePosixPath, int]):
+        relpath, relfile = idx if isinstance(idx, tuple) else (idx, 0)
+        begin, end = 0, len(self._listing)
+        level = 0
+        isfile = 0
+        while level < len(relpath.parts):
+            # Enter a subdirectory
+            level += 1
+            begin += 1
+            if level == len(relpath.parts):
+                isfile = relfile
+            name = relpath.parts[level - 1]
+            namesort = sortkey(name)
+            r = self._listing[begin]
+            assert r.level == level
+            # Iterate over items at this level
+            while (
+                begin < end
+                and r.name != name
+                and r.isfile <= isfile
+                and sortkey(r.name) < namesort
+            ):
+                # Skip contents
+                begin += 1
+                while begin < end and self._listing[begin].level > level:
+                    begin += 1
+                # Not found?
+                if begin == end or self._listing[begin].level < level:
+                    return slice(begin, begin)
+                r = self._listing[begin]
+            # Not found?
+            if begin == end or r.name != name:
+                return slice(begin, begin)
+        # Found an item, now find its end
+        for end in range(begin + 1, len(self._listing)):
+            if self._listing[end].level <= level:
+                break
+        return slice(begin, end)
+
+    def __getitem__(self, index: PurePosixPath | tuple[PurePosixPath, int]):
+        with self.lock:
+            print(self._slice(index))
+            return self._listing[self._slice(index)]
+
+    def __setitem__(
+        self, index: tuple[PurePosixPath, int], value: list[FileEntry]
+    ) -> None:
+        rel, isfile = index
+        with self.lock:
+            if rel.parts:
+                parent = self._slice(rel.parent)
+                if parent.start == parent.stop:
+                    raise ValueError(
+                        f"Parent folder {rel.as_posix()} is missing for {rel.name}"
+                    )
+            self._listing[self._slice(index)] = value
+
+    def __delitem__(self, relpath: PurePosixPath):
+        with self.lock:
+            del self._listing[self._slice(relpath)]
+
+    def _index(self, rel: PurePosixPath):
+        idx = 0
+        ret = []
+
+    def _dir(self, idx: int):
+        level = self._listing[idx].level + 1
+        end = len(self._listing)
+        idx += 1
+        ret = []
+        while idx < end and (r := self._listing[idx]).level >= level:
+            if r.level == level:
+                ret.append(idx)
+        return ret, idx
+
+    def update(self, rel: PurePosixPath, value: FileEntry):
+        begin = 0
+        parents = []
+        while self._listing[begin].level < len(rel.parts):
+            parents.append(begin)
+
+
+state = State()
 rootpath: Path = None  # type: ignore
 quit = False
 modified_flags = (
@@ -26,23 +139,22 @@ modified_flags = (
     "IN_MOVED_FROM",
     "IN_MOVED_TO",
 )
-disk_usage = None
 
 
 def watcher_thread(loop):
-    global disk_usage, rootpath
+    global rootpath
     import inotify.adapters
 
     while True:
         rootpath = config.config.path
         i = inotify.adapters.InotifyTree(rootpath.as_posix())
-        old = format_tree() if tree[""] else None
-        with tree_lock:
-            # Initialize the tree from filesystem
-            tree[""] = walk(rootpath)
-        msg = format_tree()
-        if msg != old:
-            asyncio.run_coroutine_threadsafe(broadcast(msg), loop)
+        # Initialize the tree from filesystem
+        old, new = state.root, walk()
+        if old != new:
+            with state.lock:
+                state.root = new
+                msg = format_tree(new)
+            asyncio.run_coroutine_threadsafe(broadcast(msg), loop).result()
 
         # The watching is not entirely reliable, so do a full refresh every minute
         refreshdl = time.monotonic() + 60.0
@@ -52,9 +164,12 @@ def watcher_thread(loop):
                 return
             # Disk usage update
             du = shutil.disk_usage(rootpath)
-            if du != disk_usage:
-                disk_usage = du
-                asyncio.run_coroutine_threadsafe(broadcast(format_du()), loop)
+            space = Space(*du, storage=state.root[0].size)
+            if space != state.space:
+                state.space = space
+                asyncio.run_coroutine_threadsafe(
+                    broadcast(format_du(space)), loop
+                ).result()
                 break
             # Do a full refresh?
             if time.monotonic() > refreshdl:
@@ -75,141 +190,136 @@ def watcher_thread(loop):
 
 
 def watcher_thread_poll(loop):
-    global disk_usage, rootpath
+    global rootpath
 
     while not quit:
         rootpath = config.config.path
-        old = format_tree() if tree[""] else None
-        with tree_lock:
-            # Initialize the tree from filesystem
-            tree[""] = walk(rootpath)
-        msg = format_tree()
-        if msg != old:
-            asyncio.run_coroutine_threadsafe(broadcast(msg), loop)
+        old = state.root
+        new = walk()
+        if old != new:
+            state.root = new
+            asyncio.run_coroutine_threadsafe(broadcast(format_tree(new)), loop).result()
 
         # Disk usage update
         du = shutil.disk_usage(rootpath)
-        if du != disk_usage:
-            disk_usage = du
-            asyncio.run_coroutine_threadsafe(broadcast(format_du()), loop)
+        space = Space(*du, storage=state.root[0].size)
+        if space != state.space:
+            state.space = space
+            asyncio.run_coroutine_threadsafe(broadcast(format_du(space)), loop).result()
 
-        time.sleep(1.0)
+        time.sleep(2.0)
 
 
-def format_du():
-    return msgspec.json.encode(
-        {
-            "space": {
-                "disk": disk_usage.total,
-                "used": disk_usage.used,
-                "free": disk_usage.free,
-                "storage": tree[""].size,
-            },
-        },
-    ).decode()
+def format_du(usage):
+    return msgspec.json.encode({"space": usage}).decode()
 
 
-def format_tree():
-    root = tree[""]
+def format_tree(root):
     return msgspec.json.encode({"root": root}).decode()
 
 
-def walk(path: Path) -> DirEntry | FileEntry | None:
+def walk(rel=PurePosixPath()) -> list[FileEntry]:  # noqa: B008
+    path = rootpath / rel
     try:
-        s = path.stat()
-        key = fuid(s)
-        assert key, repr(key)
-        mtime = int(s.st_mtime)
-        if path.is_file():
-            return FileEntry(key, s.st_size, mtime)
+        st = path.stat()
+    except OSError:
+        return []
+    return _walk(rel, int(not stat.S_ISDIR(st.st_mode)), st)
 
-        tree = {
-            p.name: v
-            for p in path.iterdir()
-            if not p.name.startswith(".")
-            if (v := walk(p)) is not None
-        }
-        if tree:
-            size = sum(v.size for v in tree.values())
-            mtime = max(mtime, *(v.mtime for v in tree.values()))
-        else:
-            size = 0
-        return DirEntry(key, size, mtime, tree)
+
+def _walk(rel: PurePosixPath, isfile: int, st: stat_result) -> list[FileEntry]:
+    entry = FileEntry(
+        level=len(rel.parts),
+        name=rel.name,
+        key=fuid(st),
+        mtime=int(st.st_mtime),
+        size=st.st_size if isfile else 0,
+        isfile=isfile,
+    )
+    if isfile:
+        return [entry]
+    ret = [entry]
+    path = rootpath / rel
+    try:
+        li = []
+        for f in path.iterdir():
+            if f.name.startswith("."):
+                continue  # No dotfiles
+            s = f.stat()
+            li.append((int(not stat.S_ISDIR(s.st_mode)), f.name, s))
+        for [isfile, name, s] in humansorted(li):
+            subtree = _walk(rel / name, isfile, s)
+            child = subtree[0]
+            entry.mtime = max(entry.mtime, child.mtime)
+            entry.size += child.size
+            ret.extend(subtree)
     except FileNotFoundError:
-        return None
+        pass  # Things may be rapidly in motion
     except OSError as e:
         print("OS error walking path", path, e)
-        return None
+    return ret
 
 
 def update(relpath: PurePosixPath, loop):
     """Called by inotify updates, check the filesystem and broadcast any changes."""
     if rootpath is None or relpath is None:
         print("ERROR", rootpath, relpath)
-    new = walk(rootpath / relpath)
-    with tree_lock:
-        update = update_internal(relpath, new)
-        if not update:
-            return  # No changes
-        msg = msgspec.json.encode({"update": update}).decode()
-        asyncio.run_coroutine_threadsafe(broadcast(msg), loop)
-
-
-def update_internal(
-    relpath: PurePosixPath,
-    new: DirEntry | FileEntry | None,
-) -> list[UpdateEntry]:
-    path = "", *relpath.parts
-    old = tree
-    elems = []
-    for name in path:
-        if name not in old:
-            # File or folder created
-            old = None
-            elems.append((name, None))
-            if len(elems) < len(path):
-                # We got a notify for an item whose parent is not in tree
-                print("Tree out of sync DEBUG", relpath)
-                print(elems)
-                print("Current tree:")
-                print(tree[""])
-                print("Walking all:")
-                print(walk(rootpath))
-                raise ValueError("Tree out of sync")
-            break
-        old = old[name]
-        elems.append((name, old))
+    new = walk(relpath)
+    old = state[relpath]
     if old == new:
-        return []
-    mt = new.mtime if new else 0
-    szdiff = (new.size if new else 0) - (old.size if old else 0)
-    # Update parents
-    update = []
-    for name, entry in elems[:-1]:
-        u = UpdateEntry(name, entry.key)
-        if szdiff:
-            entry.size += szdiff
-            u.size = entry.size
-        if mt > entry.mtime:
-            u.mtime = entry.mtime = mt
-        update.append(u)
-    # The last element is the one that changed
-    name, entry = elems[-1]
-    parent = elems[-2][1] if len(elems) > 1 else tree
-    u = UpdateEntry(name, new.key if new else entry.key)
+        return
+    old = state.root
     if new:
-        parent[name] = new
-        if u.size != new.size:
-            u.size = new.size
-        if u.mtime != new.mtime:
-            u.mtime = new.mtime
-        if isinstance(new, DirEntry) and u.dir != new.dir:
-            u.dir = new.dir
+        state[relpath, new[0].isfile] = new
     else:
-        del parent[name]
-        u.deleted = True
-    update.append(u)
-    return update
+        del state[relpath]
+    # FIXME: broadcast format_update()
+    msg = format_update(old, state.root)
+    asyncio.run_coroutine_threadsafe(broadcast(msg), loop).result()
+
+
+def format_update(old, new):
+    # Make keep/del/insert diff until one of the lists ends
+    oidx, nidx = 0, 0
+    update = []
+    keep_count = 0
+    while oidx < len(old) and nidx < len(new):
+        if old[oidx] == new[nidx]:
+            keep_count += 1
+            oidx += 1
+            nidx += 1
+            continue
+        if keep_count > 0:
+            update.append(UpdKeep(keep_count))
+            keep_count = 0
+
+        del_count = 0
+        rest = new[nidx:]
+        while old[oidx] not in rest:
+            del_count += 1
+            oidx += 1
+
+        if del_count:
+            update.append(UpdDel(del_count))
+            oidx += 1
+            continue
+
+        insert_items = []
+        rest = old[oidx:]
+        while nidx < len(new) and new[nidx] not in rest:
+            insert_items.append(new[nidx])
+            nidx += 1
+        update.append(UpdIns(insert_items))
+
+    # Diff any remaining
+    if keep_count > 0:
+        update.append(UpdKeep(keep_count))
+    if oidx < len(old):
+        update.append(UpdDel(len(old) - oidx))
+    elif nidx < len(new):
+        update.append(UpdIns(new[nidx:]))
+
+    return msgspec.json.encode({"update": update}).decode()
 
 
 async def broadcast(msg):
-- 
2.45.2


From 00a4297c0bade3ccd5a378c0be601af554764c1e Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:37:17 +0000
Subject: [PATCH 07/19] New filelist format on frontend

---
 frontend/src/App.vue                  | 18 +++++---
 frontend/src/repositories/Document.ts | 31 ++++---------
 frontend/src/repositories/WS.ts       | 55 +++++++++++++++--------
 frontend/src/stores/documents.ts      | 64 ++++++++-------------------
 frontend/src/views/ExplorerView.vue   | 14 +++---
 5 files changed, 82 insertions(+), 100 deletions(-)

diff --git a/frontend/src/App.vue b/frontend/src/App.vue
index d7a91d5..a862b9a 100644
--- a/frontend/src/App.vue
+++ b/frontend/src/App.vue
@@ -1,13 +1,13 @@
 <template>
   <LoginModal />
   <header>
-    <HeaderMain ref="headerMain" :path="path.pathList">
+    <HeaderMain ref="headerMain" :path="path.pathList" :query="path.query">
       <HeaderSelected :path="path.pathList" />
     </HeaderMain>
     <BreadCrumb :path="path.pathList" tabindex="-1"/>
   </header>
   <main>
-    <RouterView :path="path.pathList" />
+    <RouterView :path="path.pathList" :query="path.query" />
   </main>
 </template>
 
@@ -16,7 +16,7 @@ import { RouterView } from 'vue-router'
 import type { ComputedRef } from 'vue'
 import type HeaderMain from '@/components/HeaderMain.vue'
 import { onMounted, onUnmounted, ref, watchEffect } from 'vue'
-import { watchConnect, watchDisconnect } from '@/repositories/WS'
+import { loadSession, watchConnect, watchDisconnect } from '@/repositories/WS'
 import { useDocumentStore } from '@/stores/documents'
 
 import { computed } from 'vue'
@@ -25,19 +25,23 @@ import Router from '@/router/index'
 interface Path {
   path: string
   pathList: string[]
+  query: string
 }
 const documentStore = useDocumentStore()
 const path: ComputedRef<Path> = computed(() => {
-  const p = decodeURIComponent(Router.currentRoute.value.path)
-  const pathList = p.split('/').filter(value => value !== '')
+  const p = decodeURIComponent(Router.currentRoute.value.path).split('//')
+  const pathList = p[0].split('/').filter(value => value !== '')
+  const query = p.slice(1).join('//')
   return {
-    path: p,
-    pathList
+    path: p[0],
+    pathList,
+    query
   }
 })
 watchEffect(() => {
   document.title = path.value.path.replace(/\/$/, '').split('/').pop() || documentStore.server.name || 'Cista Storage'
 })
+onMounted(loadSession)
 onMounted(watchConnect)
 onUnmounted(watchDisconnect)
 // Update human-readable x seconds ago messages from mtimes
diff --git a/frontend/src/repositories/Document.ts b/frontend/src/repositories/Document.ts
index 57355b4..022b260 100644
--- a/frontend/src/repositories/Document.ts
+++ b/frontend/src/repositories/Document.ts
@@ -22,29 +22,16 @@ export type errorEvent = {
 
 // Raw types the backend /api/watch sends us
 
-export type FileEntry = {
-  key: FUID
-  size: number
-  mtime: number
-}
+export type FileEntry = [
+  number,  // level
+  string,  // name
+  FUID,
+  number, //mtime
+  number, // size
+  number, // isfile
+]
 
-export type DirEntry = {
-  key: FUID
-  size: number
-  mtime: number
-  dir: DirList
-}
-
-export type DirList = Record<string, FileEntry | DirEntry>
-
-export type UpdateEntry = {
-  name: string
-  deleted?: boolean
-  key?: FUID
-  size?: number
-  mtime?: number
-  dir?: DirList
-}
+export type UpdateEntry = ['k', number] | ['d', number] | ['i', Array<FileEntry>]
 
 // Helper structure for selections
 export interface SelectedItems {
diff --git a/frontend/src/repositories/WS.ts b/frontend/src/repositories/WS.ts
index d5ebf8a..0570921 100644
--- a/frontend/src/repositories/WS.ts
+++ b/frontend/src/repositories/WS.ts
@@ -1,14 +1,29 @@
 import { useDocumentStore } from "@/stores/documents"
-import type { DirEntry, UpdateEntry, errorEvent } from "./Document"
+import type { FileEntry, UpdateEntry, errorEvent } from "./Document"
 
 export const controlUrl = '/api/control'
 export const uploadUrl = '/api/upload'
 export const watchUrl = '/api/watch'
 
-let tree = null as DirEntry | null
+let tree = [] as FileEntry[]
 let reconnectDuration = 500
 let wsWatch = null as WebSocket | null
 
+export const loadSession = () => {
+  const store = useDocumentStore()
+  try {
+    tree = JSON.parse(sessionStorage["cista-files"])
+    store.updateRoot(tree)
+    return true
+  } catch (error) {
+    return false
+  }
+}
+
+const saveSession = () => {
+  sessionStorage["cista-files"] = JSON.stringify(tree)
+}
+
 export const connect = (path: string, handlers: Partial<Record<keyof WebSocketEventMap, any>>) => {
   const webSocket = new WebSocket(new URL(path, location.origin.replace(/^http/, 'ws')))
   for (const [event, handler] of Object.entries(handlers)) webSocket.addEventListener(event, handler)
@@ -99,29 +114,31 @@ function handleRootMessage({ root }: { root: DirEntry }) {
   console.log('Watch root', root)
   store.updateRoot(root)
   tree = root
+  saveSession()
 }
 
 function handleUpdateMessage(updateData: { update: UpdateEntry[] }) {
   const store = useDocumentStore()
-  console.log('Watch update', updateData.update)
+  const update = updateData.update
+  console.log('Watch update', update)
   if (!tree) return console.error('Watch update before root')
-  let node: DirEntry = tree
-  for (const elem of updateData.update) {
-    if (elem.deleted) {
-      delete node.dir[elem.name]
-      break // Deleted elements can't have further children
-    }
-    if (elem.name) {
-      // @ts-ignore
-      console.log(node, elem.name)
-      node = node.dir[elem.name] ||= {}
-    }
-    if (elem.key !== undefined) node.key = elem.key
-    if (elem.size !== undefined) node.size = elem.size
-    if (elem.mtime !== undefined) node.mtime = elem.mtime
-    if (elem.dir !== undefined) node.dir = elem.dir
+  let newtree = []
+  let oidx = 0
+
+  for (const [action, arg] of update) {
+      if (action === 'k') {
+          newtree.push(...tree.slice(oidx, oidx + arg))
+          oidx += arg
+      }
+      else if (action === 'd') oidx += arg
+      else if (action === 'i') newtree.push(...arg)
+      else console.log("Unknown update action", action, arg)
   }
-  store.updateRoot(tree)
+  if (oidx != tree.length)
+    throw Error(`Tree update out of sync, number of entries mismatch: got ${oidx}, expected ${tree.length}`)
+  store.updateRoot(newtree)
+  tree = newtree
+  saveSession()
 }
 
 function handleError(msg: errorEvent) {
diff --git a/frontend/src/stores/documents.ts b/frontend/src/stores/documents.ts
index 97c6ca6..985d5fd 100644
--- a/frontend/src/stores/documents.ts
+++ b/frontend/src/stores/documents.ts
@@ -1,10 +1,4 @@
-import type {
-  Document,
-  DirEntry,
-  FileEntry,
-  FUID,
-  SelectedItems
-} from '@/repositories/Document'
+import type { Document, FileEntry, FUID, SelectedItems } from '@/repositories/Document'
 import { formatSize, formatUnixDate, haystackFormat } from '@/utils'
 import { defineStore } from 'pinia'
 import { collator } from '@/utils'
@@ -26,7 +20,6 @@ export const useDocumentStore = defineStore({
   id: 'documents',
   state: () => ({
     document: [] as Document[],
-    search: "" as string,
     selected: new Set<FUID>(),
     uploadingDocuments: [],
     uploadCount: 0 as number,
@@ -41,46 +34,27 @@ export const useDocumentStore = defineStore({
       isOpenLoginModal: false
     } as User
   }),
-  persist: {
-    storage: sessionStorage,
-    paths: ['document'],
-  },
   actions: {
-    updateRoot(root: DirEntry | null = null) {
-      if (!root) {
-        this.document = []
-        return
-      }
-      // Transform tree data to flat documents array
-      let loc = ""
-      const mapper = ([name, attr]: [string, FileEntry | DirEntry]) => ({
-        ...attr,
-        loc,
-        name,
-        sizedisp: formatSize(attr.size),
-        modified: formatUnixDate(attr.mtime),
-        haystack: haystackFormat(name),
-      })
-      const queue = [...Object.entries(root.dir ?? {}).map(mapper)]
+    updateRoot(root: FileEntry[]) {
       const docs = []
-      for (let doc; (doc = queue.shift()) !== undefined;) {
-        docs.push(doc)
-        if ("dir" in doc) {
-          // Recurse but replace recursive structure with boolean
-          loc = doc.loc ? `${doc.loc}/${doc.name}` : doc.name
-          queue.push(...Object.entries(doc.dir).map(mapper))
-          // @ts-ignore
-          doc.dir = true
-        }
-        // @ts-ignore
-        else doc.dir = false
+      let loc = [] as string[]
+      for (const [level, name, key, mtime, size, isfile] of root) {
+        if (level === 0) continue
+        loc = loc.slice(0, level - 1)
+        docs.push({
+          name,
+          loc: loc.join('/'),
+          key,
+          size,
+          sizedisp: formatSize(size),
+          mtime,
+          modified: formatUnixDate(mtime),
+          haystack: haystackFormat(name),
+          dir: !isfile,
+        })
+        loc.push(name)
       }
-      // Pre sort directory entries folders first then files, names in natural ordering
-      docs.sort((a, b) =>
-        // @ts-ignore
-        b.dir - a.dir ||
-        collator.compare(a.name, b.name)
-      )
+      console.log("Documents", docs)
       this.document = docs as Document[]
     },
     login(username: string, privileged: boolean) {
diff --git a/frontend/src/views/ExplorerView.vue b/frontend/src/views/ExplorerView.vue
index b163caa..773d2ee 100644
--- a/frontend/src/views/ExplorerView.vue
+++ b/frontend/src/views/ExplorerView.vue
@@ -16,17 +16,17 @@ import { needleFormat, localeIncludes, collator } from '@/utils';
 
 const documentStore = useDocumentStore()
 const fileExplorer = ref()
-const props = defineProps({
+const props = defineProps<{
   path: Array<string>
-})
+  query: string
+}>()
 const documents = computed(() => {
-  if (!props.path) return []
   const loc = props.path.join('/')
+  const query = props.query
   // List the current location
-  if (!documentStore.search) return documentStore.document.filter(doc => doc.loc === loc)
+  if (!query) return documentStore.document.filter(doc => doc.loc === loc)
   // Find up to 100 newest documents that match the search
-  const search = documentStore.search
-  const needle = needleFormat(search)
+  const needle = needleFormat(query)
   let limit = 100
   let docs = []
   for (const doc of documentStore.recentDocuments) {
@@ -46,7 +46,7 @@ const documents = computed(() => {
     // @ts-ignore
     (a.type === 'file') - (b.type === 'file') ||
     // @ts-ignore
-    b.name.includes(search) - a.name.includes(search) ||
+    b.name.includes(query) - a.name.includes(query) ||
     collator.compare(a.name, b.name)
   ))
   return docs
-- 
2.45.2


From be1c4c1504e2d7f29ba595ad0318c8fb21b1291a Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:38:23 +0000
Subject: [PATCH 08/19] Fixes to URL path handling, search query on URL

---
 frontend/src/components/BreadCrumb.vue   |  5 +++-
 frontend/src/components/FileExplorer.vue | 13 ++++-------
 frontend/src/components/HeaderMain.vue   | 29 ++++++++++++++++++------
 3 files changed, 31 insertions(+), 16 deletions(-)

diff --git a/frontend/src/components/BreadCrumb.vue b/frontend/src/components/BreadCrumb.vue
index addac26..ce98fda 100644
--- a/frontend/src/components/BreadCrumb.vue
+++ b/frontend/src/components/BreadCrumb.vue
@@ -46,8 +46,11 @@ const isCurrent = (index: number) => index == props.path.length ? 'location' : u
 const navigate = (index: number) => {
   const link = links[index]
   if (!link) throw Error(`No link at index ${index} (path: ${props.path})`)
+  const url = `/${longest.value.slice(0, index).join('/')}/`
+  const here = `/${longest.value.join('/')}/`
   link.focus()
-  router.replace(`/${longest.value.slice(0, index).join('/')}`)
+  if (here.startsWith(location.hash.slice(1))) router.replace(url)
+  else router.push(url)
 }
 
 const move = (dir: number) => {
diff --git a/frontend/src/components/FileExplorer.vue b/frontend/src/components/FileExplorer.vue
index e7636ef..c63040d 100644
--- a/frontend/src/components/FileExplorer.vue
+++ b/frontend/src/components/FileExplorer.vue
@@ -87,13 +87,10 @@ import { connect, controlUrl } from '@/repositories/WS'
 import { collator, formatSize, formatUnixDate } from '@/utils'
 import { useRouter } from 'vue-router'
 
-const props = withDefaults(
-  defineProps<{
-    path: Array<string>
-    documents: Document[]
-  }>(),
-  {}
-)
+const props = defineProps<{
+  path: Array<string>
+  documents: Document[]
+}>()
 const documentStore = useDocumentStore()
 const router = useRouter()
 const url_for = (doc: Document) => {
@@ -249,7 +246,7 @@ const mkdir = (doc: Document, name: string) => {
         editing.value = null
       } else {
         console.log('mkdir', msg)
-        router.push(`/${doc.loc}/${name}/`)
+        router.push(doc.loc ? `/${doc.loc}/${name}/` : `/${name}/`)
       }
     }
   })
diff --git a/frontend/src/components/HeaderMain.vue b/frontend/src/components/HeaderMain.vue
index a9826b1..58c6e53 100644
--- a/frontend/src/components/HeaderMain.vue
+++ b/frontend/src/components/HeaderMain.vue
@@ -17,7 +17,9 @@
         <input
           ref="search"
           type="search"
-          v-model="documentStore.search"
+          :value="query"
+          @blur="ev => { if (!query) closeSearch(ev) }"
+          @input="updateSearch"
           placeholder="Search words"
           class="margin-input"
           @keyup.escape="closeSearch"
@@ -31,20 +33,30 @@
 
 <script setup lang="ts">
 import { useDocumentStore } from '@/stores/documents'
-import { ref, nextTick } from 'vue'
+import { ref, nextTick, watchEffect } from 'vue'
 import ContextMenu from '@imengyu/vue3-context-menu'
+import router from '@/router';
 
 const documentStore = useDocumentStore()
 const showSearchInput = ref<boolean>(false)
 const search = ref<HTMLInputElement | null>()
 const searchButton = ref<HTMLButtonElement | null>()
 
-const closeSearch = () => {
+const closeSearch = ev => {
   if (!showSearchInput.value) return  // Already closing
   showSearchInput.value = false
-  documentStore.search = ''
   const breadcrumb = document.querySelector('.breadcrumb') as HTMLElement
   breadcrumb.focus()
+  updateSearch(ev)
+}
+const updateSearch = ev => {
+  const q = ev.target.value
+  let p = props.path.join('/')
+  p = p ? `/${p}` : ''
+  const url = q ? `${p}//${q}` : (p || '/')
+  console.log("Update search", url)
+  if (!props.query && q) router.push(url)
+  else router.replace(url)
 }
 const toggleSearchInput = () => {
   showSearchInput.value = !showSearchInput.value
@@ -54,7 +66,9 @@ const toggleSearchInput = () => {
     if (input) input.focus()
   })
 }
-
+watchEffect(() => {
+  if (props.query) showSearchInput.value = true
+})
 const settingsMenu = (e: Event) => {
   // show the context menu
   const items = []
@@ -69,9 +83,10 @@ const settingsMenu = (e: Event) => {
     items,
   })
 }
-const props = defineProps({
+const props = defineProps<{
   path: Array<string>
-})
+  query: string
+}>()
 
 defineExpose({
   toggleSearchInput,
-- 
2.45.2


From 88aca511e703ad300e1f37121158b63f454a2a3a Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:38:42 +0000
Subject: [PATCH 09/19] Colored file size

---
 frontend/src/components/FileSize.vue | 39 ++++++++++++++++++----------
 1 file changed, 25 insertions(+), 14 deletions(-)

diff --git a/frontend/src/components/FileSize.vue b/frontend/src/components/FileSize.vue
index fbc0bfe..00b4658 100644
--- a/frontend/src/components/FileSize.vue
+++ b/frontend/src/components/FileSize.vue
@@ -6,27 +6,38 @@
 import type { Document } from '@/repositories/Document'
 import { computed } from 'vue'
 
-const sizeClass = computed(() => props.doc.sizedisp.split('\u202F').slice(-1)[0])
+const sizeClass = computed(() => {
+  const unit = props.doc.sizedisp.split('\u202F').slice(-1)[0]
+  return +unit ? "bytes" : unit
+})
 
 const props = defineProps<{
     doc: Document
 }>()
 </script>
 
-<style>
-.size.empty {
-  opacity: 50%;
+<style scoped>
+.size.empty { color: #555 }
+.size.bytes { color: #77a }
+.size.kB { color: #474 }
+.size.MB { color: #a80 }
+.size.GB { color: #f83 }
+.size.TB, .size.PB, .size.EB, .size.huge {
+  color: #f44;
+  text-shadow: 0 0 .2em;
 }
-.size.bytes {
-  opacity: 60%;
+
+@media (prefers-color-scheme: dark) {
+  .size.empty { color: #bbb }
+  .size.bytes { color: #99d }
+  .size.kB { color: #aea }
+  .size.MB { color: #ff4 }
+  .size.GB { color: #f86 }
+  .size.TB, .size.PB, .size.EB, .size.huge { color: #f55 }
 }
-.size.kB {
-  opacity: 70%;
-}
-.size.MB {
-  opacity: 80%;
-}
-.size.GB {
-  opacity: 90%;
+
+.cursor .size {
+  color: inherit;
+  text-shadow: none;
 }
 </style>
-- 
2.45.2


From 0be72827db960201caefde4e103e03faf196c055 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:40:05 +0000
Subject: [PATCH 10/19] Remove test.zip generation

---
 cista/app.py | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/cista/app.py b/cista/app.py
index 2bf7e93..a2e643e 100644
--- a/cista/app.py
+++ b/cista/app.py
@@ -239,10 +239,8 @@ async def zip_download(req, keys, zipfile, ext):
 
     def worker():
         try:
-            with open("test2.zip", "wb") as f:
-                for chunk in stream_zip(local_files(files)):
-                    f.write(chunk)
-                    asyncio.run_coroutine_threadsafe(queue.put(chunk), loop).result()
+            for chunk in stream_zip(local_files(files)):
+                asyncio.run_coroutine_threadsafe(queue.put(chunk), loop).result()
         except Exception:
             logging.exception("Error streaming ZIP")
             raise
-- 
2.45.2


From 540e825cc3609dcf0c9a295ffaebff9dfcd2452b Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 19:58:37 +0000
Subject: [PATCH 11/19] Watching code cleanup

---
 cista/api.py      |  4 ++--
 cista/watching.py | 58 +++++++++++++++++++++++------------------------
 2 files changed, 31 insertions(+), 31 deletions(-)

diff --git a/cista/api.py b/cista/api.py
index 55c760c..c97d893 100644
--- a/cista/api.py
+++ b/cista/api.py
@@ -107,8 +107,8 @@ async def watch(req, ws):
         with watching.state.lock:
             q = watching.pubsub[uuid] = asyncio.Queue()
             # Init with disk usage and full tree
-            await ws.send(watching.format_du(watching.state.space))
-            await ws.send(watching.format_tree(watching.state.root))
+            await ws.send(watching.format_space(watching.state.space))
+            await ws.send(watching.format_root(watching.state.root))
         # Send updates
         while True:
             await ws.send(await q.get())
diff --git a/cista/watching.py b/cista/watching.py
index aa704e5..49c4f29 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -86,7 +86,6 @@ class State:
 
     def __getitem__(self, index: PurePosixPath | tuple[PurePosixPath, int]):
         with self.lock:
-            print(self._slice(index))
             return self._listing[self._slice(index)]
 
     def __setitem__(
@@ -153,8 +152,7 @@ def watcher_thread(loop):
         if old != new:
             with state.lock:
                 state.root = new
-                msg = format_tree(new)
-            asyncio.run_coroutine_threadsafe(broadcast(msg), loop).result()
+                broadcast(format_root(new), loop)
 
         # The watching is not entirely reliable, so do a full refresh every minute
         refreshdl = time.monotonic() + 60.0
@@ -167,9 +165,7 @@ def watcher_thread(loop):
             space = Space(*du, storage=state.root[0].size)
             if space != state.space:
                 state.space = space
-                asyncio.run_coroutine_threadsafe(
-                    broadcast(format_du(space)), loop
-                ).result()
+                broadcast(format_space(space), loop)
                 break
             # Do a full refresh?
             if time.monotonic() > refreshdl:
@@ -197,27 +193,20 @@ def watcher_thread_poll(loop):
         old = state.root
         new = walk()
         if old != new:
-            state.root = new
-            asyncio.run_coroutine_threadsafe(broadcast(format_tree(new)), loop).result()
+            with state.lock:
+                state.root = new
+                broadcast(format_update(old, new), loop)
 
         # Disk usage update
         du = shutil.disk_usage(rootpath)
         space = Space(*du, storage=state.root[0].size)
         if space != state.space:
             state.space = space
-            asyncio.run_coroutine_threadsafe(broadcast(format_du(space)), loop).result()
+            broadcast(format_space(space), loop)
 
         time.sleep(2.0)
 
 
-def format_du(usage):
-    return msgspec.json.encode({"space": usage}).decode()
-
-
-def format_tree(root):
-    return msgspec.json.encode({"root": root}).decode()
-
-
 def walk(rel=PurePosixPath()) -> list[FileEntry]:  # noqa: B008
     path = rootpath / rel
     try:
@@ -265,17 +254,16 @@ def update(relpath: PurePosixPath, loop):
     if rootpath is None or relpath is None:
         print("ERROR", rootpath, relpath)
     new = walk(relpath)
-    old = state[relpath]
-    if old == new:
-        return
-    old = state.root
-    if new:
-        state[relpath, new[0].isfile] = new
-    else:
-        del state[relpath]
-    # FIXME: broadcast format_update()
-    msg = format_update(old, state.root)
-    asyncio.run_coroutine_threadsafe(broadcast(msg), loop).result()
+    with state.lock:
+        old = state[relpath]
+        if old == new:
+            return
+        old = state.root
+        if new:
+            state[relpath, new[0].isfile] = new
+        else:
+            del state[relpath]
+        broadcast(format_update(old, state.root), loop)
 
 
 def format_update(old, new):
@@ -322,7 +310,19 @@ def format_update(old, new):
     return msgspec.json.encode({"update": update}).decode()
 
 
-async def broadcast(msg):
+def format_space(usage):
+    return msgspec.json.encode({"space": usage}).decode()
+
+
+def format_root(root):
+    return msgspec.json.encode({"root": root}).decode()
+
+
+def broadcast(msg, loop):
+    return asyncio.run_coroutine_threadsafe(abroadcast(msg), loop).result()
+
+
+async def abroadcast(msg):
     try:
         for queue in pubsub.values():
             queue.put_nowait(msg)
-- 
2.45.2


From 2978e0c9681ab1f3088cc8f37ce644f5c6d82634 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 20:09:29 +0000
Subject: [PATCH 12/19] Better special handling for root Document. Restore live
 updates of relative modified times.

---
 frontend/src/stores/documents.ts | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/frontend/src/stores/documents.ts b/frontend/src/stores/documents.ts
index 985d5fd..0d40d75 100644
--- a/frontend/src/stores/documents.ts
+++ b/frontend/src/stores/documents.ts
@@ -4,6 +4,7 @@ import { defineStore } from 'pinia'
 import { collator } from '@/utils'
 import { logoutUser } from '@/repositories/User'
 import { watchConnect } from '@/repositories/WS'
+import { format } from 'path'
 
 type FileData = { id: string; mtime: number; size: number; dir: DirectoryData }
 type DirectoryData = {
@@ -39,11 +40,10 @@ export const useDocumentStore = defineStore({
       const docs = []
       let loc = [] as string[]
       for (const [level, name, key, mtime, size, isfile] of root) {
-        if (level === 0) continue
         loc = loc.slice(0, level - 1)
         docs.push({
           name,
-          loc: loc.join('/'),
+          loc: level ? loc.join('/') : '/',
           key,
           size,
           sizedisp: formatSize(size),
@@ -57,6 +57,9 @@ export const useDocumentStore = defineStore({
       console.log("Documents", docs)
       this.document = docs as Document[]
     },
+    updateModified() {
+      for (const doc of this.document) doc.modified = formatUnixDate(doc.mtime)
+    },
     login(username: string, privileged: boolean) {
       this.user.username = username
       this.user.privileged = privileged
-- 
2.45.2


From c31fb2475205ba1b5cadd80ccf19dd8429b7ec6a Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 20:30:35 +0000
Subject: [PATCH 13/19] Correct locking in thread poll watcher

---
 cista/watching.py                | 10 +++++-----
 frontend/src/repositories/WS.ts  | 16 ++++++++--------
 frontend/src/stores/documents.ts |  1 -
 3 files changed, 13 insertions(+), 14 deletions(-)

diff --git a/cista/watching.py b/cista/watching.py
index 49c4f29..ab62ab6 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -1,7 +1,6 @@
 import asyncio
 import shutil
 import stat
-import sys
 import threading
 import time
 from os import stat_result
@@ -190,10 +189,10 @@ def watcher_thread_poll(loop):
 
     while not quit:
         rootpath = config.config.path
-        old = state.root
         new = walk()
-        if old != new:
-            with state.lock:
+        with state.lock:
+            old = state.root
+            if old != new:
                 state.root = new
                 broadcast(format_update(old, new), loop)
 
@@ -333,8 +332,9 @@ async def abroadcast(msg):
 
 async def start(app, loop):
     config.load_config()
+    use_inotify = False  # sys.platform == "linux"
     app.ctx.watcher = threading.Thread(
-        target=watcher_thread if sys.platform == "linux" else watcher_thread_poll,
+        target=watcher_thread if use_inotify else watcher_thread_poll,
         args=[loop],
     )
     app.ctx.watcher.start()
diff --git a/frontend/src/repositories/WS.ts b/frontend/src/repositories/WS.ts
index 0570921..a2476ce 100644
--- a/frontend/src/repositories/WS.ts
+++ b/frontend/src/repositories/WS.ts
@@ -126,16 +126,16 @@ function handleUpdateMessage(updateData: { update: UpdateEntry[] }) {
   let oidx = 0
 
   for (const [action, arg] of update) {
-      if (action === 'k') {
-          newtree.push(...tree.slice(oidx, oidx + arg))
-          oidx += arg
-      }
-      else if (action === 'd') oidx += arg
-      else if (action === 'i') newtree.push(...arg)
-      else console.log("Unknown update action", action, arg)
+    if (action === 'k') {
+      newtree.push(...tree.slice(oidx, oidx + arg))
+      oidx += arg
+    }
+    else if (action === 'd') oidx += arg
+    else if (action === 'i') newtree.push(...arg)
+    else console.log("Unknown update action", action, arg)
   }
   if (oidx != tree.length)
-    throw Error(`Tree update out of sync, number of entries mismatch: got ${oidx}, expected ${tree.length}`)
+    throw Error(`Tree update out of sync, number of entries mismatch: got ${oidx}, expected ${tree.length}, new tree ${newtree.length}`)
   store.updateRoot(newtree)
   tree = newtree
   saveSession()
diff --git a/frontend/src/stores/documents.ts b/frontend/src/stores/documents.ts
index 0d40d75..6004d19 100644
--- a/frontend/src/stores/documents.ts
+++ b/frontend/src/stores/documents.ts
@@ -4,7 +4,6 @@ import { defineStore } from 'pinia'
 import { collator } from '@/utils'
 import { logoutUser } from '@/repositories/User'
 import { watchConnect } from '@/repositories/WS'
-import { format } from 'path'
 
 type FileData = { id: string; mtime: number; size: number; dir: DirectoryData }
 type DirectoryData = {
-- 
2.45.2


From 12c954394aa245d0a139ac75cb583203eb912e00 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 21:10:20 +0000
Subject: [PATCH 14/19] Added tests for backend watching tree diff, fixed bugs.

---
 cista/protocol.py      |  7 ++++
 cista/watching.py      |  4 +--
 tests/test_watching.py | 77 ++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 85 insertions(+), 3 deletions(-)
 create mode 100644 tests/test_watching.py

diff --git a/cista/protocol.py b/cista/protocol.py
index 86617f6..ff76abe 100644
--- a/cista/protocol.py
+++ b/cista/protocol.py
@@ -120,6 +120,9 @@ class FileEntry(msgspec.Struct, array_like=True):
     size: int
     isfile: int
 
+    def __repr__(self):
+        return self.key or "FileEntry()"
+
 
 class Update(msgspec.Struct, array_like=True):
     ...
@@ -137,6 +140,10 @@ class UpdIns(Update, tag="i"):
     items: list[FileEntry]
 
 
+class UpdateMessage(msgspec.Struct):
+    update: list[UpdKeep | UpdDel | UpdIns]
+
+
 class Space(msgspec.Struct):
     disk: int
     free: int
diff --git a/cista/watching.py b/cista/watching.py
index ab62ab6..b8d4ae8 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -282,13 +282,11 @@ def format_update(old, new):
 
         del_count = 0
         rest = new[nidx:]
-        while old[oidx] not in rest:
+        while oidx < len(old) and old[oidx] not in rest:
             del_count += 1
             oidx += 1
-
         if del_count:
             update.append(UpdDel(del_count))
-            oidx += 1
             continue
 
         insert_items = []
diff --git a/tests/test_watching.py b/tests/test_watching.py
new file mode 100644
index 0000000..8e65faf
--- /dev/null
+++ b/tests/test_watching.py
@@ -0,0 +1,77 @@
+import msgspec
+
+from cista.protocol import FileEntry, UpdateMessage, UpdDel, UpdIns, UpdKeep
+from cista.watching import format_update
+
+
+def decode(data: str):
+    return msgspec.json.decode(data, type=UpdateMessage).update
+
+
+# Helper function to create a list of FileEntry objects
+def f(count, start=0):
+    return [FileEntry(i, str(i), str(i), 0, 0, 0) for i in range(start, start + count)]
+
+
+def test_identical_lists():
+    old_list = f(3)
+    new_list = old_list.copy()
+    expected = [UpdKeep(3)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_completely_different_lists():
+    old_list = f(3)
+    new_list = f(3, 3)  # Different entries
+    expected = [UpdDel(3), UpdIns(new_list)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_insertions():
+    old_list = f(3)
+    new_list = old_list[:2] + f(1, 10) + old_list[2:]
+    expected = [UpdKeep(2), UpdIns(f(1, 10)), UpdKeep(1)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_deletions():
+    old_list = f(3)
+    new_list = [old_list[0], old_list[2]]
+    expected = [UpdKeep(1), UpdDel(1), UpdKeep(1)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_mixed_operations():
+    old_list = f(4)
+    new_list = [old_list[0], old_list[2], *f(1, 10)]
+    expected = [UpdKeep(1), UpdDel(1), UpdKeep(1), UpdDel(1), UpdIns(f(1, 10))]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_empty_old_list():
+    old_list = []
+    new_list = f(3)
+    expected = [UpdIns(new_list)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_empty_new_list():
+    old_list = f(3)
+    new_list = []
+    expected = [UpdDel(3)]
+    assert decode(format_update(old_list, new_list)) == expected
+
+
+def test_longer_lists():
+    old_list = f(6)
+    new_list = f(1, 6) + old_list[1:3] + old_list[4:5] + f(2, 7)
+    expected = [
+        UpdDel(1),
+        UpdIns(f(1, 6)),
+        UpdKeep(2),
+        UpdDel(1),
+        UpdKeep(1),
+        UpdDel(1),
+        UpdIns(f(2, 7)),
+    ]
+    assert decode(format_update(old_list, new_list)) == expected
-- 
2.45.2


From 97c694a6548ab808108f47f77bfc0c666d86c383 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 21:15:35 +0000
Subject: [PATCH 15/19] Correct locking on inotify watching, always use
 updates.

---
 cista/watching.py | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/cista/watching.py b/cista/watching.py
index b8d4ae8..d0a4988 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -1,6 +1,7 @@
 import asyncio
 import shutil
 import stat
+import sys
 import threading
 import time
 from os import stat_result
@@ -147,11 +148,12 @@ def watcher_thread(loop):
         rootpath = config.config.path
         i = inotify.adapters.InotifyTree(rootpath.as_posix())
         # Initialize the tree from filesystem
-        old, new = state.root, walk()
-        if old != new:
-            with state.lock:
+        new = walk()
+        with state.lock:
+            old = state.root
+            if old != new:
                 state.root = new
-                broadcast(format_root(new), loop)
+                broadcast(format_update(old, new), loop)
 
         # The watching is not entirely reliable, so do a full refresh every minute
         refreshdl = time.monotonic() + 60.0
@@ -330,7 +332,7 @@ async def abroadcast(msg):
 
 async def start(app, loop):
     config.load_config()
-    use_inotify = False  # sys.platform == "linux"
+    use_inotify = sys.platform == "linux"
     app.ctx.watcher = threading.Thread(
         target=watcher_thread if use_inotify else watcher_thread_poll,
         args=[loop],
-- 
2.45.2


From e206a1a3592013f7844849360a20a59fc3bc7166 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 22:32:10 +0000
Subject: [PATCH 16/19] Added watch slicing tests, rewritten slice function.

---
 cista/watching.py      | 61 +++++++++++++++++++++++-------------------
 tests/test_watching.py | 61 +++++++++++++++++++++++++++++++++++++++++-
 2 files changed, 93 insertions(+), 29 deletions(-)

diff --git a/cista/watching.py b/cista/watching.py
index d0a4988..caaf97f 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -50,37 +50,42 @@ class State:
         begin, end = 0, len(self._listing)
         level = 0
         isfile = 0
-        while level < len(relpath.parts):
-            # Enter a subdirectory
+
+        # Special case for root
+        if not relpath.parts:
+            return slice(begin, end)
+
+        begin += 1
+        for part in relpath.parts:
             level += 1
-            begin += 1
-            if level == len(relpath.parts):
-                isfile = relfile
-            name = relpath.parts[level - 1]
-            namesort = sortkey(name)
-            r = self._listing[begin]
-            assert r.level == level
-            # Iterate over items at this level
-            while (
-                begin < end
-                and r.name != name
-                and r.isfile <= isfile
-                and sortkey(r.name) < namesort
-            ):
-                # Skip contents
+            found = False
+
+            while begin < end:
+                entry = self._listing[begin]
+
+                if entry.level < level:
+                    break
+
+                if entry.level == level:
+                    if entry.name == part:
+                        found = True
+                        if level == len(relpath.parts):
+                            isfile = relfile
+                        else:
+                            begin += 1
+                        break
+                    cmp = entry.isfile - isfile or sortkey(entry.name) > sortkey(part)
+                    if cmp > 0:
+                        break
+
                 begin += 1
-                while begin < end and self._listing[begin].level > level:
-                    begin += 1
-                # Not found?
-                if begin == end or self._listing[begin].level < level:
-                    return slice(begin, begin)
-                r = self._listing[begin]
-            # Not found?
-            if begin == end or r.name != name:
+
+            if not found:
                 return slice(begin, begin)
-        # Found an item, now find its end
-        for end in range(begin + 1, len(self._listing)):
-            if self._listing[end].level <= level:
+
+        # Found the starting point, now find the end of the slice
+        for end in range(begin + 1, len(self._listing) + 1):
+            if end == len(self._listing) or self._listing[end].level <= level:
                 break
         return slice(begin, end)
 
diff --git a/tests/test_watching.py b/tests/test_watching.py
index 8e65faf..81301a7 100644
--- a/tests/test_watching.py
+++ b/tests/test_watching.py
@@ -1,7 +1,10 @@
+from pathlib import PurePosixPath
+
 import msgspec
+import pytest
 
 from cista.protocol import FileEntry, UpdateMessage, UpdDel, UpdIns, UpdKeep
-from cista.watching import format_update
+from cista.watching import State, format_update
 
 
 def decode(data: str):
@@ -75,3 +78,59 @@ def test_longer_lists():
         UpdIns(f(2, 7)),
     ]
     assert decode(format_update(old_list, new_list)) == expected
+
+
+def sortkey(name):
+    # Define the sorting key for names here
+    return name.lower()
+
+
+@pytest.fixture()
+def state():
+    entries = [
+        FileEntry(0, "", "root", 0, 0, 0),
+        FileEntry(1, "bar", "bar", 0, 0, 0),
+        FileEntry(2, "baz", "bar/baz", 0, 0, 0),
+        FileEntry(1, "foo", "foo", 0, 0, 0),
+        FileEntry(1, "xxx", "xxx", 0, 0, 0),
+        FileEntry(2, "yyy", "xxx/yyy", 0, 0, 1),
+    ]
+    s = State()
+    s._listing = entries
+    return s
+
+
+def test_existing_directory(state):
+    path = PurePosixPath("bar")
+    expected_slice = slice(1, 3)  # Includes 'bar' and 'baz'
+    assert state._slice(path) == expected_slice
+
+
+def test_existing_file(state):
+    path = PurePosixPath("xxx/yyy")
+    expected_slice = slice(5, 6)  # Only includes 'yyy'
+    assert state._slice(path) == expected_slice
+
+
+def test_nonexistent_directory(state):
+    path = PurePosixPath("zzz")
+    expected_slice = slice(6, 6)  # 'zzz' would be inserted at end
+    assert state._slice(path) == expected_slice
+
+
+def test_nonexistent_file(state):
+    path = (PurePosixPath("bar/mmm"), 1)
+    expected_slice = slice(3, 3)  # A file would be inserted after 'baz' under 'bar'
+    assert state._slice(path) == expected_slice
+
+
+def test_root_directory(state):
+    path = PurePosixPath()
+    expected_slice = slice(0, 6)  # Entire tree
+    assert state._slice(path) == expected_slice
+
+
+def test_directory_with_subdirs_and_files(state):
+    path = PurePosixPath("xxx")
+    expected_slice = slice(4, 6)  # Includes 'xxx' and 'yyy'
+    assert state._slice(path) == expected_slice
-- 
2.45.2


From 5bdeb180b5b145ab38ff0f7a7cd4781d22f0824b Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 22:38:27 +0000
Subject: [PATCH 17/19] Inotify is still missing some changes, prefer polling
 for now.

---
 cista/watching.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cista/watching.py b/cista/watching.py
index caaf97f..aa50005 100644
--- a/cista/watching.py
+++ b/cista/watching.py
@@ -337,7 +337,7 @@ async def abroadcast(msg):
 
 async def start(app, loop):
     config.load_config()
-    use_inotify = sys.platform == "linux"
+    use_inotify = False and sys.platform == "linux"
     app.ctx.watcher = threading.Thread(
         target=watcher_thread if use_inotify else watcher_thread_poll,
         args=[loop],
-- 
2.45.2


From c2b9ef6c2f33b3f4f98845a8c6374dda12c1c8e4 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 22:58:56 +0000
Subject: [PATCH 18/19] Frontend typing fixes, removing dead code.

---
 frontend/src/components/FileViewer.vue        | 52 -------------------
 frontend/src/components/HeaderMain.vue        | 12 ++---
 frontend/src/components/HeaderSelected.vue    |  2 +-
 .../src/components/NotificationLoading.vue    | 27 ----------
 frontend/src/components/UploadButton.vue      |  7 +--
 frontend/src/repositories/WS.ts               |  2 +-
 frontend/src/stores/documents.ts              |  5 +-
 7 files changed, 13 insertions(+), 94 deletions(-)
 delete mode 100644 frontend/src/components/FileViewer.vue
 delete mode 100644 frontend/src/components/NotificationLoading.vue

diff --git a/frontend/src/components/FileViewer.vue b/frontend/src/components/FileViewer.vue
deleted file mode 100644
index 4e45e02..0000000
--- a/frontend/src/components/FileViewer.vue
+++ /dev/null
@@ -1,52 +0,0 @@
-<template>
-  <object
-    v-if="props.type === 'pdf'"
-    :data="dataURL"
-    type="application/pdf"
-    width="100%"
-    height="100%"
-  ></object>
-  <a-image
-    v-else-if="props.type === 'image'"
-    width="50%"
-    :src="dataURL"
-    @click="() => setVisible(true)"
-    :previewMask="false"
-    :preview="{
-      visibleImg,
-      onVisibleChange: setVisible
-    }"
-  />
-  <!-- Unknown case -->
-  <h1 v-else>Unsupported file type</h1>
-</template>
-
-<script setup lang="ts">
-import { watchEffect, ref } from 'vue'
-import Router from '@/router/index'
-import { url_document_get } from '@/repositories/Document'
-
-const dataURL = ref('')
-watchEffect(() => {
-  dataURL.value = new URL(
-    url_document_get + Router.currentRoute.value.path,
-    location.origin
-  ).toString()
-})
-const emit = defineEmits({
-  visibleImg(value: boolean) {
-    return value
-  }
-})
-
-function setVisible(value: boolean) {
-  emit('visibleImg', value)
-}
-
-const props = defineProps<{
-  type?: string
-  visibleImg: boolean
-}>()
-</script>
-
-<style></style>
diff --git a/frontend/src/components/HeaderMain.vue b/frontend/src/components/HeaderMain.vue
index 58c6e53..f8206c1 100644
--- a/frontend/src/components/HeaderMain.vue
+++ b/frontend/src/components/HeaderMain.vue
@@ -9,7 +9,7 @@
       <SvgButton
         name="create-folder"
         data-tooltip="New folder"
-        @click="() => documentStore.fileExplorer.newFolder()"
+        @click="() => documentStore.fileExplorer!.newFolder()"
       />
       <slot></slot>
       <div class="spacer smallgap"></div>
@@ -42,15 +42,15 @@ const showSearchInput = ref<boolean>(false)
 const search = ref<HTMLInputElement | null>()
 const searchButton = ref<HTMLButtonElement | null>()
 
-const closeSearch = ev => {
+const closeSearch = (ev: Event) => {
   if (!showSearchInput.value) return  // Already closing
   showSearchInput.value = false
   const breadcrumb = document.querySelector('.breadcrumb') as HTMLElement
   breadcrumb.focus()
   updateSearch(ev)
 }
-const updateSearch = ev => {
-  const q = ev.target.value
+const updateSearch = (ev: Event) => {
+  const q = (ev.target as HTMLInputElement).value
   let p = props.path.join('/')
   p = p ? `/${p}` : ''
   const url = q ? `${p}//${q}` : (p || '/')
@@ -58,9 +58,9 @@ const updateSearch = ev => {
   if (!props.query && q) router.push(url)
   else router.replace(url)
 }
-const toggleSearchInput = () => {
+const toggleSearchInput = (ev: Event) => {
   showSearchInput.value = !showSearchInput.value
-  if (!showSearchInput.value) return closeSearch()
+  if (!showSearchInput.value) return closeSearch(ev)
   nextTick(() => {
     const input = search.value
     if (input) input.focus()
diff --git a/frontend/src/components/HeaderSelected.vue b/frontend/src/components/HeaderSelected.vue
index cdfd0d7..3cf27a1 100644
--- a/frontend/src/components/HeaderSelected.vue
+++ b/frontend/src/components/HeaderSelected.vue
@@ -34,7 +34,7 @@ const op = (op: string, dst?: string) => {
   // @ts-ignore
   if (dst !== undefined) msg.dst = dst
   const control = connect(controlUrl, {
-    message(ev: WebSocmetMessageEvent) {
+    message(ev: MessageEvent) {
       const res = JSON.parse(ev.data)
       if ('error' in res) {
         console.error('Control socket error', msg, res.error)
diff --git a/frontend/src/components/NotificationLoading.vue b/frontend/src/components/NotificationLoading.vue
deleted file mode 100644
index 81e9cde..0000000
--- a/frontend/src/components/NotificationLoading.vue
+++ /dev/null
@@ -1,27 +0,0 @@
-<template>
-  <template v-for="upload in documentStore.uploadingDocuments" :key="upload.key">
-    <span>{{ upload.name }}</span>
-    <div class="progress-container">
-      <a-progress :percent="upload.progress" />
-      <CloseCircleOutlined class="close-button" @click="dismissUpload(upload.key)" />
-    </div>
-  </template>
-</template>
-<script setup lang="ts">
-import { useDocumentStore } from '@/stores/documents'
-const documentStore = useDocumentStore()
-
-function dismissUpload(key: number) {
-  documentStore.deleteUploadingDocument(key)
-}
-</script>
-
-<style scoped>
-.progress-container {
-  display: flex;
-  align-items: center;
-}
-.close-button:hover {
-  color: #b81414;
-}
-</style>
diff --git a/frontend/src/components/UploadButton.vue b/frontend/src/components/UploadButton.vue
index b2b69d9..91d7521 100644
--- a/frontend/src/components/UploadButton.vue
+++ b/frontend/src/components/UploadButton.vue
@@ -32,7 +32,7 @@ function uploadHandler(event: Event) {
   if (!infiles.length) return
   infiles.sort((a, b) => collator.compare(a.cloudName, b.cloudName))
   // @ts-ignore
-  upqueue = upqueue.concat(infiles)
+  upqueue = [...upqueue, ...infiles]
   statsAdd(infiles)
   startWorker()
 }
@@ -49,13 +49,14 @@ const uprogress_init = {
   tlast: 0,
   statbytes: 0,
   statdur: 0,
-  files: [],
+  files: [] as File[],
   filestart: 0,
   fileidx: 0,
   filecount: 0,
   filename: '',
   filesize: 0,
   filepos: 0,
+  status: 'idle',
 }
 const uprogress = reactive({...uprogress_init})
 const percent = computed(() => uprogress.uploaded / uprogress.total * 100)
@@ -109,7 +110,7 @@ const statsAdd = (f: Array<File>) => {
   if (uprogress.files.length === 0) statReset()
   uprogress.total += f.reduce((a, b) => a + b.size, 0)
   uprogress.filecount += f.length
-  uprogress.files = uprogress.files.concat(f)
+  uprogress.files = [...uprogress.files, ...f]
   statNextFile()
 }
 let upqueue = [] as File[]
diff --git a/frontend/src/repositories/WS.ts b/frontend/src/repositories/WS.ts
index a2476ce..0e582dc 100644
--- a/frontend/src/repositories/WS.ts
+++ b/frontend/src/repositories/WS.ts
@@ -109,7 +109,7 @@ const handleWatchMessage = (event: MessageEvent) => {
   }
 }
 
-function handleRootMessage({ root }: { root: DirEntry }) {
+function handleRootMessage({ root }: { root: FileEntry[] }) {
   const store = useDocumentStore()
   console.log('Watch root', root)
   store.updateRoot(root)
diff --git a/frontend/src/stores/documents.ts b/frontend/src/stores/documents.ts
index 6004d19..a99cbfb 100644
--- a/frontend/src/stores/documents.ts
+++ b/frontend/src/stores/documents.ts
@@ -21,9 +21,7 @@ export const useDocumentStore = defineStore({
   state: () => ({
     document: [] as Document[],
     selected: new Set<FUID>(),
-    uploadingDocuments: [],
-    uploadCount: 0 as number,
-    fileExplorer: null,
+    fileExplorer: null as any,
     error: '' as string,
     connected: false,
     server: {} as Record<string, any>,
@@ -53,7 +51,6 @@ export const useDocumentStore = defineStore({
         })
         loc.push(name)
       }
-      console.log("Documents", docs)
       this.document = docs as Document[]
     },
     updateModified() {
-- 
2.45.2


From 445ce075d493b4fc1617dc2bd94b0a40e7602697 Mon Sep 17 00:00:00 2001
From: Leo Vasanko <leo@git>
Date: Sun, 12 Nov 2023 23:15:11 +0000
Subject: [PATCH 19/19] Remaining typing fixes, compiles cleanly.

---
 frontend/src/components/UploadButton.vue | 51 ++++++++++++++----------
 1 file changed, 31 insertions(+), 20 deletions(-)

diff --git a/frontend/src/components/UploadButton.vue b/frontend/src/components/UploadButton.vue
index 91d7521..d3ca167 100644
--- a/frontend/src/components/UploadButton.vue
+++ b/frontend/src/components/UploadButton.vue
@@ -11,29 +11,38 @@ const props = defineProps({
   path: Array<string>
 })
 
+type CloudFile = {
+  file: File
+  cloudName: string
+  cloudPos: number
+}
 
 function uploadHandler(event: Event) {
   event.preventDefault()
   event.stopPropagation()
   // @ts-ignore
-  let infiles = Array.from(event.dataTransfer?.files || event.target.files) as File[]
+  const infiles = Array.from(event.dataTransfer?.files || event.target.files) as File[]
   if (!infiles.length) return
   const loc = props.path!.join('/')
-  for (const f of infiles) {
-    f.cloudName = loc + '/' + (f.webkitRelativePath || f.name)
-    f.cloudPos = 0
+  let files = []
+  for (const file of infiles) {
+    files.push({
+      file,
+      cloudName: loc + '/' + (file.webkitRelativePath || file.name),
+      cloudPos: 0,
+    })
   }
-  const dotfiles = infiles.filter(f => f.cloudName.includes('/.'))
+  const dotfiles = files.filter(f => f.cloudName.includes('/.'))
   if (dotfiles.length) {
     documentStore.error = "Won't upload dotfiles"
     console.log("Dotfiles omitted", dotfiles)
-    infiles = infiles.filter(f => !f.cloudName.includes('/.'))
+    files = files.filter(f => !f.cloudName.includes('/.'))
   }
-  if (!infiles.length) return
-  infiles.sort((a, b) => collator.compare(a.cloudName, b.cloudName))
+  if (!files.length) return
+  files.sort((a, b) => collator.compare(a.cloudName, b.cloudName))
   // @ts-ignore
-  upqueue = [...upqueue, ...infiles]
-  statsAdd(infiles)
+  upqueue = [...upqueue, ...files]
+  statsAdd(files)
   startWorker()
 }
 
@@ -49,7 +58,7 @@ const uprogress_init = {
   tlast: 0,
   statbytes: 0,
   statdur: 0,
-  files: [] as File[],
+  files: [] as CloudFile[],
   filestart: 0,
   fileidx: 0,
   filecount: 0,
@@ -79,7 +88,7 @@ setInterval(() => {
     uprogress.statdur *= .9
   }
 }, 100)
-const statUpdate = ({name, size, start, end}) => {
+const statUpdate = ({name, size, start, end}: {name: string, size: number, start: number, end: number}) => {
   if (name !== uprogress.filename) return  // If stats have been reset
   const now = Date.now()
   uprogress.uploaded = uprogress.filestart + end
@@ -98,7 +107,7 @@ const statNextFile = () => {
   const f = uprogress.files.shift()
   if (!f) return statReset()
   uprogress.filepos = 0
-  uprogress.filesize = f.size
+  uprogress.filesize = f.file.size
   uprogress.filename = f.cloudName
 }
 const statReset = () => {
@@ -106,14 +115,14 @@ const statReset = () => {
   uprogress.t0 = Date.now()
   uprogress.tlast = uprogress.t0 + 1
 }
-const statsAdd = (f: Array<File>) => {
+const statsAdd = (f: CloudFile[]) => {
   if (uprogress.files.length === 0) statReset()
-  uprogress.total += f.reduce((a, b) => a + b.size, 0)
+  uprogress.total += f.reduce((a, b) => a + b.file.size, 0)
   uprogress.filecount += f.length
   uprogress.files = [...uprogress.files, ...f]
   statNextFile()
 }
-let upqueue = [] as File[]
+let upqueue = [] as CloudFile[]
 
 // TODO: Rewrite as WebSocket class
 const WSCreate = async () => await new Promise<WebSocket>(resolve => {
@@ -156,17 +165,19 @@ const worker = async () => {
   const ws = await WSCreate()
   while (upqueue.length) {
     const f = upqueue[0]
-    if (f.cloudPos === f.size) {
+    if (f.cloudPos === f.file.size) {
       upqueue.shift()
       continue
     }
     const start = f.cloudPos
-    const end = Math.min(f.size, start + (1<<20))
-    const control = { name: f.cloudName, size: f.size, start, end }
-    const data = f.slice(start, end)
+    const end = Math.min(f.file.size, start + (1<<20))
+    const control = { name: f.cloudName, size: f.file.size, start, end }
+    const data = f.file.slice(start, end)
     f.cloudPos = end
     // Note: files may get modified during I/O
+    // @ts-ignore FIXME proper WebSocket class, avoid attaching functions to WebSocket object
     ws.sendMsg(control)
+    // @ts-ignore
     await ws.sendData(data)
   }
   if (upqueue.length) startWorker()
-- 
2.45.2