Compare commits
	
		
			19 Commits
		
	
	
		
			v0.5.0
			...
			e56cc47105
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | e56cc47105 | ||
|   | ebbd96bc94 | ||
|   | a9b6d04361 | ||
|   | 5808fe17ad | ||
|   | 671359e327 | ||
|   | ba9495eb65 | ||
|   | de482afd60 | ||
|   | a547052e29 | ||
|   | 07c2ff4c15 | ||
|   | e20b04189f | ||
|   | 8da141744e | ||
|   | 11887edde3 | ||
|   | 034c6fdea9 | ||
|   | c5083f0f2b | ||
|   | f8a9197474 | ||
|   | 5285cb2fb5 | ||
|   | b6b387d09b | ||
|   | 669762dfe7 | ||
|   | 51fd07d4fa | 
							
								
								
									
										20
									
								
								README.md
									
									
									
									
									
								
							
							
						
						
									
										20
									
								
								README.md
									
									
									
									
									
								
							| @@ -1,8 +1,8 @@ | ||||
| # Cista Web Storage | ||||
|  | ||||
| <img src="https://git.zi.fi/Vasanko/cista-storage/raw/branch/main/docs/cista.jpg" align=right width=250> | ||||
| <img src="https://git.zi.fi/Vasanko/cista-storage/raw/branch/main/docs/cista.webp" align=left width=250> | ||||
|  | ||||
| Cista takes its name from the ancient cistae, metal containers used by Greeks and Egyptians to safeguard valuable items. This modern application provides a browser interface for secure and accessible file storage, echoing the trust and reliability of its historical namesake. | ||||
| Cista takes its name from the ancient *cistae*, metal containers used by Greeks and Egyptians to safeguard valuable items. This modern application provides a browser interface for secure and accessible file storage, echoing the trust and reliability of its historical namesake. | ||||
|  | ||||
| This is a cutting-edge **file and document server** designed for speed, efficiency, and unparalleled ease of use. Experience **lightning-fast browsing**, thanks to the file list maintained directly in your browser and updated from server filesystem events, coupled with our highly optimized code. Fully **keyboard-navigable** and with a responsive layout, Cista flawlessly adapts to your devices, providing a seamless experience wherever you are. Our powerful **instant search** means you're always just a few keystrokes away from finding exactly what you need. Press **1/2/3** to switch ordering, navigate with all four arrow keys (+Shift to select). Or click your way around on **breadcrumbs that remember where you were**. | ||||
|  | ||||
| @@ -46,7 +46,9 @@ To use your own TLS certificates, place them in the config folder and run: | ||||
| cista -l cista.example.com | ||||
| ``` | ||||
|  | ||||
| Most admins instead find the [Caddy](https://caddyserver.com/) web server convenient for its auto TLS certificates and all. A proxy also allows running multiple web services or Cista instances on the same IP address. Caddy configuration **/etc/caddy/Caddyfile** is dead simple: | ||||
| Most admins instead find the [Caddy](https://caddyserver.com/) web server convenient for its auto TLS certificates and all. A proxy also allows running multiple web services or Cista instances on the same IP address but different (sub)domains. | ||||
|  | ||||
| `/etc/caddy/Caddyfile`: | ||||
|  | ||||
| ```Caddyfile | ||||
| cista.example.com { | ||||
| @@ -72,7 +74,7 @@ pip install -e '.[dev]' | ||||
| cista --dev -l :8000 /path/to/files | ||||
| ``` | ||||
|  | ||||
| We use `hatch shell` for installing on a virtual environment, to not disturb the rest of the system with our hacking. | ||||
| We use `hatch shell` for installing on a virtual environment, to avoid disturbing the rest of the system with our hacking. | ||||
|  | ||||
| Vue is used to build files in `cista/wwwroot`, included prebuilt in the Python package. Running `hatch build` builds the frontend and creates a NodeJS-independent Python package. | ||||
|  | ||||
| @@ -80,9 +82,9 @@ Vue is used to build files in `cista/wwwroot`, included prebuilt in the Python p | ||||
|  | ||||
| This setup allows easy addition of storages, each with its own domain, configuration, and files. | ||||
|  | ||||
| Assuming a restricted user account **storage** for serving files and that cista is installed system-wide or on this account (check with `sudo -u storage -s`). Alternatively, use `pipx run cista` or `hatch run cista` as the ExecStart command. | ||||
| Assuming a restricted user account `storage` for serving files and that cista is installed system-wide or on this account (check with `sudo -u storage -s`). Alternatively, use `pipx run cista` or `hatch run cista` as the ExecStart command. | ||||
|  | ||||
| Create **/etc/systemd/system/cista@.service**: | ||||
| Create `/etc/systemd/system/cista@.service`: | ||||
|  | ||||
| ```ini | ||||
| [Unit] | ||||
| @@ -90,7 +92,7 @@ Description=Cista storage %i | ||||
|  | ||||
| [Service] | ||||
| User=storage | ||||
| ExecStart=cista -c /srv/cista/%i -l /srv/cista/%i/socket /media/storage/@%i/ | ||||
| ExecStart=cista -c /srv/cista/%i -l /srv/cista/%i/socket /media/storage/%i | ||||
| Restart=always | ||||
|  | ||||
| [Install] | ||||
| @@ -105,9 +107,9 @@ systemctl enable --now cista@foo.example.com | ||||
| systemctl enable --now cista@bar.example.com | ||||
| ``` | ||||
|  | ||||
| Public exposure is easiest using the Caddy web server, but Nginx or others also work. Run the server with -l domain.example.com if you have TLS certificates in the config folder. | ||||
| Public exposure is easiest using the Caddy web server. | ||||
|  | ||||
| **/etc/caddy/Caddyfile**: | ||||
| `/etc/caddy/Caddyfile`: | ||||
|  | ||||
| ```Caddyfile | ||||
| foo.example.com, bar.example.com { | ||||
|   | ||||
							
								
								
									
										21
									
								
								cista/api.py
									
									
									
									
									
								
							
							
						
						
									
										21
									
								
								cista/api.py
									
									
									
									
									
								
							| @@ -111,13 +111,24 @@ async def watch(req, ws): | ||||
|     ) | ||||
|     uuid = token_bytes(16) | ||||
|     try: | ||||
|         with watching.state.lock: | ||||
|             q = watching.pubsub[uuid] = asyncio.Queue() | ||||
|             # Init with disk usage and full tree | ||||
|             await ws.send(watching.format_space(watching.state.space)) | ||||
|             await ws.send(watching.format_root(watching.state.root)) | ||||
|         q, space, root = await asyncio.get_event_loop().run_in_executor( | ||||
|             req.app.ctx.threadexec, subscribe, uuid, ws | ||||
|         ) | ||||
|         await ws.send(space) | ||||
|         await ws.send(root) | ||||
|         # Send updates | ||||
|         while True: | ||||
|             await ws.send(await q.get()) | ||||
|     finally: | ||||
|         del watching.pubsub[uuid] | ||||
|  | ||||
|  | ||||
| def subscribe(uuid, ws): | ||||
|     with watching.state.lock: | ||||
|         q = watching.pubsub[uuid] = asyncio.Queue() | ||||
|         # Init with disk usage and full tree | ||||
|         return ( | ||||
|             q, | ||||
|             watching.format_space(watching.state.space), | ||||
|             watching.format_root(watching.state.root), | ||||
|         ) | ||||
|   | ||||
							
								
								
									
										56
									
								
								cista/app.py
									
									
									
									
									
								
							
							
						
						
									
										56
									
								
								cista/app.py
									
									
									
									
									
								
							| @@ -1,6 +1,7 @@ | ||||
| import asyncio | ||||
| import datetime | ||||
| import mimetypes | ||||
| import threading | ||||
| from concurrent.futures import ThreadPoolExecutor | ||||
| from pathlib import Path, PurePath, PurePosixPath | ||||
| from stat import S_IFDIR, S_IFREG | ||||
| @@ -12,7 +13,7 @@ import sanic.helpers | ||||
| from blake3 import blake3 | ||||
| from sanic import Blueprint, Sanic, empty, raw | ||||
| from sanic.exceptions import Forbidden, NotFound | ||||
| from sanic.log import logging | ||||
| from sanic.log import logger | ||||
| from stream_zip import ZIP_AUTO, stream_zip | ||||
|  | ||||
| from cista import auth, config, session, watching | ||||
| @@ -31,14 +32,15 @@ app.exception(Exception)(handle_sanic_exception) | ||||
| @app.before_server_start | ||||
| async def main_start(app, loop): | ||||
|     config.load_config() | ||||
|     await watching.start(app, loop) | ||||
|     app.ctx.threadexec = ThreadPoolExecutor( | ||||
|         max_workers=8, thread_name_prefix="cista-ioworker" | ||||
|     ) | ||||
|     await watching.start(app, loop) | ||||
|  | ||||
|  | ||||
| @app.after_server_stop | ||||
| async def main_stop(app, loop): | ||||
|     quit.set() | ||||
|     await watching.stop(app, loop) | ||||
|     app.ctx.threadexec.shutdown() | ||||
|  | ||||
| @@ -122,7 +124,7 @@ def _load_wwwroot(www): | ||||
|     if not wwwnew: | ||||
|         msg = f"Web frontend missing from {base}\n  Did you forget: hatch build\n" | ||||
|         if not www: | ||||
|             logging.warning(msg) | ||||
|             logger.warning(msg) | ||||
|         if not app.debug: | ||||
|             msg = "Web frontend missing. Cista installation is broken.\n" | ||||
|         wwwnew[""] = ( | ||||
| @@ -141,7 +143,7 @@ def _load_wwwroot(www): | ||||
| async def start(app): | ||||
|     await load_wwwroot(app) | ||||
|     if app.debug: | ||||
|         app.add_task(refresh_wwwroot()) | ||||
|         app.add_task(refresh_wwwroot(), name="refresh_wwwroot") | ||||
|  | ||||
|  | ||||
| async def load_wwwroot(app): | ||||
| @@ -151,27 +153,31 @@ async def load_wwwroot(app): | ||||
|     ) | ||||
|  | ||||
|  | ||||
| quit = threading.Event() | ||||
|  | ||||
|  | ||||
| async def refresh_wwwroot(): | ||||
|     while True: | ||||
|         await asyncio.sleep(0.5) | ||||
|         try: | ||||
|             wwwold = www | ||||
|             await load_wwwroot(app) | ||||
|             changes = "" | ||||
|             for name in sorted(www): | ||||
|                 attr = www[name] | ||||
|                 if wwwold.get(name) == attr: | ||||
|                     continue | ||||
|                 headers = attr[2] | ||||
|                 changes += f"{headers['last-modified']} {headers['etag']} /{name}\n" | ||||
|             for name in sorted(set(wwwold) - set(www)): | ||||
|                 changes += f"Deleted /{name}\n" | ||||
|             if changes: | ||||
|                 print(f"Updated wwwroot:\n{changes}", end="", flush=True) | ||||
|         except Exception as e: | ||||
|             print("Error loading wwwroot", e) | ||||
|         if not app.debug: | ||||
|             return | ||||
|     try: | ||||
|         while not quit.is_set(): | ||||
|             try: | ||||
|                 wwwold = www | ||||
|                 await load_wwwroot(app) | ||||
|                 changes = "" | ||||
|                 for name in sorted(www): | ||||
|                     attr = www[name] | ||||
|                     if wwwold.get(name) == attr: | ||||
|                         continue | ||||
|                     headers = attr[2] | ||||
|                     changes += f"{headers['last-modified']} {headers['etag']} /{name}\n" | ||||
|                 for name in sorted(set(wwwold) - set(www)): | ||||
|                     changes += f"Deleted /{name}\n" | ||||
|                 if changes: | ||||
|                     print(f"Updated wwwroot:\n{changes}", end="", flush=True) | ||||
|             except Exception as e: | ||||
|                 print(f"Error loading wwwroot: {e!r}") | ||||
|             await asyncio.sleep(0.5) | ||||
|     except asyncio.CancelledError: | ||||
|         pass | ||||
|  | ||||
|  | ||||
| @app.route("/<path:path>", methods=["GET", "HEAD"]) | ||||
| @@ -251,7 +257,7 @@ async def zip_download(req, keys, zipfile, ext): | ||||
|             for chunk in stream_zip(local_files(files)): | ||||
|                 asyncio.run_coroutine_threadsafe(queue.put(chunk), loop).result() | ||||
|         except Exception: | ||||
|             logging.exception("Error streaming ZIP") | ||||
|             logger.exception("Error streaming ZIP") | ||||
|             raise | ||||
|         finally: | ||||
|             asyncio.run_coroutine_threadsafe(queue.put(None), loop) | ||||
|   | ||||
| @@ -71,7 +71,7 @@ def verify(request, *, privileged=False): | ||||
|             raise Forbidden("Access Forbidden: Only for privileged users", quiet=True) | ||||
|     elif config.config.public or request.ctx.user: | ||||
|         return | ||||
|     raise Unauthorized("Login required", "cookie", quiet=True) | ||||
|     raise Unauthorized(f"Login required for {request.path}", "cookie", quiet=True) | ||||
|  | ||||
|  | ||||
| bp = Blueprint("auth") | ||||
|   | ||||
| @@ -51,7 +51,7 @@ def parse_listen(listen): | ||||
|             raise ValueError( | ||||
|                 f"Directory for unix socket does not exist: {unix.parent}/", | ||||
|             ) | ||||
|         return "http://localhost", {"unix": unix} | ||||
|         return "http://localhost", {"unix": unix.as_posix()} | ||||
|     if re.fullmatch(r"(\w+(-\w+)*\.)+\w{2,}", listen, re.UNICODE): | ||||
|         return f"https://{listen}", {"host": listen, "port": 443, "ssl": True} | ||||
|     try: | ||||
|   | ||||
| @@ -21,7 +21,6 @@ def jres(data, **kwargs): | ||||
|  | ||||
|  | ||||
| async def handle_sanic_exception(request, e): | ||||
|     logger.exception(e) | ||||
|     context, code = {}, 500 | ||||
|     message = str(e) | ||||
|     if isinstance(e, SanicException): | ||||
| @@ -42,7 +41,7 @@ async def handle_sanic_exception(request, e): | ||||
|         res.cookies.add_cookie("message", message, max_age=5) | ||||
|         return res | ||||
|     # Otherwise use Sanic's default error page | ||||
|     return errorpages.HTMLRenderer(request, e, debug=request.app.debug).full() | ||||
|     return errorpages.HTMLRenderer(request, e, debug=request.app.debug).render() | ||||
|  | ||||
|  | ||||
| def websocket_wrapper(handler): | ||||
| @@ -54,13 +53,14 @@ def websocket_wrapper(handler): | ||||
|             auth.verify(request) | ||||
|             await handler(request, ws, *args, **kwargs) | ||||
|         except Exception as e: | ||||
|             logger.exception(e) | ||||
|             context, code, message = {}, 500, str(e) or "Internal Server Error" | ||||
|             if isinstance(e, SanicException): | ||||
|                 context = e.context or {} | ||||
|                 code = e.status_code | ||||
|             message = f"⚠️ {message}" if code < 500 else f"🛑 {message}" | ||||
|             await asend(ws, ErrorMsg({"code": code, "message": message, **context})) | ||||
|             if not getattr(e, "quiet", False): | ||||
|                 logger.exception(f"{code} {e!r}") | ||||
|             raise | ||||
|  | ||||
|     return wrapper | ||||
|   | ||||
| @@ -1,15 +1,16 @@ | ||||
| import asyncio | ||||
| import shutil | ||||
| import stat | ||||
| import sys | ||||
| import threading | ||||
| import time | ||||
| from contextlib import suppress | ||||
| from os import stat_result | ||||
| from pathlib import Path, PurePosixPath | ||||
| from stat import S_ISDIR, S_ISREG | ||||
|  | ||||
| import msgspec | ||||
| from natsort import humansorted, natsort_keygen, ns | ||||
| from sanic.log import logging | ||||
| from sanic.log import logger | ||||
|  | ||||
| from cista import config | ||||
| from cista.fileio import fuid | ||||
| @@ -113,136 +114,70 @@ class State: | ||||
|  | ||||
| state = State() | ||||
| rootpath: Path = None  # type: ignore | ||||
| quit = False | ||||
| modified_flags = ( | ||||
|     "IN_CREATE", | ||||
|     "IN_DELETE", | ||||
|     "IN_DELETE_SELF", | ||||
|     "IN_MODIFY", | ||||
|     "IN_MOVE_SELF", | ||||
|     "IN_MOVED_FROM", | ||||
|     "IN_MOVED_TO", | ||||
| ) | ||||
| quit = threading.Event() | ||||
|  | ||||
| ## Filesystem scanning | ||||
|  | ||||
|  | ||||
| def watcher_thread(loop): | ||||
|     global rootpath | ||||
|     import inotify.adapters | ||||
|  | ||||
|     while not quit: | ||||
|         rootpath = config.config.path | ||||
|         i = inotify.adapters.InotifyTree(rootpath.as_posix()) | ||||
|         # Initialize the tree from filesystem | ||||
|         new = walk() | ||||
|         with state.lock: | ||||
|             old = state.root | ||||
|             if old != new: | ||||
|                 state.root = new | ||||
|                 broadcast(format_update(old, new), loop) | ||||
|  | ||||
|         # The watching is not entirely reliable, so do a full refresh every 30 seconds | ||||
|         refreshdl = time.monotonic() + 30.0 | ||||
|  | ||||
|         for event in i.event_gen(): | ||||
|             if quit: | ||||
|                 return | ||||
|             # Disk usage update | ||||
|             du = shutil.disk_usage(rootpath) | ||||
|             space = Space(*du, storage=state.root[0].size) | ||||
|             if space != state.space: | ||||
|                 state.space = space | ||||
|                 broadcast(format_space(space), loop) | ||||
|                 break | ||||
|             # Do a full refresh? | ||||
|             if time.monotonic() > refreshdl: | ||||
|                 break | ||||
|             if event is None: | ||||
|                 continue | ||||
|             _, flags, path, filename = event | ||||
|             if not any(f in modified_flags for f in flags): | ||||
|                 continue | ||||
|             # Update modified path | ||||
|             path = PurePosixPath(path) / filename | ||||
|             try: | ||||
|                 update(path.relative_to(rootpath), loop) | ||||
|             except Exception as e: | ||||
|                 print("Watching error", e, path, rootpath) | ||||
|                 raise | ||||
|         i = None  # Free the inotify object | ||||
|  | ||||
|  | ||||
| def watcher_thread_poll(loop): | ||||
|     global rootpath | ||||
|  | ||||
|     while not quit: | ||||
|         rootpath = config.config.path | ||||
|         new = walk() | ||||
|         with state.lock: | ||||
|             old = state.root | ||||
|             if old != new: | ||||
|                 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 | ||||
|             broadcast(format_space(space), loop) | ||||
|  | ||||
|         time.sleep(2.0) | ||||
|  | ||||
|  | ||||
| def walk(rel=PurePosixPath()) -> list[FileEntry]:  # noqa: B008 | ||||
|     path = rootpath / rel | ||||
|     try: | ||||
|         st = path.stat() | ||||
|     except OSError: | ||||
|         return [] | ||||
|     return _walk(rel, int(not stat.S_ISDIR(st.st_mode)), st) | ||||
|  | ||||
|  | ||||
| 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] | ||||
| def walk(rel: PurePosixPath, stat: stat_result | None = None) -> list[FileEntry]: | ||||
|     path = rootpath / rel | ||||
|     ret = [] | ||||
|     try: | ||||
|         st = stat or path.stat() | ||||
|         isfile = not S_ISDIR(st.st_mode) | ||||
|         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] | ||||
|         # Walk all entries of the directory | ||||
|         ret = [entry] | ||||
|         li = [] | ||||
|         for f in path.iterdir(): | ||||
|             if quit: | ||||
|             if quit.is_set(): | ||||
|                 raise SystemExit("quit") | ||||
|             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): | ||||
|             if quit: | ||||
|                 raise SystemExit("quit") | ||||
|             subtree = _walk(rel / name, isfile, s) | ||||
|             child = subtree[0] | ||||
|             with suppress(FileNotFoundError): | ||||
|                 s = f.lstat() | ||||
|                 isfile = S_ISREG(s.st_mode) | ||||
|                 isdir = S_ISDIR(s.st_mode) | ||||
|                 if not isfile and not isdir: | ||||
|                     continue | ||||
|                 li.append((int(isfile), f.name, s)) | ||||
|         # Build the tree as a list of FileEntries | ||||
|         for [_, name, s] in humansorted(li): | ||||
|             sub = walk(rel / name, stat=s) | ||||
|             ret.extend(sub) | ||||
|             child = sub[0] | ||||
|             entry.mtime = max(entry.mtime, child.mtime) | ||||
|             entry.size += child.size | ||||
|             ret.extend(subtree) | ||||
|     except FileNotFoundError: | ||||
|         pass  # Things may be rapidly in motion | ||||
|     except OSError as e: | ||||
|         print("OS error walking path", path, e) | ||||
|         if e.errno == 13:  # Permission denied | ||||
|             pass | ||||
|         logger.error(f"Watching {path=}: {e!r}") | ||||
|     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) | ||||
| def update_root(loop): | ||||
|     """Full filesystem scan""" | ||||
|     new = walk(PurePosixPath()) | ||||
|     with state.lock: | ||||
|         old = state.root | ||||
|         if old != new: | ||||
|             state.root = new | ||||
|             broadcast(format_update(old, new), loop) | ||||
|  | ||||
|  | ||||
| def update_path(relpath: PurePosixPath, loop): | ||||
|     """Called on FS updates, check the filesystem and broadcast any changes.""" | ||||
|     new = walk(relpath) | ||||
|     with state.lock: | ||||
|         old = state[relpath] | ||||
| @@ -256,6 +191,22 @@ def update(relpath: PurePosixPath, loop): | ||||
|         broadcast(format_update(old, state.root), loop) | ||||
|  | ||||
|  | ||||
| def update_space(loop): | ||||
|     """Called periodically to update the disk usage.""" | ||||
|     du = shutil.disk_usage(rootpath) | ||||
|     space = Space(*du, storage=state.root[0].size) | ||||
|     # Update only on difference above 1 MB | ||||
|     tol = 10**6 | ||||
|     old = msgspec.structs.astuple(state.space) | ||||
|     new = msgspec.structs.astuple(space) | ||||
|     if any(abs(o - n) > tol for o, n in zip(old, new, strict=True)): | ||||
|         state.space = space | ||||
|         broadcast(format_space(space), loop) | ||||
|  | ||||
|  | ||||
| ## Messaging | ||||
|  | ||||
|  | ||||
| def format_update(old, new): | ||||
|     # Make keep/del/insert diff until one of the lists ends | ||||
|     oidx, nidx = 0, 0 | ||||
| @@ -316,20 +267,77 @@ async def abroadcast(msg): | ||||
|             queue.put_nowait(msg) | ||||
|     except Exception: | ||||
|         # Log because asyncio would silently eat the error | ||||
|         logging.exception("Broadcast error") | ||||
|         logger.exception("Broadcast error") | ||||
|  | ||||
|  | ||||
| ## Watcher thread | ||||
|  | ||||
|  | ||||
| def watcher_inotify(loop): | ||||
|     """Inotify watcher thread (Linux only)""" | ||||
|     import inotify.adapters | ||||
|  | ||||
|     modified_flags = ( | ||||
|         "IN_CREATE", | ||||
|         "IN_DELETE", | ||||
|         "IN_DELETE_SELF", | ||||
|         "IN_MODIFY", | ||||
|         "IN_MOVE_SELF", | ||||
|         "IN_MOVED_FROM", | ||||
|         "IN_MOVED_TO", | ||||
|     ) | ||||
|     while not quit.is_set(): | ||||
|         i = inotify.adapters.InotifyTree(rootpath.as_posix()) | ||||
|         # Initialize the tree from filesystem | ||||
|         update_root(loop) | ||||
|         trefresh = time.monotonic() + 30.0 | ||||
|         tspace = time.monotonic() + 5.0 | ||||
|         # Watch for changes (frequent wakeups needed for quiting) | ||||
|         for event in i.event_gen(timeout_s=0.1): | ||||
|             if quit.is_set(): | ||||
|                 break | ||||
|             t = time.monotonic() | ||||
|             # The watching is not entirely reliable, so do a full refresh every 30 seconds | ||||
|             if t >= trefresh: | ||||
|                 break | ||||
|             # Disk usage update | ||||
|             if t >= tspace: | ||||
|                 tspace = time.monotonic() + 5.0 | ||||
|                 update_space(loop) | ||||
|             # Inotify event, update the tree | ||||
|             if event and any(f in modified_flags for f in event[1]): | ||||
|                 # Update modified path | ||||
|                 update_path(PurePosixPath(event[2]) / event[3], loop) | ||||
|  | ||||
|         del i  # Free the inotify object | ||||
|  | ||||
|  | ||||
| def watcher_poll(loop): | ||||
|     """Polling version of the watcher thread.""" | ||||
|     while not quit.is_set(): | ||||
|         t0 = time.perf_counter() | ||||
|         update_root(loop) | ||||
|         update_space(loop) | ||||
|         dur = time.perf_counter() - t0 | ||||
|         if dur > 1.0: | ||||
|             logger.debug(f"Reading the full file list took {dur:.1f}s") | ||||
|         quit.wait(0.1 + 8 * dur) | ||||
|  | ||||
|  | ||||
| async def start(app, loop): | ||||
|     global rootpath | ||||
|     config.load_config() | ||||
|     rootpath = config.config.path | ||||
|     use_inotify = sys.platform == "linux" | ||||
|     app.ctx.watcher = threading.Thread( | ||||
|         target=watcher_thread if use_inotify else watcher_thread_poll, | ||||
|         target=watcher_inotify if use_inotify else watcher_poll, | ||||
|         args=[loop], | ||||
|         # Descriptive name for system monitoring | ||||
|         name=f"cista-watcher {rootpath}", | ||||
|     ) | ||||
|     app.ctx.watcher.start() | ||||
|  | ||||
|  | ||||
| async def stop(app, loop): | ||||
|     global quit | ||||
|     quit = True | ||||
|     quit.set() | ||||
|     app.ctx.watcher.join() | ||||
|   | ||||
							
								
								
									
										
											BIN
										
									
								
								docs/cista.jpg
									
									
									
									
									
								
							
							
						
						
									
										
											BIN
										
									
								
								docs/cista.jpg
									
									
									
									
									
								
							
										
											Binary file not shown.
										
									
								
							| Before Width: | Height: | Size: 39 KiB | 
							
								
								
									
										
											BIN
										
									
								
								docs/cista.webp
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										
											BIN
										
									
								
								docs/cista.webp
									
									
									
									
									
										Normal file
									
								
							
										
											Binary file not shown.
										
									
								
							| After Width: | Height: | Size: 363 KiB | 
