Compare commits
	
		
			110 Commits
		
	
	
		
			v0.4.1
			...
			be1bc22538
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | be1bc22538 | ||
|   | 259f585968 | ||
|   | 4bb7d091e4 | ||
|   | 4ae31fe241 | ||
|   | f0c7465944 | ||
|   | a3a6b3771c | ||
|   | 348f8e183e | ||
|   | 37167a41a6 | ||
|   | 63f6008a0a | ||
|   | 4fd769cce2 | ||
|   | 2695fc67f3 | ||
|   | d42f0f7601 | ||
|   | 4c51029c9f | ||
|   | 4de2027959 | ||
|   | d5e1304c0d | ||
|   | 54d6ea6332 | ||
|   | c695c09ecc | ||
|   | d36605cd5b | ||
|   | fc1fb3ea5d | ||
|   | 32fa005c62 | ||
|   | fabec4dd7e | ||
|   | ece64f48be | ||
|   | 1f24313d23 | ||
|   | e3af21af91 | ||
|   | 6938740b0f | ||
|   | b25d0fc14b | ||
|   | 5386508e28 | ||
|   | 129250e072 | ||
|   | c2be2ecd31 | ||
|   | dd1d85f412 | ||
|   | 4c7b310f82 | ||
|   | 1250037cfd | ||
|   | cdc936d2d5 | ||
|   | 4f370440d9 | ||
|   | feaa8e315e | ||
|   | 14f7253ece | ||
|   | 9d3d27faf3 | ||
|   | dd235e8f25 | ||
|   | 139ff51dcd | ||
|   | 589e5a682c | ||
|   | 8114d679ef | ||
|   | 32b8e0702c | ||
|   | cc74912bb9 | ||
|   | c3cf4caa9a | ||
|   | b3eacf04f7 | ||
|   | 047facaacb | ||
|   | 41fbd3d122 | ||
|   | 40a45568c1 | ||
|   | 8c6690ea98 | ||
|   | 997e0b8549 | ||
|   | 115bb5db59 | ||
|   | 5f1eb0503a | ||
|   | 4aae194060 | ||
|   | 12eabd29c3 | ||
|   | 589b21f944 | ||
|   | d3f584b738 | ||
|   | 225f2b0651 | ||
|   | b759d8324c | ||
|   | 119aba2b3c | ||
|   | f52d58d645 | ||
|   | 6cba674b30 | ||
|   | 831b2716f7 | ||
|   | 7e5901a2cf | ||
|   | a4f95d730b | ||
|   | 56082cba15 | ||
|   | 3479a0da57 | ||
|   | f99d92b217 | ||
|   | 68a701538b | ||
|   | 05a16e3037 | ||
|   | 52ecbc3d36 | ||
|   | 042f1b7f42 | ||
|   | d27cb2133a | ||
|   | a8ea43194d | ||
|   | 07fe7448cc | ||
|   | 783af44e26 | ||
|   | 0d6180e8a4 | ||
|   | bdc0bbd44f | ||
|   | ba36eaec1b | ||
|   | a435a30c88 | ||
|   | 742b05ed66 | ||
|   | a26dc42d88 | ||
|   | 9002afbc7e | ||
|   | acdd776b92 | ||
| b3fd9637eb | |||
| 2b72508206 | |||
|   | b0d6b75ac1 | ||
|   | 8cc3ed1a04 | ||
|   | 0d186726b5 | ||
|   | 63bbe84859 | ||
|   | 202f28ff15 | ||
| 41772e6c18 | |||
| e52379d515 | |||
| 74987898c9 | |||
| 859d312913 | |||
| 4bc9cf4534 | |||
| 754d779069 | |||
| 367e4ba0ea | |||
| c2e9a4af05 | |||
| 6cdc37a172 | |||
| 19699564c2 | |||
| 7baf8b3f9b | |||
| 47329ac04e | |||
| f4013d1196 | |||
| 3672156b5e | |||
| f2b37852da | |||
| 708e54d080 | |||
| d051265f40 | |||
| 5cf133465e | |||
| 1c91bf2e87 | |||
| 9cd6f83bec | 
							
								
								
									
										71
									
								
								README.md
									
									
									
									
									
								
							
							
						
						| @@ -1,78 +1,25 @@ | |||||||