| @@ -1,6 +1,6 @@ | ||||
| # cista-front | ||||
| # Cista Vue Frontend | ||||
|  | ||||
| This template should help get you started developing with Vue 3 in Vite. | ||||
| The frontend is a Single-Page App implemented with Vue 3. Development uses the Vite server together with the main Python backend, but in production the latter also serves the prebuilt frontend files. | ||||
|  | ||||
| ## Recommended IDE Setup | ||||
|  | ||||
| @@ -17,24 +17,30 @@ If the standalone TypeScript plugin doesn't feel fast enough to you, Volar has a | ||||
|     2) Find `TypeScript and JavaScript Language Features`, right click and select `Disable (Workspace)` | ||||
| 2. Reload the VSCode window by running `Developer: Reload Window` from the command palette. | ||||
|  | ||||
| ## Customize configuration | ||||
| ## Hot-Reload for Development | ||||
|  | ||||
| See [Vite Configuration Reference](https://vitejs.dev/config/). | ||||
| ### Run the backend | ||||
|  | ||||
| ## Project Setup | ||||
|  | ||||
| ```sh | ||||
| npm install | ||||
| ```fish | ||||
| hatch shell | ||||
| cista --dev -l :8000 | ||||
| ``` | ||||
|  | ||||
| ### Compile and Hot-Reload for Development | ||||
| ### And the Vite server (in another terminal) | ||||
|  | ||||
| ```sh | ||||
| ```fish | ||||
| cd frontend | ||||
| npm install | ||||
| npm run dev | ||||
| ``` | ||||
| Browse to Vite, which will proxy API requests to port 8000. Both servers live reload changes. | ||||
|  | ||||
|  | ||||
| ### Type-Check, Compile and Minify for Production | ||||
|  | ||||
| ```sh | ||||
| This is also called by `hatch build` during Python packaging: | ||||
|  | ||||
| ```fish | ||||
| npm run build | ||||
| ``` | ||||
|  | ||||
|   | ||||
| @@ -21,6 +21,7 @@ import { useMainStore } from '@/stores/main' | ||||
|  | ||||
| import { computed } from 'vue' | ||||
| import Router from '@/router/index' | ||||
| import type { SortOrder } from './utils/docsort' | ||||
|  | ||||
| interface Path { | ||||
|   path: string | ||||
| @@ -57,16 +58,18 @@ const globalShortcutHandler = (event: KeyboardEvent) => { | ||||
|     if ( | ||||
|       event.key === 'ArrowUp' || | ||||
|       event.key === 'ArrowDown' || | ||||
|       event.key === 'ArrowLeft' || | ||||
|       event.key === 'ArrowRight' || | ||||
|       (c && event.code === 'Space') | ||||
|     ) { | ||||
|       event.preventDefault() | ||||
|       if (!input) event.preventDefault() | ||||
|     } | ||||
|     return | ||||
|   } | ||||
|   //console.log("key pressed", event) | ||||
|   // For up/down implement custom fast repeat | ||||
|   if (event.key === 'ArrowUp') vert = keyup ? 0 : event.altKey ? -10 : -1 | ||||
|   else if (event.key === 'ArrowDown') vert = keyup ? 0 : event.altKey ? 10 : 1 | ||||
|   /// Long if-else machina for all keys we handle here | ||||
|   let arrow = '' | ||||
|   if (event.key.startsWith("Arrow")) arrow = event.key.slice(5).toLowerCase() | ||||
|   // Find: process on keydown so that we can bypass the built-in search hotkey | ||||
|   else if (!keyup && event.key === 'f' && (event.ctrlKey || event.metaKey)) { | ||||
|     headerMain.value!.toggleSearchInput() | ||||
| @@ -75,21 +78,30 @@ const globalShortcutHandler = (event: KeyboardEvent) => { | ||||
|   else if (keyup && !input && event.key === '/') { | ||||
|     headerMain.value!.toggleSearchInput() | ||||
|   } | ||||
|   // Globally close search on Escape | ||||
|   // Globally close search, clear errors on Escape | ||||
|   else if (keyup && event.key === 'Escape') { | ||||
|     store.error = '' | ||||
|     headerMain.value!.closeSearch(event) | ||||
|     store.focusBreadcrumb() | ||||
|   } | ||||
|   // Select all (toggle); keydown to prevent builtin | ||||
|   else if (!input && keyup && event.key === 'Backspace') { | ||||
|     Router.back() | ||||
|   } | ||||
|   // Select all (toggle); keydown to precede and prevent builtin | ||||
|   else if (!keyup && event.key === 'a' && (event.ctrlKey || event.metaKey)) { | ||||
|     fileExplorer.toggleSelectAll() | ||||
|   } | ||||
|   // Keys 1-3 to sort columns | ||||
|   // G toggles Gallery | ||||
|   else if (!input && keyup && event.key === 'g') { | ||||
|     store.gallery = !store.gallery | ||||
|   } | ||||
|   // Keys Backquote-1-2-3 to sort columns | ||||
|   else if ( | ||||
|     !input && | ||||
|     keyup && | ||||
|     (event.key === '1' || event.key === '2' || event.key === '3') | ||||
|     (event.code === 'Backquote' || event.key === '1' || event.key === '2' || event.key === '3') | ||||
|   ) { | ||||
|     fileExplorer.toggleSortColumn(+event.key) | ||||
|     store.sort(['', 'name', 'modified', 'size'][+event.key || 0] as SortOrder) | ||||
|   } | ||||
|   // Rename | ||||
|   else if (c && keyup && !event.ctrlKey && (event.key === 'F2' || event.key === 'r')) { | ||||
| @@ -99,28 +111,26 @@ const globalShortcutHandler = (event: KeyboardEvent) => { | ||||
|   else if (c && event.code === 'Space') { | ||||
|     if (keyup && !event.altKey && !event.ctrlKey) | ||||
|       fileExplorer.cursorSelect() | ||||
|   } else return | ||||
|   event.preventDefault() | ||||
|   if (!vert) { | ||||
|     if (timer) { | ||||
|       clearTimeout(timer) // Good for either timeout or interval | ||||
|       timer = null | ||||
|     } | ||||
|     return | ||||
|   } | ||||
|   if (!timer) { | ||||
|   else return | ||||
|   /// We are handling this! | ||||
|   event.preventDefault() | ||||
|   if (timer) { | ||||
|     clearTimeout(timer) // Good for either timeout or interval | ||||
|     timer = null | ||||
|   } | ||||
|   let f: any | ||||
|   switch (arrow) { | ||||
|     case 'up': f = () => fileExplorer.up(event); break | ||||
|     case 'down': f = () => fileExplorer.down(event); break | ||||
|     case 'left': f = () => fileExplorer.left(event); break | ||||
|     case 'right': f = () => fileExplorer.right(event); break | ||||
|   } | ||||
|   if (f && !keyup) { | ||||
|     // Initial move, then t0 delay until repeats at tr intervals | ||||
|     const select = event.shiftKey | ||||
|     fileExplorer.cursorMove(vert, select) | ||||
|     const t0 = 200, | ||||
|       tr = 30 | ||||
|     timer = setTimeout( | ||||
|       () => | ||||
|         (timer = setInterval(() => { | ||||
|           fileExplorer.cursorMove(vert, select) | ||||
|         }, tr)), | ||||
|       t0 - tr | ||||
|     ) | ||||
|     const t0 = 200, tr = event.altKey ? 20 : 100 | ||||
|     f() | ||||
|     timer = setTimeout(() => { timer = setInterval(f, tr) }, t0 - tr) | ||||
|   } | ||||
| } | ||||
| onMounted(() => { | ||||
| @@ -133,4 +143,3 @@ onUnmounted(() => { | ||||
| }) | ||||
| export type { Path } | ||||
| </script> | ||||
| @/stores/main | ||||
|   | ||||
| @@ -14,7 +14,7 @@ | ||||
|   /* The following are overridden by responsive layouts */ | ||||
|   --root-font-size: 1rem; | ||||
|   --header-font-size: 1rem; | ||||
|   --header-height: calc(6.5 * var(--header-font-size)); | ||||
|   --header-height: 4rem; | ||||
| } | ||||
| @media (prefers-color-scheme: dark) { | ||||
|   :root { | ||||
| @@ -37,12 +37,6 @@ | ||||
|   :root { | ||||
|     --root-font-size: calc(8px + 8 * 100vw / 1000); | ||||
|   } | ||||
|   header .buttons:has(input[type='search']) > div { | ||||
|     display: none; | ||||
|   } | ||||
|   header .buttons > div:has(input[type='search']) { | ||||
|     display: inherit; | ||||
|   } | ||||
| } | ||||
| @media screen and (min-width: 2000px) { | ||||
|   :root { | ||||
| @@ -54,6 +48,7 @@ | ||||
|   :root { | ||||
|     --header-font-size: calc(10px + 10 * 100vh / 600);  /* 20px at 600px height */ | ||||
|     --root-font-size: 0.8rem; | ||||
|     --header-height: 2rem; | ||||
|   } | ||||
|   header .breadcrumb > * { | ||||
|     padding-top: calc(8 + 8 * 100vh / 600) !important; | ||||
| @@ -78,17 +73,13 @@ | ||||
|   } | ||||
|   header { | ||||
|     display: flex; | ||||
|     flex-direction: row-reverse; | ||||
|     justify-content: space-between; | ||||
|     align-items: end; | ||||
|   } | ||||
|   header .breadcrumb { | ||||
|     flex-shrink: 1; | ||||
|   } | ||||
|   header .breadcrumb > * { | ||||
|     flex-shrink: 1; | ||||
|     padding-top: 1rem !important; | ||||
|     padding-bottom: 1rem !important; | ||||
|   header .headermain { order: 1; } | ||||
|   header .breadcrumb { align-self: stretch; } | ||||
|   header .action-button { | ||||
|     width: 2em; | ||||
|     height: 2em; | ||||
|   } | ||||
| } | ||||
| @media print { | ||||
| @@ -101,7 +92,7 @@ | ||||
|   nav, | ||||
|   .menu, | ||||
|   .rename-button { | ||||
|     display: none; | ||||
|     display: none !important; | ||||
|   } | ||||
|   .breadcrumb > a { | ||||
|     color: black !important; | ||||
| @@ -122,6 +113,7 @@ | ||||
|     padding-bottom: 0 !important; | ||||
|   } | ||||
|   thead tr { | ||||
|     font-size: 1rem !important; | ||||
|     position: static !important; | ||||
|     background: none !important; | ||||
|     border-bottom: 1pt solid black !important; | ||||
| @@ -142,6 +134,9 @@ | ||||
|     left: 0; | ||||
|   } | ||||
| } | ||||
| * { | ||||
|   box-sizing: border-box; | ||||
| } | ||||
| html { | ||||
|   font-size: var(--root-font-size); | ||||
|   overflow: hidden; | ||||
|   | ||||
| @@ -2,8 +2,8 @@ | ||||
|   <nav | ||||
|     class="breadcrumb" | ||||
|     aria-label="Breadcrumb" | ||||
|     @keyup.left.stop="move(-1)" | ||||
|     @keyup.right.stop="move(1)" | ||||
|     @keydown.left.stop="move(-1)" | ||||
|     @keydown.right.stop="move(1)" | ||||
|     @keyup.enter="move(0)" | ||||
|     @focus=focusCurrent | ||||
|     tabindex=0 | ||||
| @@ -12,6 +12,8 @@ | ||||
|       :ref="el => setLinkRef(0, el)" | ||||
|       :class="{ current: !!isCurrent(0) }" | ||||
|       :aria-current="isCurrent(0)" | ||||
|       @click.prevent="navigate(0)" | ||||
|       title="/" | ||||
|     > | ||||
|       <component :is="home" /> | ||||
|     </a> | ||||
| @@ -21,6 +23,7 @@ | ||||
|         :aria-current="isCurrent(index + 1)" | ||||
|         @click.prevent="navigate(index + 1)" | ||||
|         :ref="el => setLinkRef(index + 1, el)" | ||||
|         :title="`/${longest.slice(0, index + 1).join('/')}`" | ||||
|       >{{ location }}</a> | ||||
|     </template> | ||||
|   </nav> | ||||
| @@ -101,31 +104,35 @@ watchEffect(() => { | ||||
|   --breadcrumb-transtime: 0.3s; | ||||
| } | ||||
| .breadcrumb { | ||||
|   flex: 1 1 auto; | ||||
|   display: flex; | ||||
|   list-style: none; | ||||
|   min-width: 20%; | ||||
|   max-width: 100%; | ||||
|   min-height: 2em; | ||||
|   margin: 0; | ||||
|   padding: 0 1em 0 0; | ||||
| } | ||||
| .breadcrumb > a { | ||||
|   flex: 0 4 auto; | ||||
|   display: flex; | ||||
|   align-items: center; | ||||
|   margin: 0 -0.5em 0 -0.5em; | ||||
|   padding: 0; | ||||
|   max-width: 8em; | ||||
|   white-space: nowrap; | ||||
|   text-overflow: ellipsis; | ||||
|   overflow: hidden; | ||||
|   height: 1.5em; | ||||
|   color: var(--breadcrumb-color); | ||||
|   padding: 0.3em 1.5em; | ||||
|   clip-path: polygon(0 0, 1em 50%, 0 100%, 100% 100%, 100% 0, 0 0); | ||||
|   transition: all var(--breadcrumb-transtime); | ||||
| } | ||||
| .breadcrumb a:first-child { | ||||
|   margin-left: 0; | ||||
|   padding-left: .2em; | ||||
| .breadcrumb > a:first-child { | ||||
|   flex: 0 0 auto; | ||||
|   padding-left: 1.5em; | ||||
|   padding-right: 1.7em; | ||||
|   clip-path: none; | ||||
| } | ||||
| .breadcrumb a:last-child { | ||||
|   max-width: none; | ||||
| .breadcrumb > a:last-child { | ||||
|   clip-path: polygon( | ||||
|     0 0, | ||||
|     calc(100% - 1em) 0, | ||||
| @@ -136,7 +143,7 @@ watchEffect(() => { | ||||
|     0 0 | ||||
|   ); | ||||
| } | ||||
| .breadcrumb a:only-child { | ||||
| .breadcrumb > a:only-child { | ||||
|   clip-path: polygon( | ||||
|     0 0, | ||||
|     calc(100% - 1em) 0, | ||||
| @@ -148,9 +155,9 @@ watchEffect(() => { | ||||
| } | ||||
| .breadcrumb svg { | ||||
|   /* FIXME: Custom positioning to align it well; needs proper solution */ | ||||
|   padding-left: 0.8em; | ||||
|   width: 1.3em; | ||||
|   height: 1.3em; | ||||
|   margin: -.5em; | ||||
|   fill: var(--breadcrumb-color); | ||||
|   transition: fill var(--breadcrumb-transtime); | ||||
| } | ||||
| @@ -170,6 +177,6 @@ watchEffect(() => { | ||||
| } | ||||
| .breadcrumb a:hover { color: var(--breadcrumb-hover-color) } | ||||
| .breadcrumb a:hover svg { fill: var(--breadcrumb-hover-color) } | ||||
| .breadcrumb a.current { color: var(--accent-color) } | ||||
| .breadcrumb a.current { color: var(--accent-color); max-width: none; flex: 0 1 auto; } | ||||
| .breadcrumb a.current svg { fill: var(--accent-color) } | ||||
| </style> | ||||
|   | ||||
| @@ -28,11 +28,11 @@ | ||||
|  | ||||
|         <tr | ||||
|           :id="`file-${doc.key}`" | ||||
|           :class="{ file: !doc.dir, folder: doc.dir, cursor: cursor === doc }" | ||||
|           @click="cursor = cursor === doc ? null : doc" | ||||
|           :class="{ file: !doc.dir, folder: doc.dir, cursor: store.cursor === doc.key }" | ||||
|           @click="store.cursor = store.cursor === doc.key ? '' : doc.key" | ||||
|           @contextmenu.prevent="contextMenu($event, doc)" | ||||
|         > | ||||
|           <td class="selection" @click.up.stop="cursor = cursor === doc ? doc : null"> | ||||
|           <td class="selection" @click.up.stop="store.cursor = store.cursor === doc.key ? doc.key : ''"> | ||||
|             <input | ||||
|               type="checkbox" | ||||
|               tabindex="-1" | ||||
| @@ -49,16 +49,10 @@ | ||||
|               <FileRenameInput :doc="doc" :rename="rename" :exit="() => {editing = null}" /> | ||||
|             </template> | ||||
|             <template v-else> | ||||
|               <a | ||||
|                 :href="doc.url" | ||||
|                 tabindex="-1" | ||||
|                 @contextmenu.prevent | ||||
|                 @focus.stop="cursor = doc" | ||||
|                 @keyup.left="router.back()" | ||||
|                 @keyup.right.stop="ev => { if (doc.dir) (ev.target as HTMLElement).click() }" | ||||
|                 >{{ doc.name }}</a | ||||
|               > | ||||
|               <button tabindex=-1 v-if="cursor == doc" class="rename-button" @click="() => (editing = doc)">🖊️</button> | ||||
|               <a :href=doc.url tabindex=-1 @contextmenu.stop @focus.stop="store.cursor = doc.key"> | ||||
|                 {{ doc.name }} | ||||
|               </a> | ||||
|               <button tabindex=-1 v-if="store.cursor == doc.key" class="rename-button" @click="() => (editing = doc)">🖊️</button> | ||||
|             </template> | ||||
|           </td> | ||||
|           <FileModified :doc=doc :key=nowkey /> | ||||
| @@ -75,7 +69,6 @@ | ||||
|       </tr> | ||||
|     </tbody> | ||||
|   </table> | ||||
|   <div v-else class="empty-container">Nothing to see here</div> | ||||
| </template> | ||||
|  | ||||
| <script setup lang="ts"> | ||||
| @@ -88,6 +81,7 @@ import { formatSize } from '@/utils' | ||||
| import { useRouter } from 'vue-router' | ||||
| import ContextMenu from '@imengyu/vue3-context-menu' | ||||
| import type { SortOrder } from '@/utils/docsort' | ||||
| import type SvgButtonVue from './SvgButton.vue' | ||||
|  | ||||
| const props = defineProps<{ | ||||
|   path: Array<string> | ||||
| @@ -95,7 +89,6 @@ const props = defineProps<{ | ||||
| }>() | ||||
| const store = useMainStore() | ||||
| const router = useRouter() | ||||
| const cursor = shallowRef<Doc | null>(null) | ||||
| // File rename | ||||
| const editing = shallowRef<Doc | null>(null) | ||||
| const rename = (doc: Doc, newName: string) => { | ||||
| @@ -138,41 +131,45 @@ defineExpose({ | ||||
|     console.log('Select') | ||||
|     allSelected.value = !allSelected.value | ||||
|   }, | ||||
|   toggleSortColumn(column: number) { | ||||
|     const order = ['', 'name', 'modified', 'size', ''][column] | ||||
|     if (order) store.toggleSort(order as SortOrder) | ||||
|   }, | ||||
|   isCursor() { | ||||
|     return cursor.value !== null && editing.value === null | ||||
|     return store.cursor && editing.value === null | ||||
|   }, | ||||
|   cursorRename() { | ||||
|     editing.value = cursor.value | ||||
|     editing.value = props.documents.find(doc => doc.key === store.cursor) ?? null | ||||
|   }, | ||||
|   cursorSelect() { | ||||
|     const doc = cursor.value | ||||
|     if (!doc) return | ||||
|     if (store.selected.has(doc.key)) { | ||||
|       store.selected.delete(doc.key) | ||||
|     const key = store.cursor | ||||
|     if (!key) return | ||||
|     if (store.selected.has(key)) { | ||||
|       store.selected.delete(key) | ||||
|     } else { | ||||
|       store.selected.add(doc.key) | ||||
|       store.selected.add(key) | ||||
|     } | ||||
|     this.cursorMove(1) | ||||
|     this.cursorMove(1, null) | ||||
|   }, | ||||
|   cursorMove(d: number, select = false) { | ||||
|   up(ev: KeyboardEvent) { this.cursorMove(-1, ev) }, | ||||
|   down(ev: KeyboardEvent) { this.cursorMove(1, ev) }, | ||||
|   left(ev: KeyboardEvent) { router.back() }, | ||||
|   right(ev: KeyboardEvent) { | ||||
|     const a = document.querySelector(`#file-${store.cursor} a`) as HTMLAnchorElement | null | ||||
|     if (a) a.click() | ||||
|   }, | ||||
|   cursorMove(d: number, ev: KeyboardEvent | null) { | ||||
|     const select = !!ev?.shiftKey | ||||
|     // Move cursor up or down (keyboard navigation) | ||||
|     const docs = props.documents | ||||
|     if (docs.length === 0) { | ||||
|       cursor.value = null | ||||
|       store.cursor = '' | ||||
|       return | ||||
|     } | ||||
|     const N = docs.length | ||||
|     const mod = (a: number, b: number) => ((a % b) + b) % b | ||||
|     const increment = (i: number, d: number) => mod(i + d, N + 1) | ||||
|     const index = | ||||
|       cursor.value !== null ? docs.indexOf(cursor.value) : docs.length | ||||
|       store.cursor ? docs.findIndex(doc => doc.key === store.cursor) : docs.length | ||||
|     const moveto = increment(index, d) | ||||
|     cursor.value = docs[moveto] ?? null | ||||
|     const tr = cursor.value ? document.getElementById(`file-${cursor.value.key}`) : null | ||||
|     store.cursor = docs[moveto]?.key ?? '' | ||||
|     const tr = store.cursor ? document.getElementById(`file-${store.cursor}`) : '' | ||||
|     if (select) { | ||||
|       // Go forwards, possibly wrapping over the end; the last entry is not toggled | ||||
|       let [begin, end] = d > 0 ? [index, moveto] : [moveto, index] | ||||
| @@ -202,18 +199,18 @@ const focusBreadcrumb = () => { | ||||
| let scrolltimer: any = null | ||||
| let scrolltr: any = null | ||||
| watchEffect(() => { | ||||
|   if (cursor.value && cursor.value !== editing.value) editing.value = null | ||||
|   if (editing.value) cursor.value = editing.value | ||||
|   if (cursor.value) { | ||||
|   if (store.cursor && store.cursor !== editing.value?.key) editing.value = null | ||||
|   if (editing.value) store.cursor = editing.value?.key | ||||
|   if (store.cursor) { | ||||
|     const a = document.querySelector( | ||||
|       `#file-${cursor.value.key} .name a` | ||||
|       `#file-${store.cursor} .name a` | ||||
|     ) as HTMLAnchorElement | null | ||||
|     if (a) a.focus() | ||||
|   } | ||||
| }) | ||||
| watchEffect(() => { | ||||
|   if (!props.documents.length && cursor.value) { | ||||
|     cursor.value = null | ||||
|   if (!props.documents.length && store.cursor) { | ||||
|     store.cursor = '' | ||||
|     focusBreadcrumb() | ||||
|   } | ||||
| }) | ||||
| @@ -287,7 +284,7 @@ const allSelected = computed({ | ||||
| const loc = computed(() => props.path.join('/')) | ||||
|  | ||||
| const contextMenu = (ev: MouseEvent, doc: Doc) => { | ||||
|   cursor.value = doc | ||||
|   store.cursor = doc.key | ||||
|   ContextMenu.showContextMenu({ | ||||
|     x: ev.x, y: ev.y, items: [ | ||||
|       { label: 'Rename', onClick: () => { editing.value = doc } }, | ||||
| @@ -310,29 +307,36 @@ tbody tr { | ||||
|   position: relative; | ||||
|   z-index: auto; | ||||
| } | ||||
| table thead input[type='checkbox'] { | ||||
| table thead .selection input[type='checkbox'] { | ||||
|   position: inherit; | ||||
|   width: 1em; | ||||
|   height: 1em; | ||||
|   padding: 0.5rem 0.5em; | ||||
|   width: 1rem; | ||||
|   height: 1rem; | ||||
|   padding: 0; | ||||
|   margin: auto; | ||||
| } | ||||
| table tbody input[type='checkbox'] { | ||||
| table tbody .selection input[type='checkbox'] { | ||||
|   width: 2rem; | ||||
|   height: 2rem; | ||||
| } | ||||
| table .selection { | ||||
|   width: 2rem; | ||||
|   width: 3rem; | ||||
|   text-align: center; | ||||
|   text-overflow: clip; | ||||
|   padding: 0; | ||||
| } | ||||
| table .selection input { | ||||
|   margin: auto; | ||||
| } | ||||
| table .modified { | ||||
|   width: 9em; | ||||
|   width: 10rem; | ||||
|   text-overflow: clip; | ||||
| } | ||||
| table .size { | ||||
|   width: 5em; | ||||
|   width: 7rem; | ||||
|   text-overflow: clip; | ||||
| } | ||||
| table .menu { | ||||
|   width: 1rem; | ||||
|   width: 2rem; | ||||
| } | ||||
| tbody td { | ||||
|   font-size: 1.2rem; | ||||
| @@ -367,7 +371,7 @@ table td { | ||||
|   } | ||||
| } | ||||
| thead tr { | ||||
|   font-size: var(--header-font-size); | ||||
|   font-size: 0.8rem; | ||||
|   background: linear-gradient(to bottom, #eee, #fff 30%, #ddd); | ||||
|   color: #000; | ||||
|   box-shadow: 0 0 .2rem black; | ||||
| @@ -388,9 +392,11 @@ tbody tr.cursor { | ||||
|   padding-right: 1.5rem; | ||||
| } | ||||
| .sortcolumn::after { | ||||
|   font-size: 1rem; | ||||
|   content: '▸'; | ||||
|   color: #888; | ||||
|   margin-left: 0.5em; | ||||
|   margin-left: 0.5rem; | ||||
|   margin-top: -.2rem; | ||||
|   position: absolute; | ||||
|   transition: all var(--transition-time) linear; | ||||
| } | ||||
|   | ||||
							
								
								
									
										254
									
								
								frontend/src/components/Gallery.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										254
									
								
								frontend/src/components/Gallery.vue
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,254 @@ | ||||
| <template> | ||||
|   <div v-if="props.documents.length || editing" class="gallery" ref="gallery"> | ||||
|     <GalleryFigure v-for="(doc, index) in documents" :key="doc.key" :doc="doc" :index="index"> | ||||
|       <BreadCrumb :path="doc.loc ? doc.loc.split('/') : []" v-if="showFolderBreadcrumb(index)" class="folder-change"/> | ||||
|     </GalleryFigure> | ||||
|   </div> | ||||
| </template> | ||||
|  | ||||
| <script setup lang="ts"> | ||||
| import { ref, computed, watchEffect, shallowRef, onMounted, onUnmounted, nextTick } from 'vue' | ||||
| import { useMainStore } from '@/stores/main' | ||||
| import { Doc } from '@/repositories/Document' | ||||
| import FileRenameInput from './FileRenameInput.vue' | ||||
| import { connect, controlUrl } from '@/repositories/WS' | ||||
| import { formatSize } from '@/utils' | ||||
| import { useRouter } from 'vue-router' | ||||
| import ContextMenu from '@imengyu/vue3-context-menu' | ||||
| import type { SortOrder } from '@/utils/docsort' | ||||
|  | ||||
| const props = defineProps<{ | ||||
|   path: Array<string> | ||||
|   documents: Doc[] | ||||
| }>() | ||||
| const store = useMainStore() | ||||
| const router = useRouter() | ||||
| // File rename | ||||
| const editing = shallowRef<Doc | null>(null) | ||||
| const rename = (doc: Doc, newName: string) => { | ||||
|   const oldName = doc.name | ||||
|   const control = connect(controlUrl, { | ||||
|     message(ev: MessageEvent) { | ||||
|       const msg = JSON.parse(ev.data) | ||||
|       if ('error' in msg) { | ||||
|         console.error('Rename failed', msg.error.message, msg.error) | ||||
|         doc.name = oldName | ||||
|       } else { | ||||
|         console.log('Rename succeeded', msg) | ||||
|       } | ||||
|     } | ||||
|   }) | ||||
|   control.onopen = () => { | ||||
|     control.send( | ||||
|       JSON.stringify({ | ||||
|         op: 'rename', | ||||
|         path: `${doc.loc}/${oldName}`, | ||||
|         to: newName | ||||
|       }) | ||||
|     ) | ||||
|   } | ||||
|   doc.name = newName // We should get an update from watch but this is quicker | ||||
| } | ||||
| const gallery = ref<HTMLElement>() | ||||
| const columns = computed(() => { | ||||
|   if (!gallery.value) return 1 | ||||
|   return getComputedStyle(gallery.value).gridTemplateColumns.split(' ').length | ||||
| }) | ||||
| defineExpose({ | ||||
|   newFolder() { | ||||
|     const now = Math.floor(Date.now() / 1000) | ||||
|     editing.value = new Doc({ | ||||
|       loc: loc.value, | ||||
|       key: 'new', | ||||
|       name: 'New Folder', | ||||
|       dir: true, | ||||
|       mtime: now, | ||||
|       size: 0, | ||||
|     }) | ||||
|   }, | ||||
|   toggleSelectAll() { | ||||
|     console.log('Select') | ||||
|     allSelected.value = !allSelected.value | ||||
|   }, | ||||
|   toggleSortColumn(column: number) { | ||||
|     const order = ['', 'name', 'modified', 'size', ''][column] | ||||
|     if (order) store.toggleSort(order as SortOrder) | ||||
|   }, | ||||
|   isCursor() { | ||||
|     return store.cursor && editing.value === null | ||||
|   }, | ||||
|   cursorRename() { | ||||
|     editing.value = props.documents.find(doc => doc.key === store.cursor) ?? null | ||||
|   }, | ||||
|   cursorSelect() { | ||||
|     const key = store.cursor | ||||
|     if (!key) return | ||||
|     if (store.selected.has(key)) { | ||||
|       store.selected.delete(key) | ||||
|     } else { | ||||
|       store.selected.add(key) | ||||
|     } | ||||
|     this.cursorMove(1, null) | ||||
|   }, | ||||
|   up(ev: KeyboardEvent) { this.cursorMove(-columns.value, ev) }, | ||||
|   down(ev: KeyboardEvent) { this.cursorMove(columns.value, ev) }, | ||||
|   left(ev: KeyboardEvent) { this.cursorMove(-1, ev) }, | ||||
|   right(ev: KeyboardEvent) { this.cursorMove(1, ev) }, | ||||
|   cursorMove(d: number, ev: KeyboardEvent | null) { | ||||
|     const select = !!ev?.shiftKey | ||||
|     // Move cursor up or down (keyboard navigation) | ||||
|     const docs = props.documents | ||||
|     if (docs.length === 0) { | ||||
|       store.cursor = '' | ||||
|       return | ||||
|     } | ||||
|     const N = docs.length | ||||
|     const mod = (a: number, b: number) => ((a % b) + b) % b | ||||
|     const increment = (i: number, d: number) => mod(i + d, N + 1) | ||||
|     const index = | ||||
|       store.cursor ? docs.findIndex(doc => doc.key === store.cursor) : N | ||||
|     let moveto | ||||
|     if (index === N) moveto = d > 0 ? 0 : N - 1 | ||||
|     else { | ||||
|       moveto = increment(index, d) | ||||
|       // Wrapping either end, just land outside the list | ||||
|       if (Math.abs(d) >= N || Math.sign(d) !== Math.sign(moveto - index)) moveto = N | ||||
|     } | ||||
|     console.log("Gallery cursorMove", d, index, moveto, moveto - index) | ||||
|     store.cursor = docs[moveto]?.key ?? '' | ||||
|     const tr = store.cursor ? document.getElementById(`file-${store.cursor}`) : '' | ||||
|     if (select) { | ||||
|       // Go forwards, possibly wrapping over the end; the last entry is not toggled | ||||
|       let [begin, end] = d > 0 ? [index, moveto] : [moveto, index] | ||||
|       for (let p = begin; p !== end; p = increment(p, 1)) { | ||||
|         if (p === N) continue | ||||
|         const key = docs[p].key | ||||
|         if (store.selected.has(key)) store.selected.delete(key) | ||||
|         else store.selected.add(key) | ||||
|       } | ||||
|     } | ||||
|     // @ts-ignore | ||||
|     scrolltr = tr | ||||
|     if (!scrolltimer) { | ||||
|       scrolltimer = setTimeout(() => { | ||||
|         if (scrolltr) | ||||
|           scrolltr.scrollIntoView({ block: 'center', behavior: 'smooth' }) | ||||
|         scrolltimer = null | ||||
|       }, 300) | ||||
|     } | ||||
|     if (moveto === N) focusBreadcrumb() | ||||
|   } | ||||
| }) | ||||
| const focusBreadcrumb = () => { | ||||
|   const el = document.querySelector('.breadcrumb') as HTMLElement | null | ||||
|   if (el) el.focus() | ||||
| } | ||||
| let scrolltimer: any = null | ||||
| let scrolltr: any = null | ||||
| watchEffect(() => { | ||||
|   if (store.cursor && store.cursor !== editing.value?.key) editing.value = null | ||||
|   if (editing.value) store.cursor = editing.value.key | ||||
|   if (store.cursor) { | ||||
|     const a = document.querySelector(`#file-${store.cursor}`) as HTMLAnchorElement | null | ||||
|     if (a) { a.focus(); a.scrollIntoView({ block: 'center', behavior: 'smooth' }) } | ||||
|   } | ||||
| }) | ||||
| watchEffect(() => { | ||||
|   if (!props.documents.length && store.cursor) { | ||||
|     store.cursor = '' | ||||
|     focusBreadcrumb() | ||||
|   } | ||||
| }) | ||||
| let nowkey = ref(0) | ||||
| let modifiedTimer: any = null | ||||
| const updateModified = () => { | ||||
|   nowkey.value = Math.floor(Date.now() / 1000) | ||||
| } | ||||
| onMounted(() => { updateModified(); modifiedTimer = setInterval(updateModified, 1000) }) | ||||
| onUnmounted(() => { clearInterval(modifiedTimer) }) | ||||
| const mkdir = (doc: Doc, name: string) => { | ||||
|   const control = connect(controlUrl, { | ||||
|     open() { | ||||
|       control.send( | ||||
|         JSON.stringify({ | ||||
|           op: 'mkdir', | ||||
|           path: `${doc.loc}/${name}` | ||||
|         }) | ||||
|       ) | ||||
|     }, | ||||
|     message(ev: MessageEvent) { | ||||
|       const msg = JSON.parse(ev.data) | ||||
|       if ('error' in msg) { | ||||
|         console.error('Mkdir failed', msg.error.message, msg.error) | ||||
|         editing.value = null | ||||
|       } else { | ||||
|         console.log('mkdir', msg) | ||||
|         router.push(doc.urlrouter) | ||||
|       } | ||||
|     } | ||||
|   }) | ||||
|   // We should get an update from watch but this is quicker | ||||
|   doc.name = name | ||||
|   doc.key = crypto.randomUUID() | ||||
| } | ||||
| const showFolderBreadcrumb = (i: number) => { | ||||
|   const docs = props.documents | ||||
|   const docloc = docs[i].loc | ||||
|   return i === 0 ? docloc !== loc.value : docloc !== docs[i - 1].loc | ||||
| } | ||||
| const selectionIndeterminate = computed({ | ||||
|   get: () => { | ||||
|     return ( | ||||
|       props.documents.length > 0 && | ||||
|       props.documents.some((doc: Doc) => store.selected.has(doc.key)) && | ||||
|       !allSelected.value | ||||
|     ) | ||||
|   }, | ||||
|   // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||||
|   set: (value: boolean) => {} | ||||
| }) | ||||
| const allSelected = computed({ | ||||
|   get: () => { | ||||
|     return ( | ||||
|       props.documents.length > 0 && | ||||
|       props.documents.every((doc: Doc) => store.selected.has(doc.key)) | ||||
|     ) | ||||
|   }, | ||||
|   set: (value: boolean) => { | ||||
|     console.log('Setting allSelected', value) | ||||
|     for (const doc of props.documents) { | ||||
|       if (value) { | ||||
|         store.selected.add(doc.key) | ||||
|       } else { | ||||
|         store.selected.delete(doc.key) | ||||
|       } | ||||
|     } | ||||
|   } | ||||
| }) | ||||
|  | ||||
| const loc = computed(() => props.path.join('/')) | ||||
|  | ||||
| const contextMenu = (ev: MouseEvent, doc: Doc) => { | ||||
|   store.cursor = doc.key | ||||
|   ContextMenu.showContextMenu({ | ||||
|     x: ev.x, y: ev.y, items: [ | ||||
|       { label: 'Rename', onClick: () => { editing.value = doc } }, | ||||
|     ], | ||||
|   }) | ||||
| } | ||||
| </script> | ||||
|  | ||||
| <style scoped> | ||||
| .gallery { | ||||
|   padding: 1rem; | ||||
|   width: 100%; | ||||
|   display: grid; | ||||
|   gap: .5rem; | ||||
|   grid-template-columns: repeat(auto-fill, minmax(15rem, 1fr)); | ||||
|   grid-auto-rows: 15rem; | ||||
| } | ||||
| .breadcrumb { | ||||
|   position: absolute; | ||||
|   z-index: 1; | ||||
| } | ||||
| </style> | ||||
							
								
								
									
										95
									
								
								frontend/src/components/GalleryFigure.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										95
									
								
								frontend/src/components/GalleryFigure.vue
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,95 @@ | ||||
| <template> | ||||
|   <a :id="`file-${doc.key}`" :href=doc.url tabindex=-1 | ||||
|     :class="{ file: !doc.dir, folder: doc.dir, cursor: store.cursor === doc.key }" | ||||
|     @contextmenu.stop | ||||
|     @focus.stop="store.cursor = doc.key" | ||||
|     @click="ev => { | ||||
|       console.log('Gallery click', doc.key, store.cursor, !!media) | ||||
|       if (m!.play()) ev.preventDefault() | ||||
|       store.cursor = doc.key | ||||
|     }" | ||||
|   > | ||||
|     <figure> | ||||
|       <slot></slot> | ||||
|       <MediaPreview ref=m :doc="doc" :tabindex=-1 /> | ||||
|       <caption> | ||||
|         <label> | ||||
|           <SelectBox :doc=doc /> | ||||
|           <span :title="doc.name + '\n' + doc.modified + '\n' + doc.sizedisp">{{ doc.name }}</span> | ||||
|         </label> | ||||
|       </caption> | ||||
|     </figure> | ||||
|   </a> | ||||
| </template> | ||||
|  | ||||
| <script setup lang=ts> | ||||
| import { ref } from 'vue' | ||||
| import { useMainStore } from '@/stores/main' | ||||
| import { Doc } from '@/repositories/Document' | ||||
| import MediaPreview from '@/components/MediaPreview.vue' | ||||
|  | ||||
| const store = useMainStore() | ||||
| const props = defineProps<{ | ||||
|   doc: Doc | ||||
|   index: number | ||||
| }>() | ||||
| const m = ref<typeof MediaPreview | null>(null) | ||||
| </script> | ||||
|  | ||||
| <style scoped> | ||||
| .gallery figure { | ||||
|   height: 15rem; | ||||
|   position: relative; | ||||
|   border-radius: .5rem; | ||||
|   overflow: hidden; | ||||
|   margin: 0; | ||||
|   display: flex; | ||||
|   flex-direction: column; | ||||
|   align-items: center; | ||||
|   justify-content: space-between; | ||||
|   overflow: hidden; | ||||
| } | ||||
| figure caption { | ||||
|   font-weight: 600; | ||||
|   color: var(--text-color); | ||||
|   text-shadow: 0 0 .2rem #000, 0 0 1rem #000; | ||||
| } | ||||
| .cursor caption { | ||||
|   background: var(--accent-color); | ||||
| } | ||||
| caption { | ||||
|   position: absolute; | ||||
|   overflow: hidden; | ||||
|   bottom: 0; | ||||
|   display: flex; | ||||
|   flex-direction: column; | ||||
|   align-items: center; | ||||
|   width: 100%; | ||||
| } | ||||
| caption label { | ||||
|   width: 100%; | ||||
|   display: flex; | ||||
|   align-items: center; | ||||
| } | ||||
| label span { | ||||
|   flex: 1 1; | ||||
|   margin-right: 2rem; | ||||
|   text-align: center; | ||||
|   overflow: hidden; | ||||
|   white-space: nowrap; | ||||
|   text-overflow: ellipsis; | ||||
| } | ||||
| label input[type='checkbox'] { | ||||
|   width: 2rem; | ||||
|   height: 2rem; | ||||
|   opacity: 0; | ||||
|   flex-shrink: 0; | ||||
| } | ||||
| label input[type='checkbox']:checked { | ||||
|   opacity: 1; | ||||
| } | ||||
| a { | ||||
|   text-decoration: none; | ||||
| } | ||||
|  | ||||
| </style> | ||||
| @@ -1,31 +1,30 @@ | ||||
| <template> | ||||
|   <nav class="headermain"> | ||||
|     <div class="buttons"> | ||||
|       <template v-if="store.error"> | ||||
|         <div class="error-message" @click="store.error = ''">{{ store.error }}</div> | ||||
|         <div class="smallgap"></div> | ||||
|       </template> | ||||
|       <UploadButton :path="props.path" /> | ||||
|       <SvgButton | ||||
|         name="create-folder" | ||||
|         data-tooltip="New folder" | ||||
|         @click="() => store.fileExplorer!.newFolder()" | ||||
|   <nav class="headermain buttons"> | ||||
|     <template v-if="store.error"> | ||||
|       <div class="error-message" @click="store.error = ''">{{ store.error }}</div> | ||||
|       <div class="smallgap"></div> | ||||
|     </template> | ||||
|     <UploadButton :path="props.path" /> | ||||
|     <SvgButton | ||||
|       name="create-folder" | ||||
|       data-tooltip="New folder" | ||||
|       @click="() => store.fileExplorer!.newFolder()" | ||||
|     /> | ||||
|     <slot></slot> | ||||
|     <div class="spacer smallgap"></div> | ||||
|     <template v-if="showSearchInput"> | ||||
|       <input | ||||
|         ref="search" | ||||
|         type="search" | ||||
|         :value="query" | ||||
|         @input="updateSearch" | ||||
|         placeholder="Find files" | ||||
|         class="margin-input" | ||||
|       /> | ||||
|       <slot></slot> | ||||
|       <div class="spacer smallgap"></div> | ||||
|       <template v-if="showSearchInput"> | ||||
|         <input | ||||
|           ref="search" | ||||
|           type="search" | ||||
|           :value="query" | ||||
|           @input="updateSearch" | ||||
|           placeholder="Search words" | ||||
|           class="margin-input" | ||||
|         /> | ||||
|       </template> | ||||
|       <SvgButton ref="searchButton" name="find" @click.prevent="toggleSearchInput" /> | ||||
|       <SvgButton name="cog" @click="settingsMenu" /> | ||||
|     </div> | ||||
|     </template> | ||||
|     <SvgButton ref="searchButton" name="find" @click.prevent="toggleSearchInput" /> | ||||
|     <SvgButton name="eye" @click="store.gallery = !store.gallery" /> | ||||
|     <SvgButton name="cog" @click="settingsMenu" /> | ||||
|   </nav> | ||||
| </template> | ||||
|  | ||||
| @@ -93,24 +92,18 @@ defineExpose({ | ||||
|  | ||||
| <style scoped> | ||||
| .buttons { | ||||
|   flex: 1000 0 auto; | ||||
|   padding: 0; | ||||
|   display: flex; | ||||
|   align-items: center; | ||||
|   height: 3.5em; | ||||
|   z-index: 10; | ||||
| } | ||||
| .buttons > * { | ||||
|   flex-shrink: 1; | ||||
| } | ||||
| input[type='search'] { | ||||
|   background: var(--input-background); | ||||
|   color: var(--input-color); | ||||
|   border: 0; | ||||
|   border-radius: 0.1em; | ||||
|   padding: 0.5em; | ||||
|   outline: none; | ||||
|   font-size: 1.5em; | ||||
|   max-width: 30vw; | ||||
|   max-width: 15ch; | ||||
| } | ||||
| </style> | ||||
| @/stores/main | ||||
|   | ||||
| @@ -150,6 +150,6 @@ const download = async () => { | ||||
|   white-space: nowrap; | ||||
|   overflow: hidden; | ||||
|   text-overflow: ellipsis; | ||||
|   margin: 0; | ||||
| } | ||||
| </style> | ||||
| @/stores/main | ||||
|   | ||||
							
								
								
									
										97
									
								
								frontend/src/components/MediaPreview.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										97
									
								
								frontend/src/components/MediaPreview.vue
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,97 @@ | ||||
| <template> | ||||
|   <img v-if=doc.img :src=doc.url alt=""> | ||||
|   <span v-else-if=doc.dir class="folder icon"></span> | ||||
|   <video ref=vid v-else-if=video() :src=doc.url controls preload=none @click.prevent>📄</video> | ||||
|   <audio ref=aud v-else-if=audio() :src=doc.url controls preload=metadata @click.stop>📄</audio> | ||||
|   <span v-else-if=archive() class="archive icon"></span> | ||||
|   <span v-else class="file icon" :class="`ext-${doc.ext}`"></span> | ||||
| </template> | ||||
|  | ||||
| <script setup lang=ts> | ||||
| import { compile, computed, ref } from 'vue' | ||||
| import type { Doc } from '@/repositories/Document' | ||||
|  | ||||
| const aud = ref<HTMLAudioElement | null>(null) | ||||
| const vid = ref<HTMLVideoElement | null>(null) | ||||
| const media = computed(() => aud.value || vid.value) | ||||
| const props = defineProps<{ | ||||
|   doc: Doc | ||||
| }>() | ||||
|  | ||||
| defineExpose({ | ||||
|   play() { | ||||
|     if (media.value) { | ||||
|       if (media.value.paused) media.value.play() | ||||
|       else media.value.pause() | ||||
|       return true | ||||
|     } | ||||
|     return false | ||||
|   }, | ||||
| }) | ||||
|  | ||||
|  | ||||
| const video = () => ['mkv', 'mp4', 'webm', 'mov', 'avi'].includes(props.doc.ext) | ||||
| const audio = () => ['mp3', 'flac', 'ogg', 'aac'].includes(props.doc.ext) | ||||
| const embed = () => ['txt', 'py', 'html', 'css', 'js', 'json', 'xml', 'csv', 'tsv'].includes(props.doc.ext) | ||||
| const archive = () => ['zip', 'tar', 'gz', 'bz2', 'xz', '7z', 'rar'].includes(props.doc.ext) | ||||
| </script> | ||||
|  | ||||
| <style scoped> | ||||
| img, embed, .icon { | ||||
|   font-size: 10em; | ||||
|   border-radius: .5rem; | ||||
|   overflow: hidden; | ||||
|   text-align: center; | ||||
|   object-fit: cover; | ||||
|   object-position: center; | ||||
|   min-width: 50%; | ||||
|   height: 100%; | ||||
| } | ||||
| audio, video { | ||||
|   height: 100%; | ||||
|   min-width: 50%; | ||||
|   max-width: 100%; | ||||
|   padding-bottom: 2rem; | ||||
|   margin: auto; | ||||
| } | ||||
| .folder::before { | ||||
|   content: '📁'; | ||||
| } | ||||
| .folder:hover::before, .cursor .folder::before { | ||||
|   content: '📂'; | ||||
| } | ||||
| .archive::before { | ||||
|   content: '📦'; | ||||
| } | ||||
| .file::before { | ||||
|   content: '📄'; | ||||
| } | ||||
| .ext-img::before { | ||||
|   content: '💿'; | ||||
| } | ||||
| .ext-exe::before, .ext-msi::before, .ext-dmg::before, .ext-pkg::before { | ||||
|   content: '⚙️'; | ||||
| } | ||||
| .ext-torrent::before { | ||||
|   content: '🏴☠️'; | ||||
| } | ||||
| .icon { | ||||
|   filter: brightness(0.9); | ||||
| } | ||||
| figure.cursor .icon { | ||||
|   filter: brightness(1); | ||||
| } | ||||
| img::before, video::before { | ||||
|   /* broken image */ | ||||
|   background: #888; | ||||
|   position: absolute; | ||||
|   width: 100%; | ||||
|   height: 100%; | ||||
|   top: 0; | ||||
|   left: 0; | ||||
|   text-align: center; | ||||
|   text-shadow: 0 0 .5rem #000; | ||||
|   filter: grayscale(1); | ||||
|   content: '❌'; | ||||
| } | ||||
| </style> | ||||
							
								
								
									
										22
									
								
								frontend/src/components/SelectBox.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										22
									
								
								frontend/src/components/SelectBox.vue
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,22 @@ | ||||
| <template> | ||||
|   <input type=checkbox tabindex=-1 :checked="store.selected.has(doc.key)" | ||||
|     @change="ev => { | ||||
|       if ((ev.target as HTMLInputElement).checked) { | ||||
|         store.selected.add(doc.key) | ||||
|       } else { | ||||
|         store.selected.delete(doc.key) | ||||
|       } | ||||
|     }" | ||||
|   > | ||||
| </template> | ||||
|  | ||||
| <script setup lang=ts> | ||||
| import { useMainStore } from '@/stores/main' | ||||
| import type { Doc } from '@/repositories/Document' | ||||
|  | ||||
| const props = defineProps<{ | ||||
|   doc: Doc | ||||
| }>() | ||||
| const store = useMainStore() | ||||
|  | ||||
| </script> | ||||
| @@ -6,7 +6,7 @@ | ||||
| </template> | ||||
|  | ||||
| <script setup lang="ts"> | ||||
| import { defineAsyncComponent, defineProps } from 'vue' | ||||
| import { defineAsyncComponent } from 'vue' | ||||
|  | ||||
| const props = defineProps<{ | ||||
|   name: string | ||||
|   | ||||
| @@ -36,6 +36,14 @@ export class Doc { | ||||
|   get urlrouter(): string { | ||||
|     return this.url.replace(/^\/#/, '') | ||||
|   } | ||||
|   get img(): boolean { | ||||
|     const ext = this.name.split('.').pop()?.toLowerCase() | ||||
|     return ['jpg', 'jpeg', 'png', 'gif', 'webp', 'avif', 'svg'].includes(ext || '') | ||||
|   } | ||||
|   get ext(): string { | ||||
|     const ext = this.name.split('.').pop() | ||||
|     return ext ? ext.toLowerCase() : '' | ||||
|   } | ||||
| } | ||||
| export type errorEvent = { | ||||
|   error: { | ||||
|   | ||||
| @@ -23,6 +23,8 @@ export const useMainStore = defineStore({ | ||||
|     fileExplorer: null as any, | ||||
|     error: '' as string, | ||||
|     connected: false, | ||||
|     gallery: false, | ||||
|     cursor: '' as string, | ||||
|     server: {} as Record<string, any>, | ||||
|     prefs: { | ||||
|       sortListing: '' as SortOrder, | ||||
| @@ -77,6 +79,13 @@ export const useMainStore = defineStore({ | ||||
|       if (this.query) this.prefs.sortFiltered = this.prefs.sortFiltered === name ? '' : name | ||||
|       else this.prefs.sortListing = this.prefs.sortListing === name ? '' : name | ||||
|     }, | ||||
|     sort(name: SortOrder | '') { | ||||
|       if (this.query) this.prefs.sortFiltered = name | ||||
|       else this.prefs.sortListing = name | ||||
|     }, | ||||
|     focusBreadcrumb() { | ||||
|       (document.querySelector('.breadcrumb') as HTMLAnchorElement).focus() | ||||
|     } | ||||
|   }, | ||||
|   getters: { | ||||
|     sortOrder(): SortOrder { return this.query ? this.prefs.sortFiltered : this.prefs.sortListing }, | ||||
|   | ||||
| @@ -1,19 +1,40 @@ | ||||
| <template> | ||||
|   <FileExplorer | ||||
|   <div v-if="!props.path || documents.length === 0" class="empty-container"> | ||||
|     <component :is="cog" class="cog"/> | ||||
|     <p v-if="!store.connected">No Connection</p> | ||||
|     <p v-else-if="store.document.length === 0">Waiting for Files</p> | ||||
|     <p v-else-if="store.query">No matches!</p> | ||||
|     <p v-else-if="!store.document.some(doc => `${doc.loc}/${doc.name}` === props.path.join('/'))">Folder not found.</p> | ||||
|     <p v-else>Empty folder</p> | ||||
|   </div> | ||||
|   <Gallery | ||||
|     v-else-if="store.gallery" | ||||
|     ref="fileExplorer" | ||||
|     :key="Router.currentRoute.value.path" | ||||
|     :key="`gallery-${Router.currentRoute.value.path}`" | ||||
|     :path="props.path" | ||||
|     :documents="documents" | ||||
|     v-if="props.path" | ||||
|   /> | ||||
|   <FileExplorer | ||||
|     v-else | ||||
|     ref="fileExplorer" | ||||
|     :key="`explorer-${Router.currentRoute.value.path}`" | ||||
|     :path="props.path" | ||||
|     :documents="documents" | ||||
|   /> | ||||
|   <div v-if="!store.gallery && documents.some(doc => doc.img)" class="suggest-gallery"> | ||||
|     <p>Media files found. Would you like a gallery view?</p> | ||||
|     <SvgButton name="eye" taborder=0 @click="() => { store.gallery = true }">Gallery</SvgButton> | ||||
|   </div> | ||||
| </template> | ||||
|  | ||||
| <script setup lang="ts"> | ||||
| import { watchEffect, ref, computed } from 'vue' | ||||
| import { useMainStore } from '@/stores/main' | ||||
| import Router from '@/router/index' | ||||
| import { needleFormat, localeIncludes, collator } from '@/utils'; | ||||
| import { sorted } from '@/utils/docsort'; | ||||
| import { needleFormat, localeIncludes, collator } from '@/utils' | ||||
| import { sorted } from '@/utils/docsort' | ||||
| import FileExplorer from '@/components/FileExplorer.vue' | ||||
| import cog from '@/assets/svg/cog.svg' | ||||
|  | ||||
| const store = useMainStore() | ||||
| const fileExplorer = ref() | ||||
| @@ -64,3 +85,39 @@ watchEffect(() => { | ||||
|   store.query = props.query | ||||
| }) | ||||
| </script> | ||||
|  | ||||
| <style scoped> | ||||
| .empty-container { | ||||
|   display: flex; | ||||
|   flex-direction: column; | ||||
|   align-items: center; | ||||
|   justify-content: center; | ||||
|   height: 100%; | ||||
|   font-size: 2rem; | ||||
|   text-shadow: 0 0 1rem #000, 0 0 2rem #000; | ||||
|   color: var(--accent-color); | ||||
| } | ||||
| @keyframes rotate { | ||||
|   0% { transform: rotate(0deg); } | ||||
|   100% { transform: rotate(359deg); } | ||||
| } | ||||
| .suggest-gallery p { | ||||
|   font-size: 2rem; | ||||
|   color: var(--accent-color); | ||||
| } | ||||
| .suggest-gallery { | ||||
|   display: flex; | ||||
|   flex-direction: column; | ||||
|   align-items: center; | ||||
|   justify-content: center; | ||||
| } | ||||
|  | ||||
| svg.cog { | ||||
|   width: 10rem; | ||||
|   height: 10rem; | ||||
|   margin: 0 auto; | ||||
|   animation: rotate 10s linear infinite; | ||||
|   filter: drop-shadow(0 0 1rem black); | ||||
|   fill: var(--primary-color); | ||||
| } | ||||
| </style> | ||||
|   | ||||
		Reference in New Issue
	
	Block a user