| # Web File Storage | # Web File Storage | ||||||
|  |  | ||||||
| The Python package installs a `cista` executable. Use `hatch shell` to initiate and install in a virtual environment, or `pip install` it on your system. Alternatively `hatch run cista` may be used to skip the shell step but stay virtual. `pip install hatch` first if needed. | Run directly from repository with Hatch (or use pip install as usual): | ||||||
|  | ```sh | ||||||
|  | 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: | Create your user account: | ||||||
|  |  | ||||||
| ```sh | ```sh | ||||||
| cista --user admin --privileged | hatch run cista --user admin --privileged | ||||||
| ``` | ``` | ||||||
|  |  | ||||||
| ## Running the server |  | ||||||
|  |  | ||||||
| Serve your files on localhost:8000: |  | ||||||
|  |  | ||||||
| ```sh |  | ||||||
| cista -l :8000 /path/to/files |  | ||||||
| ``` |  | ||||||
|  |  | ||||||
| The Git repository does not contain a frontend build, so you should first do that... |  | ||||||
|  |  | ||||||
| ## Build frontend | ## Build frontend | ||||||
|  |  | ||||||
| Frontend needs to be built before using and after any frontend changes: | Prebuilt frontend is provided in repository but for any changes it will need to be manually rebuilt: | ||||||
|  |  | ||||||
| ```sh | ```sh | ||||||
| cd frontend | cd cista-front | ||||||
| npm install | npm install | ||||||
| npm run build | npm run build | ||||||
| ``` | ``` | ||||||
|  |  | ||||||
| This will place the front in `cista/wwwroot` from where the backend server delivers it, and that also gets included in the Python package built via `hatch build`. | This will place the front in `cista/wwwroot` from where the backend server delivers it, and that also gets included in the Python package built via `hatch build`. | ||||||
|  |  | ||||||
| ## Development setup |  | ||||||
|  |  | ||||||
| For rapid turnaround during development, you should run `npm run dev` Vite development server on the Vue frontend. While that is running, start the backend on another terminal `hatch run cista --dev -l :8000` and connect to the frontend. |  | ||||||
|  |  | ||||||
| The backend and the frontend will each reload automatically at any code or config changes. |  | ||||||
|  |  | ||||||
| ## System deployment |  | ||||||
|  |  | ||||||
| Clone the repository to `/srv/cista/cista-storage` or other suitable location accessible to the storage user account you plan to use. `sudo -u storage -s` and build the frontend if you hadn't already. |  | ||||||
|  |  | ||||||
| Create **/etc/systemd/system/cista@.service**: |  | ||||||
|  |  | ||||||
| ```ini |  | ||||||
| [Unit] |  | ||||||
| Description=Cista storage %i |  | ||||||
|  |  | ||||||
| [Service] |  | ||||||
| User=storage |  | ||||||
| WorkingDirectory=/srv/cista/cista-storage |  | ||||||
| ExecStart=hatch run cista -c /srv/cista/%i -l /srv/cista/%i/socket /media/storage/@%i/ |  | ||||||
| TimeoutStopSec=2 |  | ||||||
| Restart=always |  | ||||||
|  |  | ||||||
| [Install] |  | ||||||
| WantedBy=multi-user.target |  | ||||||
| ``` |  | ||||||
|  |  | ||||||
| This assumes you may want to run multiple separate storages, each having their files under `/media/storage/<domain>` and configuration under `/srv/cista/<domain>/`. Instead of numeric ports, we use UNIX sockets for convenience. |  | ||||||
|  |  | ||||||
| ```sh |  | ||||||
| systemctl daemon-reload |  | ||||||
| systemctl enable --now cista@foo.example.com |  | ||||||
| systemctl enable --now cista@bar.example.com |  | ||||||
| ``` |  | ||||||
|  |  | ||||||
| Exposing this publicly online is the most convenient using the [Caddy](https://caddyserver.com/) web server but you can of course use Nginx or others as well. Or even run the server with `-l domain.example.com` given TLS certificates in the config folder. |  | ||||||
|  |  | ||||||
| **/etc/caddy/Caddyfile**: |  | ||||||
|  |  | ||||||
| ```Caddyfile |  | ||||||
| foo.example.com, bar.example.com { |  | ||||||
|     reverse_proxy unix//srv/cista/{host}/socket |  | ||||||
| } |  | ||||||
| ``` |  | ||||||
|  |  | ||||||
| Using the `{host}` placeholder we can just put all the domains on the same block. That's the full server configuration you need. `systemctl enable --now caddy` or `systemctl restart caddy` for the config to take effect. |  | ||||||
|   | |||||||
| @@ -1,9 +1,9 @@ | |||||||
| <!DOCTYPE html> | <!DOCTYPE html> | ||||||
| <html lang=en> | <html lang=en> | ||||||
| <meta charset=UTF-8> | <meta charset=UTF-8> | ||||||
| <title>Cista Storage</title> | <title>Cista</title> | ||||||
| <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no"> | <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no"> | ||||||
| <link rel="icon" href="/src/assets/logo.svg"> | <link rel="icon" href="/favicon.ico"> | ||||||
| <link rel="preconnect" href="https://fonts.googleapis.com"> | <link rel="preconnect" href="https://fonts.googleapis.com"> | ||||||
| <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin> | <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin> | ||||||
| <link href="https://fonts.googleapis.com/css2?family=Roboto+Mono&family=Roboto:wght@400;700&display=swap" rel="stylesheet"> | <link href="https://fonts.googleapis.com/css2?family=Roboto+Mono&family=Roboto:wght@400;700&display=swap" rel="stylesheet"> | ||||||
| @@ -1,5 +1,5 @@ | |||||||
| { | { | ||||||
|   "name": "cista-frontend", |   "name": "front", | ||||||
|   "version": "0.0.0", |   "version": "0.0.0", | ||||||
|   "private": true, |   "private": true, | ||||||
|   "scripts": { |   "scripts": { | ||||||
							
								
								
									
										
											BIN
										
									
								
								cista-front/public/favicon.ico
									
									
									
									
									
										Normal file
									
								
							
							
						
						| After Width: | Height: | Size: 4.2 KiB | 
							
								
								
									
										241
									
								
								cista-front/public/old-index.html
									
									
									
									
									
										Executable file
									
								
							
							
						
						| @@ -0,0 +1,241 @@ | |||||||
|  | <!DOCTYPE html> | ||||||
|  | <title>Storage</title> | ||||||
|  | <style> | ||||||
|  |   body { | ||||||
|  |     font-family: sans-serif; | ||||||
|  |     max-width: 100ch; | ||||||
|  |     margin: 0 auto; | ||||||
|  |     padding: 1em; | ||||||
|  |     background-color: #333; | ||||||
|  |     color: #eee; | ||||||
|  |   } | ||||||
|  |   td { | ||||||
|  |     text-align: right; | ||||||
|  |     padding: .5em; | ||||||
|  |   } | ||||||
|  |   td:first-child { | ||||||
|  |     text-align: left; | ||||||
|  |   } | ||||||
|  |   a { | ||||||
|  |     color: inherit; | ||||||
|  |     text-decoration: none; | ||||||
|  |   } | ||||||
|  | </style> | ||||||
|  | <div> | ||||||
|  |   <h2>Quick file upload</h2> | ||||||
|  |   <p>Uses parallel WebSocket connections for increased bandwidth /api/upload</p> | ||||||
|  |   <input type=file id=fileInput> | ||||||
|  |   <progress id=progressBar value=0 max=1></progress> | ||||||
|  | </div> | ||||||
|  |  | ||||||
|  | <div> | ||||||
|  |   <h2>Files</h2> | ||||||
|  |   <ul id=file_list></ul> | ||||||
|  | </div> | ||||||
|  |  | ||||||
|  | <script> | ||||||
|  | let files = {} | ||||||
|  | let flatfiles = {} | ||||||
|  |  | ||||||
|  | function createWatchSocket() { | ||||||
|  |   const wsurl = new URL("/api/watch", location.href.replace(/^http/, 'ws')) | ||||||
|  |   const ws = new WebSocket(wsurl) | ||||||
|  |   ws.onmessage = event => { | ||||||
|  |     msg = JSON.parse(event.data) | ||||||
|  |     if (msg.update) { | ||||||
|  |       tree_update(msg.update) | ||||||
|  |       file_list(files) | ||||||
|  |     } else { | ||||||
|  |       console.log("Unkonwn message from watch socket", msg) | ||||||
|  |     } | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | createWatchSocket() | ||||||
|  |  | ||||||
|  | function tree_update(msg) { | ||||||
|  |   console.log("Tree update", msg) | ||||||
|  |   let node = files | ||||||
|  |   for (const elem of msg) { | ||||||
|  |     if (elem.deleted) { | ||||||
|  |       const p = node.dir[elem.name].path | ||||||
|  |       delete node.dir[elem.name] | ||||||
|  |       delete flatfiles[p] | ||||||
|  |       break | ||||||
|  |     } | ||||||
|  |     if (elem.name !== undefined) node = node.dir[elem.name] ||= {} | ||||||
|  |     if (elem.size !== undefined) node.size = elem.size | ||||||
|  |     if (elem.mtime !== undefined) node.mtime = elem.mtime | ||||||
|  |     if (elem.dir !== undefined) node.dir = elem.dir | ||||||
|  |   } | ||||||
|  |   // Update paths and flatfiles | ||||||
|  |   files.path = "/" | ||||||
|  |   const nodes = [files] | ||||||
|  |   flatfiles = {} | ||||||
|  |   while (node = nodes.pop()) { | ||||||
|  |     flatfiles[node.path] = node | ||||||
|  |     if (node.dir === undefined) continue | ||||||
|  |     for (const name of Object.keys(node.dir)) { | ||||||
|  |       const child = node.dir[name] | ||||||
|  |       child.path = node.path + name + (child.dir === undefined ? "" : "/") | ||||||
|  |       nodes.push(child) | ||||||
|  |     } | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | var collator = new Intl.Collator(undefined, {numeric: true, sensitivity: 'base'}); | ||||||
|  |  | ||||||
|  | const compare_path = (a, b) => collator.compare(a.path, b.path) | ||||||
|  | const compare_time = (a, b) => a.mtime > b.mtime | ||||||
|  |  | ||||||
|  | function file_list(files) { | ||||||
|  |   const table = document.getElementById("file_list") | ||||||
|  |   const sorted = Object.values(flatfiles).sort(compare_time) | ||||||
|  |   table.innerHTML = "" | ||||||
|  |   for (const f of sorted) { | ||||||
|  |     const {path, size, mtime} = f | ||||||
|  |     const tr = document.createElement("tr") | ||||||
|  |     const name_td = document.createElement("td") | ||||||
|  |     const size_td = document.createElement("td") | ||||||
|  |     const mtime_td = document.createElement("td") | ||||||
|  |     const a = document.createElement("a") | ||||||
|  |     table.appendChild(tr) | ||||||
|  |     tr.appendChild(name_td) | ||||||
|  |     tr.appendChild(size_td) | ||||||
|  |     tr.appendChild(mtime_td) | ||||||
|  |     name_td.appendChild(a) | ||||||
|  |     size_td.textContent = size | ||||||
|  |     mtime_td.textContent = formatUnixDate(mtime) | ||||||
|  |     a.textContent = path | ||||||
|  |     a.href = `/files${path}` | ||||||
|  |     /*a.onclick = event => { | ||||||
|  |       if (window.showSaveFilePicker) { | ||||||
|  |         event.preventDefault() | ||||||
|  |         download_ws(name, size) | ||||||
|  |       } | ||||||
|  |     } | ||||||
|  |     a.download = ""*/ | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | function formatUnixDate(t) { | ||||||
|  |     const date = new Date(t * 1000) | ||||||
|  |     const now = new Date() | ||||||
|  |     const diff = date - now | ||||||
|  |     const formatter = new Intl.RelativeTimeFormat('en', { numeric: 'auto' }) | ||||||
|  |  | ||||||
|  |     if (Math.abs(diff) <= 60000) { | ||||||
|  |         return formatter.format(Math.round(diff / 1000), 'second') | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     if (Math.abs(diff) <= 3600000) { | ||||||
|  |         return formatter.format(Math.round(diff / 60000), 'minute') | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     if (Math.abs(diff) <= 86400000) { | ||||||
|  |         return formatter.format(Math.round(diff / 3600000), 'hour') | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     if (Math.abs(diff) <= 604800000) { | ||||||
|  |         return formatter.format(Math.round(diff / 86400000), 'day') | ||||||
|  |     } | ||||||
|  |  | ||||||
|  |     return date.toLocaleDateString() | ||||||
|  | } | ||||||
|  |  | ||||||
|  | async function download_ws(name, size) { | ||||||
|  |   const fh = await window.showSaveFilePicker({ | ||||||
|  |     suggestedName: name, | ||||||
|  |   }) | ||||||
|  |   const writer = await fh.createWritable() | ||||||
|  |   writer.truncate(size) | ||||||
|  |   const wsurl = new URL("/api/download", location.href.replace(/^http/, 'ws')) | ||||||
|  |   const ws = new WebSocket(wsurl) | ||||||
|  |   let pos = 0 | ||||||
|  |   ws.onopen = () => { | ||||||
|  |     console.log("Downloading over WebSocket", name, size) | ||||||
|  |     ws.send(JSON.stringify({name, start: 0, end: size, size})) | ||||||
|  |   } | ||||||
|  |   ws.onmessage = event => { | ||||||
|  |     if (typeof event.data === 'string') { | ||||||
|  |       const msg = JSON.parse(event.data) | ||||||
|  |       console.log("Download finished", msg) | ||||||
|  |       ws.close() | ||||||
|  |       return | ||||||
|  |     } | ||||||
|  |     console.log("Received chunk", name, pos, pos + event.data.size) | ||||||
|  |     pos += event.data.size | ||||||
|  |     writer.write(event.data) | ||||||
|  |   } | ||||||
|  |   ws.onclose = () => { | ||||||
|  |     if (pos < size) { | ||||||
|  |       console.log("Download aborted", name, pos) | ||||||
|  |       writer.truncate(pos) | ||||||
|  |     } | ||||||
|  |     writer.close() | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | const fileInput = document.getElementById("fileInput") | ||||||
|  | const progress = document.getElementById("progressBar") | ||||||
|  | const numConnections = 2 | ||||||
|  | const chunkSize = 1<<20 | ||||||
|  | const wsConnections = new Set() | ||||||
|  |  | ||||||
|  | //for (let i = 0; i < numConnections; i++) createUploadWS() | ||||||
|  |  | ||||||
|  | function createUploadWS() { | ||||||
|  |   const wsurl = new URL("/api/upload", location.href.replace(/^http/, 'ws')) | ||||||
|  |   const ws = new WebSocket(wsurl) | ||||||
|  |   ws.binaryType = 'arraybuffer' | ||||||
|  |   ws.onopen = () => { | ||||||
|  |     wsConnections.add(ws) | ||||||
|  |     console.log("Upload socket connected") | ||||||
|  |   } | ||||||
|  |   ws.onmessage = event => { | ||||||
|  |     msg = JSON.parse(event.data) | ||||||
|  |     if (msg.written) progress.value += +msg.written | ||||||
|  |     else console.log(`Error: ${msg.error}`) | ||||||
|  |   } | ||||||
|  |   ws.onclose = () => { | ||||||
|  |     wsConnections.delete(ws) | ||||||
|  |     console.log("Upload socket disconnected, reconnecting...") | ||||||
|  |     setTimeout(createUploadWS, 1000) | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | async function load(file, start, end) { | ||||||
|  |   const reader = new FileReader() | ||||||
|  |   const load = new Promise(resolve => reader.onload = resolve) | ||||||
|  |   reader.readAsArrayBuffer(file.slice(start, end)) | ||||||
|  |   const event = await load | ||||||
|  |   return event.target.result | ||||||
|  | } | ||||||
|  |  | ||||||
|  | async function sendChunk(file, start, end, ws) { | ||||||
|  |   const chunk = await load(file, start, end) | ||||||
|  |   ws.send(JSON.stringify({ | ||||||
|  |     name: file.name, | ||||||
|  |     size: file.size, | ||||||
|  |     start: start, | ||||||
|  |     end: end | ||||||
|  |   })) | ||||||
|  |   ws.send(chunk) | ||||||
|  | } | ||||||
|  |  | ||||||
|  | fileInput.addEventListener("change", async function() { | ||||||
|  |   const file = this.files[0] | ||||||
|  |   const numChunks = Math.ceil(file.size / chunkSize) | ||||||
|  |   progress.value = 0 | ||||||
|  |   progress.max = file.size | ||||||
|  |  | ||||||
|  |   console.log(wsConnections) | ||||||
|  |   for (let i = 0; i < numChunks; i++) { | ||||||
|  |     const ws = Array.from(wsConnections)[i % wsConnections.size] | ||||||
|  |     const start = i * chunkSize | ||||||
|  |     const end = Math.min(file.size, start + chunkSize) | ||||||
|  |     const res = await sendChunk(file, start, end, ws) | ||||||
|  |   } | ||||||
|  | }) | ||||||
|  |  | ||||||
|  | </script> | ||||||
| @@ -1,13 +1,13 @@ | |||||||
| <template> | <template> | ||||||
|   <LoginModal /> |   <LoginModal /> | ||||||
|   <header> |   <header> | ||||||
|     <HeaderMain ref="headerMain" :path="path.pathList" :query="path.query"> |     <HeaderMain ref="headerMain" :path="path.pathList"> | ||||||
|       <HeaderSelected :path="path.pathList" /> |       <HeaderSelected :path="path.pathList" /> | ||||||
|     </HeaderMain> |     </HeaderMain> | ||||||
|     <BreadCrumb :path="path.pathList" tabindex="-1"/> |     <BreadCrumb :path="path.pathList" tabindex="-1"/> | ||||||
|   </header> |   </header> | ||||||
|   <main> |   <main> | ||||||
|     <RouterView :path="path.pathList" :query="path.query" /> |     <RouterView :path="path.pathList" /> | ||||||
|   </main> |   </main> | ||||||
| </template> | </template> | ||||||
| 
 | 
 | ||||||
| @@ -15,9 +15,9 @@ | |||||||
| import { RouterView } from 'vue-router' | import { RouterView } from 'vue-router' | ||||||
| import type { ComputedRef } from 'vue' | import type { ComputedRef } from 'vue' | ||||||
| import type HeaderMain from '@/components/HeaderMain.vue' | import type HeaderMain from '@/components/HeaderMain.vue' | ||||||
| import { onMounted, onUnmounted, ref, watchEffect } from 'vue' | import { onMounted, onUnmounted, ref } from 'vue' | ||||||
| import { loadSession, watchConnect, watchDisconnect } from '@/repositories/WS' | import { watchConnect, watchDisconnect } from '@/repositories/WS' | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| 
 | 
 | ||||||
| import { computed } from 'vue' | import { computed } from 'vue' | ||||||
| import Router from '@/router/index' | import Router from '@/router/index' | ||||||
| @@ -25,30 +25,25 @@ import Router from '@/router/index' | |||||||
| interface Path { | interface Path { | ||||||
|   path: string |   path: string | ||||||
|   pathList: string[] |   pathList: string[] | ||||||
|   query: string |  | ||||||
| } | } | ||||||
| const store = useMainStore() | const documentStore = useDocumentStore() | ||||||
| const path: ComputedRef<Path> = computed(() => { | const path: ComputedRef<Path> = computed(() => { | ||||||
|   const p = decodeURIComponent(Router.currentRoute.value.path).split('//') |   const p = decodeURIComponent(Router.currentRoute.value.path) | ||||||
|   const pathList = p[0].split('/').filter(value => value !== '') |   const pathList = p.split('/').filter(value => value !== '') | ||||||
|   const query = p.slice(1).join('//') |  | ||||||
|   return { |   return { | ||||||
|     path: p[0], |     path: p, | ||||||
|     pathList, |     pathList | ||||||
|     query |  | ||||||
|   } |   } | ||||||
| }) | }) | ||||||
| watchEffect(() => { |  | ||||||
|   document.title = path.value.path.replace(/\/$/, '').split('/').pop() || store.server.name || 'Cista Storage' |  | ||||||
| }) |  | ||||||
| onMounted(loadSession) |  | ||||||
| onMounted(watchConnect) | onMounted(watchConnect) | ||||||
| onUnmounted(watchDisconnect) | onUnmounted(watchDisconnect) | ||||||
|  | // Update human-readable x seconds ago messages from mtimes | ||||||
|  | setInterval(documentStore.updateModified, 1000) | ||||||
| const headerMain = ref<typeof HeaderMain | null>(null) | const headerMain = ref<typeof HeaderMain | null>(null) | ||||||
| let vert = 0 | let vert = 0 | ||||||
| let timer: any = null | let timer: any = null | ||||||
| const globalShortcutHandler = (event: KeyboardEvent) => { | const globalShortcutHandler = (event: KeyboardEvent) => { | ||||||
|   const fileExplorer = store.fileExplorer as any |   const fileExplorer = documentStore.fileExplorer as any | ||||||
|   if (!fileExplorer) return |   if (!fileExplorer) return | ||||||
|   const c = fileExplorer.isCursor() |   const c = fileExplorer.isCursor() | ||||||
|   const keyup = event.type === 'keyup' |   const keyup = event.type === 'keyup' | ||||||
| @@ -124,4 +119,3 @@ onUnmounted(() => { | |||||||
| }) | }) | ||||||
| export type { Path } | export type { Path } | ||||||
| </script> | </script> | ||||||
| @/stores/main |  | ||||||
| Before Width: | Height: | Size: 158 B After Width: | Height: | Size: 158 B | 
| Before Width: | Height: | Size: 168 B After Width: | Height: | Size: 168 B | 
| Before Width: | Height: | Size: 388 B After Width: | Height: | Size: 388 B | 
| Before Width: | Height: | Size: 128 B After Width: | Height: | Size: 128 B | 
| Before Width: | Height: | Size: 126 B After Width: | Height: | Size: 126 B | 
| Before Width: | Height: | Size: 158 B After Width: | Height: | Size: 158 B | 
| Before Width: | Height: | Size: 208 B After Width: | Height: | Size: 208 B | 
| Before Width: | Height: | Size: 563 B After Width: | Height: | Size: 563 B | 
| Before Width: | Height: | Size: 212 B After Width: | Height: | Size: 212 B | 
| Before Width: | Height: | Size: 293 B After Width: | Height: | Size: 293 B | 
| Before Width: | Height: | Size: 310 B After Width: | Height: | Size: 310 B | 
| Before Width: | Height: | Size: 193 B After Width: | Height: | Size: 193 B | 
| Before Width: | Height: | Size: 278 B After Width: | Height: | Size: 278 B | 
| Before Width: | Height: | Size: 711 B After Width: | Height: | Size: 711 B | 
| Before Width: | Height: | Size: 365 B After Width: | Height: | Size: 365 B | 
| Before Width: | Height: | Size: 783 B After Width: | Height: | Size: 783 B | 
| Before Width: | Height: | Size: 382 B After Width: | Height: | Size: 382 B | 
| Before Width: | Height: | Size: 200 B After Width: | Height: | Size: 200 B | 
| Before Width: | Height: | Size: 698 B After Width: | Height: | Size: 698 B | 
| Before Width: | Height: | Size: 156 B After Width: | Height: | Size: 156 B | 
| Before Width: | Height: | Size: 416 B After Width: | Height: | Size: 416 B | 
| Before Width: | Height: | Size: 517 B After Width: | Height: | Size: 517 B | 
| Before Width: | Height: | Size: 257 B After Width: | Height: | Size: 257 B | 
| Before Width: | Height: | Size: 297 B After Width: | Height: | Size: 297 B | 
| Before Width: | Height: | Size: 312 B After Width: | Height: | Size: 312 B | 
| Before Width: | Height: | Size: 109 B After Width: | Height: | Size: 109 B | 
| Before Width: | Height: | Size: 587 B After Width: | Height: | Size: 587 B | 
| Before Width: | Height: | Size: 269 B After Width: | Height: | Size: 269 B | 
| Before Width: | Height: | Size: 106 B After Width: | Height: | Size: 106 B | 
| Before Width: | Height: | Size: 393 B After Width: | Height: | Size: 393 B | 
| Before Width: | Height: | Size: 94 B After Width: | Height: | Size: 94 B | 
| Before Width: | Height: | Size: 229 B After Width: | Height: | Size: 229 B | 
| Before Width: | Height: | Size: 108 B After Width: | Height: | Size: 108 B | 
| Before Width: | Height: | Size: 407 B After Width: | Height: | Size: 407 B | 
| Before Width: | Height: | Size: 887 B After Width: | Height: | Size: 887 B | 
| Before Width: | Height: | Size: 908 B After Width: | Height: | Size: 908 B | 
| Before Width: | Height: | Size: 417 B After Width: | Height: | Size: 417 B | 
| Before Width: | Height: | Size: 554 B After Width: | Height: | Size: 554 B | 
| Before Width: | Height: | Size: 552 B After Width: | Height: | Size: 552 B | 
| Before Width: | Height: | Size: 114 B After Width: | Height: | Size: 114 B | 
| Before Width: | Height: | Size: 1.1 KiB After Width: | Height: | Size: 1.1 KiB | 
| Before Width: | Height: | Size: 91 B After Width: | Height: | Size: 91 B | 
| Before Width: | Height: | Size: 647 B After Width: | Height: | Size: 647 B | 
| Before Width: | Height: | Size: 95 B After Width: | Height: | Size: 95 B | 
| Before Width: | Height: | Size: 208 B After Width: | Height: | Size: 208 B | 
| Before Width: | Height: | Size: 104 B After Width: | Height: | Size: 104 B | 
| Before Width: | Height: | Size: 508 B After Width: | Height: | Size: 508 B | 
| Before Width: | Height: | Size: 1009 B After Width: | Height: | Size: 1009 B | 
| Before Width: | Height: | Size: 278 B After Width: | Height: | Size: 278 B | 
| Before Width: | Height: | Size: 753 B After Width: | Height: | Size: 753 B | 
| Before Width: | Height: | Size: 353 B After Width: | Height: | Size: 353 B | 
| Before Width: | Height: | Size: 542 B After Width: | Height: | Size: 542 B | 
| Before Width: | Height: | Size: 292 B After Width: | Height: | Size: 292 B | 
| Before Width: | Height: | Size: 621 B After Width: | Height: | Size: 621 B | 
| Before Width: | Height: | Size: 517 B After Width: | Height: | Size: 517 B | 
| Before Width: | Height: | Size: 289 B After Width: | Height: | Size: 289 B | 
| Before Width: | Height: | Size: 498 B After Width: | Height: | Size: 498 B | 
| Before Width: | Height: | Size: 464 B After Width: | Height: | Size: 464 B | 
| @@ -4,7 +4,7 @@ | |||||||
|     aria-label="Breadcrumb" |     aria-label="Breadcrumb" | ||||||
|     @keyup.left.stop="move(-1)" |     @keyup.left.stop="move(-1)" | ||||||
|     @keyup.right.stop="move(1)" |     @keyup.right.stop="move(1)" | ||||||
|     @keyup.enter="move(0)" |     @focus="move(0)" | ||||||
|   > |   > | ||||||
|     <a href="#/" |     <a href="#/" | ||||||
|       :ref="el => setLinkRef(0, el)" |       :ref="el => setLinkRef(0, el)" | ||||||
| @@ -46,13 +46,8 @@ const isCurrent = (index: number) => index == props.path.length ? 'location' : u | |||||||
| const navigate = (index: number) => { | const navigate = (index: number) => { | ||||||
|   const link = links[index] |   const link = links[index] | ||||||
|   if (!link) throw Error(`No link at index ${index} (path: ${props.path})`) |   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('/')}/` |  | ||||||
|   const current = decodeURIComponent(location.hash.slice(1).split('//')[0]) |  | ||||||
|   const u = url.replaceAll('?', '%3F').replaceAll('#', '%23') |  | ||||||
|   if (here.startsWith(current)) router.replace(u) |  | ||||||
|   else router.push(u) |  | ||||||
|   link.focus() |   link.focus() | ||||||
|  |   router.replace(`/${longest.value.slice(0, index).join('/')}`) | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| const move = (dir: number) => { | const move = (dir: number) => { | ||||||
| @@ -3,11 +3,34 @@ | |||||||
|     <thead> |     <thead> | ||||||
|       <tr> |       <tr> | ||||||
|         <th class="selection"> |         <th class="selection"> | ||||||
|           <input type="checkbox" tabindex="-1" v-model="allSelected" :indeterminate="selectionIndeterminate"> |           <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> | ||||||
|         <th class="sortcolumn" :class="{ sortactive: store.sortOrder === 'name' }" @click="store.toggleSort('name')">Name</th> |  | ||||||
|         <th class="sortcolumn modified right" :class="{ sortactive: store.sortOrder === 'modified' }" @click="store.toggleSort('modified')">Modified</th> |  | ||||||
|         <th class="sortcolumn size right" :class="{ sortactive: store.sortOrder === 'size' }" @click="store.toggleSort('size')">Size</th> |  | ||||||
|         <th class="menu"></th> |         <th class="menu"></th> | ||||||
|       </tr> |       </tr> | ||||||
|     </thead> |     </thead> | ||||||
| @@ -15,13 +38,27 @@ | |||||||
|       <tr v-if="editing?.key === 'new'" class="folder"> |       <tr v-if="editing?.key === 'new'" class="folder"> | ||||||
|         <td class="selection"></td> |         <td class="selection"></td> | ||||||
|         <td class="name"> |         <td class="name"> | ||||||
|           <FileRenameInput :doc="editing" :rename="mkdir" :exit="() => {editing = null}" /> |           <FileRenameInput | ||||||
|  |             :doc="editing" | ||||||
|  |             :rename="mkdir" | ||||||
|  |             :exit=" | ||||||
|  |               () => { | ||||||
|  |                 editing = null | ||||||
|  |               } | ||||||
|  |             " | ||||||
|  |           /> | ||||||
|         </td> |         </td> | ||||||
|         <FileModified :doc=editing :key=nowkey /> |         <td class="modified right"> | ||||||
|         <FileSize :doc=editing /> |           <time :datetime="new Date(editing.mtime).toISOString().replace('.000', '')">{{ | ||||||
|  |             editing.modified | ||||||
|  |           }}</time> | ||||||
|  |         </td> | ||||||
|  |         <td class="size right">{{ editing.sizedisp }}</td> | ||||||
|         <td class="menu"></td> |         <td class="menu"></td> | ||||||
|       </tr> |       </tr> | ||||||
|       <template v-for="(doc, index) in documents" :key="doc.key"> |       <template | ||||||
|  |         v-for="(doc, index) in sortedDocuments" | ||||||
|  |         :key="doc.key"> | ||||||
|         <tr class="folder-change" v-if="showFolderBreadcrumb(index)"> |         <tr class="folder-change" v-if="showFolderBreadcrumb(index)"> | ||||||
|           <th colspan="5"><BreadCrumb :path="doc.loc ? doc.loc.split('/') : []" /></th> |           <th colspan="5"><BreadCrumb :path="doc.loc ? doc.loc.split('/') : []" /></th> | ||||||
|         </tr> |         </tr> | ||||||
| @@ -36,21 +73,28 @@ | |||||||
|             <input |             <input | ||||||
|               type="checkbox" |               type="checkbox" | ||||||
|               tabindex="-1" |               tabindex="-1" | ||||||
|               :checked="store.selected.has(doc.key)" |               :checked="documentStore.selected.has(doc.key)" | ||||||
|               @change=" |               @change=" | ||||||
|                 ($event.target as HTMLInputElement).checked |                 ($event.target as HTMLInputElement).checked | ||||||
|                   ? store.selected.add(doc.key) |                   ? documentStore.selected.add(doc.key) | ||||||
|                   : store.selected.delete(doc.key) |                   : documentStore.selected.delete(doc.key) | ||||||
|               " |               " | ||||||
|             /> |             /> | ||||||
|           </td> |           </td> | ||||||
|           <td class="name"> |           <td class="name"> | ||||||
|             <template v-if="editing === doc"> |             <template v-if="editing === doc" | ||||||
|               <FileRenameInput :doc="doc" :rename="rename" :exit="() => {editing = null}" /> |               ><FileRenameInput | ||||||
|             </template> |                 :doc="doc" | ||||||
|  |                 :rename="rename" | ||||||
|  |                 :exit=" | ||||||
|  |                   () => { | ||||||
|  |                     editing = null | ||||||
|  |                   } | ||||||
|  |                 " | ||||||
|  |             /></template> | ||||||
|             <template v-else> |             <template v-else> | ||||||
|               <a |               <a | ||||||
|                 :href="doc.url" |                 :href="url_for(doc)" | ||||||
|                 tabindex="-1" |                 tabindex="-1" | ||||||
|                 @contextmenu.prevent |                 @contextmenu.prevent | ||||||
|                 @focus.stop="cursor = doc" |                 @focus.stop="cursor = doc" | ||||||
| @@ -58,13 +102,29 @@ | |||||||
|                 @keyup.right.stop="ev => { if (doc.dir) (ev.target as HTMLElement).click() }" |                 @keyup.right.stop="ev => { if (doc.dir) (ev.target as HTMLElement).click() }" | ||||||
|                 >{{ doc.name }}</a |                 >{{ 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> |             </template> | ||||||
|           </td> |           </td> | ||||||
|           <FileModified :doc=doc :key=nowkey /> |           <td class="modified right"> | ||||||
|           <FileSize :doc=doc /> |             <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> | ||||||
|           <td class="menu"> |           <td class="menu"> | ||||||
|             <button tabindex="-1" @click.stop="contextMenu($event, doc)">⋮</button> |             <button | ||||||
|  |               tabindex="-1" | ||||||
|  |               @click.stop="contextMenu($event, doc)" | ||||||
|  |             > | ||||||
|  |               ⋮ | ||||||
|  |             </button> | ||||||
|           </td> |           </td> | ||||||
|         </tr> |         </tr> | ||||||
|       </template> |       </template> | ||||||
| @@ -79,26 +139,31 @@ | |||||||
| </template> | </template> | ||||||
| 
 | 
 | ||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import { ref, computed, watchEffect, shallowRef, onMounted, onUnmounted } from 'vue' | import { ref, computed, watchEffect } from 'vue' | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| import { Doc } from '@/repositories/Document' | import type { Document } from '@/repositories/Document' | ||||||
| import FileRenameInput from './FileRenameInput.vue' | import FileRenameInput from './FileRenameInput.vue' | ||||||
| import { connect, controlUrl } from '@/repositories/WS' | import { connect, controlUrl } from '@/repositories/WS' | ||||||
| import { formatSize } from '@/utils' | import { collator, formatSize, formatUnixDate } from '@/utils' | ||||||
| import { useRouter } from 'vue-router' | import { useRouter } from 'vue-router' | ||||||
| import ContextMenu from '@imengyu/vue3-context-menu' |  | ||||||
| import type { SortOrder } from '@/utils/docsort' |  | ||||||
| 
 | 
 | ||||||
| const props = defineProps<{ | const props = withDefaults( | ||||||
|   path: Array<string> |   defineProps<{ | ||||||
|   documents: Doc[] |     path: Array<string> | ||||||
| }>() |     documents: Document[] | ||||||
| const store = useMainStore() |   }>(), | ||||||
|  |   {} | ||||||
|  | ) | ||||||
|  | const documentStore = useDocumentStore() | ||||||
| const router = useRouter() | const router = useRouter() | ||||||
| const cursor = shallowRef<Doc | null>(null) | const url_for = (doc: Document) => { | ||||||
|  |   const p = doc.loc ? `${doc.loc}/${doc.name}` : doc.name | ||||||
|  |   return doc.dir ? `#/${p}/` : `/files/${p}` | ||||||
|  | } | ||||||
|  | const cursor = ref<Document | null>(null) | ||||||
| // File rename | // File rename | ||||||
| const editing = shallowRef<Doc | null>(null) | const editing = ref<Document | null>(null) | ||||||
| const rename = (doc: Doc, newName: string) => { | const rename = (doc: Document, newName: string) => { | ||||||
|   const oldName = doc.name |   const oldName = doc.name | ||||||
|   const control = connect(controlUrl, { |   const control = connect(controlUrl, { | ||||||
|     message(ev: MessageEvent) { |     message(ev: MessageEvent) { | ||||||
| @@ -122,25 +187,35 @@ const rename = (doc: Doc, newName: string) => { | |||||||
|   } |   } | ||||||
|   doc.name = newName // We should get an update from watch but this is quicker |   doc.name = newName // We should get an update from watch but this is quicker | ||||||
| } | } | ||||||
|  | const sortedDocuments = computed(() => sorted(props.documents as Document[])) | ||||||
|  | const showFolderBreadcrumb = (i: number) => { | ||||||
|  |   const docs = sortedDocuments.value | ||||||
|  |   const docloc = docs[i].loc | ||||||
|  |   return i === 0 ? docloc !== loc.value : docloc !== docs[i - 1].loc | ||||||
|  | } | ||||||
| defineExpose({ | defineExpose({ | ||||||
|   newFolder() { |   newFolder() { | ||||||
|     const now = Math.floor(Date.now() / 1000) |     const now = Date.now() / 1000 | ||||||
|     editing.value = new Doc({ |     editing.value = { | ||||||
|       loc: loc.value, |       loc: loc.value, | ||||||
|       key: 'new', |       key: 'new', | ||||||
|       name: 'New Folder', |       name: 'New Folder', | ||||||
|       dir: true, |       dir: true, | ||||||
|       mtime: now, |       mtime: now, | ||||||
|       size: 0, |       size: 0, | ||||||
|     }) |       sizedisp: formatSize(0), | ||||||
|  |       modified: formatUnixDate(now), | ||||||
|  |       haystack: '', | ||||||
|  |     } | ||||||
|  |     console.log("New") | ||||||
|   }, |   }, | ||||||
|   toggleSelectAll() { |   toggleSelectAll() { | ||||||
|     console.log('Select') |     console.log('Select') | ||||||
|     allSelected.value = !allSelected.value |     allSelected.value = !allSelected.value | ||||||
|   }, |   }, | ||||||
|   toggleSortColumn(column: number) { |   toggleSortColumn(column: number) { | ||||||
|     const order = ['', 'name', 'modified', 'size', ''][column] |     const columns = ['', 'name', 'modified', 'size', ''] | ||||||
|     if (order) store.toggleSort(order as SortOrder) |     toggleSort(columns[column]) | ||||||
|   }, |   }, | ||||||
|   isCursor() { |   isCursor() { | ||||||
|     return cursor.value !== null && editing.value === null |     return cursor.value !== null && editing.value === null | ||||||
| @@ -151,36 +226,36 @@ defineExpose({ | |||||||
|   cursorSelect() { |   cursorSelect() { | ||||||
|     const doc = cursor.value |     const doc = cursor.value | ||||||
|     if (!doc) return |     if (!doc) return | ||||||
|     if (store.selected.has(doc.key)) { |     if (documentStore.selected.has(doc.key)) { | ||||||
|       store.selected.delete(doc.key) |       documentStore.selected.delete(doc.key) | ||||||
|     } else { |     } else { | ||||||
|       store.selected.add(doc.key) |       documentStore.selected.add(doc.key) | ||||||
|     } |     } | ||||||
|     this.cursorMove(1) |     this.cursorMove(1) | ||||||
|   }, |   }, | ||||||
|   cursorMove(d: number, select = false) { |   cursorMove(d: number, select = false) { | ||||||
|     // Move cursor up or down (keyboard navigation) |     // Move cursor up or down (keyboard navigation) | ||||||
|     const docs = props.documents |     const documents = sortedDocuments.value | ||||||
|     if (docs.length === 0) { |     if (documents.length === 0) { | ||||||
|       cursor.value = null |       cursor.value = null | ||||||
|       return |       return | ||||||
|     } |     } | ||||||
|     const N = docs.length |     const N = documents.length | ||||||
|     const mod = (a: number, b: number) => ((a % b) + b) % b |     const mod = (a: number, b: number) => ((a % b) + b) % b | ||||||
|     const increment = (i: number, d: number) => mod(i + d, N + 1) |     const increment = (i: number, d: number) => mod(i + d, N + 1) | ||||||
|     const index = |     const index = | ||||||
|       cursor.value !== null ? docs.indexOf(cursor.value) : docs.length |       cursor.value !== null ? documents.indexOf(cursor.value) : documents.length | ||||||
|     const moveto = increment(index, d) |     const moveto = increment(index, d) | ||||||
|     cursor.value = docs[moveto] ?? null |     cursor.value = documents[moveto] ?? null | ||||||
|     const tr = cursor.value ? document.getElementById(`file-${cursor.value.key}`) : null |     const tr = cursor.value ? document.getElementById(`file-${cursor.value.key}`) : null | ||||||
|     if (select) { |     if (select) { | ||||||
|       // Go forwards, possibly wrapping over the end; the last entry is not toggled |       // Go forwards, possibly wrapping over the end; the last entry is not toggled | ||||||
|       let [begin, end] = d > 0 ? [index, moveto] : [moveto, index] |       let [begin, end] = d > 0 ? [index, moveto] : [moveto, index] | ||||||
|       for (let p = begin; p !== end; p = increment(p, 1)) { |       for (let p = begin; p !== end; p = increment(p, 1)) { | ||||||
|         if (p === N) continue |         if (p === N) continue | ||||||
|         const key = docs[p].key |         const key = documents[p].key | ||||||
|         if (store.selected.has(key)) store.selected.delete(key) |         if (documentStore.selected.has(key)) documentStore.selected.delete(key) | ||||||
|         else store.selected.add(key) |         else documentStore.selected.add(key) | ||||||
|       } |       } | ||||||
|     } |     } | ||||||
|     // @ts-ignore |     // @ts-ignore | ||||||
| @@ -217,14 +292,7 @@ watchEffect(() => { | |||||||
|     focusBreadcrumb() |     focusBreadcrumb() | ||||||
|   } |   } | ||||||
| }) | }) | ||||||
| let nowkey = ref(0) | const mkdir = (doc: Document, name: string) => { | ||||||
| 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, { |   const control = connect(controlUrl, { | ||||||
|     open() { |     open() { | ||||||
|       control.send( |       control.send( | ||||||
| @@ -241,24 +309,34 @@ const mkdir = (doc: Doc, name: string) => { | |||||||
|         editing.value = null |         editing.value = null | ||||||
|       } else { |       } else { | ||||||
|         console.log('mkdir', msg) |         console.log('mkdir', msg) | ||||||
|         router.push(doc.urlrouter) |         router.push(`/${doc.loc}/${name}/`) | ||||||
|       } |       } | ||||||
|     } |     } | ||||||
|   }) |   }) | ||||||
|   // We should get an update from watch but this is quicker |   doc.name = name // 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 | // Column sort | ||||||
|   const docloc = docs[i].loc | const toggleSort = (name: string) => { | ||||||
|   return i === 0 ? docloc !== loc.value : docloc !== docs[i - 1].loc |   sort.value = sort.value === name ? '' : name | ||||||
|  | } | ||||||
|  | const sort = ref<string>('') | ||||||
|  | const sortCompare = { | ||||||
|  |   name: (a: Document, b: Document) => collator.compare(a.name, b.name), | ||||||
|  |   modified: (a: Document, b: Document) => b.mtime - a.mtime, | ||||||
|  |   size: (a: Document, b: Document) => b.size - a.size | ||||||
|  | } | ||||||
|  | const sorted = (documents: Document[]) => { | ||||||
|  |   const cmp = sortCompare[sort.value as keyof typeof sortCompare] | ||||||
|  |   const sorted = [...documents] | ||||||
|  |   if (cmp) sorted.sort(cmp) | ||||||
|  |   return sorted | ||||||
| } | } | ||||||
| const selectionIndeterminate = computed({ | const selectionIndeterminate = computed({ | ||||||
|   get: () => { |   get: () => { | ||||||
|     return ( |     return ( | ||||||
|       props.documents.length > 0 && |       props.documents.length > 0 && | ||||||
|       props.documents.some((doc: Doc) => store.selected.has(doc.key)) && |       props.documents.some((doc: Document) => documentStore.selected.has(doc.key)) && | ||||||
|       !allSelected.value |       !allSelected.value | ||||||
|     ) |     ) | ||||||
|   }, |   }, | ||||||
| @@ -269,16 +347,16 @@ const allSelected = computed({ | |||||||
|   get: () => { |   get: () => { | ||||||
|     return ( |     return ( | ||||||
|       props.documents.length > 0 && |       props.documents.length > 0 && | ||||||
|       props.documents.every((doc: Doc) => store.selected.has(doc.key)) |       props.documents.every((doc: Document) => documentStore.selected.has(doc.key)) | ||||||
|     ) |     ) | ||||||
|   }, |   }, | ||||||
|   set: (value: boolean) => { |   set: (value: boolean) => { | ||||||
|     console.log('Setting allSelected', value) |     console.log('Setting allSelected', value) | ||||||
|     for (const doc of props.documents) { |     for (const doc of props.documents) { | ||||||
|       if (value) { |       if (value) { | ||||||
|         store.selected.add(doc.key) |         documentStore.selected.add(doc.key) | ||||||
|       } else { |       } else { | ||||||
|         store.selected.delete(doc.key) |         documentStore.selected.delete(doc.key) | ||||||
|       } |       } | ||||||
|     } |     } | ||||||
|   } |   } | ||||||
| @@ -286,13 +364,9 @@ const allSelected = computed({ | |||||||
| 
 | 
 | ||||||
| const loc = computed(() => props.path.join('/')) | const loc = computed(() => props.path.join('/')) | ||||||
| 
 | 
 | ||||||
| const contextMenu = (ev: MouseEvent, doc: Doc) => { | const contextMenu = (ev: Event, doc: Document) => { | ||||||
|   cursor.value = doc |   cursor.value = doc | ||||||
|   ContextMenu.showContextMenu({ |   console.log('Context menu', ev, doc) | ||||||
|     x: ev.x, y: ev.y, items: [ |  | ||||||
|       { label: 'Rename', onClick: () => { editing.value = doc } }, |  | ||||||
|     ], |  | ||||||
|   }) |  | ||||||
| } | } | ||||||
| </script> | </script> | ||||||
| 
 | 
 | ||||||
| @@ -326,7 +400,7 @@ table .selection { | |||||||
|   text-overflow: clip; |   text-overflow: clip; | ||||||
| } | } | ||||||
| table .modified { | table .modified { | ||||||
|   width: 9em; |   width: 8em; | ||||||
| } | } | ||||||
| table .size { | table .size { | ||||||
|   width: 5em; |   width: 5em; | ||||||
| @@ -440,4 +514,3 @@ tbody .selection input { | |||||||
|   color: #888; |   color: #888; | ||||||
| } | } | ||||||
| </style> | </style> | ||||||
| @/stores/main |  | ||||||
| @@ -12,7 +12,7 @@ | |||||||
| </template> | </template> | ||||||
| 
 | 
 | ||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import { Doc } from '@/repositories/Document' | import type { Document } from '@/repositories/Document' | ||||||
| import { ref, onMounted, nextTick } from 'vue' | import { ref, onMounted, nextTick } from 'vue' | ||||||
| 
 | 
 | ||||||
| const input = ref<HTMLInputElement | null>(null) | const input = ref<HTMLInputElement | null>(null) | ||||||
| @@ -28,8 +28,8 @@ onMounted(() => { | |||||||
| }) | }) | ||||||
| 
 | 
 | ||||||
| const props = defineProps<{ | const props = defineProps<{ | ||||||
|   doc: Doc |   doc: Document | ||||||
|   rename: (doc: Doc, newName: string) => void |   rename: (doc: Document, newName: string) => void | ||||||
|   exit: () => void |   exit: () => void | ||||||
| }>() | }>() | ||||||
| 
 | 
 | ||||||
							
								
								
									
										52
									
								
								cista-front/src/components/FileViewer.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						| @@ -0,0 +1,52 @@ | |||||||
|  | <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> | ||||||
| @@ -1,15 +1,15 @@ | |||||||
| <template> | <template> | ||||||
|   <nav class="headermain"> |   <nav class="headermain"> | ||||||
|     <div class="buttons"> |     <div class="buttons"> | ||||||
|       <template v-if="store.error"> |       <template v-if="documentStore.error"> | ||||||
|         <div class="error-message" @click="store.error = ''">{{ store.error }}</div> |         <div class="error-message" @click="documentStore.error = ''">{{ documentStore.error }}</div> | ||||||
|         <div class="smallgap"></div> |         <div class="smallgap"></div> | ||||||
|       </template> |       </template> | ||||||
|       <UploadButton :path="props.path" /> |       <UploadButton :path="props.path" /> | ||||||
|       <SvgButton |       <SvgButton | ||||||
|         name="create-folder" |         name="create-folder" | ||||||
|         data-tooltip="New folder" |         data-tooltip="New folder" | ||||||
|         @click="() => store.fileExplorer!.newFolder()" |         @click="() => documentStore.fileExplorer.newFolder()" | ||||||
|       /> |       /> | ||||||
|       <slot></slot> |       <slot></slot> | ||||||
|       <div class="spacer smallgap"></div> |       <div class="spacer smallgap"></div> | ||||||
| @@ -17,8 +17,7 @@ | |||||||
|         <input |         <input | ||||||
|           ref="search" |           ref="search" | ||||||
|           type="search" |           type="search" | ||||||
|           :value="query" |           v-model="documentStore.search" | ||||||
|           @input="updateSearch" |  | ||||||
|           placeholder="Search words" |           placeholder="Search words" | ||||||
|           class="margin-input" |           class="margin-input" | ||||||
|           @keyup.escape="closeSearch" |           @keyup.escape="closeSearch" | ||||||
| @@ -31,54 +30,38 @@ | |||||||
| </template> | </template> | ||||||
| 
 | 
 | ||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| import { ref, nextTick, watchEffect } from 'vue' | import { ref, nextTick } from 'vue' | ||||||
| import ContextMenu from '@imengyu/vue3-context-menu' | import ContextMenu from '@imengyu/vue3-context-menu' | ||||||
| import router from '@/router'; |  | ||||||
| 
 | 
 | ||||||
| const store = useMainStore() | const documentStore = useDocumentStore() | ||||||
| const showSearchInput = ref<boolean>(false) | const showSearchInput = ref<boolean>(false) | ||||||
| const search = ref<HTMLInputElement | null>() | const search = ref<HTMLInputElement | null>() | ||||||
| const searchButton = ref<HTMLButtonElement | null>() | const searchButton = ref<HTMLButtonElement | null>() | ||||||
|   const props = defineProps<{ |  | ||||||
|   path: Array<string> |  | ||||||
|   query: string |  | ||||||
| }>() |  | ||||||
| 
 | 
 | ||||||
| const closeSearch = (ev: Event) => { | const closeSearch = () => { | ||||||
|   if (!showSearchInput.value) return  // Already closing |   if (!showSearchInput.value) return  // Already closing | ||||||
|   showSearchInput.value = false |   showSearchInput.value = false | ||||||
|  |   documentStore.search = '' | ||||||
|   const breadcrumb = document.querySelector('.breadcrumb') as HTMLElement |   const breadcrumb = document.querySelector('.breadcrumb') as HTMLElement | ||||||
|   breadcrumb.focus() |   breadcrumb.focus() | ||||||
|   updateSearch(ev) |  | ||||||
| } | } | ||||||
| const updateSearch = (ev: Event) => { | const toggleSearchInput = () => { | ||||||
|   const q = (ev.target as HTMLInputElement).value |  | ||||||
|   let p = props.path.join('/') |  | ||||||
|   p = p ? `/${p}` : '' |  | ||||||
|   const url = q ? `${p}//${q}` : (p || '/') |  | ||||||
|   const u = url.replaceAll('?', '%3F').replaceAll('#', '%23') |  | ||||||
|   if (!props.query && q) router.push(u) |  | ||||||
|   else router.replace(u) |  | ||||||
| } |  | ||||||
| const toggleSearchInput = (ev: Event) => { |  | ||||||
|   showSearchInput.value = !showSearchInput.value |   showSearchInput.value = !showSearchInput.value | ||||||
|   if (!showSearchInput.value) return closeSearch(ev) |   if (!showSearchInput.value) return closeSearch() | ||||||
|   nextTick(() => { |   nextTick(() => { | ||||||
|     const input = search.value |     const input = search.value | ||||||
|     if (input) input.focus() |     if (input) input.focus() | ||||||
|   }) |   }) | ||||||
| } | } | ||||||
| watchEffect(() => { | 
 | ||||||
|   if (props.query) showSearchInput.value = true |  | ||||||
| }) |  | ||||||
| const settingsMenu = (e: Event) => { | const settingsMenu = (e: Event) => { | ||||||
|   // show the context menu |   // show the context menu | ||||||
|   const items = [] |   const items = [] | ||||||
|   if (store.user.isLoggedIn) { |   if (documentStore.user.isLoggedIn) { | ||||||
|     items.push({ label: `Logout ${store.user.username ?? ''}`, onClick: () => store.logout() }) |     items.push({ label: `Logout ${documentStore.user.username ?? ''}`, onClick: () => documentStore.logout() }) | ||||||
|   } else { |   } else { | ||||||
|     items.push({ label: 'Login', onClick: () => store.loginDialog() }) |     items.push({ label: 'Login', onClick: () => documentStore.loginDialog() }) | ||||||
|   } |   } | ||||||
|   ContextMenu.showContextMenu({ |   ContextMenu.showContextMenu({ | ||||||
|     // @ts-ignore |     // @ts-ignore | ||||||
| @@ -86,6 +69,10 @@ const settingsMenu = (e: Event) => { | |||||||
|     items, |     items, | ||||||
|   }) |   }) | ||||||
| } | } | ||||||
|  | const props = defineProps({ | ||||||
|  |   path: Array<string> | ||||||
|  | }) | ||||||
|  | 
 | ||||||
| defineExpose({ | defineExpose({ | ||||||
|   toggleSearchInput, |   toggleSearchInput, | ||||||
|   closeSearch, |   closeSearch, | ||||||
| @@ -114,4 +101,3 @@ input[type='search'] { | |||||||
|   max-width: 30vw; |   max-width: 30vw; | ||||||
| } | } | ||||||
| </style> | </style> | ||||||
| @/stores/main |  | ||||||
| @@ -1,29 +1,29 @@ | |||||||
| <template> | <template> | ||||||
|   <template v-if="store.selected.size"> |   <template v-if="documentStore.selected.size"> | ||||||
|     <div class="smallgap"></div> |     <div class="smallgap"></div> | ||||||
|     <p class="select-text">{{ store.selected.size }} selected ➤</p> |     <p class="select-text">{{ documentStore.selected.size }} selected ➤</p> | ||||||
|     <SvgButton name="download" data-tooltip="Download" @click="download" /> |     <SvgButton name="download" data-tooltip="Download" @click="download" /> | ||||||
|     <SvgButton name="copy" data-tooltip="Copy here" @click="op('cp', dst)" /> |     <SvgButton name="copy" data-tooltip="Copy here" @click="op('cp', dst)" /> | ||||||
|     <SvgButton name="paste" data-tooltip="Move here" @click="op('mv', dst)" /> |     <SvgButton name="paste" data-tooltip="Move here" @click="op('mv', dst)" /> | ||||||
|     <SvgButton name="trash" data-tooltip="Delete ⚠️" @click="op('rm')" /> |     <SvgButton name="trash" data-tooltip="Delete ⚠️" @click="op('rm')" /> | ||||||
|     <button class="action-button unselect" data-tooltip="Unselect all" @click="store.selected.clear()">❌</button> |     <button class="action-button unselect" data-tooltip="Unselect all" @click="documentStore.selected.clear()">❌</button> | ||||||
|   </template> |   </template> | ||||||
| </template> | </template> | ||||||
| 
 | 
 | ||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import {connect, controlUrl} from '@/repositories/WS' | import {connect, controlUrl} from '@/repositories/WS' | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| import { computed } from 'vue' | import { computed } from 'vue' | ||||||
| import type { SelectedItems } from '@/repositories/Document' | import type { SelectedItems } from '@/repositories/Document' | ||||||
| 
 | 
 | ||||||
| const store = useMainStore() | const documentStore = useDocumentStore() | ||||||
| const props = defineProps({ | const props = defineProps({ | ||||||
|   path: Array<string> |   path: Array<string> | ||||||
| }) | }) | ||||||
| 
 | 
 | ||||||
| const dst = computed(() => props.path!.join('/')) | const dst = computed(() => props.path!.join('/')) | ||||||
| const op = (op: string, dst?: string) => { | const op = (op: string, dst?: string) => { | ||||||
|   const sel = store.selectedFiles |   const sel = documentStore.selectedFiles | ||||||
|   const msg = { |   const msg = { | ||||||
|     op, |     op, | ||||||
|     sel: sel.keys.map(key => { |     sel: sel.keys.map(key => { | ||||||
| @@ -34,16 +34,16 @@ const op = (op: string, dst?: string) => { | |||||||
|   // @ts-ignore |   // @ts-ignore | ||||||
|   if (dst !== undefined) msg.dst = dst |   if (dst !== undefined) msg.dst = dst | ||||||
|   const control = connect(controlUrl, { |   const control = connect(controlUrl, { | ||||||
|     message(ev: MessageEvent) { |     message(ev: WebSocmetMessageEvent) { | ||||||
|       const res = JSON.parse(ev.data) |       const res = JSON.parse(ev.data) | ||||||
|       if ('error' in res) { |       if ('error' in res) { | ||||||
|         console.error('Control socket error', msg, res.error) |         console.error('Control socket error', msg, res.error) | ||||||
|         store.error = res.error.message |         documentStore.error = res.error.message | ||||||
|         return |         return | ||||||
|       } else if (res.status === 'ack') { |       } else if (res.status === 'ack') { | ||||||
|         console.log('Control ack OK', res) |         console.log('Control ack OK', res) | ||||||
|         control.close() |         control.close() | ||||||
|         store.selected.clear() |         documentStore.selected.clear() | ||||||
|         return |         return | ||||||
|       } else console.log('Unknown control response', msg, res) |       } else console.log('Unknown control response', msg, res) | ||||||
|     } |     } | ||||||
| @@ -108,17 +108,17 @@ const filesystemdl = async (sel: SelectedItems, handle: FileSystemDirectoryHandl | |||||||
| } | } | ||||||
| 
 | 
 | ||||||
| const download = async () => { | const download = async () => { | ||||||
|   const sel = store.selectedFiles |   const sel = documentStore.selectedFiles | ||||||
|   console.log('Download', sel) |   console.log('Download', sel) | ||||||
|   if (sel.keys.length === 0) { |   if (sel.keys.length === 0) { | ||||||
|     console.warn('Attempted download but no files found. Missing selected keys:', sel.missing) |     console.warn('Attempted download but no files found. Missing selected keys:', sel.missing) | ||||||
|     store.selected.clear() |     documentStore.selected.clear() | ||||||
|     return |     return | ||||||
|   } |   } | ||||||
|   // Plain old a href download if only one file (ignoring any folders) |   // Plain old a href download if only one file (ignoring any folders) | ||||||
|   const files = sel.recursive.filter(([rel, full, doc]) => !doc.dir) |   const files = sel.recursive.filter(([rel, full, doc]) => !doc.dir) | ||||||
|   if (files.length === 1) { |   if (files.length === 1) { | ||||||
|     store.selected.clear() |     documentStore.selected.clear() | ||||||
|     return linkdl(`/files/${files[0][1]}`) |     return linkdl(`/files/${files[0][1]}`) | ||||||
|   } |   } | ||||||
|   // Use FileSystem API if multiple files and the browser supports it |   // Use FileSystem API if multiple files and the browser supports it | ||||||
| @@ -130,7 +130,7 @@ const download = async () => { | |||||||
|         mode: 'readwrite' |         mode: 'readwrite' | ||||||
|       }) |       }) | ||||||
|       filesystemdl(sel, handle).then(() => { |       filesystemdl(sel, handle).then(() => { | ||||||
|         store.selected.clear() |         documentStore.selected.clear() | ||||||
|       }) |       }) | ||||||
|       return |       return | ||||||
|     } catch (e) { |     } catch (e) { | ||||||
| @@ -140,7 +140,7 @@ const download = async () => { | |||||||
|   // Otherwise, zip and download |   // Otherwise, zip and download | ||||||
|   const name = sel.keys.length === 1 ? sel.docs[sel.keys[0]].name : 'download' |   const name = sel.keys.length === 1 ? sel.docs[sel.keys[0]].name : 'download' | ||||||
|   linkdl(`/zip/${Array.from(sel.keys).join('+')}/${name}.zip`) |   linkdl(`/zip/${Array.from(sel.keys).join('+')}/${name}.zip`) | ||||||
|   store.selected.clear() |   documentStore.selected.clear() | ||||||
| } | } | ||||||
| </script> | </script> | ||||||
| 
 | 
 | ||||||
| @@ -152,4 +152,3 @@ const download = async () => { | |||||||
|   text-overflow: ellipsis; |   text-overflow: ellipsis; | ||||||
| } | } | ||||||
| </style> | </style> | ||||||
| @/stores/main |  | ||||||
| @@ -39,10 +39,10 @@ | |||||||
| import { reactive, ref } from 'vue' | import { reactive, ref } from 'vue' | ||||||
| import { loginUser } from '@/repositories/User' | import { loginUser } from '@/repositories/User' | ||||||
| import type { ISimpleError } from '@/repositories/Client' | import type { ISimpleError } from '@/repositories/Client' | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| 
 | 
 | ||||||
| const confirmLoading = ref<boolean>(false) | const confirmLoading = ref<boolean>(false) | ||||||
| const store = useMainStore() | const store = useDocumentStore() | ||||||
| 
 | 
 | ||||||
| const loginForm = reactive({ | const loginForm = reactive({ | ||||||
|   username: '', |   username: '', | ||||||
| @@ -99,4 +99,3 @@ const login = async () => { | |||||||
|   height: 1em; |   height: 1em; | ||||||
| } | } | ||||||
| </style> | </style> | ||||||
| @/stores/main |  | ||||||
							
								
								
									
										27
									
								
								cista-front/src/components/NotificationLoading.vue
									
									
									
									
									
										Normal file
									
								
							
							
						
						| @@ -0,0 +1,27 @@ | |||||||
|  | <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> | ||||||
| @@ -1,89 +1,39 @@ | |||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import { connect, uploadUrl } from '@/repositories/WS'; | import { connect, uploadUrl } from '@/repositories/WS'; | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| import { collator } from '@/utils'; | import { collator } from '@/utils'; | ||||||
| import { computed, onMounted, onUnmounted, reactive, ref } from 'vue' | import { computed, onMounted, onUnmounted, reactive, ref } from 'vue' | ||||||
| 
 | 
 | ||||||
| const fileInput = ref() | const fileInput = ref() | ||||||
| const folderInput = ref() | const folderInput = ref() | ||||||
| const store = useMainStore() | const documentStore = useDocumentStore() | ||||||
| const props = defineProps({ | const props = defineProps({ | ||||||
|   path: Array<string> |   path: Array<string> | ||||||
| }) | }) | ||||||
| 
 | 
 | ||||||
| type CloudFile = { | 
 | ||||||
|   file: File |  | ||||||
|   cloudName: string |  | ||||||
|   cloudPos: number |  | ||||||
| } |  | ||||||
| function pasteHandler(event: ClipboardEvent) { |  | ||||||
|   const items = Array.from(event.clipboardData?.items ?? []) |  | ||||||
|   const infiles = [] as File[] |  | ||||||
|   const dirs = [] as FileSystemDirectoryEntry[] |  | ||||||
|   for (const item of items) { |  | ||||||
|     if (item.kind !== 'file') continue |  | ||||||
|     const entry = item.webkitGetAsEntry() |  | ||||||
|     if (entry?.isFile) { |  | ||||||
|       const file = item.getAsFile() |  | ||||||
|       if (file) infiles.push(file) |  | ||||||
|     } else if (entry?.isDirectory) { |  | ||||||
|       dirs.push(entry as FileSystemDirectoryEntry) |  | ||||||
|     } |  | ||||||
|   } |  | ||||||
|   if (infiles.length || dirs.length) { |  | ||||||
|     event.preventDefault() |  | ||||||
|     uploadFiles(infiles) |  | ||||||
|     for (const entry of dirs) pasteDirectory(entry, `${props.path!.join('/')}/${entry.name}`) |  | ||||||
|   } |  | ||||||
| } |  | ||||||
| const pasteDirectory = async (entry: FileSystemDirectoryEntry, loc: string) => { |  | ||||||
|   const reader = entry.createReader() |  | ||||||
|   const entries = await new Promise<any[]>(resolve => reader.readEntries(resolve)) |  | ||||||
|   const cloudfiles = [] as CloudFile[] |  | ||||||
|   for (const entry of entries) { |  | ||||||
|     const cloudName = `${loc}/${entry.name}` |  | ||||||
|     if (entry.isFile) { |  | ||||||
|       const file = await new Promise(resolve => entry.file(resolve)) as File |  | ||||||
|       cloudfiles.push({file, cloudName, cloudPos: 0}) |  | ||||||
|     } else if (entry.isDirectory) { |  | ||||||
|       await pasteDirectory(entry, cloudName) |  | ||||||
|     } |  | ||||||
|   } |  | ||||||
|   if (cloudfiles.length) uploadCloudFiles(cloudfiles) |  | ||||||
| } |  | ||||||
| function uploadHandler(event: Event) { | function uploadHandler(event: Event) { | ||||||
|   event.preventDefault() |   event.preventDefault() | ||||||
|  |   event.stopPropagation() | ||||||
|   // @ts-ignore |   // @ts-ignore | ||||||
|   const input = event.target as HTMLInputElement | null |   let infiles = Array.from(event.dataTransfer?.files || event.target.files) as File[] | ||||||
|   const infiles = Array.from((input ?? (event as DragEvent).dataTransfer)?.files ?? []) as File[] |   if (!infiles.length) return | ||||||
|   if (input) input.value = '' |  | ||||||
|   if (infiles.length) uploadFiles(infiles) |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| const uploadFiles = (infiles: File[]) => { |  | ||||||
|   const loc = props.path!.join('/') |   const loc = props.path!.join('/') | ||||||
|   let files = [] |   for (const f of infiles) { | ||||||
|   for (const file of infiles) { |     f.cloudName = loc + '/' + (f.webkitRelativePath || f.name) | ||||||
|     files.push({ |     f.cloudPos = 0 | ||||||
|       file, |  | ||||||
|       cloudName: loc + '/' + (file.webkitRelativePath || file.name), |  | ||||||
|       cloudPos: 0, |  | ||||||
|     }) |  | ||||||
|   } |   } | ||||||
|   uploadCloudFiles(files) |   const dotfiles = infiles.filter(f => f.cloudName.includes('/.')) | ||||||
| } |  | ||||||
| const uploadCloudFiles = (files: CloudFile[]) => { |  | ||||||
|   const dotfiles = files.filter(f => f.cloudName.includes('/.')) |  | ||||||
|   if (dotfiles.length) { |   if (dotfiles.length) { | ||||||
|     store.error = "Won't upload dotfiles" |     documentStore.error = "Won't upload dotfiles" | ||||||
|     console.log("Dotfiles omitted", dotfiles) |     console.log("Dotfiles omitted", dotfiles) | ||||||
|     files = files.filter(f => !f.cloudName.includes('/.')) |     infiles = infiles.filter(f => !f.cloudName.includes('/.')) | ||||||
|   } |   } | ||||||
|   if (!files.length) return |   if (!infiles.length) return | ||||||
|   files.sort((a, b) => collator.compare(a.cloudName, b.cloudName)) |   infiles.sort((a, b) => collator.compare(a.cloudName, b.cloudName)) | ||||||
|   // @ts-ignore |   // @ts-ignore | ||||||
|   upqueue = [...upqueue, ...files] |   upqueue = upqueue.concat(infiles) | ||||||
|   statsAdd(files) |   statsAdd(infiles) | ||||||
|   startWorker() |   startWorker() | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| @@ -99,14 +49,13 @@ const uprogress_init = { | |||||||
|   tlast: 0, |   tlast: 0, | ||||||
|   statbytes: 0, |   statbytes: 0, | ||||||
|   statdur: 0, |   statdur: 0, | ||||||
|   files: [] as CloudFile[], |   files: [], | ||||||
|   filestart: 0, |   filestart: 0, | ||||||
|   fileidx: 0, |   fileidx: 0, | ||||||
|   filecount: 0, |   filecount: 0, | ||||||
|   filename: '', |   filename: '', | ||||||
|   filesize: 0, |   filesize: 0, | ||||||
|   filepos: 0, |   filepos: 0, | ||||||
|   status: 'idle', |  | ||||||
| } | } | ||||||
| const uprogress = reactive({...uprogress_init}) | const uprogress = reactive({...uprogress_init}) | ||||||
| const percent = computed(() => uprogress.uploaded / uprogress.total * 100) | const percent = computed(() => uprogress.uploaded / uprogress.total * 100) | ||||||
| @@ -117,7 +66,7 @@ const speed = computed(() => { | |||||||
|   if (tsince > 1 / s) return 1 / tsince  // Next block is late or not coming, decay |   if (tsince > 1 / s) return 1 / tsince  // Next block is late or not coming, decay | ||||||
|   return s  // "Current speed" |   return s  // "Current speed" | ||||||
| }) | }) | ||||||
| const speeddisp = computed(() => speed.value ? speed.value.toFixed(speed.value < 10 ? 1 : 0) + '\u202FMB/s': 'stalled') | const speeddisp = computed(() => speed.value ? speed.value.toFixed(speed.value < 100 ? 1 : 0) + '\u202FMB/s': 'stalled') | ||||||
| setInterval(() => { | setInterval(() => { | ||||||
|   if (Date.now() - uprogress.tlast > 3000) { |   if (Date.now() - uprogress.tlast > 3000) { | ||||||
|     // Reset |     // Reset | ||||||
| @@ -129,7 +78,7 @@ setInterval(() => { | |||||||
|     uprogress.statdur *= .9 |     uprogress.statdur *= .9 | ||||||
|   } |   } | ||||||
| }, 100) | }, 100) | ||||||
| const statUpdate = ({name, size, start, end}: {name: string, size: number, start: number, end: number}) => { | const statUpdate = ({name, size, start, end}) => { | ||||||
|   if (name !== uprogress.filename) return  // If stats have been reset |   if (name !== uprogress.filename) return  // If stats have been reset | ||||||
|   const now = Date.now() |   const now = Date.now() | ||||||
|   uprogress.uploaded = uprogress.filestart + end |   uprogress.uploaded = uprogress.filestart + end | ||||||
| @@ -148,7 +97,7 @@ const statNextFile = () => { | |||||||
|   const f = uprogress.files.shift() |   const f = uprogress.files.shift() | ||||||
|   if (!f) return statReset() |   if (!f) return statReset() | ||||||
|   uprogress.filepos = 0 |   uprogress.filepos = 0 | ||||||
|   uprogress.filesize = f.file.size |   uprogress.filesize = f.size | ||||||
|   uprogress.filename = f.cloudName |   uprogress.filename = f.cloudName | ||||||
| } | } | ||||||
| const statReset = () => { | const statReset = () => { | ||||||
| @@ -156,14 +105,14 @@ const statReset = () => { | |||||||
|   uprogress.t0 = Date.now() |   uprogress.t0 = Date.now() | ||||||
|   uprogress.tlast = uprogress.t0 + 1 |   uprogress.tlast = uprogress.t0 + 1 | ||||||
| } | } | ||||||
| const statsAdd = (f: CloudFile[]) => { | const statsAdd = (f: Array<File>) => { | ||||||
|   if (uprogress.files.length === 0) statReset() |   if (uprogress.files.length === 0) statReset() | ||||||
|   uprogress.total += f.reduce((a, b) => a + b.file.size, 0) |   uprogress.total += f.reduce((a, b) => a + b.size, 0) | ||||||
|   uprogress.filecount += f.length |   uprogress.filecount += f.length | ||||||
|   uprogress.files = [...uprogress.files, ...f] |   uprogress.files = uprogress.files.concat(f) | ||||||
|   statNextFile() |   statNextFile() | ||||||
| } | } | ||||||
| let upqueue = [] as CloudFile[] | let upqueue = [] as File[] | ||||||
| 
 | 
 | ||||||
| // TODO: Rewrite as WebSocket class | // TODO: Rewrite as WebSocket class | ||||||
| const WSCreate = async () => await new Promise<WebSocket>(resolve => { | const WSCreate = async () => await new Promise<WebSocket>(resolve => { | ||||||
| @@ -171,13 +120,13 @@ const WSCreate = async () => await new Promise<WebSocket>(resolve => { | |||||||
|     open(ev: Event) { resolve(ws) }, |     open(ev: Event) { resolve(ws) }, | ||||||
|     error(ev: Event) { |     error(ev: Event) { | ||||||
|       console.error('Upload socket error', ev) |       console.error('Upload socket error', ev) | ||||||
|       store.error = 'Upload socket error' |       documentStore.error = 'Upload socket error' | ||||||
|     }, |     }, | ||||||
|     message(ev: MessageEvent) { |     message(ev: MessageEvent) { | ||||||
|       const res = JSON.parse(ev!.data) |       const res = JSON.parse(ev!.data) | ||||||
|       if ('error' in res) { |       if ('error' in res) { | ||||||
|         console.error('Upload socket error', res.error) |         console.error('Upload socket error', res.error) | ||||||
|         store.error = res.error.message |         documentStore.error = res.error.message | ||||||
|         return |         return | ||||||
|       } |       } | ||||||
|       if (res.status === 'ack') { |       if (res.status === 'ack') { | ||||||
| @@ -206,17 +155,18 @@ const worker = async () => { | |||||||
|   const ws = await WSCreate() |   const ws = await WSCreate() | ||||||
|   while (upqueue.length) { |   while (upqueue.length) { | ||||||
|     const f = upqueue[0] |     const f = upqueue[0] | ||||||
|  |     if (f.cloudPos === f.size) { | ||||||
|  |       upqueue.shift() | ||||||
|  |       continue | ||||||
|  |     } | ||||||
|     const start = f.cloudPos |     const start = f.cloudPos | ||||||
|     const end = Math.min(f.file.size, start + (1<<20)) |     const end = Math.min(f.size, start + (1<<20)) | ||||||
|     const control = { name: f.cloudName, size: f.file.size, start, end } |     const control = { name: f.cloudName, size: f.size, start, end } | ||||||
|     const data = f.file.slice(start, end) |     const data = f.slice(start, end) | ||||||
|     f.cloudPos = end |     f.cloudPos = end | ||||||
|     // Note: files may get modified during I/O |     // Note: files may get modified during I/O | ||||||
|     // @ts-ignore FIXME proper WebSocket class, avoid attaching functions to WebSocket object |  | ||||||
|     ws.sendMsg(control) |     ws.sendMsg(control) | ||||||
|     // @ts-ignore |  | ||||||
|     await ws.sendData(data) |     await ws.sendData(data) | ||||||
|     if (f.cloudPos === f.file.size) upqueue.shift() |  | ||||||
|   } |   } | ||||||
|   if (upqueue.length) startWorker() |   if (upqueue.length) startWorker() | ||||||
|   uprogress.status = "idle" |   uprogress.status = "idle" | ||||||
| @@ -234,10 +184,8 @@ onMounted(() => { | |||||||
|   // Need to prevent both to prevent browser from opening the file |   // Need to prevent both to prevent browser from opening the file | ||||||
|   addEventListener('dragover', uploadHandler) |   addEventListener('dragover', uploadHandler) | ||||||
|   addEventListener('drop', uploadHandler) |   addEventListener('drop', uploadHandler) | ||||||
|   addEventListener('paste', pasteHandler) |  | ||||||
| }) | }) | ||||||
| onUnmounted(() => { | onUnmounted(() => { | ||||||
|   removeEventListener('paste', pasteHandler) |  | ||||||
|   removeEventListener('dragover', uploadHandler) |   removeEventListener('dragover', uploadHandler) | ||||||
|   removeEventListener('drop', uploadHandler) |   removeEventListener('drop', uploadHandler) | ||||||
| }) | }) | ||||||
| @@ -259,7 +207,7 @@ onUnmounted(() => { | |||||||
|           {{ (uprogress.filepos / uprogress.filesize * 100).toFixed(0) + '\u202F%' }} |           {{ (uprogress.filepos / uprogress.filesize * 100).toFixed(0) + '\u202F%' }} | ||||||
|         </span> |         </span> | ||||||
|       </span> |       </span> | ||||||
|       <span class="position" v-if="uprogress.total > 1e7"> |       <span class="position" v-if="uprogress.filesize > 1e7"> | ||||||
|         {{ (uprogress.uploaded / 1e6).toFixed(0) + '\u202F/\u202F' + (uprogress.total / 1e6).toFixed(0) + '\u202FMB' }} |         {{ (uprogress.uploaded / 1e6).toFixed(0) + '\u202F/\u202F' + (uprogress.total / 1e6).toFixed(0) + '\u202FMB' }} | ||||||
|       </span> |       </span> | ||||||
|       <span class="speed">{{ speeddisp }}</span> |       <span class="speed">{{ speeddisp }}</span> | ||||||
| @@ -302,4 +250,3 @@ span { | |||||||
| .position { min-width: 4em } | .position { min-width: 4em } | ||||||
| .speed { min-width: 4em } | .speed { min-width: 4em } | ||||||
| </style> | </style> | ||||||
| @/stores/main |  | ||||||
							
								
								
									
										55
									
								
								cista-front/src/repositories/Document.ts
									
									
									
									
									
										Normal file
									
								
							
							
						
						| @@ -0,0 +1,55 @@ | |||||||
|  | export type FUID = string | ||||||
|  |  | ||||||
|  | export type Document = { | ||||||
|  |   loc: string | ||||||
|  |   name: string | ||||||
|  |   key: FUID | ||||||
|  |   size: number | ||||||
|  |   sizedisp: string | ||||||
|  |   mtime: number | ||||||
|  |   modified: string | ||||||
|  |   haystack: string | ||||||
|  |   dir: boolean | ||||||
|  | } | ||||||
|  |  | ||||||
|  | export type errorEvent = { | ||||||
|  |   error: { | ||||||
|  |     code: number | ||||||
|  |     message: string | ||||||
|  |     redirect: string | ||||||
|  |   } | ||||||
|  | } | ||||||
|  |  | ||||||
|  | // Raw types the backend /api/watch sends us | ||||||
|  |  | ||||||
|  | export type FileEntry = { | ||||||
|  |   key: FUID | ||||||
|  |   size: number | ||||||
|  |   mtime: number | ||||||
|  | } | ||||||
|  |  | ||||||
|  | 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 | ||||||
|  | } | ||||||
|  |  | ||||||
|  | // Helper structure for selections | ||||||
|  | export interface SelectedItems { | ||||||
|  |   keys: FUID[] | ||||||
|  |   docs: Record<FUID, Document> | ||||||
|  |   recursive: Array<[string, string, Document]> | ||||||
|  |   missing: Set<FUID> | ||||||
|  | } | ||||||
| @@ -1,33 +1,14 @@ | |||||||
| import { useMainStore } from "@/stores/main" | import { useDocumentStore } from "@/stores/documents" | ||||||
| import type { FileEntry, UpdateEntry, errorEvent } from "./Document" | import type { DirEntry, UpdateEntry, errorEvent } from "./Document" | ||||||
| 
 | 
 | ||||||
| export const controlUrl = '/api/control' | export const controlUrl = '/api/control' | ||||||
| export const uploadUrl = '/api/upload' | export const uploadUrl = '/api/upload' | ||||||
| export const watchUrl = '/api/watch' | export const watchUrl = '/api/watch' | ||||||
| 
 | 
 | ||||||
| let tree = [] as FileEntry[] | let tree = null as DirEntry | null | ||||||
| let reconnDelay = 500 | let reconnectDuration = 500 | ||||||
| let wsWatch = null as WebSocket | null | let wsWatch = null as WebSocket | null | ||||||
| 
 | 
 | ||||||
| export const loadSession = () => { |  | ||||||
|   const s = localStorage['cista-files'] |  | ||||||
|   if (!s) return false |  | ||||||
|   const store = useMainStore() |  | ||||||
|   try { |  | ||||||
|     tree = JSON.parse(s) |  | ||||||
|     store.updateRoot(tree) |  | ||||||
|     console.log(`Loaded session with ${tree.length} items cached`) |  | ||||||
|     return true |  | ||||||
|   } catch (error) { |  | ||||||
|     console.log("Loading session failed", error) |  | ||||||
|     return false |  | ||||||
|   } |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| const saveSession = () => { |  | ||||||
|   localStorage["cista-files"] = JSON.stringify(tree) |  | ||||||
| } |  | ||||||
| 
 |  | ||||||
| export const connect = (path: string, handlers: Partial<Record<keyof WebSocketEventMap, any>>) => { | export const connect = (path: string, handlers: Partial<Record<keyof WebSocketEventMap, any>>) => { | ||||||
|   const webSocket = new WebSocket(new URL(path, location.origin.replace(/^http/, 'ws'))) |   const webSocket = new WebSocket(new URL(path, location.origin.replace(/^http/, 'ws'))) | ||||||
|   for (const [event, handler] of Object.entries(handlers)) webSocket.addEventListener(event, handler) |   for (const [event, handler] of Object.entries(handlers)) webSocket.addEventListener(event, handler) | ||||||
| @@ -39,7 +20,7 @@ export const watchConnect = () => { | |||||||
|     clearTimeout(watchTimeout) |     clearTimeout(watchTimeout) | ||||||
|     watchTimeout = null |     watchTimeout = null | ||||||
|   } |   } | ||||||
|   const store = useMainStore() |   const store = useDocumentStore() | ||||||
|   if (store.error !== 'Reconnecting...') store.error = 'Connecting...' |   if (store.error !== 'Reconnecting...') store.error = 'Connecting...' | ||||||
|   console.log(store.error) |   console.log(store.error) | ||||||
| 
 | 
 | ||||||
| @@ -61,9 +42,8 @@ export const watchConnect = () => { | |||||||
|     } |     } | ||||||
|     if ("server" in msg) { |     if ("server" in msg) { | ||||||
|       console.log('Connected to backend', msg) |       console.log('Connected to backend', msg) | ||||||
|       store.server = msg.server |  | ||||||
|       store.connected = true |       store.connected = true | ||||||
|       reconnDelay = 500 |       reconnectDuration = 500 | ||||||
|       store.error = '' |       store.error = '' | ||||||
|       if (msg.user) store.login(msg.user.username, msg.user.privileged) |       if (msg.user) store.login(msg.user.username, msg.user.privileged) | ||||||
|       else if (store.isUserLogged) store.logout() |       else if (store.isUserLogged) store.logout() | ||||||
| @@ -81,16 +61,16 @@ export const watchDisconnect = () => { | |||||||
| let watchTimeout: any = null | let watchTimeout: any = null | ||||||
| 
 | 
 | ||||||
| const watchReconnect = (event: MessageEvent) => { | const watchReconnect = (event: MessageEvent) => { | ||||||
|   const store = useMainStore() |   const store = useDocumentStore() | ||||||
|   if (store.connected) { |   if (store.connected) { | ||||||
|     console.warn("Disconnected from server", event) |     console.warn("Disconnected from server", event) | ||||||
|     store.connected = false |     store.connected = false | ||||||
|     store.error = 'Reconnecting...' |     store.error = 'Reconnecting...' | ||||||
|   } |   } | ||||||
|   reconnDelay = Math.min(5000, reconnDelay + 500) |   reconnectDuration = Math.min(5000, reconnectDuration + 500) | ||||||
|   // The server closes the websocket after errors, so we need to reopen it
 |   // The server closes the websocket after errors, so we need to reopen it
 | ||||||
|   if (watchTimeout !== null) clearTimeout(watchTimeout) |   if (watchTimeout !== null) clearTimeout(watchTimeout) | ||||||
|   watchTimeout = setTimeout(watchConnect, reconnDelay) |   watchTimeout = setTimeout(watchConnect, reconnectDuration) | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| 
 | 
 | ||||||
| @@ -113,40 +93,38 @@ const handleWatchMessage = (event: MessageEvent) => { | |||||||
|   } |   } | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| function handleRootMessage({ root }: { root: FileEntry[] }) { | function handleRootMessage({ root }: { root: DirEntry }) { | ||||||
|   const store = useMainStore() |   const store = useDocumentStore() | ||||||
|   console.log('Watch root', root) |   console.log('Watch root', root) | ||||||
|   store.updateRoot(root) |   store.updateRoot(root) | ||||||
|   tree = root |   tree = root | ||||||
|   saveSession() |  | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| function handleUpdateMessage(updateData: { update: UpdateEntry[] }) { | function handleUpdateMessage(updateData: { update: UpdateEntry[] }) { | ||||||
|   const store = useMainStore() |   const store = useDocumentStore() | ||||||
|   const update = updateData.update |   console.log('Watch update', updateData.update) | ||||||
|   console.log('Watch update', update) |  | ||||||
|   if (!tree) return console.error('Watch update before root') |   if (!tree) return console.error('Watch update before root') | ||||||
|   let newtree = [] |   let node: DirEntry = tree | ||||||
|   let oidx = 0 |   for (const elem of updateData.update) { | ||||||
| 
 |     if (elem.deleted) { | ||||||
|   for (const [action, arg] of update) { |       delete node.dir[elem.name] | ||||||
|     if (action === 'k') { |       break // Deleted elements can't have further children
 | ||||||
|       newtree.push(...tree.slice(oidx, oidx + arg)) |  | ||||||
|       oidx += arg |  | ||||||
|     } |     } | ||||||
|     else if (action === 'd') oidx += arg |     if (elem.name) { | ||||||
|     else if (action === 'i') newtree.push(...arg) |       // @ts-ignore
 | ||||||
|     else console.log("Unknown update action", action, arg) |       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 | ||||||
|   } |   } | ||||||
|   if (oidx != tree.length) |   store.updateRoot(tree) | ||||||
|     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() |  | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| function handleError(msg: errorEvent) { | function handleError(msg: errorEvent) { | ||||||
|   const store = useMainStore() |   const store = useDocumentStore() | ||||||
|   if (msg.error.code === 401) { |   if (msg.error.code === 401) { | ||||||
|     store.user.isOpenLoginModal = true |     store.user.isOpenLoginModal = true | ||||||
|     store.user.isLoggedIn = false |     store.user.isLoggedIn = false | ||||||
| @@ -1,12 +1,20 @@ | |||||||
| import type { FileEntry, FUID, SelectedItems } from '@/repositories/Document' | import type { | ||||||
| import { Doc } from '@/repositories/Document' |   Document, | ||||||
|  |   DirEntry, | ||||||
|  |   FileEntry, | ||||||
|  |   FUID, | ||||||
|  |   SelectedItems | ||||||
|  | } from '@/repositories/Document' | ||||||
|  | import { formatSize, formatUnixDate, haystackFormat } from '@/utils' | ||||||
| import { defineStore } from 'pinia' | import { defineStore } from 'pinia' | ||||||
| import { collator } from '@/utils' | import { collator } from '@/utils' | ||||||
| import { logoutUser } from '@/repositories/User' | import { logoutUser } from '@/repositories/User' | ||||||
| import { watchConnect } from '@/repositories/WS' | import { watchConnect } from '@/repositories/WS' | ||||||
| import { shallowRef } from 'vue' |  | ||||||
| import { sorted, type SortOrder } from '@/utils/docsort' |  | ||||||
| 
 | 
 | ||||||
|  | type FileData = { id: string; mtime: number; size: number; dir: DirectoryData } | ||||||
|  | type DirectoryData = { | ||||||
|  |   [filename: string]: FileData | ||||||
|  | } | ||||||
| type User = { | type User = { | ||||||
|   username: string |   username: string | ||||||
|   privileged: boolean |   privileged: boolean | ||||||
| @@ -14,20 +22,17 @@ type User = { | |||||||
|   isLoggedIn: boolean |   isLoggedIn: boolean | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| export const useMainStore = defineStore({ | export const useDocumentStore = defineStore({ | ||||||
|   id: 'main', |   id: 'documents', | ||||||
|   state: () => ({ |   state: () => ({ | ||||||
|     document: shallowRef<Doc[]>([]), |     document: [] as Document[], | ||||||
|  |     search: "" as string, | ||||||
|     selected: new Set<FUID>(), |     selected: new Set<FUID>(), | ||||||
|     query: '' as string, |     uploadingDocuments: [], | ||||||
|     fileExplorer: null as any, |     uploadCount: 0 as number, | ||||||
|  |     fileExplorer: null, | ||||||
|     error: '' as string, |     error: '' as string, | ||||||
|     connected: false, |     connected: false, | ||||||
|     server: {} as Record<string, any>, |  | ||||||
|     prefs: { |  | ||||||
|       sortListing: '' as SortOrder, |  | ||||||
|       sortFiltered: '' as SortOrder, |  | ||||||
|     }, |  | ||||||
|     user: { |     user: { | ||||||
|       username: '', |       username: '', | ||||||
|       privileged: false, |       privileged: false, | ||||||
| @@ -36,25 +41,46 @@ export const useMainStore = defineStore({ | |||||||
|     } as User |     } as User | ||||||
|   }), |   }), | ||||||
|   persist: { |   persist: { | ||||||
|     paths: ['prefs'], |     storage: sessionStorage, | ||||||
|  |     paths: ['document'], | ||||||
|   }, |   }, | ||||||
|   actions: { |   actions: { | ||||||
|     updateRoot(root: FileEntry[]) { |     updateRoot(root: DirEntry | null = null) { | ||||||
|       const docs = [] |       if (!root) { | ||||||
|       let loc = [] as string[] |         this.document = [] | ||||||
|       for (const [level, name, key, mtime, size, isfile] of root) { |         return | ||||||
|         loc = loc.slice(0, level - 1) |  | ||||||
|         docs.push(new Doc({ |  | ||||||
|           name, |  | ||||||
|           loc: level ? loc.join('/') : '/', |  | ||||||
|           key, |  | ||||||
|           size, |  | ||||||
|           mtime, |  | ||||||
|           dir: !isfile, |  | ||||||
|         })) |  | ||||||
|         loc.push(name) |  | ||||||
|       } |       } | ||||||
|       this.document = docs |       // 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)] | ||||||
|  |       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 | ||||||
|  |       } | ||||||
|  |       // 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) | ||||||
|  |       ) | ||||||
|  |       this.document = docs as Document[] | ||||||
|     }, |     }, | ||||||
|     login(username: string, privileged: boolean) { |     login(username: string, privileged: boolean) { | ||||||
|       this.user.username = username |       this.user.username = username | ||||||
| @@ -70,18 +96,23 @@ export const useMainStore = defineStore({ | |||||||
|       console.log("Logout") |       console.log("Logout") | ||||||
|       await logoutUser() |       await logoutUser() | ||||||
|       this.$reset() |       this.$reset() | ||||||
|       localStorage.clear() |  | ||||||
|       history.go() // Reload page
 |       history.go() // Reload page
 | ||||||
|     }, |     } | ||||||
|     toggleSort(name: SortOrder) { |  | ||||||
|       if (this.query) this.prefs.sortFiltered = this.prefs.sortFiltered === name ? '' : name |  | ||||||
|       else this.prefs.sortListing = this.prefs.sortListing === name ? '' : name |  | ||||||
|     }, |  | ||||||
|   }, |   }, | ||||||
|   getters: { |   getters: { | ||||||
|     sortOrder(): SortOrder { return this.query ? this.prefs.sortFiltered : this.prefs.sortListing }, |     isUserLogged(): boolean { | ||||||
|     isUserLogged(): boolean { return this.user.isLoggedIn }, |       return this.user.isLoggedIn | ||||||
|     recentDocuments(): Doc[] { return sorted(this.document, 'modified') }, |     }, | ||||||
|  |     recentDocuments(): Document[] { | ||||||
|  |       const ret = [...this.document] | ||||||
|  |       ret.sort((a, b) => b.mtime - a.mtime) | ||||||
|  |       return ret | ||||||
|  |     }, | ||||||
|  |     largeDocuments(): Document[] { | ||||||
|  |       const ret = [...this.document] | ||||||
|  |       ret.sort((a, b) => b.size - a.size) | ||||||
|  |       return ret | ||||||
|  |     }, | ||||||
|     selectedFiles(): SelectedItems { |     selectedFiles(): SelectedItems { | ||||||
|       const selected = this.selected |       const selected = this.selected | ||||||
|       const found = new Set<FUID>() |       const found = new Set<FUID>() | ||||||
| @@ -102,7 +133,7 @@ export const useMainStore = defineStore({ | |||||||
|       for (const key of selected) if (!found.has(key)) ret.missing.add(key) |       for (const key of selected) if (!found.has(key)) ret.missing.add(key) | ||||||
|       // Build a flat list including contents recursively
 |       // Build a flat list including contents recursively
 | ||||||
|       const relnames = new Set<string>() |       const relnames = new Set<string>() | ||||||
|       function add(rel: string, full: string, doc: Doc) { |       function add(rel: string, full: string, doc: Document) { | ||||||
|         if (!doc.dir && relnames.has(rel)) throw Error(`Multiple selections conflict for: ${rel}`) |         if (!doc.dir && relnames.has(rel)) throw Error(`Multiple selections conflict for: ${rel}`) | ||||||
|         relnames.add(rel) |         relnames.add(rel) | ||||||
|         ret.recursive.push([rel, full, doc]) |         ret.recursive.push([rel, full, doc]) | ||||||
| @@ -86,7 +86,7 @@ export function haystackFormat(str: string) { | |||||||
| // Preformat search string for faster search
 | // Preformat search string for faster search
 | ||||||
| export function needleFormat(query: string) { | export function needleFormat(query: string) { | ||||||
|   const based = query.normalize('NFKD').replace(/[\u0300-\u036f]/g, '').toLowerCase() |   const based = query.normalize('NFKD').replace(/[\u0300-\u036f]/g, '').toLowerCase() | ||||||
|   return {based, words: based.split(/\s+/)} |   return {based, words: based.split(/\W+/)} | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| // Test if haystack includes needle
 | // Test if haystack includes needle
 | ||||||
| @@ -10,40 +10,33 @@ | |||||||
| 
 | 
 | ||||||
| <script setup lang="ts"> | <script setup lang="ts"> | ||||||
| import { watchEffect, ref, computed } from 'vue' | import { watchEffect, ref, computed } from 'vue' | ||||||
| import { useMainStore } from '@/stores/main' | import { useDocumentStore } from '@/stores/documents' | ||||||
| import Router from '@/router/index' | import Router from '@/router/index' | ||||||
| import { needleFormat, localeIncludes, collator } from '@/utils'; | import { needleFormat, localeIncludes, collator } from '@/utils'; | ||||||
| import { sorted } from '@/utils/docsort'; |  | ||||||
| 
 | 
 | ||||||
| const store = useMainStore() | const documentStore = useDocumentStore() | ||||||
| const fileExplorer = ref() | const fileExplorer = ref() | ||||||
| const props = defineProps<{ | const props = defineProps({ | ||||||
|   path: Array<string> |   path: Array<string> | ||||||
|   query: string | }) | ||||||
| }>() |  | ||||||
| const documents = computed(() => { | const documents = computed(() => { | ||||||
|  |   if (!props.path) return [] | ||||||
|   const loc = props.path.join('/') |   const loc = props.path.join('/') | ||||||
|   const query = props.query |  | ||||||
|   // List the current location |   // List the current location | ||||||
|   if (!query) return sorted( |   if (!documentStore.search) return documentStore.document.filter(doc => doc.loc === loc) | ||||||
|     store.document.filter(doc => doc.loc === loc), |  | ||||||
|     store.prefs.sortListing, |  | ||||||
|   ) |  | ||||||
|   // Find up to 100 newest documents that match the search |   // Find up to 100 newest documents that match the search | ||||||
|   const needle = needleFormat(query) |   const search = documentStore.search | ||||||
|  |   const needle = needleFormat(search) | ||||||
|   let limit = 100 |   let limit = 100 | ||||||
|   let docs = [] |   let docs = [] | ||||||
|   for (const doc of store.recentDocuments) { |   for (const doc of documentStore.recentDocuments) { | ||||||
|     if (localeIncludes(doc.haystack, needle)) { |     if (localeIncludes(doc.haystack, needle)) { | ||||||
|       docs.push(doc) |       docs.push(doc) | ||||||
|       if (--limit === 0) break |       if (--limit === 0) break | ||||||
|     } |     } | ||||||
|   } |   } | ||||||
|  |   // Organize by folder, by relevance | ||||||
|   const locsub = loc + '/' |   const locsub = loc + '/' | ||||||
|   // Custom sort override in effect? |  | ||||||
|   const order = store.prefs.sortFiltered |  | ||||||
|   if (order) return sorted(docs, order) |  | ||||||
|   // Sort by relevance - current folder, then subfolders, then others |  | ||||||
|   docs.sort((a, b) => ( |   docs.sort((a, b) => ( | ||||||
|     // @ts-ignore |     // @ts-ignore | ||||||
|     (b.loc === loc) - (a.loc === loc) || |     (b.loc === loc) - (a.loc === loc) || | ||||||
| @@ -53,14 +46,13 @@ const documents = computed(() => { | |||||||
|     // @ts-ignore |     // @ts-ignore | ||||||
|     (a.type === 'file') - (b.type === 'file') || |     (a.type === 'file') - (b.type === 'file') || | ||||||
|     // @ts-ignore |     // @ts-ignore | ||||||
|     b.name.includes(query) - a.name.includes(query) || |     b.name.includes(search) - a.name.includes(search) || | ||||||
|     collator.compare(a.name, b.name) |     collator.compare(a.name, b.name) | ||||||
|   )) |   )) | ||||||
|   return docs |   return docs | ||||||
| }) | }) | ||||||
| 
 | 
 | ||||||
| watchEffect(() => { | watchEffect(() => { | ||||||
|   store.fileExplorer = fileExplorer.value |   documentStore.fileExplorer = fileExplorer.value | ||||||
|   store.query = props.query |  | ||||||
| }) | }) | ||||||
| </script> | </script> | ||||||
| @@ -98,6 +98,7 @@ def _main(): | |||||||
|     return 0 |     return 0 | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| def _confdir(args): | def _confdir(args): | ||||||
|     if args["-c"]: |     if args["-c"]: | ||||||
|         # Custom config directory |         # Custom config directory | ||||||
| @@ -105,9 +106,9 @@ def _confdir(args): | |||||||
|         if confdir.exists() and not confdir.is_dir(): |         if confdir.exists() and not confdir.is_dir(): | ||||||
|             if confdir.name != config.conffile.name: |             if confdir.name != config.conffile.name: | ||||||
|                 raise ValueError("Config path is not a directory") |                 raise ValueError("Config path is not a directory") | ||||||
|             # Accidentally pointed to the db.toml, use parent |             # Accidentally pointed to the cista.toml, use parent | ||||||
|             confdir = confdir.parent |             confdir = confdir.parent | ||||||
|         config.conffile = confdir / config.conffile.name |         config.conffile = config.conffile.with_parent(confdir) | ||||||
|  |  | ||||||
|  |  | ||||||
| def _user(args): | def _user(args): | ||||||
|   | |||||||
							
								
								
									
										22
									
								
								cista/api.py
									
									
									
									
									
								
							
							
						
						| @@ -37,23 +37,16 @@ async def upload(req, ws): | |||||||
|             ) |             ) | ||||||
|         req = msgspec.json.decode(text, type=FileRange) |         req = msgspec.json.decode(text, type=FileRange) | ||||||
|         pos = req.start |         pos = req.start | ||||||
|         while True: |         data = None | ||||||
|             data = await ws.recv() |         while pos < req.end and (data := await ws.recv()) and isinstance(data, bytes): | ||||||
|             if not isinstance(data, bytes): |  | ||||||
|                 break |  | ||||||
|             if len(data) > req.end - pos: |  | ||||||
|                 raise ValueError( |  | ||||||
|                     f"Expected up to {req.end - pos} bytes, got {len(data)} bytes" |  | ||||||
|                 ) |  | ||||||
|             sentsize = await alink(("upload", req.name, pos, data, req.size)) |             sentsize = await alink(("upload", req.name, pos, data, req.size)) | ||||||
|             pos += typing.cast(int, sentsize) |             pos += typing.cast(int, sentsize) | ||||||
|             if pos >= req.end: |  | ||||||
|                 break |  | ||||||
|         if pos != req.end: |         if pos != req.end: | ||||||
|             d = f"{len(data)} bytes" if isinstance(data, bytes) else data |             d = f"{len(data)} bytes" if isinstance(data, bytes) else data | ||||||
|             raise ValueError(f"Expected {req.end - pos} more bytes, got {d}") |             raise ValueError(f"Expected {req.end - pos} more bytes, got {d}") | ||||||
|         # Report success |         # Report success | ||||||
|         res = StatusMsg(status="ack", req=req) |         res = StatusMsg(status="ack", req=req) | ||||||
|  |         print("ack", res) | ||||||
|         await asend(ws, res) |         await asend(ws, res) | ||||||
|  |  | ||||||
|  |  | ||||||
| @@ -89,6 +82,7 @@ async def control(req, ws): | |||||||
|         await asend(ws, StatusMsg(status="ack", req=cmd)) |         await asend(ws, StatusMsg(status="ack", req=cmd)) | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| @bp.websocket("watch") | @bp.websocket("watch") | ||||||
| @websocket_wrapper | @websocket_wrapper | ||||||
| async def watch(req, ws): | async def watch(req, ws): | ||||||
| @@ -96,7 +90,7 @@ async def watch(req, ws): | |||||||
|         msgspec.json.encode( |         msgspec.json.encode( | ||||||
|             { |             { | ||||||
|                 "server": { |                 "server": { | ||||||
|                     "name": config.config.name or config.config.path.name, |                     "name": "Cista",  # Should be configurable | ||||||
|                     "version": __version__, |                     "version": __version__, | ||||||
|                     "public": config.config.public, |                     "public": config.config.public, | ||||||
|                 }, |                 }, | ||||||
| @@ -111,11 +105,11 @@ async def watch(req, ws): | |||||||
|     ) |     ) | ||||||
|     uuid = token_bytes(16) |     uuid = token_bytes(16) | ||||||
|     try: |     try: | ||||||
|         with watching.state.lock: |         with watching.tree_lock: | ||||||
|             q = watching.pubsub[uuid] = asyncio.Queue() |             q = watching.pubsub[uuid] = asyncio.Queue() | ||||||
|             # Init with disk usage and full tree |             # Init with disk usage and full tree | ||||||
|             await ws.send(watching.format_space(watching.state.space)) |             await ws.send(watching.format_du()) | ||||||
|             await ws.send(watching.format_root(watching.state.root)) |             await ws.send(watching.format_tree()) | ||||||
|         # Send updates |         # Send updates | ||||||
|         while True: |         while True: | ||||||
|             await ws.send(await q.get()) |             await ws.send(await q.get()) | ||||||
|   | |||||||
							
								
								
									
										124
									
								
								cista/app.py
									
									
									
									
									
								
							
							
						
						| @@ -1,8 +1,10 @@ | |||||||
| import asyncio | import asyncio | ||||||
| import datetime | import datetime | ||||||
| import mimetypes | import mimetypes | ||||||
|  | from collections import deque | ||||||
| from concurrent.futures import ThreadPoolExecutor | from concurrent.futures import ThreadPoolExecutor | ||||||
| from pathlib import Path, PurePath, PurePosixPath | from importlib.resources import files | ||||||
|  | from pathlib import Path | ||||||
| from stat import S_IFDIR, S_IFREG | from stat import S_IFDIR, S_IFREG | ||||||
| from urllib.parse import unquote | from urllib.parse import unquote | ||||||
| from wsgiref.handlers import format_date_time | from wsgiref.handlers import format_date_time | ||||||
| @@ -10,13 +12,15 @@ from wsgiref.handlers import format_date_time | |||||||
| import brotli | import brotli | ||||||
| import sanic.helpers | import sanic.helpers | ||||||
| from blake3 import blake3 | from blake3 import blake3 | ||||||
|  | from natsort import natsorted, ns | ||||||
| from sanic import Blueprint, Sanic, empty, raw | from sanic import Blueprint, Sanic, empty, raw | ||||||
| from sanic.exceptions import Forbidden, NotFound, ServerError | from sanic.exceptions import Forbidden, NotFound | ||||||
| from sanic.log import logging | from sanic.log import logging | ||||||
| from stream_zip import ZIP_AUTO, stream_zip | from stream_zip import ZIP_AUTO, stream_zip | ||||||
|  |  | ||||||
| from cista import auth, config, session, watching | from cista import auth, config, session, watching | ||||||
| from cista.api import bp | from cista.api import bp | ||||||
|  | from cista.protocol import DirEntry | ||||||
| from cista.util.apphelpers import handle_sanic_exception | from cista.util.apphelpers import handle_sanic_exception | ||||||
|  |  | ||||||
| # Workaround until Sanic PR #2824 is merged | # Workaround until Sanic PR #2824 is merged | ||||||
| @@ -32,9 +36,8 @@ app.exception(Exception)(handle_sanic_exception) | |||||||
| async def main_start(app, loop): | async def main_start(app, loop): | ||||||
|     config.load_config() |     config.load_config() | ||||||
|     await watching.start(app, loop) |     await watching.start(app, loop) | ||||||
|     app.ctx.threadexec = ThreadPoolExecutor( |     app.ctx.threadexec = ThreadPoolExecutor(max_workers=8) | ||||||
|         max_workers=8, thread_name_prefix="cista-ioworker" |  | ||||||
|     ) |  | ||||||
|  |  | ||||||
|  |  | ||||||
| @app.after_server_stop | @app.after_server_stop | ||||||
| @@ -43,12 +46,13 @@ async def main_stop(app, loop): | |||||||
|     app.ctx.threadexec.shutdown() |     app.ctx.threadexec.shutdown() | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| @app.on_request | @app.on_request | ||||||
| async def use_session(req): | async def use_session(req): | ||||||
|     req.ctx.session = session.get(req) |     req.ctx.session = session.get(req) | ||||||
|     try: |     try: | ||||||
|         req.ctx.username = req.ctx.session["username"]  # type: ignore |         req.ctx.username = req.ctx.session["username"] | ||||||
|         req.ctx.user = config.config.users[req.ctx.username] |         req.ctx.user = config.config.users[req.ctx.session["username"]]  # type: ignore | ||||||
|     except (AttributeError, KeyError, TypeError): |     except (AttributeError, KeyError, TypeError): | ||||||
|         req.ctx.username = None |         req.ctx.username = None | ||||||
|         req.ctx.user = None |         req.ctx.user = None | ||||||
| @@ -79,16 +83,22 @@ def http_fileserver(app, _): | |||||||
| www = {} | 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): | def _load_wwwroot(www): | ||||||
|     wwwnew = {} |     wwwnew = {} | ||||||
|     base = Path(__file__).with_name("wwwroot") |     base = files("cista") / "wwwroot" | ||||||
|     paths = [PurePath()] |     paths = ["."] | ||||||
|     while paths: |     while paths: | ||||||
|         path = paths.pop(0) |         path = paths.pop(0) | ||||||
|         current = base / path |         current = base / path | ||||||
|         for p in current.iterdir(): |         for p in current.iterdir(): | ||||||
|             if p.is_dir(): |             if p.is_dir(): | ||||||
|                 paths.append(p.relative_to(base)) |                 paths.append(current / p.parts[-1]) | ||||||
|                 continue |                 continue | ||||||
|             name = p.relative_to(base).as_posix() |             name = p.relative_to(base).as_posix() | ||||||
|             mime = mimetypes.guess_type(name)[0] or "application/octet-stream" |             mime = mimetypes.guess_type(name)[0] or "application/octet-stream" | ||||||
| @@ -119,35 +129,15 @@ def _load_wwwroot(www): | |||||||
|             if len(br) >= len(data): |             if len(br) >= len(data): | ||||||
|                 br = False |                 br = False | ||||||
|             wwwnew[name] = data, br, headers |             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 |     return wwwnew | ||||||
|  |  | ||||||
|  |  | ||||||
| @app.before_server_start | @app.add_task | ||||||
| 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(): | async def refresh_wwwroot(): | ||||||
|     while True: |     while True: | ||||||
|         await asyncio.sleep(0.5) |  | ||||||
|         try: |         try: | ||||||
|             wwwold = www |             wwwold = www | ||||||
|             await load_wwwroot(app) |             await load_wwwroot() | ||||||
|             changes = "" |             changes = "" | ||||||
|             for name in sorted(www): |             for name in sorted(www): | ||||||
|                 attr = www[name] |                 attr = www[name] | ||||||
| @@ -163,6 +153,7 @@ async def refresh_wwwroot(): | |||||||
|             print("Error loading wwwroot", e) |             print("Error loading wwwroot", e) | ||||||
|         if not app.debug: |         if not app.debug: | ||||||
|             return |             return | ||||||
|  |         await asyncio.sleep(0.5) | ||||||
|  |  | ||||||
|  |  | ||||||
| @app.route("/<path:path>", methods=["GET", "HEAD"]) | @app.route("/<path:path>", methods=["GET", "HEAD"]) | ||||||
| @@ -177,70 +168,66 @@ async def wwwroot(req, path=""): | |||||||
|         return empty(304, headers=headers) |         return empty(304, headers=headers) | ||||||
|     # Brotli compressed? |     # Brotli compressed? | ||||||
|     if br and "br" in req.headers.accept_encoding.split(", "): |     if br and "br" in req.headers.accept_encoding.split(", "): | ||||||
|         headers = {**headers, "content-encoding": "br"} |         headers = { | ||||||
|  |             **headers, | ||||||
|  |             "content-encoding": "br", | ||||||
|  |         } | ||||||
|         data = br |         data = br | ||||||
|     return raw(data, headers=headers) |     return raw(data, headers=headers) | ||||||
|  |  | ||||||
|  |  | ||||||
| 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>") | @app.get("/zip/<keys>/<zipfile:ext=zip>") | ||||||
| async def zip_download(req, keys, zipfile, ext): | async def zip_download(req, keys, zipfile, ext): | ||||||
|     """Download a zip archive of the given keys""" |     """Download a zip archive of the given keys""" | ||||||
|  |  | ||||||
|     wanted = set(keys.split("+")) |     wanted = set(keys.split("+")) | ||||||
|     files = get_files(wanted) |     with watching.tree_lock: | ||||||
|  |         q = deque([([], None, watching.tree[""].dir)]) | ||||||
|  |         files = [] | ||||||
|  |         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), Path(watching.rootpath.joinpath(*loc))) | ||||||
|  |                     ) | ||||||
|  |  | ||||||
|     if not files: |     if not files: | ||||||
|         raise NotFound( |         raise NotFound( | ||||||
|             "No files found", |             "No files found", | ||||||
|             context={"keys": keys, "zipfile": f"{zipfile}.{ext}", "wanted": wanted}, |             context={"keys": keys, "zipfile": zipfile, "wanted": wanted}, | ||||||
|         ) |         ) | ||||||
|     if wanted: |     if wanted: | ||||||
|         raise NotFound("Files not found", context={"missing": wanted}) |         raise NotFound("Files not found", context={"missing": wanted}) | ||||||
|  |  | ||||||
|  |     files = natsorted(files, key=lambda f: f[0], alg=ns.IGNORECASE) | ||||||
|  |  | ||||||
|     def local_files(files): |     def local_files(files): | ||||||
|         for rel, p in files: |         for rel, p in files: | ||||||
|             s = p.stat() |             s = p.stat() | ||||||
|             size = s.st_size |             size = s.st_size | ||||||
|             modified = datetime.datetime.fromtimestamp(s.st_mtime, datetime.UTC) |             modified = datetime.datetime.fromtimestamp(s.st_mtime, datetime.UTC) | ||||||
|             name = rel.as_posix() |  | ||||||
|             if p.is_dir(): |             if p.is_dir(): | ||||||
|                 yield f"{name}/", modified, S_IFDIR | 0o755, ZIP_AUTO(size), iter(b"") |                 yield rel, modified, S_IFDIR | 0o755, ZIP_AUTO(size), b"" | ||||||
|             else: |             else: | ||||||
|                 yield name, modified, S_IFREG | 0o644, ZIP_AUTO(size), contents(p, size) |                 yield rel, modified, S_IFREG | 0o644, ZIP_AUTO(size), contents(p) | ||||||
|  |  | ||||||
|     def contents(name, size): |     def contents(name): | ||||||
|         with name.open("rb") as f: |         with name.open("rb") as f: | ||||||
|             while size > 0 and (chunk := f.read(min(size, 1 << 20))): |             while chunk := f.read(65536): | ||||||
|                 size -= len(chunk) |  | ||||||
|                 yield chunk |                 yield chunk | ||||||
|         assert size == 0 |  | ||||||
|  |  | ||||||
|     def worker(): |     def worker(): | ||||||
|         try: |         try: | ||||||
|             for chunk in stream_zip(local_files(files)): |             for chunk in stream_zip(local_files(files)): | ||||||
|                 asyncio.run_coroutine_threadsafe(queue.put(chunk), loop).result() |                 asyncio.run_coroutine_threadsafe(queue.put(chunk), loop) | ||||||
|         except Exception: |         except Exception: | ||||||
|             logging.exception("Error streaming ZIP") |             logging.exception("Error streaming ZIP") | ||||||
|             raise |             raise | ||||||
| @@ -253,10 +240,7 @@ async def zip_download(req, keys, zipfile, ext): | |||||||
|     thread = loop.run_in_executor(app.ctx.threadexec, worker) |     thread = loop.run_in_executor(app.ctx.threadexec, worker) | ||||||
|  |  | ||||||
|     # Stream the response |     # Stream the response | ||||||
|     res = await req.respond( |     res = await req.respond(content_type="application/zip") | ||||||
|         content_type="application/zip", |  | ||||||
|         headers={"cache-control": "no-store"}, |  | ||||||
|     ) |  | ||||||
|     while chunk := await queue.get(): |     while chunk := await queue.get(): | ||||||
|         await res.send(chunk) |         await res.send(chunk) | ||||||
|  |  | ||||||
|   | |||||||
| @@ -68,10 +68,11 @@ def verify(request, *, privileged=False): | |||||||
|         if request.ctx.user: |         if request.ctx.user: | ||||||
|             if request.ctx.user.privileged: |             if request.ctx.user.privileged: | ||||||
|                 return |                 return | ||||||
|             raise Forbidden("Access Forbidden: Only for privileged users", quiet=True) |             raise Forbidden("Access Forbidden: Only for privileged users") | ||||||
|     elif config.config.public or request.ctx.user: |     elif config.config.public or request.ctx.user: | ||||||
|         return |         return | ||||||
|     raise Unauthorized("Login required", "cookie", quiet=True) |     raise Unauthorized("Login required", "cookie") | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| bp = Blueprint("auth") | bp = Blueprint("auth") | ||||||
|   | |||||||
| @@ -14,7 +14,6 @@ class Config(msgspec.Struct): | |||||||
|     listen: str |     listen: str | ||||||
|     secret: str = secrets.token_hex(12) |     secret: str = secrets.token_hex(12) | ||||||
|     public: bool = False |     public: bool = False | ||||||
|     name: str = "" |  | ||||||
|     users: dict[str, User] = {} |     users: dict[str, User] = {} | ||||||
|     links: dict[str, Link] = {} |     links: dict[str, Link] = {} | ||||||
|  |  | ||||||
| @@ -25,6 +24,7 @@ class User(msgspec.Struct, omit_defaults=True): | |||||||
|     lastSeen: int = 0  # noqa: N815 |     lastSeen: int = 0  # noqa: N815 | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| class Link(msgspec.Struct, omit_defaults=True): | class Link(msgspec.Struct, omit_defaults=True): | ||||||
|     location: str |     location: str | ||||||
|     creator: str = "" |     creator: str = "" | ||||||
|   | |||||||
| @@ -34,11 +34,9 @@ class File: | |||||||
|             self.open_rw() |             self.open_rw() | ||||||
|         assert self.fd is not None |         assert self.fd is not None | ||||||
|         if file_size is not None: |         if file_size is not None: | ||||||
|             assert pos + len(buffer) <= file_size |  | ||||||
|             os.ftruncate(self.fd, file_size) |             os.ftruncate(self.fd, file_size) | ||||||
|         if buffer: |         os.lseek(self.fd, pos, os.SEEK_SET) | ||||||
|             os.lseek(self.fd, pos, os.SEEK_SET) |         os.write(self.fd, buffer) | ||||||
|             os.write(self.fd, buffer) |  | ||||||
|  |  | ||||||
|     def __getitem__(self, slice): |     def __getitem__(self, slice): | ||||||
|         if self.fd is None: |         if self.fd is None: | ||||||
|   | |||||||
| @@ -25,6 +25,7 @@ class MkDir(ControlBase): | |||||||
|         path.mkdir(parents=True, exist_ok=False) |         path.mkdir(parents=True, exist_ok=False) | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| class Rename(ControlBase): | class Rename(ControlBase): | ||||||
|     path: str |     path: str | ||||||
|     to: str |     to: str | ||||||
| @@ -50,6 +51,7 @@ class Rm(ControlBase): | |||||||
|                 p.unlink() |                 p.unlink() | ||||||
|  |  | ||||||
|  |  | ||||||
|  |  | ||||||
| class Mv(ControlBase): | class Mv(ControlBase): | ||||||
|     sel: list[str] |     sel: list[str] | ||||||
|     dst: str |     dst: str | ||||||
| @@ -112,40 +114,56 @@ class ErrorMsg(msgspec.Struct): | |||||||
| ## Directory listings | ## Directory listings | ||||||
|  |  | ||||||
|  |  | ||||||
| class FileEntry(msgspec.Struct, array_like=True): | class FileEntry(msgspec.Struct): | ||||||
|     level: int |     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.""" | ||||||
|  |  | ||||||
|     name: str |     name: str | ||||||
|     key: str |     key: str | ||||||
|     mtime: int |     deleted: bool = False | ||||||
|     size: int |     size: int | None = None | ||||||
|     isfile: int |     mtime: int | None = None | ||||||
|  |     dir: DirList | None = None | ||||||
|     def __repr__(self): |  | ||||||
|         return self.key or "FileEntry()" |  | ||||||
|  |  | ||||||
|  |  | ||||||
| class Update(msgspec.Struct, array_like=True): | def make_dir_data(root): | ||||||
|     ... |     if len(root) == 3: | ||||||
|  |         return FileEntry(*root) | ||||||
|  |     id_, size, mtime, listing = root | ||||||
| class UpdKeep(Update, tag="k"): |     converted = {} | ||||||
|     count: int |     for name, data in listing.items(): | ||||||
|  |         converted[name] = make_dir_data(data) | ||||||
|  |     sz = sum(x.size for x in converted.values()) | ||||||
| class UpdDel(Update, tag="d"): |     mt = max(x.mtime for x in converted.values()) | ||||||
|     count: int |     return DirEntry(id_, sz, max(mt, mtime), converted) | ||||||
|  |  | ||||||
|  |  | ||||||
| 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 |  | ||||||
|     usage: int |  | ||||||
|     storage: int |  | ||||||
|   | |||||||