Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
002e51f36e | ||
|
|
7167af8984 | ||
|
|
037b68fc9d | ||
|
|
5cb00f3ef0 | ||
|
|
30d0b3064e |
Generated
+1
@@ -2574,6 +2574,7 @@ dependencies = [
|
|||||||
"time",
|
"time",
|
||||||
"tokio",
|
"tokio",
|
||||||
"tokio-util",
|
"tokio-util",
|
||||||
|
"tower",
|
||||||
"tower-http",
|
"tower-http",
|
||||||
"tracing",
|
"tracing",
|
||||||
"tracing-subscriber",
|
"tracing-subscriber",
|
||||||
|
|||||||
+2
-1
@@ -37,7 +37,8 @@ tempfile = "3"
|
|||||||
time = "0.3"
|
time = "0.3"
|
||||||
tokio = { version = "1", features = ["full"] }
|
tokio = { version = "1", features = ["full"] }
|
||||||
tokio-util = { version = "0.7", features = ["io"] }
|
tokio-util = { version = "0.7", features = ["io"] }
|
||||||
tower-http = { version = "0.6", features = ["fs", "trace"] }
|
tower = { version = "0.5", features = ["util"] }
|
||||||
|
tower-http = { version = "0.6", features = ["fs", "set-header", "trace"] }
|
||||||
tracing = "0.1"
|
tracing = "0.1"
|
||||||
tracing-subscriber = { version = "0.3", features = ["env-filter"] }
|
tracing-subscriber = { version = "0.3", features = ["env-filter"] }
|
||||||
urlencoding = "2"
|
urlencoding = "2"
|
||||||
|
|||||||
@@ -2,7 +2,25 @@
|
|||||||
|
|
||||||
Self-hosted client gallery for photographers. Upload RAWs/JPGs into albums,
|
Self-hosted client gallery for photographers. Upload RAWs/JPGs into albums,
|
||||||
share them with clients via private (optionally password-protected) links,
|
share them with clients via private (optionally password-protected) links,
|
||||||
collect ratings and tags, and let clients download originals.
|
collect accept/reject votes, ratings and tags, and let clients download
|
||||||
|
originals.
|
||||||
|
|
||||||
|
## Screenshots
|
||||||
|
|
||||||
|
The album view — drag-and-drop upload, justified gallery, and each client's
|
||||||
|
feedback (votes, stars, tags) overlaid on the thumbnails:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
What clients see on a share link — vote on favorites, filter by verdict,
|
||||||
|
download selects or the whole album as a ZIP:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
The lightbox — accept/reject, star rating, tags, and keyboard-driven culling
|
||||||
|
(`P`/`X`/`U`, `1`–`5`):
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
## Architecture
|
## Architecture
|
||||||
|
|
||||||
@@ -36,8 +54,13 @@ collect ratings and tags, and let clients download originals.
|
|||||||
revokes access immediately. Clients use unguessable share tokens, optionally
|
revokes access immediately. Clients use unguessable share tokens, optionally
|
||||||
gated by an argon2-hashed password (10 wrong guesses lock the link for
|
gated by an argon2-hashed password (10 wrong guesses lock the link for
|
||||||
15 minutes).
|
15 minutes).
|
||||||
- **Frontend**: React + Vite SPA — justified gallery, lightbox with rating
|
- **Frontend**: React + Vite SPA — justified gallery, lightbox with
|
||||||
stars and tag chips, drag-and-drop multi-file upload with progress.
|
accept/reject thumbs, rating stars and tag chips, keyboard-driven culling
|
||||||
|
(`P`/`X`/`U`, `1`–`5`, `?` shows all shortcuts), drag-and-drop multi-file
|
||||||
|
upload with progress. Touch-first on mobile: swipe sideways to browse,
|
||||||
|
flick a photo up/down to accept/reject (real physics — votes commit
|
||||||
|
instantly, the animation is decoration), pinch to zoom, always-visible
|
||||||
|
selection checkmarks. Voting the last photo fades back to the gallery.
|
||||||
|
|
||||||
## Local development
|
## Local development
|
||||||
|
|
||||||
@@ -85,20 +108,20 @@ All configuration is via environment variables:
|
|||||||
|
|
||||||
## Deploying to Kubernetes
|
## Deploying to Kubernetes
|
||||||
|
|
||||||
Build and push the image (single image contains `server`, `worker`, and the
|
The prebuilt image is at `git.draic.info/nils/photos` (single image contains
|
||||||
built frontend):
|
`server`, `worker`, and the built frontend). To build your own instead:
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
docker build -t ghcr.io/YOU/photos:0.1.0 .
|
docker build -t registry.example.com/you/photos:0.4.0 .
|
||||||
docker push ghcr.io/YOU/photos:0.1.0
|
docker push registry.example.com/you/photos:0.4.0
|
||||||
```
|
```
|
||||||
|
|
||||||
Install the chart, pointing it at your existing Postgres and S3:
|
Install the chart, pointing it at your existing Postgres and S3:
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
helm install photos deploy/chart \
|
helm install photos deploy/chart \
|
||||||
--set image.repository=ghcr.io/YOU/photos \
|
--set image.repository=git.draic.info/nils/photos \
|
||||||
--set image.tag=0.1.0 \
|
--set image.tag=0.4.0 \
|
||||||
--set publicUrl=https://photos.example.com \
|
--set publicUrl=https://photos.example.com \
|
||||||
--set ingress.host=photos.example.com \
|
--set ingress.host=photos.example.com \
|
||||||
--set config.oidcIssuer=https://auth.example.com \
|
--set config.oidcIssuer=https://auth.example.com \
|
||||||
@@ -135,9 +158,12 @@ Notes:
|
|||||||
- Each album can have any number of share links (`/s/<24-char-token>`), each
|
- Each album can have any number of share links (`/s/<24-char-token>`), each
|
||||||
with its own label (e.g. the client's name), optional password, optional
|
with its own label (e.g. the client's name), optional password, optional
|
||||||
expiry, and a per-link download toggle.
|
expiry, and a per-link download toggle.
|
||||||
- Ratings (1–5 stars) and free-form tags are stored **per link**, so create
|
- Accept/reject votes (👍/👎), ratings (1–5 stars) and free-form tags are
|
||||||
one link per client to keep feedback separate. The album view shows all
|
stored **per link**, so create one link per client to keep feedback
|
||||||
feedback grouped by link label.
|
separate. The album view shows all feedback grouped by link label, and
|
||||||
|
clients can filter their gallery by verdict (e.g. review only what's still
|
||||||
|
undecided, or select-all + download the accepted set). Culling works with
|
||||||
|
keyboard (`P`/`X` auto-advance) on desktop and swipe gestures on mobile.
|
||||||
- Clients (and you) can multi-select photos and download them — or the whole
|
- Clients (and you) can multi-select photos and download them — or the whole
|
||||||
album — as a ZIP. Archives are streamed (each file spools briefly through a
|
album — as a ZIP. Archives are streamed (each file spools briefly through a
|
||||||
temp file for its checksum, then pipelines while the next one prefetches),
|
temp file for its checksum, then pipelines while the next one prefetches),
|
||||||
@@ -150,8 +176,8 @@ Notes:
|
|||||||
- 10 wrong passwords lock a link for 15 minutes (fresh attempts after the
|
- 10 wrong passwords lock a link for 15 minutes (fresh attempts after the
|
||||||
window). A locked link shows in the album's share list with an Unlock
|
window). A locked link shows in the album's share list with an Unlock
|
||||||
button.
|
button.
|
||||||
- Deleting a link removes its ratings/tags; deleting photos or albums cleans
|
- Deleting a link removes its votes/ratings/tags; deleting photos or albums
|
||||||
up S3 objects via background jobs.
|
cleans up S3 objects via background jobs.
|
||||||
|
|
||||||
## Known limitations / deliberate v1 cuts
|
## Known limitations / deliberate v1 cuts
|
||||||
|
|
||||||
|
|||||||
Binary file not shown.
|
After Width: | Height: | Size: 400 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 528 KiB |
Binary file not shown.
|
After Width: | Height: | Size: 389 KiB |
@@ -36,14 +36,13 @@ export default function Gallery({ photos, onOpen, overlay, selected, onToggleSel
|
|||||||
const [width, setWidth] = useState(0)
|
const [width, setWidth] = useState(0)
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const el = containerRef.current
|
|
||||||
if (!el) return
|
|
||||||
const observer = new ResizeObserver((entries) => setWidth(entries[0].contentRect.width))
|
const observer = new ResizeObserver((entries) => setWidth(entries[0].contentRect.width))
|
||||||
observer.observe(el)
|
observer.observe(containerRef.current)
|
||||||
return () => observer.disconnect()
|
return () => observer.disconnect()
|
||||||
}, [])
|
}, [])
|
||||||
|
|
||||||
if (photos.length === 0) return null
|
// The container renders even with zero photos — unmounting it would detach
|
||||||
|
// the observer and leave a later non-empty render stuck at width 0.
|
||||||
const gap = 6
|
const gap = 6
|
||||||
const targetHeight = width < 700 ? 170 : 240
|
const targetHeight = width < 700 ? 170 : 240
|
||||||
const rows = width > 0 ? layoutRows(photos, width, targetHeight, gap) : []
|
const rows = width > 0 ? layoutRows(photos, width, targetHeight, gap) : []
|
||||||
@@ -69,7 +68,7 @@ export default function Gallery({ photos, onOpen, overlay, selected, onToggleSel
|
|||||||
title={isSelected ? 'Deselect' : 'Select'}
|
title={isSelected ? 'Deselect' : 'Select'}
|
||||||
onClick={(e) => {
|
onClick={(e) => {
|
||||||
e.stopPropagation()
|
e.stopPropagation()
|
||||||
onToggleSelect(p.id)
|
onToggleSelect(p.id, e.shiftKey)
|
||||||
}}
|
}}
|
||||||
>
|
>
|
||||||
✓
|
✓
|
||||||
|
|||||||
@@ -1,18 +1,87 @@
|
|||||||
import { useEffect } from 'react'
|
import { useEffect, useRef, useState } from 'react'
|
||||||
import { imgUrl } from '../api'
|
import { imgUrl } from '../api'
|
||||||
|
import useSwipe from '../useSwipe'
|
||||||
|
|
||||||
export default function Lightbox({ photos, index, onClose, onNav, footer }) {
|
const BASE_SHORTCUTS = [
|
||||||
|
['← / →', 'previous / next photo'],
|
||||||
|
['Space', 'next photo (Shift+Space back)'],
|
||||||
|
['?', 'show / hide shortcuts'],
|
||||||
|
['Esc', 'close'],
|
||||||
|
]
|
||||||
|
|
||||||
|
// `actions` defines the page's shortcuts as one table — display and dispatch
|
||||||
|
// come from the same entry, so the help overlay can't drift from behavior:
|
||||||
|
// { keys: ['p'], help: ['P', 'accept…'], run: (photo, key) => … }.
|
||||||
|
// Keys fire only outside text inputs and while the help overlay is closed.
|
||||||
|
// `gestures` ({ up, down }) maps vertical touch flicks on the photo — the
|
||||||
|
// horizontal axis always navigates, so voting and browsing never collide.
|
||||||
|
// `closing` fades the whole modal out; `onClosed` fires when the fade ends
|
||||||
|
// (the page then actually unmounts the lightbox).
|
||||||
|
export default function Lightbox({
|
||||||
|
photos,
|
||||||
|
index,
|
||||||
|
onClose,
|
||||||
|
onNav,
|
||||||
|
footer,
|
||||||
|
actions,
|
||||||
|
gestures,
|
||||||
|
closing,
|
||||||
|
onClosed,
|
||||||
|
}) {
|
||||||
const photo = photos[index]
|
const photo = photos[index]
|
||||||
|
const [showHelp, setShowHelp] = useState(false)
|
||||||
|
|
||||||
|
// Handlers and view state live in a ref, updated every render, so the
|
||||||
|
// window listener is attached once yet always dispatches against current
|
||||||
|
// values — re-subscribing per render leaves a gap until effects re-run in
|
||||||
|
// which a fast second keystroke hits a stale closure (and e.g. re-votes
|
||||||
|
// the previous photo).
|
||||||
|
const live = useRef({})
|
||||||
|
live.current = { index, count: photos.length, photo, onClose, onNav, actions, showHelp, closing }
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const onKey = (e) => {
|
// Only text entry captures keys (Escape leaves the field); focus on a
|
||||||
if (e.key === 'Escape') onClose()
|
// checkbox or button must not disable lightbox navigation.
|
||||||
if (e.key === 'ArrowRight' && index < photos.length - 1) onNav(index + 1)
|
const isTyping = (el) =>
|
||||||
if (e.key === 'ArrowLeft' && index > 0) onNav(index - 1)
|
el.tagName === 'TEXTAREA' ||
|
||||||
|
el.isContentEditable ||
|
||||||
|
(el.tagName === 'INPUT' && !['checkbox', 'radio', 'button'].includes(el.type))
|
||||||
|
const handler = (e) => {
|
||||||
|
const s = live.current
|
||||||
|
if (s.closing) return
|
||||||
|
if (isTyping(e.target)) {
|
||||||
|
if (e.key === 'Escape') e.target.blur()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (e.metaKey || e.ctrlKey || e.altKey) return
|
||||||
|
if (e.key === 'Escape') {
|
||||||
|
if (s.showHelp) setShowHelp(false)
|
||||||
|
else s.onClose()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (e.key === '?') {
|
||||||
|
setShowHelp((h) => !h)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
// With the help overlay up, keys must not act on the photo behind it.
|
||||||
|
if (s.showHelp) return
|
||||||
|
if (e.key === 'ArrowRight' || (e.key === ' ' && !e.shiftKey)) {
|
||||||
|
e.preventDefault()
|
||||||
|
if (s.index < s.count - 1) s.onNav(s.index + 1)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (e.key === 'ArrowLeft' || (e.key === ' ' && e.shiftKey)) {
|
||||||
|
e.preventDefault()
|
||||||
|
if (s.index > 0) s.onNav(s.index - 1)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const key = e.key.toLowerCase()
|
||||||
|
const action = s.actions?.find((a) => a.keys.includes(key))
|
||||||
|
if (action && s.photo) action.run(s.photo, key)
|
||||||
}
|
}
|
||||||
window.addEventListener('keydown', onKey)
|
window.addEventListener('keydown', handler)
|
||||||
return () => window.removeEventListener('keydown', onKey)
|
return () => window.removeEventListener('keydown', handler)
|
||||||
}, [index, photos.length, onClose, onNav])
|
}, [])
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
document.body.style.overflow = 'hidden'
|
document.body.style.overflow = 'hidden'
|
||||||
@@ -21,15 +90,53 @@ export default function Lightbox({ photos, index, onClose, onNav, footer }) {
|
|||||||
}
|
}
|
||||||
}, [])
|
}, [])
|
||||||
|
|
||||||
|
const preview = (p) => imgUrl(p, 'preview')
|
||||||
|
const prevPhoto = photos[index - 1]
|
||||||
|
const nextPhoto = photos[index + 1]
|
||||||
|
|
||||||
|
const swipe = useSwipe({
|
||||||
|
photo,
|
||||||
|
index,
|
||||||
|
count: photos.length,
|
||||||
|
onNav,
|
||||||
|
gestures,
|
||||||
|
hasNext: index < photos.length - 1,
|
||||||
|
})
|
||||||
|
|
||||||
|
// Immediate neighbors are real DOM slides (loaded by definition); warm the
|
||||||
|
// browser cache a few photos further out so fast swiping never hits the
|
||||||
|
// network.
|
||||||
|
useEffect(() => {
|
||||||
|
for (const i of [index + 2, index + 3, index - 2]) {
|
||||||
|
if (photos[i]) new Image().src = preview(photos[i])
|
||||||
|
}
|
||||||
|
}, [index, photos])
|
||||||
|
|
||||||
if (!photo) return null
|
if (!photo) return null
|
||||||
|
|
||||||
|
// Did the vote fly off the photo we're still showing (no advance target)?
|
||||||
|
const exitSelf = swipe.exit && swipe.exit.photo.id === photo.id
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="lightbox" onClick={onClose}>
|
<div
|
||||||
|
className={`lightbox${closing ? ' lb-closing' : ''}`}
|
||||||
|
onClick={onClose}
|
||||||
|
onAnimationEnd={(e) => {
|
||||||
|
if (e.animationName === 'lb-fade-out') onClosed?.()
|
||||||
|
}}
|
||||||
|
>
|
||||||
<div className="lb-top" onClick={(e) => e.stopPropagation()}>
|
<div className="lb-top" onClick={(e) => e.stopPropagation()}>
|
||||||
<span className="lb-name">{photo.filename}</span>
|
<span className="lb-name">{photo.filename}</span>
|
||||||
<span className="lb-count">
|
<span className="lb-count">
|
||||||
{index + 1} / {photos.length}
|
{index + 1} / {photos.length}
|
||||||
</span>
|
</span>
|
||||||
|
<button
|
||||||
|
className="lb-btn"
|
||||||
|
onClick={() => setShowHelp((h) => !h)}
|
||||||
|
title="Keyboard shortcuts (?)"
|
||||||
|
>
|
||||||
|
?
|
||||||
|
</button>
|
||||||
<button className="lb-btn" onClick={onClose} title="Close (Esc)">
|
<button className="lb-btn" onClick={onClose} title="Close (Esc)">
|
||||||
✕
|
✕
|
||||||
</button>
|
</button>
|
||||||
@@ -44,13 +151,59 @@ export default function Lightbox({ photos, index, onClose, onNav, footer }) {
|
|||||||
>
|
>
|
||||||
‹
|
‹
|
||||||
</button>
|
</button>
|
||||||
<div className="lb-stage">
|
<div className="lb-stage" {...swipe.handlers}>
|
||||||
<img
|
<div
|
||||||
className="lb-img"
|
className="lb-track"
|
||||||
src={imgUrl(photo, 'preview')}
|
ref={swipe.trackRef}
|
||||||
alt={photo.filename}
|
style={swipe.trackStyle}
|
||||||
onClick={(e) => e.stopPropagation()}
|
onTransitionEnd={swipe.onTrackTransitionEnd}
|
||||||
/>
|
>
|
||||||
|
{prevPhoto && (
|
||||||
|
<div key={prevPhoto.id} className="lb-slide" style={{ transform: 'translateX(-100vw)' }}>
|
||||||
|
<img className="lb-img" src={preview(prevPhoto)} alt="" />
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
<div key={photo.id} className="lb-slide" style={{ zIndex: 1 }}>
|
||||||
|
<img
|
||||||
|
ref={swipe.imgRef}
|
||||||
|
className={`lb-img${swipe.exit ? (exitSelf ? ' lb-hidden' : ' lb-enter') : ''}`}
|
||||||
|
style={swipe.imgStyle}
|
||||||
|
onTransitionEnd={swipe.onImgTransitionEnd}
|
||||||
|
src={preview(photo)}
|
||||||
|
alt={photo.filename}
|
||||||
|
onClick={(e) => e.stopPropagation()}
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
{nextPhoto &&
|
||||||
|
(swipe.showBehind ? (
|
||||||
|
<div
|
||||||
|
key={nextPhoto.id}
|
||||||
|
ref={swipe.behindRef}
|
||||||
|
className="lb-slide lb-behind"
|
||||||
|
style={swipe.behindStyle}
|
||||||
|
>
|
||||||
|
<img className="lb-img" src={preview(nextPhoto)} alt="" />
|
||||||
|
</div>
|
||||||
|
) : (
|
||||||
|
<div key={nextPhoto.id} className="lb-slide" style={{ transform: 'translateX(100vw)' }}>
|
||||||
|
<img className="lb-img" src={preview(nextPhoto)} alt="" />
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
{swipe.exit && (
|
||||||
|
<div
|
||||||
|
className="lb-slide lb-ghost"
|
||||||
|
style={{ '--dy': `${swipe.exit.dy}px`, '--rot': `${swipe.exit.dy / 40}deg` }}
|
||||||
|
onAnimationEnd={swipe.clearExit}
|
||||||
|
>
|
||||||
|
<img
|
||||||
|
className={`lb-img lb-exit-${swipe.exit.dir}`}
|
||||||
|
src={preview(swipe.exit.photo)}
|
||||||
|
alt=""
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
|
{swipe.showBadge && <div ref={swipe.badgeRef} className="lb-flick" />}
|
||||||
</div>
|
</div>
|
||||||
<button
|
<button
|
||||||
className="lb-nav lb-next"
|
className="lb-nav lb-next"
|
||||||
@@ -67,6 +220,25 @@ export default function Lightbox({ photos, index, onClose, onNav, footer }) {
|
|||||||
{footer(photo)}
|
{footer(photo)}
|
||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
|
{showHelp && (
|
||||||
|
<div
|
||||||
|
className="lb-help"
|
||||||
|
onClick={(e) => {
|
||||||
|
e.stopPropagation()
|
||||||
|
setShowHelp(false)
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<div className="lb-help-card">
|
||||||
|
<h3>Keyboard shortcuts</h3>
|
||||||
|
{[...(actions?.map((a) => a.help) || []), ...BASE_SHORTCUTS].map(([keys, label]) => (
|
||||||
|
<div key={keys} className="lb-help-row">
|
||||||
|
<kbd>{keys}</kbd>
|
||||||
|
<span className="muted">{label}</span>
|
||||||
|
</div>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
</div>
|
</div>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -15,6 +15,7 @@ export default function SelectionBar({
|
|||||||
onClear,
|
onClear,
|
||||||
onDownload,
|
onDownload,
|
||||||
onDownloadAll,
|
onDownloadAll,
|
||||||
|
onDelete,
|
||||||
}) {
|
}) {
|
||||||
if (total === 0) return null
|
if (total === 0) return null
|
||||||
|
|
||||||
@@ -47,6 +48,11 @@ export default function SelectionBar({
|
|||||||
<button className="btn btn-primary" onClick={onDownload}>
|
<button className="btn btn-primary" onClick={onDownload}>
|
||||||
Download {count} as ZIP ({fmtBytes(selectedBytes)})
|
Download {count} as ZIP ({fmtBytes(selectedBytes)})
|
||||||
</button>
|
</button>
|
||||||
|
{onDelete && (
|
||||||
|
<button className="btn btn-danger" onClick={onDelete}>
|
||||||
|
Delete {count}
|
||||||
|
</button>
|
||||||
|
)}
|
||||||
</div>
|
</div>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,27 @@
|
|||||||
|
export const ACCEPT_GLYPH = '👍'
|
||||||
|
export const REJECT_GLYPH = '👎'
|
||||||
|
|
||||||
|
// Accept/reject vote. `value` is 'accept', 'reject' or null; clicking the
|
||||||
|
// active thumb clears it. Without onChange it renders read-only.
|
||||||
|
export default function Thumbs({ value, onChange, small }) {
|
||||||
|
const thumb = (verdict, glyph, label) => (
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
className={`thumb${value === verdict ? ' active' : ''}`}
|
||||||
|
disabled={!onChange}
|
||||||
|
onClick={(e) => {
|
||||||
|
e.stopPropagation()
|
||||||
|
onChange(value === verdict ? null : verdict)
|
||||||
|
}}
|
||||||
|
title={onChange ? label : undefined}
|
||||||
|
>
|
||||||
|
{glyph}
|
||||||
|
</button>
|
||||||
|
)
|
||||||
|
return (
|
||||||
|
<span className={`thumbs${small ? ' thumbs-small' : ''}`}>
|
||||||
|
{thumb('accept', ACCEPT_GLYPH, 'Accept (P)')}
|
||||||
|
{thumb('reject', REJECT_GLYPH, 'Reject (X)')}
|
||||||
|
</span>
|
||||||
|
)
|
||||||
|
}
|
||||||
@@ -5,6 +5,8 @@ import Gallery from '../components/Gallery'
|
|||||||
import Lightbox from '../components/Lightbox'
|
import Lightbox from '../components/Lightbox'
|
||||||
import SelectionBar, { fmtBytes } from '../components/SelectionBar'
|
import SelectionBar, { fmtBytes } from '../components/SelectionBar'
|
||||||
import Stars from '../components/Stars'
|
import Stars from '../components/Stars'
|
||||||
|
import Thumbs from '../components/Thumbs'
|
||||||
|
import useLightbox from '../useLightbox'
|
||||||
import useSelection from '../useSelection'
|
import useSelection from '../useSelection'
|
||||||
|
|
||||||
function fmtEta(seconds) {
|
function fmtEta(seconds) {
|
||||||
@@ -16,6 +18,67 @@ function fmtEta(seconds) {
|
|||||||
|
|
||||||
const UPLOAD_CONCURRENCY = 3
|
const UPLOAD_CONCURRENCY = 3
|
||||||
|
|
||||||
|
// Expiry convention, in one place for the create form and the row editor:
|
||||||
|
// end of the chosen day in the photographer's local timezone — date-only
|
||||||
|
// strings would parse as UTC midnight and expire a day early.
|
||||||
|
const endOfDayIso = (day) => (day ? new Date(`${day}T23:59:59`).toISOString() : null)
|
||||||
|
|
||||||
|
// ISO timestamp -> local yyyy-mm-dd for date inputs.
|
||||||
|
const localDate = (iso) => {
|
||||||
|
const d = new Date(iso)
|
||||||
|
return `${d.getFullYear()}-${String(d.getMonth() + 1).padStart(2, '0')}-${String(d.getDate()).padStart(2, '0')}`
|
||||||
|
}
|
||||||
|
|
||||||
|
// Staged expiry editor: commits on blur/Enter, never per keystroke — typing
|
||||||
|
// a year fires change events with bogus intermediate dates (year 0002) that
|
||||||
|
// must not hit the live link. The ✕ clears explicitly; Safari's date input
|
||||||
|
// has no native clear control.
|
||||||
|
function ExpiryDate({ value, onCommit }) {
|
||||||
|
const current = value ? localDate(value) : ''
|
||||||
|
const [draft, setDraft] = useState(current)
|
||||||
|
useEffect(() => setDraft(current), [current])
|
||||||
|
|
||||||
|
const commit = () => {
|
||||||
|
if (draft === current) return
|
||||||
|
// A half-typed year (e.g. 0002) can survive until blur; don't persist it.
|
||||||
|
if (draft && draft.slice(0, 4) < '2000') {
|
||||||
|
setDraft(current)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
onCommit(endOfDayIso(draft))
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<label className="row field-label" title="Expiry date — empty means the link never expires">
|
||||||
|
<span className="muted">expires</span>
|
||||||
|
<input
|
||||||
|
type="date"
|
||||||
|
value={draft}
|
||||||
|
onChange={(e) => setDraft(e.target.value)}
|
||||||
|
onBlur={commit}
|
||||||
|
onKeyDown={(e) => {
|
||||||
|
if (e.key === 'Enter') e.target.blur()
|
||||||
|
}}
|
||||||
|
/>
|
||||||
|
{draft ? (
|
||||||
|
<button
|
||||||
|
type="button"
|
||||||
|
className="btn btn-ghost"
|
||||||
|
title="Remove expiry — link never expires"
|
||||||
|
onClick={() => {
|
||||||
|
setDraft('')
|
||||||
|
onCommit(null)
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
✕
|
||||||
|
</button>
|
||||||
|
) : (
|
||||||
|
<span className="muted">never</span>
|
||||||
|
)}
|
||||||
|
</label>
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
function UploadZone({ albumId, onUploaded }) {
|
function UploadZone({ albumId, onUploaded }) {
|
||||||
const [queue, setQueue] = useState([])
|
const [queue, setQueue] = useState([])
|
||||||
const [dragging, setDragging] = useState(false)
|
const [dragging, setDragging] = useState(false)
|
||||||
@@ -196,11 +259,7 @@ function SharesPanel({ albumId }) {
|
|||||||
label: form.label,
|
label: form.label,
|
||||||
password: form.password || null,
|
password: form.password || null,
|
||||||
allow_download: form.allow_download,
|
allow_download: form.allow_download,
|
||||||
// End of the chosen day in the photographer's local timezone —
|
expires_at: endOfDayIso(form.expires_at),
|
||||||
// date-only strings would parse as UTC midnight and expire a day early.
|
|
||||||
expires_at: form.expires_at
|
|
||||||
? new Date(`${form.expires_at}T23:59:59`).toISOString()
|
|
||||||
: null,
|
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
setForm({ label: '', password: '', allow_download: true, expires_at: '' })
|
setForm({ label: '', password: '', allow_download: true, expires_at: '' })
|
||||||
@@ -217,6 +276,18 @@ function SharesPanel({ albumId }) {
|
|||||||
setTimeout(() => setCopied(null), 1500)
|
setTimeout(() => setCopied(null), 1500)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const update = async (shareId, patch) => {
|
||||||
|
try {
|
||||||
|
const updated = await api(`/api/shares/${shareId}`, { method: 'PATCH', body: patch })
|
||||||
|
setShares((list) => list.map((s) => (s.id === shareId ? updated : s)))
|
||||||
|
setError(null)
|
||||||
|
} catch (e) {
|
||||||
|
setError(e.message)
|
||||||
|
// Re-sync the controlled inputs with what the server actually has.
|
||||||
|
load()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<section className="panel">
|
<section className="panel">
|
||||||
<h2>Client links</h2>
|
<h2>Client links</h2>
|
||||||
@@ -231,15 +302,20 @@ function SharesPanel({ albumId }) {
|
|||||||
<span className="muted">
|
<span className="muted">
|
||||||
{s.has_password ? '🔒 password' : 'no password'}
|
{s.has_password ? '🔒 password' : 'no password'}
|
||||||
{' · '}
|
{' · '}
|
||||||
{s.allow_download ? 'downloads on' : 'downloads off'}
|
{s.rating_count} ratings, {s.tag_count} tags, 👍 {s.accept_count} 👎{' '}
|
||||||
{s.expires_at
|
{s.reject_count}
|
||||||
? ` · expires ${new Date(s.expires_at).toLocaleDateString()}`
|
|
||||||
: ' · never expires'}
|
|
||||||
{' · '}
|
|
||||||
{s.rating_count} ratings, {s.tag_count} tags
|
|
||||||
</span>
|
</span>
|
||||||
</div>
|
</div>
|
||||||
<div className="row">
|
<div className="row">
|
||||||
|
<label className="select-toggle" title="Allow this link to download originals/ZIPs">
|
||||||
|
<input
|
||||||
|
type="checkbox"
|
||||||
|
checked={s.allow_download}
|
||||||
|
onChange={(e) => update(s.id, { allow_download: e.target.checked })}
|
||||||
|
/>
|
||||||
|
downloads
|
||||||
|
</label>
|
||||||
|
<ExpiryDate value={s.expires_at} onCommit={(iso) => update(s.id, { expires_at: iso })} />
|
||||||
{s.locked && (
|
{s.locked && (
|
||||||
<button
|
<button
|
||||||
className="btn"
|
className="btn"
|
||||||
@@ -320,9 +396,6 @@ export default function AlbumPage() {
|
|||||||
const navigate = useNavigate()
|
const navigate = useNavigate()
|
||||||
const [detail, setDetail] = useState(null)
|
const [detail, setDetail] = useState(null)
|
||||||
const [error, setError] = useState(null)
|
const [error, setError] = useState(null)
|
||||||
// Track the open photo by id, not index — the polling refetch can reorder
|
|
||||||
// the array underneath an open lightbox.
|
|
||||||
const [lightboxId, setLightboxId] = useState(null)
|
|
||||||
|
|
||||||
const load = useCallback(
|
const load = useCallback(
|
||||||
() => api(`/api/albums/${id}`).then(setDetail).catch((e) => setError(e.message)),
|
() => api(`/api/albums/${id}`).then(setDetail).catch((e) => setError(e.message)),
|
||||||
@@ -342,14 +415,7 @@ export default function AlbumPage() {
|
|||||||
|
|
||||||
const ready = (detail?.photos ?? []).filter((p) => p.status === 'ready')
|
const ready = (detail?.photos ?? []).filter((p) => p.status === 'ready')
|
||||||
const { selected, toggle, selectAll, clear, selectedBytes, totalBytes } = useSelection(ready)
|
const { selected, toggle, selectAll, clear, selectedBytes, totalBytes } = useSelection(ready)
|
||||||
const lightboxIndex = ready.findIndex((p) => p.id === lightboxId)
|
const lightbox = useLightbox(ready)
|
||||||
|
|
||||||
// If the open photo leaves the ready list (deleted elsewhere, reprocess),
|
|
||||||
// close for good — otherwise the lightbox would pop back open when the
|
|
||||||
// photo returns to ready.
|
|
||||||
useEffect(() => {
|
|
||||||
if (lightboxId && lightboxIndex < 0) setLightboxId(null)
|
|
||||||
}, [lightboxId, lightboxIndex])
|
|
||||||
|
|
||||||
if (error) return <p className="error">{error}</p>
|
if (error) return <p className="error">{error}</p>
|
||||||
if (!detail) return <p className="muted">Loading…</p>
|
if (!detail) return <p className="muted">Loading…</p>
|
||||||
@@ -379,11 +445,23 @@ export default function AlbumPage() {
|
|||||||
|
|
||||||
const removePhoto = async (photoId) => {
|
const removePhoto = async (photoId) => {
|
||||||
if (!confirm('Delete this photo?')) return
|
if (!confirm('Delete this photo?')) return
|
||||||
setLightboxId(null)
|
lightbox.close()
|
||||||
await api(`/api/photos/${photoId}`, { method: 'DELETE' })
|
await api(`/api/photos/${photoId}`, { method: 'DELETE' })
|
||||||
load()
|
load()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const removeSelected = async () => {
|
||||||
|
if (!confirm(`Delete ${selected.size} selected photo${selected.size === 1 ? '' : 's'}? This cannot be undone.`))
|
||||||
|
return
|
||||||
|
try {
|
||||||
|
await api('/api/photos/delete', { method: 'POST', body: { ids: [...selected] } })
|
||||||
|
clear()
|
||||||
|
} catch (e) {
|
||||||
|
alert(`Delete failed: ${e.message}`)
|
||||||
|
}
|
||||||
|
load()
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<>
|
<>
|
||||||
<div className="page-head">
|
<div className="page-head">
|
||||||
@@ -436,15 +514,20 @@ export default function AlbumPage() {
|
|||||||
|
|
||||||
<Gallery
|
<Gallery
|
||||||
photos={ready}
|
photos={ready}
|
||||||
onOpen={(i) => setLightboxId(ready[i].id)}
|
onOpen={lightbox.openAt}
|
||||||
selected={selected}
|
selected={selected}
|
||||||
onToggleSelect={toggle}
|
onToggleSelect={toggle}
|
||||||
overlay={(p) => {
|
overlay={(p) => {
|
||||||
const avg = avgRating(p.id)
|
const avg = avgRating(p.id)
|
||||||
const tagCount = feedback[p.id]?.tags.length || 0
|
const tagCount = feedback[p.id]?.tags.length || 0
|
||||||
if (avg === null && tagCount === 0) return null
|
const verdicts = feedback[p.id]?.verdicts || []
|
||||||
|
const accepts = verdicts.filter((v) => v.verdict === 'accept').length
|
||||||
|
const rejects = verdicts.length - accepts
|
||||||
|
if (avg === null && tagCount === 0 && accepts === 0 && rejects === 0) return null
|
||||||
return (
|
return (
|
||||||
<div className="g-overlay">
|
<div className="g-overlay">
|
||||||
|
{accepts > 0 && <span>👍 {accepts}</span>}
|
||||||
|
{rejects > 0 && <span>👎 {rejects}</span>}
|
||||||
{avg !== null && <span>★ {avg.toFixed(1)}</span>}
|
{avg !== null && <span>★ {avg.toFixed(1)}</span>}
|
||||||
{tagCount > 0 && <span># {tagCount}</span>}
|
{tagCount > 0 && <span># {tagCount}</span>}
|
||||||
</div>
|
</div>
|
||||||
@@ -460,26 +543,35 @@ export default function AlbumPage() {
|
|||||||
total={ready.length}
|
total={ready.length}
|
||||||
selectedBytes={selectedBytes}
|
selectedBytes={selectedBytes}
|
||||||
totalBytes={totalBytes}
|
totalBytes={totalBytes}
|
||||||
onSelectAll={selectAll}
|
onSelectAll={() => selectAll(ready)}
|
||||||
onClear={clear}
|
onClear={clear}
|
||||||
onDownload={() => postDownload(`/api/albums/${id}/zip`, [...selected].join(','))}
|
onDownload={() => postDownload(`/api/albums/${id}/zip`, [...selected].join(','))}
|
||||||
onDownloadAll={() => postDownload(`/api/albums/${id}/zip`)}
|
onDownloadAll={() => postDownload(`/api/albums/${id}/zip`)}
|
||||||
|
onDelete={removeSelected}
|
||||||
/>
|
/>
|
||||||
|
|
||||||
{lightboxIndex >= 0 && (
|
{lightbox.index >= 0 && (
|
||||||
<Lightbox
|
<Lightbox
|
||||||
photos={ready}
|
photos={ready}
|
||||||
index={lightboxIndex}
|
index={lightbox.index}
|
||||||
onClose={() => setLightboxId(null)}
|
onClose={lightbox.close}
|
||||||
onNav={(i) => setLightboxId(ready[i].id)}
|
onNav={lightbox.openAt}
|
||||||
|
actions={[
|
||||||
|
{ keys: ['s'], help: ['S', 'select for download'], run: (p) => toggle(p.id) },
|
||||||
|
]}
|
||||||
footer={(p) => {
|
footer={(p) => {
|
||||||
const fb = feedback[p.id] || { ratings: [], tags: [] }
|
const fb = feedback[p.id] || { ratings: [], verdicts: [], tags: [] }
|
||||||
return (
|
return (
|
||||||
<div className="admin-footer">
|
<div className="admin-footer">
|
||||||
<div className="feedback">
|
<div className="feedback">
|
||||||
{fb.ratings.length === 0 && fb.tags.length === 0 && (
|
{fb.ratings.length === 0 && fb.verdicts.length === 0 && fb.tags.length === 0 && (
|
||||||
<span className="muted">No client feedback yet</span>
|
<span className="muted">No client feedback yet</span>
|
||||||
)}
|
)}
|
||||||
|
{fb.verdicts.map((v, i) => (
|
||||||
|
<span key={`v${i}`} className="feedback-item">
|
||||||
|
{v.share_label || 'client'}: <Thumbs value={v.verdict} small />
|
||||||
|
</span>
|
||||||
|
))}
|
||||||
{fb.ratings.map((r, i) => (
|
{fb.ratings.map((r, i) => (
|
||||||
<span key={`r${i}`} className="feedback-item">
|
<span key={`r${i}`} className="feedback-item">
|
||||||
{r.share_label || 'client'}: <Stars value={r.rating} small />
|
{r.share_label || 'client'}: <Stars value={r.rating} small />
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { useCallback, useEffect, useState } from 'react'
|
import { useCallback, useEffect, useMemo, useRef, useState } from 'react'
|
||||||
import { useParams } from 'react-router-dom'
|
import { useParams } from 'react-router-dom'
|
||||||
import { api, postDownload } from '../api'
|
import { api, postDownload } from '../api'
|
||||||
import Gallery from '../components/Gallery'
|
import Gallery from '../components/Gallery'
|
||||||
@@ -6,18 +6,49 @@ import Lightbox from '../components/Lightbox'
|
|||||||
import SelectionBar from '../components/SelectionBar'
|
import SelectionBar from '../components/SelectionBar'
|
||||||
import Stars from '../components/Stars'
|
import Stars from '../components/Stars'
|
||||||
import TagEditor from '../components/TagEditor'
|
import TagEditor from '../components/TagEditor'
|
||||||
|
import Thumbs from '../components/Thumbs'
|
||||||
|
import useLightbox from '../useLightbox'
|
||||||
import useSelection from '../useSelection'
|
import useSelection from '../useSelection'
|
||||||
|
|
||||||
|
const FILTERS = [
|
||||||
|
{ key: 'all', label: 'All' },
|
||||||
|
{ key: 'accept', label: '👍' },
|
||||||
|
{ key: 'reject', label: '👎' },
|
||||||
|
{ key: 'undecided', label: 'Undecided' },
|
||||||
|
]
|
||||||
|
|
||||||
|
const matchesFilter = (photo, key) =>
|
||||||
|
key === 'all' || (key === 'undecided' ? !photo.my_verdict : photo.my_verdict === key)
|
||||||
|
|
||||||
export default function SharePage() {
|
export default function SharePage() {
|
||||||
const { token } = useParams()
|
const { token } = useParams()
|
||||||
const [view, setView] = useState(null)
|
const [view, setView] = useState(null)
|
||||||
const [error, setError] = useState(null)
|
const [error, setError] = useState(null)
|
||||||
const [password, setPassword] = useState('')
|
const [password, setPassword] = useState('')
|
||||||
const [unlockError, setUnlockError] = useState(null)
|
const [unlockError, setUnlockError] = useState(null)
|
||||||
const [lightbox, setLightbox] = useState(-1)
|
const [filter, setFilter] = useState('all')
|
||||||
const { selected, toggle, selectAll, clear, selectedBytes, totalBytes } = useSelection(
|
|
||||||
view?.photos ?? [],
|
const photos = view?.photos ?? []
|
||||||
)
|
const visible = useMemo(() => photos.filter((p) => matchesFilter(p, filter)), [photos, filter])
|
||||||
|
const filterCounts = useMemo(() => {
|
||||||
|
const counts = { all: photos.length, accept: 0, reject: 0, undecided: 0 }
|
||||||
|
for (const p of photos) counts[p.my_verdict ?? 'undecided'] += 1
|
||||||
|
return counts
|
||||||
|
}, [photos])
|
||||||
|
|
||||||
|
// Selection spans the whole album (so switching filters keeps it), while
|
||||||
|
// the selection bar describes only the current view: its counts, bytes and
|
||||||
|
// downloads cover the visible photos, and "select all" adds them.
|
||||||
|
const { selected, toggle, selectAll, clear } = useSelection(photos)
|
||||||
|
const visibleSelected = visible.filter((p) => selected.has(p.id))
|
||||||
|
const sumBytes = (list) => list.reduce((sum, p) => sum + p.size_bytes, 0)
|
||||||
|
const lightbox = useLightbox(visible)
|
||||||
|
// Voting the last photo ends the run: fade the modal out over the gallery
|
||||||
|
// instead of cutting hard.
|
||||||
|
const [lightboxFading, setLightboxFading] = useState(false)
|
||||||
|
useEffect(() => {
|
||||||
|
if (lightbox.index < 0) setLightboxFading(false)
|
||||||
|
}, [lightbox.index])
|
||||||
|
|
||||||
const load = useCallback(
|
const load = useCallback(
|
||||||
() => api(`/api/share/${token}`).then(setView).catch((e) => setError(e.message)),
|
() => api(`/api/share/${token}`).then(setView).catch((e) => setError(e.message)),
|
||||||
@@ -45,29 +76,77 @@ export default function SharePage() {
|
|||||||
}))
|
}))
|
||||||
}
|
}
|
||||||
|
|
||||||
const setRating = async (photo, rating) => {
|
// Optimistic write: patch local state, PUT, reload from the server on
|
||||||
patchPhoto(photo.id, { my_rating: rating || null })
|
// failure to undo the patch.
|
||||||
|
const saveFeedback = async (photo, patch, endpoint, body) => {
|
||||||
|
patchPhoto(photo.id, patch)
|
||||||
try {
|
try {
|
||||||
await api(`/api/share/${token}/photos/${photo.id}/rating`, {
|
await api(`/api/share/${token}/photos/${photo.id}/${endpoint}`, { method: 'PUT', body })
|
||||||
method: 'PUT',
|
|
||||||
body: { rating },
|
|
||||||
})
|
|
||||||
} catch {
|
} catch {
|
||||||
load()
|
load()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
const setRating = (photo, rating) =>
|
||||||
|
saveFeedback(photo, { my_rating: rating || null }, 'rating', { rating })
|
||||||
|
const setVerdict = (photo, verdict) =>
|
||||||
|
saveFeedback(photo, { my_verdict: verdict }, 'verdict', { verdict })
|
||||||
|
const setTags = (photo, tags) => saveFeedback(photo, { my_tags: tags }, 'tags', { tags })
|
||||||
|
|
||||||
|
// Keyboard votes navigate away from the photo they change, so a transient
|
||||||
|
// toast names what just happened to it — without it the jump reads as
|
||||||
|
// "did that register?".
|
||||||
|
const [flash, setFlash] = useState(null)
|
||||||
|
const flashSeq = useRef(0)
|
||||||
|
const flashTimer = useRef()
|
||||||
|
const showFlash = (text) => {
|
||||||
|
flashSeq.current += 1
|
||||||
|
setFlash({ text, key: flashSeq.current })
|
||||||
|
clearTimeout(flashTimer.current)
|
||||||
|
flashTimer.current = setTimeout(() => setFlash(null), 1400)
|
||||||
|
}
|
||||||
|
useEffect(() => () => clearTimeout(flashTimer.current), [])
|
||||||
|
|
||||||
|
// Culling flow: vote, then advance to the photo that was next in the
|
||||||
|
// current view. Under a filter that hides the voted photo, the advance
|
||||||
|
// target stays visible, so the run continues seamlessly.
|
||||||
|
const voteAndAdvance = (photo, verdict) => {
|
||||||
|
const next = visible[lightbox.index + 1]
|
||||||
|
setVerdict(photo, verdict)
|
||||||
|
showFlash(
|
||||||
|
verdict === 'accept'
|
||||||
|
? `👍 ${photo.filename}`
|
||||||
|
: verdict === 'reject'
|
||||||
|
? `👎 ${photo.filename}`
|
||||||
|
: `↺ ${photo.filename} cleared`,
|
||||||
|
)
|
||||||
|
if (next) lightbox.show(next.id)
|
||||||
|
// Last photo voted: the run is done — fade back to the gallery.
|
||||||
|
else setLightboxFading(true)
|
||||||
|
}
|
||||||
|
|
||||||
const setTags = async (photo, tags) => {
|
const keyActions = [
|
||||||
patchPhoto(photo.id, { my_tags: tags })
|
{ keys: ['p'], help: ['P', 'accept and go to next'], run: (p) => voteAndAdvance(p, 'accept') },
|
||||||
try {
|
{ keys: ['x'], help: ['X', 'reject and go to next'], run: (p) => voteAndAdvance(p, 'reject') },
|
||||||
await api(`/api/share/${token}/photos/${photo.id}/tags`, {
|
{
|
||||||
method: 'PUT',
|
keys: ['u'],
|
||||||
body: { tags },
|
help: ['U', 'clear accept / reject'],
|
||||||
})
|
// When clearing hides the photo from the current filter, advance like
|
||||||
} catch {
|
// a vote so the lightbox doesn't just close.
|
||||||
load()
|
run: (p) =>
|
||||||
}
|
matchesFilter({ my_verdict: null }, filter)
|
||||||
}
|
? setVerdict(p, null)
|
||||||
|
: voteAndAdvance(p, null),
|
||||||
|
},
|
||||||
|
{
|
||||||
|
keys: ['1', '2', '3', '4', '5'],
|
||||||
|
help: ['1–5', 'star rating'],
|
||||||
|
run: (p, key) => setRating(p, Number(key)),
|
||||||
|
},
|
||||||
|
{ keys: ['0'], help: ['0', 'clear star rating'], run: (p) => setRating(p, 0) },
|
||||||
|
...(view?.allow_download
|
||||||
|
? [{ keys: ['s'], help: ['S', 'select for download'], run: (p) => toggle(p.id) }]
|
||||||
|
: []),
|
||||||
|
]
|
||||||
|
|
||||||
if (error) return <div className="center-page">{error}</div>
|
if (error) return <div className="center-page">{error}</div>
|
||||||
if (!view) return <div className="center-page">Loading…</div>
|
if (!view) return <div className="center-page">Loading…</div>
|
||||||
@@ -100,49 +179,89 @@ export default function SharePage() {
|
|||||||
<h1>{view.album_name}</h1>
|
<h1>{view.album_name}</h1>
|
||||||
{view.album_description && <p className="muted">{view.album_description}</p>}
|
{view.album_description && <p className="muted">{view.album_description}</p>}
|
||||||
<p className="muted">
|
<p className="muted">
|
||||||
{view.photos.length} photo{view.photos.length === 1 ? '' : 's'} · click a photo to view,
|
{photos.length} photo{photos.length === 1 ? '' : 's'} · tap a photo to view, rate and
|
||||||
rate and tag
|
tag · swipe ↑ to accept, ↓ to reject · <kbd>?</kbd> shows keyboard shortcuts
|
||||||
</p>
|
</p>
|
||||||
|
{photos.length > 0 && (
|
||||||
|
<div className="filter-bar">
|
||||||
|
{FILTERS.map((f) => (
|
||||||
|
<button
|
||||||
|
key={f.key}
|
||||||
|
className={`filter-chip${filter === f.key ? ' active' : ''}`}
|
||||||
|
onClick={() => setFilter(f.key)}
|
||||||
|
>
|
||||||
|
{f.label} {filterCounts[f.key]}
|
||||||
|
</button>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
</header>
|
</header>
|
||||||
<main className="page">
|
<main className="page">
|
||||||
<Gallery
|
<Gallery
|
||||||
photos={view.photos}
|
photos={visible}
|
||||||
onOpen={setLightbox}
|
onOpen={lightbox.openAt}
|
||||||
selected={view.allow_download ? selected : undefined}
|
selected={view.allow_download ? selected : undefined}
|
||||||
onToggleSelect={view.allow_download ? toggle : undefined}
|
// Shift-ranges must walk the filtered view, not the full album —
|
||||||
|
// otherwise hidden photos get swept into the selection.
|
||||||
|
onToggleSelect={
|
||||||
|
view.allow_download ? (id, shift) => toggle(id, shift, visible) : undefined
|
||||||
|
}
|
||||||
overlay={(p) =>
|
overlay={(p) =>
|
||||||
p.my_rating || p.my_tags.length > 0 ? (
|
p.my_verdict || p.my_rating || p.my_tags.length > 0 ? (
|
||||||
<div className="g-overlay">
|
<div className="g-overlay">
|
||||||
|
{p.my_verdict && <span>{p.my_verdict === 'accept' ? '👍' : '👎'}</span>}
|
||||||
{p.my_rating && <span>★ {p.my_rating}</span>}
|
{p.my_rating && <span>★ {p.my_rating}</span>}
|
||||||
{p.my_tags.length > 0 && <span># {p.my_tags.length}</span>}
|
{p.my_tags.length > 0 && <span># {p.my_tags.length}</span>}
|
||||||
</div>
|
</div>
|
||||||
) : null
|
) : null
|
||||||
}
|
}
|
||||||
/>
|
/>
|
||||||
{view.photos.length === 0 && (
|
{photos.length === 0 && (
|
||||||
<p className="center-page muted">Nothing here yet — check back soon.</p>
|
<p className="center-page muted">Nothing here yet — check back soon.</p>
|
||||||
)}
|
)}
|
||||||
|
{photos.length > 0 && visible.length === 0 && (
|
||||||
|
<p className="center-page muted">No photos match this filter.</p>
|
||||||
|
)}
|
||||||
</main>
|
</main>
|
||||||
{view.allow_download && (
|
{view.allow_download && (
|
||||||
<SelectionBar
|
<SelectionBar
|
||||||
count={selected.size}
|
count={visibleSelected.length}
|
||||||
total={view.photos.length}
|
total={visible.length}
|
||||||
selectedBytes={selectedBytes}
|
selectedBytes={sumBytes(visibleSelected)}
|
||||||
totalBytes={totalBytes}
|
totalBytes={sumBytes(visible)}
|
||||||
onSelectAll={selectAll}
|
onSelectAll={() => selectAll(visible)}
|
||||||
onClear={clear}
|
onClear={clear}
|
||||||
onDownload={() => postDownload(`/api/share/${token}/zip`, [...selected].join(','))}
|
onDownload={() =>
|
||||||
onDownloadAll={() => postDownload(`/api/share/${token}/zip`)}
|
postDownload(`/api/share/${token}/zip`, visibleSelected.map((p) => p.id).join(','))
|
||||||
|
}
|
||||||
|
onDownloadAll={() =>
|
||||||
|
// Under a filter, "download all" means all photos shown.
|
||||||
|
postDownload(
|
||||||
|
`/api/share/${token}/zip`,
|
||||||
|
filter === 'all' ? '' : visible.map((p) => p.id).join(','),
|
||||||
|
)
|
||||||
|
}
|
||||||
/>
|
/>
|
||||||
)}
|
)}
|
||||||
{lightbox >= 0 && (
|
{lightbox.index >= 0 && (
|
||||||
<Lightbox
|
<Lightbox
|
||||||
photos={view.photos}
|
photos={visible}
|
||||||
index={lightbox}
|
index={lightbox.index}
|
||||||
onClose={() => setLightbox(-1)}
|
onClose={lightbox.close}
|
||||||
onNav={setLightbox}
|
onNav={lightbox.openAt}
|
||||||
|
actions={keyActions}
|
||||||
|
closing={lightboxFading}
|
||||||
|
onClosed={() => {
|
||||||
|
setLightboxFading(false)
|
||||||
|
lightbox.close()
|
||||||
|
}}
|
||||||
|
gestures={{
|
||||||
|
up: (p) => voteAndAdvance(p, 'accept'),
|
||||||
|
down: (p) => voteAndAdvance(p, 'reject'),
|
||||||
|
}}
|
||||||
footer={(p) => (
|
footer={(p) => (
|
||||||
<div className="client-footer">
|
<div className="client-footer">
|
||||||
|
<Thumbs value={p.my_verdict} onChange={(v) => setVerdict(p, v)} />
|
||||||
<Stars value={p.my_rating || 0} onChange={(r) => setRating(p, r)} />
|
<Stars value={p.my_rating || 0} onChange={(r) => setRating(p, r)} />
|
||||||
<TagEditor tags={p.my_tags} onChange={(tags) => setTags(p, tags)} />
|
<TagEditor tags={p.my_tags} onChange={(tags) => setTags(p, tags)} />
|
||||||
{view.allow_download && (
|
{view.allow_download && (
|
||||||
@@ -164,6 +283,11 @@ export default function SharePage() {
|
|||||||
)}
|
)}
|
||||||
/>
|
/>
|
||||||
)}
|
)}
|
||||||
|
{flash && (
|
||||||
|
<div key={flash.key} className="action-flash">
|
||||||
|
{flash.text}
|
||||||
|
</div>
|
||||||
|
)}
|
||||||
</>
|
</>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
+248
-1
@@ -451,6 +451,18 @@ progress {
|
|||||||
.lb-stage {
|
.lb-stage {
|
||||||
flex: 1;
|
flex: 1;
|
||||||
min-height: 0;
|
min-height: 0;
|
||||||
|
position: relative;
|
||||||
|
overflow: hidden;
|
||||||
|
/* Swipes are handled in JS; stop the browser from panning/zooming. */
|
||||||
|
touch-action: none;
|
||||||
|
}
|
||||||
|
.lb-track {
|
||||||
|
position: absolute;
|
||||||
|
inset: 0;
|
||||||
|
}
|
||||||
|
.lb-slide {
|
||||||
|
position: absolute;
|
||||||
|
inset: 0;
|
||||||
display: flex;
|
display: flex;
|
||||||
align-items: center;
|
align-items: center;
|
||||||
justify-content: center;
|
justify-content: center;
|
||||||
@@ -462,6 +474,79 @@ progress {
|
|||||||
object-fit: contain;
|
object-fit: contain;
|
||||||
cursor: default;
|
cursor: default;
|
||||||
}
|
}
|
||||||
|
.lb-flick {
|
||||||
|
z-index: 2;
|
||||||
|
position: absolute;
|
||||||
|
inset: 0;
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: center;
|
||||||
|
font-size: 5rem;
|
||||||
|
opacity: 0;
|
||||||
|
pointer-events: none;
|
||||||
|
text-shadow: 0 2px 24px rgba(0, 0, 0, 0.6);
|
||||||
|
}
|
||||||
|
/* Next photo waiting behind a vote drag, before its zoom-in. */
|
||||||
|
.lb-behind {
|
||||||
|
transform: scale(0.22);
|
||||||
|
opacity: 0;
|
||||||
|
}
|
||||||
|
/* Ghost of a just-voted photo flying off; the vote itself is already saved. */
|
||||||
|
.lb-ghost {
|
||||||
|
z-index: 3;
|
||||||
|
pointer-events: none;
|
||||||
|
}
|
||||||
|
.lb-exit-up {
|
||||||
|
animation: lb-exit-up 0.26s ease-in forwards;
|
||||||
|
}
|
||||||
|
.lb-exit-down {
|
||||||
|
animation: lb-exit-down 0.26s ease-in forwards;
|
||||||
|
}
|
||||||
|
@keyframes lb-exit-up {
|
||||||
|
from {
|
||||||
|
transform: translateY(var(--dy)) rotate(var(--rot));
|
||||||
|
}
|
||||||
|
to {
|
||||||
|
transform: translateY(-120vh) rotate(var(--rot));
|
||||||
|
opacity: 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
@keyframes lb-exit-down {
|
||||||
|
from {
|
||||||
|
transform: translateY(var(--dy)) rotate(var(--rot));
|
||||||
|
}
|
||||||
|
to {
|
||||||
|
transform: translateY(120vh) rotate(var(--rot));
|
||||||
|
opacity: 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
.lb-hidden {
|
||||||
|
opacity: 0;
|
||||||
|
}
|
||||||
|
/* Whole-modal fade after voting the last photo — the gallery is behind it. */
|
||||||
|
.lightbox.lb-closing {
|
||||||
|
animation: lb-fade-out 0.26s ease forwards;
|
||||||
|
pointer-events: none;
|
||||||
|
}
|
||||||
|
@keyframes lb-fade-out {
|
||||||
|
to {
|
||||||
|
opacity: 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
/* The photo taking over after a vote zooms in organically. */
|
||||||
|
.lb-enter {
|
||||||
|
animation: lb-enter 0.26s ease-out;
|
||||||
|
}
|
||||||
|
@keyframes lb-enter {
|
||||||
|
from {
|
||||||
|
transform: scale(0.3);
|
||||||
|
opacity: 0.2;
|
||||||
|
}
|
||||||
|
to {
|
||||||
|
transform: scale(1);
|
||||||
|
opacity: 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
.lb-nav {
|
.lb-nav {
|
||||||
position: absolute;
|
position: absolute;
|
||||||
top: 50%;
|
top: 50%;
|
||||||
@@ -534,6 +619,130 @@ progress {
|
|||||||
cursor: default;
|
cursor: default;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* thumbs (accept / reject) */
|
||||||
|
.thumbs {
|
||||||
|
display: inline-flex;
|
||||||
|
gap: 0.15rem;
|
||||||
|
}
|
||||||
|
.thumb {
|
||||||
|
background: none;
|
||||||
|
border: none;
|
||||||
|
font-size: 1.35rem;
|
||||||
|
line-height: 1;
|
||||||
|
padding: 0 0.15rem;
|
||||||
|
cursor: pointer;
|
||||||
|
filter: grayscale(1);
|
||||||
|
opacity: 0.4;
|
||||||
|
transition: opacity 0.12s;
|
||||||
|
}
|
||||||
|
.thumb:hover:enabled {
|
||||||
|
opacity: 0.8;
|
||||||
|
}
|
||||||
|
.thumb.active {
|
||||||
|
filter: none;
|
||||||
|
opacity: 1;
|
||||||
|
}
|
||||||
|
.thumb:disabled {
|
||||||
|
cursor: default;
|
||||||
|
}
|
||||||
|
.thumbs-small .thumb {
|
||||||
|
font-size: 0.95rem;
|
||||||
|
}
|
||||||
|
|
||||||
|
/* verdict filter */
|
||||||
|
.filter-bar {
|
||||||
|
display: flex;
|
||||||
|
justify-content: center;
|
||||||
|
flex-wrap: wrap;
|
||||||
|
gap: 0.5rem;
|
||||||
|
margin-top: 0.9rem;
|
||||||
|
}
|
||||||
|
.filter-chip {
|
||||||
|
background: var(--panel);
|
||||||
|
border: 1px solid var(--panel-2);
|
||||||
|
border-radius: 999px;
|
||||||
|
color: var(--muted);
|
||||||
|
padding: 0.25rem 0.8rem;
|
||||||
|
font-size: 0.85rem;
|
||||||
|
cursor: pointer;
|
||||||
|
}
|
||||||
|
.filter-chip.active {
|
||||||
|
background: var(--panel-2);
|
||||||
|
color: var(--text);
|
||||||
|
border-color: var(--accent);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* transient action feedback (keyboard votes that navigate away) */
|
||||||
|
.action-flash {
|
||||||
|
position: fixed;
|
||||||
|
top: 3rem;
|
||||||
|
left: 50%;
|
||||||
|
transform: translateX(-50%);
|
||||||
|
z-index: 110;
|
||||||
|
background: var(--panel);
|
||||||
|
border: 1px solid var(--panel-2);
|
||||||
|
border-radius: 999px;
|
||||||
|
padding: 0.35rem 1rem;
|
||||||
|
font-size: 0.9rem;
|
||||||
|
white-space: nowrap;
|
||||||
|
pointer-events: none;
|
||||||
|
animation: flash-fade 1.4s ease forwards;
|
||||||
|
}
|
||||||
|
@keyframes flash-fade {
|
||||||
|
0% {
|
||||||
|
opacity: 0;
|
||||||
|
transform: translate(-50%, -6px);
|
||||||
|
}
|
||||||
|
8%,
|
||||||
|
70% {
|
||||||
|
opacity: 1;
|
||||||
|
transform: translate(-50%, 0);
|
||||||
|
}
|
||||||
|
100% {
|
||||||
|
opacity: 0;
|
||||||
|
transform: translate(-50%, 0);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* lightbox shortcut help */
|
||||||
|
.lb-help {
|
||||||
|
position: absolute;
|
||||||
|
inset: 0;
|
||||||
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
|
justify-content: center;
|
||||||
|
background: rgba(8, 9, 11, 0.6);
|
||||||
|
z-index: 102;
|
||||||
|
}
|
||||||
|
.lb-help-card {
|
||||||
|
background: var(--panel);
|
||||||
|
border: 1px solid var(--panel-2);
|
||||||
|
border-radius: 12px;
|
||||||
|
padding: 1.1rem 1.5rem 1.25rem;
|
||||||
|
min-width: 280px;
|
||||||
|
cursor: default;
|
||||||
|
}
|
||||||
|
.lb-help-card h3 {
|
||||||
|
font-size: 0.95rem;
|
||||||
|
margin: 0 0 0.6rem;
|
||||||
|
}
|
||||||
|
.lb-help-row {
|
||||||
|
display: flex;
|
||||||
|
align-items: baseline;
|
||||||
|
justify-content: space-between;
|
||||||
|
gap: 1.5rem;
|
||||||
|
padding: 0.18rem 0;
|
||||||
|
font-size: 0.88rem;
|
||||||
|
}
|
||||||
|
kbd {
|
||||||
|
background: var(--panel-2);
|
||||||
|
border-radius: 4px;
|
||||||
|
padding: 0.08rem 0.45rem;
|
||||||
|
font-family: ui-monospace, SFMono-Regular, Menlo, monospace;
|
||||||
|
font-size: 0.8rem;
|
||||||
|
white-space: nowrap;
|
||||||
|
}
|
||||||
|
|
||||||
/* tags */
|
/* tags */
|
||||||
.tag-editor {
|
.tag-editor {
|
||||||
display: inline-flex;
|
display: inline-flex;
|
||||||
@@ -564,12 +773,50 @@ progress {
|
|||||||
padding: 0;
|
padding: 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* Touch devices: no hover — selection checkmarks must always be visible,
|
||||||
|
and the overlay nav arrows give way to swiping. */
|
||||||
|
@media (hover: none) {
|
||||||
|
.g-check {
|
||||||
|
opacity: 1;
|
||||||
|
}
|
||||||
|
.lb-nav {
|
||||||
|
display: none;
|
||||||
|
}
|
||||||
|
/* No visible arrows to keep clear of — give the photo the width. */
|
||||||
|
.lb-slide {
|
||||||
|
padding: 0 0.75rem;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@media (max-width: 700px) {
|
@media (max-width: 700px) {
|
||||||
.lb-stage {
|
.lb-slide {
|
||||||
padding: 0 0.5rem;
|
padding: 0 0.5rem;
|
||||||
}
|
}
|
||||||
.login-card {
|
.login-card {
|
||||||
padding: 2rem 1.5rem;
|
padding: 2rem 1.5rem;
|
||||||
margin: 0 1rem;
|
margin: 0 1rem;
|
||||||
}
|
}
|
||||||
|
.share-head {
|
||||||
|
padding: 1.25rem 0.75rem 0.25rem;
|
||||||
|
}
|
||||||
|
.lb-footer {
|
||||||
|
padding: 0.5rem 0.6rem calc(0.8rem + env(safe-area-inset-bottom));
|
||||||
|
}
|
||||||
|
.client-footer {
|
||||||
|
gap: 0.8rem;
|
||||||
|
}
|
||||||
|
/* Finger-sized vote and rating targets in the client lightbox. */
|
||||||
|
.client-footer .thumb {
|
||||||
|
font-size: 1.7rem;
|
||||||
|
}
|
||||||
|
.client-footer .star {
|
||||||
|
font-size: 1.8rem;
|
||||||
|
}
|
||||||
|
.select-bar {
|
||||||
|
flex-wrap: wrap;
|
||||||
|
justify-content: center;
|
||||||
|
max-width: calc(100vw - 1.5rem);
|
||||||
|
padding: 0.5rem 0.75rem;
|
||||||
|
bottom: calc(0.75rem + env(safe-area-inset-bottom));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,23 @@
|
|||||||
|
import { useEffect, useState } from 'react'
|
||||||
|
|
||||||
|
// Lightbox state tracked by photo id, not index — the list can reorder
|
||||||
|
// (polling refetch) or shrink (filter change, delete) underneath an open
|
||||||
|
// lightbox. When the open photo leaves the list, close for good — otherwise
|
||||||
|
// the lightbox would pop back open when the photo returns to the list.
|
||||||
|
export default function useLightbox(photos) {
|
||||||
|
const [openId, setOpenId] = useState(null)
|
||||||
|
const index = openId ? photos.findIndex((p) => p.id === openId) : -1
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (openId && index < 0) setOpenId(null)
|
||||||
|
}, [openId, index])
|
||||||
|
|
||||||
|
return {
|
||||||
|
index,
|
||||||
|
// Bounds-safe: callers may hold a stale index (the list can shrink
|
||||||
|
// between render and dispatch).
|
||||||
|
openAt: (i) => photos[i] && setOpenId(photos[i].id),
|
||||||
|
show: (id) => setOpenId(id),
|
||||||
|
close: () => setOpenId(null),
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,10 +1,12 @@
|
|||||||
import { useEffect, useState } from 'react'
|
import { useEffect, useRef, useState } from 'react'
|
||||||
|
|
||||||
// Multi-select over a photo list. Selection lives here (not in the gallery)
|
// Multi-select over a photo list. Selection lives here (not in the gallery)
|
||||||
// so it survives lightbox open/close, and is pruned automatically when
|
// so it survives lightbox open/close, and is pruned automatically when
|
||||||
// photos disappear from the list (deletes, polling refreshes).
|
// photos disappear from the list (deletes, polling refreshes).
|
||||||
export default function useSelection(photos) {
|
export default function useSelection(photos) {
|
||||||
const [selected, setSelected] = useState(() => new Set())
|
const [selected, setSelected] = useState(() => new Set())
|
||||||
|
// Anchor for shift-click range selection: the photo last toggled.
|
||||||
|
const lastToggled = useRef(null)
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
setSelected((prev) => {
|
setSelected((prev) => {
|
||||||
@@ -15,16 +17,43 @@ export default function useSelection(photos) {
|
|||||||
})
|
})
|
||||||
}, [photos])
|
}, [photos])
|
||||||
|
|
||||||
const toggle = (photoId) =>
|
// Shift-toggle selects the whole range from the previously toggled photo
|
||||||
|
// (both directions), so contiguous runs don't need per-photo clicks. The
|
||||||
|
// range walks `list` — the photo order the user is actually looking at —
|
||||||
|
// which callers with a filtered view must pass explicitly, so hidden
|
||||||
|
// photos are never swept into the selection. Anchor updates and range
|
||||||
|
// computation stay out of the setSelected updater: React may re-invoke
|
||||||
|
// updaters (StrictMode does), so they must be pure.
|
||||||
|
const toggle = (photoId, shift = false, list = photos) => {
|
||||||
|
const anchor = lastToggled.current
|
||||||
|
lastToggled.current = photoId
|
||||||
|
if (shift && anchor) {
|
||||||
|
const a = list.findIndex((p) => p.id === anchor)
|
||||||
|
const b = list.findIndex((p) => p.id === photoId)
|
||||||
|
if (a >= 0 && b >= 0) {
|
||||||
|
const range = list.slice(Math.min(a, b), Math.max(a, b) + 1).map((p) => p.id)
|
||||||
|
setSelected((prev) => new Set([...prev, ...range]))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
}
|
||||||
setSelected((prev) => {
|
setSelected((prev) => {
|
||||||
const next = new Set(prev)
|
const next = new Set(prev)
|
||||||
if (next.has(photoId)) next.delete(photoId)
|
if (next.has(photoId)) next.delete(photoId)
|
||||||
else next.add(photoId)
|
else next.add(photoId)
|
||||||
return next
|
return next
|
||||||
})
|
})
|
||||||
|
}
|
||||||
|
|
||||||
const selectAll = () => setSelected(new Set(photos.map((p) => p.id)))
|
// Adds `list` (the caller's currently visible photos) to the selection —
|
||||||
const clear = () => setSelected(new Set())
|
// additive, so selecting all of one filtered view keeps picks from another.
|
||||||
|
const selectAll = (list) =>
|
||||||
|
setSelected((prev) => new Set([...prev, ...list.map((p) => p.id)]))
|
||||||
|
const clear = () => {
|
||||||
|
// Reset the anchor too — a shift-click after Clear must start fresh, not
|
||||||
|
// extend a range from a photo selected before the wipe.
|
||||||
|
lastToggled.current = null
|
||||||
|
setSelected(new Set())
|
||||||
|
}
|
||||||
const selectedBytes = photos.reduce((sum, p) => sum + (selected.has(p.id) ? p.size_bytes : 0), 0)
|
const selectedBytes = photos.reduce((sum, p) => sum + (selected.has(p.id) ? p.size_bytes : 0), 0)
|
||||||
const totalBytes = photos.reduce((sum, p) => sum + p.size_bytes, 0)
|
const totalBytes = photos.reduce((sum, p) => sum + p.size_bytes, 0)
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,230 @@
|
|||||||
|
import { useLayoutEffect, useRef, useState } from 'react'
|
||||||
|
import { ACCEPT_GLYPH, REJECT_GLYPH } from './components/Thumbs'
|
||||||
|
|
||||||
|
const COMMIT_MS = 260
|
||||||
|
const CANCEL_MS = 180
|
||||||
|
const DEAD_ZONE = 12 // px of travel before the axis locks
|
||||||
|
const FLICK_MS = 250 // releases faster than this commit at the lower threshold
|
||||||
|
const H_THRESHOLD = { slow: 70, fast: 30 }
|
||||||
|
const V_THRESHOLD = { slow: 90, fast: 40 }
|
||||||
|
const V_SATURATE = 160 // px of vertical drag for full badge/preview intensity
|
||||||
|
const ZOOM_MAX = 4
|
||||||
|
|
||||||
|
// Touch engine for the lightbox: horizontal swipes navigate, vertical flicks
|
||||||
|
// dispatch gestures.up/down (when provided), two fingers pinch-zoom the
|
||||||
|
// current photo (springs back on release, never votes).
|
||||||
|
//
|
||||||
|
// Navigation and votes are dispatched SYNCHRONOUSLY on release; every
|
||||||
|
// animation afterwards is pure decoration (a ghost flying off, the track
|
||||||
|
// settling). Closing the lightbox, key presses or list changes during an
|
||||||
|
// animation therefore can't drop, duplicate or misdirect an action.
|
||||||
|
//
|
||||||
|
// Per-move motion is written straight to the DOM via refs — dragging costs
|
||||||
|
// no React renders; state changes happen only at axis lock and release.
|
||||||
|
export default function useSwipe({ photo, index, count, onNav, gestures, hasNext }) {
|
||||||
|
const [dragAxis, setDragAxis] = useState(null) // 'h' | 'v' | 'z' while a finger is down
|
||||||
|
const [spring, setSpring] = useState(null) // 'h' | 'v' | 'z': sub-threshold release gliding back
|
||||||
|
const [settleFrom, setSettleFrom] = useState(null) // px the track settles from after a nav commit
|
||||||
|
const [settleRun, setSettleRun] = useState(false)
|
||||||
|
const [exit, setExit] = useState(null) // { photo, dir, dy }: ghost flying off after a vote
|
||||||
|
|
||||||
|
const trackRef = useRef(null)
|
||||||
|
const imgRef = useRef(null)
|
||||||
|
const behindRef = useRef(null)
|
||||||
|
const badgeRef = useRef(null)
|
||||||
|
const g = useRef(null)
|
||||||
|
|
||||||
|
// FLIP: paint the track at the release offset around the NEW index first,
|
||||||
|
// force a style flush, then let it transition to center.
|
||||||
|
useLayoutEffect(() => {
|
||||||
|
if (settleFrom == null) {
|
||||||
|
setSettleRun(false)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
trackRef.current?.getBoundingClientRect()
|
||||||
|
setSettleRun(true)
|
||||||
|
}, [settleFrom])
|
||||||
|
|
||||||
|
const clearManual = () => {
|
||||||
|
for (const ref of [trackRef, imgRef, behindRef, badgeRef]) {
|
||||||
|
if (ref.current) {
|
||||||
|
ref.current.style.transform = ''
|
||||||
|
ref.current.style.opacity = ''
|
||||||
|
ref.current.style.transition = ''
|
||||||
|
ref.current.style.transformOrigin = ''
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const onTouchStart = (e) => {
|
||||||
|
// Fresh input takes over: decorative animations yield immediately.
|
||||||
|
setSpring(null)
|
||||||
|
setSettleFrom(null)
|
||||||
|
if (e.touches.length === 2 && imgRef.current) {
|
||||||
|
// Second finger at any point turns the gesture into a pinch — a pinch
|
||||||
|
// never navigates and never votes.
|
||||||
|
clearManual()
|
||||||
|
const [a, b] = e.touches
|
||||||
|
const rect = imgRef.current.getBoundingClientRect()
|
||||||
|
const cx = (a.clientX + b.clientX) / 2
|
||||||
|
const cy = (a.clientY + b.clientY) / 2
|
||||||
|
imgRef.current.style.transformOrigin = `${cx - rect.left}px ${cy - rect.top}px`
|
||||||
|
g.current = {
|
||||||
|
mode: 'pinch',
|
||||||
|
d0: Math.hypot(a.clientX - b.clientX, a.clientY - b.clientY),
|
||||||
|
cx,
|
||||||
|
cy,
|
||||||
|
}
|
||||||
|
setDragAxis('z')
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (e.touches.length !== 1) {
|
||||||
|
g.current = null
|
||||||
|
setDragAxis(null)
|
||||||
|
clearManual()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const t = e.touches[0]
|
||||||
|
g.current = { mode: 'swipe', x0: t.clientX, y0: t.clientY, t0: e.timeStamp, axis: null, dx: 0, dy: 0 }
|
||||||
|
}
|
||||||
|
|
||||||
|
const onTouchMove = (e) => {
|
||||||
|
const s = g.current
|
||||||
|
if (!s) return
|
||||||
|
if (s.mode === 'pinch') {
|
||||||
|
if (e.touches.length < 2 || !imgRef.current) return
|
||||||
|
const [a, b] = e.touches
|
||||||
|
const scale = Math.min(
|
||||||
|
ZOOM_MAX,
|
||||||
|
Math.max(1, Math.hypot(a.clientX - b.clientX, a.clientY - b.clientY) / s.d0),
|
||||||
|
)
|
||||||
|
const mx = (a.clientX + b.clientX) / 2 - s.cx
|
||||||
|
const my = (a.clientY + b.clientY) / 2 - s.cy
|
||||||
|
imgRef.current.style.transition = 'none'
|
||||||
|
imgRef.current.style.transform = `translate(${mx}px, ${my}px) scale(${scale})`
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (e.touches.length !== 1) return
|
||||||
|
const t = e.touches[0]
|
||||||
|
s.dx = t.clientX - s.x0
|
||||||
|
s.dy = t.clientY - s.y0
|
||||||
|
if (!s.axis) {
|
||||||
|
if (Math.hypot(s.dx, s.dy) < DEAD_ZONE) return
|
||||||
|
s.axis = Math.abs(s.dx) >= Math.abs(s.dy) || !gestures ? 'h' : 'v'
|
||||||
|
setDragAxis(s.axis)
|
||||||
|
}
|
||||||
|
if (s.axis === 'h') {
|
||||||
|
if (trackRef.current) {
|
||||||
|
trackRef.current.style.transition = 'none'
|
||||||
|
trackRef.current.style.transform = `translateX(${s.dx}px)`
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if (imgRef.current) {
|
||||||
|
imgRef.current.style.transition = 'none'
|
||||||
|
imgRef.current.style.transform = `translateY(${s.dy}px) rotate(${s.dy / 40}deg)`
|
||||||
|
}
|
||||||
|
const p = Math.min(1, Math.abs(s.dy) / V_SATURATE)
|
||||||
|
if (behindRef.current) {
|
||||||
|
behindRef.current.style.transition = 'none'
|
||||||
|
behindRef.current.style.transform = `scale(${0.22 + 0.15 * p})`
|
||||||
|
behindRef.current.style.opacity = p
|
||||||
|
}
|
||||||
|
if (badgeRef.current) {
|
||||||
|
badgeRef.current.style.opacity = p
|
||||||
|
badgeRef.current.textContent = s.dy < 0 ? ACCEPT_GLYPH : REJECT_GLYPH
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const onTouchEnd = (e) => {
|
||||||
|
const s = g.current
|
||||||
|
if (!s) return
|
||||||
|
if (s.mode === 'pinch') {
|
||||||
|
if (e.touches.length > 0) return
|
||||||
|
g.current = null
|
||||||
|
setDragAxis(null)
|
||||||
|
setSpring('z')
|
||||||
|
return
|
||||||
|
}
|
||||||
|
g.current = null
|
||||||
|
setDragAxis(null)
|
||||||
|
if (!s.axis) {
|
||||||
|
clearManual()
|
||||||
|
return
|
||||||
|
}
|
||||||
|
const quick = e.timeStamp - s.t0 < FLICK_MS
|
||||||
|
const past = (v, th) => Math.abs(v) > th.slow || (quick && Math.abs(v) > th.fast)
|
||||||
|
if (s.axis === 'h') {
|
||||||
|
if (s.dx < 0 && past(s.dx, H_THRESHOLD) && index < count - 1) {
|
||||||
|
onNav(index + 1)
|
||||||
|
setSettleFrom(s.dx + window.innerWidth)
|
||||||
|
} else if (s.dx > 0 && past(s.dx, H_THRESHOLD) && index > 0) {
|
||||||
|
onNav(index - 1)
|
||||||
|
setSettleFrom(s.dx - window.innerWidth)
|
||||||
|
} else {
|
||||||
|
setSpring('h')
|
||||||
|
}
|
||||||
|
} else if (past(s.dy, V_THRESHOLD)) {
|
||||||
|
const dir = s.dy < 0 ? 'up' : 'down'
|
||||||
|
gestures?.[dir]?.(photo)
|
||||||
|
clearManual()
|
||||||
|
setExit({ photo, dir, dy: s.dy })
|
||||||
|
} else {
|
||||||
|
setSpring('v')
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const onTouchCancel = () => {
|
||||||
|
g.current = null
|
||||||
|
setDragAxis(null)
|
||||||
|
clearManual()
|
||||||
|
}
|
||||||
|
|
||||||
|
const trackStyle =
|
||||||
|
settleFrom != null
|
||||||
|
? settleRun
|
||||||
|
? { transform: 'translateX(0)', transition: `transform ${COMMIT_MS}ms ease-out` }
|
||||||
|
: { transform: `translateX(${settleFrom}px)`, transition: 'none' }
|
||||||
|
: spring === 'h'
|
||||||
|
? { transform: 'translateX(0)', transition: `transform ${CANCEL_MS}ms ease-out` }
|
||||||
|
: undefined
|
||||||
|
|
||||||
|
const imgStyle =
|
||||||
|
spring === 'v'
|
||||||
|
? { transform: 'translateY(0) rotate(0deg)', transition: `transform ${CANCEL_MS}ms ease-out` }
|
||||||
|
: spring === 'z'
|
||||||
|
? { transform: 'none', transition: `transform ${CANCEL_MS}ms ease-out` }
|
||||||
|
: undefined
|
||||||
|
|
||||||
|
const behindStyle =
|
||||||
|
spring === 'v'
|
||||||
|
? { transform: 'scale(0.22)', opacity: 0, transition: `all ${CANCEL_MS}ms ease-out` }
|
||||||
|
: undefined
|
||||||
|
|
||||||
|
return {
|
||||||
|
handlers: { onTouchStart, onTouchMove, onTouchEnd, onTouchCancel },
|
||||||
|
trackRef,
|
||||||
|
imgRef,
|
||||||
|
behindRef,
|
||||||
|
badgeRef,
|
||||||
|
trackStyle,
|
||||||
|
imgStyle,
|
||||||
|
behindStyle,
|
||||||
|
showBehind: (dragAxis === 'v' || spring === 'v') && hasNext,
|
||||||
|
showBadge: dragAxis === 'v',
|
||||||
|
exit,
|
||||||
|
clearExit: () => setExit(null),
|
||||||
|
onTrackTransitionEnd: (e) => {
|
||||||
|
if (e.target !== trackRef.current) return
|
||||||
|
setSettleFrom(null)
|
||||||
|
if (spring === 'h') setSpring(null)
|
||||||
|
},
|
||||||
|
onImgTransitionEnd: (e) => {
|
||||||
|
if (e.target !== imgRef.current) return
|
||||||
|
if (spring === 'v' || spring === 'z') {
|
||||||
|
setSpring(null)
|
||||||
|
clearManual()
|
||||||
|
}
|
||||||
|
},
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,13 @@
|
|||||||
|
-- Client accept/reject votes, one per (link, photo) — a separate axis from
|
||||||
|
-- the 1-5 star rating so a photo can be e.g. accepted but unrated.
|
||||||
|
create table verdicts (
|
||||||
|
share_id uuid not null references shares(id) on delete cascade,
|
||||||
|
photo_id uuid not null references photos(id) on delete cascade,
|
||||||
|
verdict text not null check (verdict in ('accept', 'reject')),
|
||||||
|
updated_at timestamptz not null default now(),
|
||||||
|
primary key (share_id, photo_id)
|
||||||
|
);
|
||||||
|
|
||||||
|
-- Cascaded photo deletes fire per-row FK triggers; without this each one
|
||||||
|
-- sequential-scans the table.
|
||||||
|
create index verdicts_photo_idx on verdicts (photo_id);
|
||||||
+26
-3
@@ -1,4 +1,8 @@
|
|||||||
|
use axum::http::{header, HeaderValue};
|
||||||
|
use tower::ServiceBuilder;
|
||||||
|
use tower_http::services::fs::ServeFileSystemResponseBody;
|
||||||
use tower_http::services::{ServeDir, ServeFile};
|
use tower_http::services::{ServeDir, ServeFile};
|
||||||
|
use tower_http::set_header::SetResponseHeaderLayer;
|
||||||
use tower_http::trace::TraceLayer;
|
use tower_http::trace::TraceLayer;
|
||||||
use tracing_subscriber::EnvFilter;
|
use tracing_subscriber::EnvFilter;
|
||||||
|
|
||||||
@@ -17,11 +21,30 @@ async fn main() -> anyhow::Result<()> {
|
|||||||
let state = AppState::new(config).await?;
|
let state = AppState::new(config).await?;
|
||||||
|
|
||||||
let static_dir = state.config.static_dir.clone();
|
let static_dir = state.config.static_dir.clone();
|
||||||
let index = std::path::Path::new(&static_dir).join("index.html");
|
let static_root = std::path::Path::new(&static_dir);
|
||||||
// .fallback (not .not_found_service) so SPA routes get index.html with a 200
|
// Hashed assets cache forever — except 404s, which would outlive the next deploy.
|
||||||
let spa = ServeDir::new(&static_dir).fallback(ServeFile::new(index));
|
let assets = ServiceBuilder::new()
|
||||||
|
.map_response(|mut response: axum::http::Response<ServeFileSystemResponseBody>| {
|
||||||
|
if response.status().is_success() {
|
||||||
|
response.headers_mut().insert(
|
||||||
|
header::CACHE_CONTROL,
|
||||||
|
HeaderValue::from_static("public, max-age=31536000, immutable"),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
response
|
||||||
|
})
|
||||||
|
.service(ServeDir::new(static_root.join("assets")));
|
||||||
|
// index.html revalidates every load (it names the asset hashes);
|
||||||
|
// .fallback (not .not_found_service) so SPA routes get it with a 200.
|
||||||
|
let spa = ServiceBuilder::new()
|
||||||
|
.layer(SetResponseHeaderLayer::overriding(
|
||||||
|
header::CACHE_CONTROL,
|
||||||
|
HeaderValue::from_static("no-cache"),
|
||||||
|
))
|
||||||
|
.service(ServeDir::new(static_root).fallback(ServeFile::new(static_root.join("index.html"))));
|
||||||
|
|
||||||
let app = photos::routes::router(&state)
|
let app = photos::routes::router(&state)
|
||||||
|
.nest_service("/assets", assets)
|
||||||
.fallback_service(spa)
|
.fallback_service(spa)
|
||||||
.layer(TraceLayer::new_for_http())
|
.layer(TraceLayer::new_for_http())
|
||||||
.with_state(state.clone());
|
.with_state(state.clone());
|
||||||
|
|||||||
+20
-1
@@ -1,5 +1,5 @@
|
|||||||
use chrono::{DateTime, Utc};
|
use chrono::{DateTime, Utc};
|
||||||
use serde::Serialize;
|
use serde::{Deserialize, Serialize};
|
||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
/// Stored as text in Postgres; decoded via TryFrom so an unknown value is a
|
/// Stored as text in Postgres; decoded via TryFrom so an unknown value is a
|
||||||
@@ -47,6 +47,25 @@ impl TryFrom<String> for PhotoStatus {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Client accept/reject vote. Same convention as PhotoStatus: text in
|
||||||
|
/// Postgres (check-constrained), this enum everywhere Rust touches the value
|
||||||
|
/// — serde rejects anything but "accept"/"reject" at the API boundary.
|
||||||
|
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
|
||||||
|
#[serde(rename_all = "lowercase")]
|
||||||
|
pub enum Verdict {
|
||||||
|
Accept,
|
||||||
|
Reject,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Verdict {
|
||||||
|
pub fn as_str(self) -> &'static str {
|
||||||
|
match self {
|
||||||
|
Self::Accept => "accept",
|
||||||
|
Self::Reject => "reject",
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
|
||||||
pub enum JobKind {
|
pub enum JobKind {
|
||||||
ProcessPhoto,
|
ProcessPhoto,
|
||||||
|
|||||||
+78
-46
@@ -7,7 +7,7 @@ use serde::{Deserialize, Serialize};
|
|||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
use crate::error::{ApiError, ApiResult};
|
use crate::error::{ApiError, ApiResult};
|
||||||
use crate::models::{Album, JobKind, Photo, PhotoStatus};
|
use crate::models::{Album, Photo, PhotoStatus};
|
||||||
use crate::state::AppState;
|
use crate::state::AppState;
|
||||||
|
|
||||||
#[derive(Serialize, sqlx::FromRow)]
|
#[derive(Serialize, sqlx::FromRow)]
|
||||||
@@ -79,12 +79,40 @@ pub struct ShareTag {
|
|||||||
pub tag: String,
|
pub tag: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Serialize)]
|
||||||
|
pub struct ShareVerdict {
|
||||||
|
pub share_label: String,
|
||||||
|
pub verdict: String,
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Serialize, Default)]
|
#[derive(Serialize, Default)]
|
||||||
pub struct PhotoFeedback {
|
pub struct PhotoFeedback {
|
||||||
pub ratings: Vec<ShareRating>,
|
pub ratings: Vec<ShareRating>,
|
||||||
|
pub verdicts: Vec<ShareVerdict>,
|
||||||
pub tags: Vec<ShareTag>,
|
pub tags: Vec<ShareTag>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async fn feedback_rows<T>(
|
||||||
|
db: &sqlx::PgPool,
|
||||||
|
sql: &str,
|
||||||
|
album_id: Uuid,
|
||||||
|
) -> Result<Vec<(Uuid, String, T)>, sqlx::Error>
|
||||||
|
where
|
||||||
|
(Uuid, String, T): for<'r> sqlx::FromRow<'r, sqlx::postgres::PgRow> + Send + Unpin,
|
||||||
|
{
|
||||||
|
sqlx::query_as(sql).bind(album_id).fetch_all(db).await
|
||||||
|
}
|
||||||
|
|
||||||
|
fn fold_feedback<T>(
|
||||||
|
feedback: &mut HashMap<Uuid, PhotoFeedback>,
|
||||||
|
rows: Vec<(Uuid, String, T)>,
|
||||||
|
push: impl Fn(&mut PhotoFeedback, String, T),
|
||||||
|
) {
|
||||||
|
for (photo_id, share_label, value) in rows {
|
||||||
|
push(feedback.entry(photo_id).or_default(), share_label, value);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Serialize)]
|
#[derive(Serialize)]
|
||||||
pub struct AlbumDetail {
|
pub struct AlbumDetail {
|
||||||
pub album: Album,
|
pub album: Album,
|
||||||
@@ -108,41 +136,49 @@ pub async fn get_one(
|
|||||||
.fetch_all(&state.db)
|
.fetch_all(&state.db)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
|
// The three feedback kinds are independent (photo_id, share label, value)
|
||||||
|
// queries — run them concurrently and fold with one shared shape.
|
||||||
|
let (ratings, verdicts, tags) = tokio::try_join!(
|
||||||
|
feedback_rows::<i32>(
|
||||||
|
&state.db,
|
||||||
|
"select r.photo_id, s.label, r.rating
|
||||||
|
from ratings r join shares s on s.id = r.share_id
|
||||||
|
where s.album_id = $1",
|
||||||
|
album_id,
|
||||||
|
),
|
||||||
|
feedback_rows::<String>(
|
||||||
|
&state.db,
|
||||||
|
"select v.photo_id, s.label, v.verdict
|
||||||
|
from verdicts v join shares s on s.id = v.share_id
|
||||||
|
where s.album_id = $1",
|
||||||
|
album_id,
|
||||||
|
),
|
||||||
|
feedback_rows::<String>(
|
||||||
|
&state.db,
|
||||||
|
"select t.photo_id, s.label, t.tag
|
||||||
|
from tags t join shares s on s.id = t.share_id
|
||||||
|
where s.album_id = $1
|
||||||
|
order by t.created_at",
|
||||||
|
album_id,
|
||||||
|
),
|
||||||
|
)?;
|
||||||
|
|
||||||
let mut feedback: HashMap<Uuid, PhotoFeedback> = HashMap::new();
|
let mut feedback: HashMap<Uuid, PhotoFeedback> = HashMap::new();
|
||||||
let ratings: Vec<(Uuid, String, i32)> = sqlx::query_as(
|
fold_feedback(&mut feedback, ratings, |f, share_label, rating| {
|
||||||
"select r.photo_id, s.label, r.rating
|
f.ratings.push(ShareRating {
|
||||||
from ratings r join shares s on s.id = r.share_id
|
share_label,
|
||||||
where s.album_id = $1",
|
rating,
|
||||||
)
|
})
|
||||||
.bind(album_id)
|
});
|
||||||
.fetch_all(&state.db)
|
fold_feedback(&mut feedback, verdicts, |f, share_label, verdict| {
|
||||||
.await?;
|
f.verdicts.push(ShareVerdict {
|
||||||
for (photo_id, share_label, rating) in ratings {
|
share_label,
|
||||||
feedback
|
verdict,
|
||||||
.entry(photo_id)
|
})
|
||||||
.or_default()
|
});
|
||||||
.ratings
|
fold_feedback(&mut feedback, tags, |f, share_label, tag| {
|
||||||
.push(ShareRating {
|
f.tags.push(ShareTag { share_label, tag })
|
||||||
share_label,
|
});
|
||||||
rating,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
let tags: Vec<(Uuid, String, String)> = sqlx::query_as(
|
|
||||||
"select t.photo_id, s.label, t.tag
|
|
||||||
from tags t join shares s on s.id = t.share_id
|
|
||||||
where s.album_id = $1
|
|
||||||
order by t.created_at",
|
|
||||||
)
|
|
||||||
.bind(album_id)
|
|
||||||
.fetch_all(&state.db)
|
|
||||||
.await?;
|
|
||||||
for (photo_id, share_label, tag) in tags {
|
|
||||||
feedback
|
|
||||||
.entry(photo_id)
|
|
||||||
.or_default()
|
|
||||||
.tags
|
|
||||||
.push(ShareTag { share_label, tag });
|
|
||||||
}
|
|
||||||
|
|
||||||
Ok(Json(AlbumDetail {
|
Ok(Json(AlbumDetail {
|
||||||
album,
|
album,
|
||||||
@@ -196,17 +232,13 @@ pub async fn delete(
|
|||||||
if locked.is_none() {
|
if locked.is_none() {
|
||||||
return Err(ApiError::not_found());
|
return Err(ApiError::not_found());
|
||||||
}
|
}
|
||||||
// Delete photos and enqueue their S3 cleanup atomically, in one statement.
|
// Delete photos through the shared path so the S3 cleanup convention
|
||||||
sqlx::query(
|
// lives in one place; the album lock above keeps this set complete.
|
||||||
"with deleted as (delete from photos where album_id = $1 returning id)
|
let photo_ids: Vec<Uuid> = sqlx::query_scalar("select id from photos where album_id = $1")
|
||||||
insert into jobs (kind, payload)
|
.bind(album_id)
|
||||||
select $2, jsonb_build_object('prefix', 'photos/' || id || '/')
|
.fetch_all(&mut *tx)
|
||||||
from deleted",
|
.await?;
|
||||||
)
|
super::photos::delete_with_cleanup(&mut tx, &photo_ids).await?;
|
||||||
.bind(album_id)
|
|
||||||
.bind(JobKind::DeleteS3Prefix.as_str())
|
|
||||||
.execute(&mut *tx)
|
|
||||||
.await?;
|
|
||||||
sqlx::query("delete from albums where id = $1")
|
sqlx::query("delete from albums where id = $1")
|
||||||
.bind(album_id)
|
.bind(album_id)
|
||||||
.execute(&mut *tx)
|
.execute(&mut *tx)
|
||||||
|
|||||||
+40
-2
@@ -10,7 +10,7 @@ use serde::{Deserialize, Serialize};
|
|||||||
use uuid::Uuid;
|
use uuid::Uuid;
|
||||||
|
|
||||||
use crate::error::{ApiError, ApiResult};
|
use crate::error::{ApiError, ApiResult};
|
||||||
use crate::models::{PhotoStatus, Share};
|
use crate::models::{PhotoStatus, Share, Verdict};
|
||||||
use crate::state::AppState;
|
use crate::state::AppState;
|
||||||
|
|
||||||
pub async fn load_share(state: &AppState, token: &str) -> Result<Share, ApiError> {
|
pub async fn load_share(state: &AppState, token: &str) -> Result<Share, ApiError> {
|
||||||
@@ -137,6 +137,7 @@ struct ClientPhotoRow {
|
|||||||
taken_at: Option<DateTime<Utc>>,
|
taken_at: Option<DateTime<Utc>>,
|
||||||
processed_at: Option<DateTime<Utc>>,
|
processed_at: Option<DateTime<Utc>>,
|
||||||
my_rating: Option<i32>,
|
my_rating: Option<i32>,
|
||||||
|
my_verdict: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Serialize)]
|
#[derive(Serialize)]
|
||||||
@@ -185,9 +186,10 @@ pub async fn get_share(
|
|||||||
let jar = grant_access(&state, jar, share.id);
|
let jar = grant_access(&state, jar, share.id);
|
||||||
|
|
||||||
let rows: Vec<ClientPhotoRow> = sqlx::query_as(
|
let rows: Vec<ClientPhotoRow> = sqlx::query_as(
|
||||||
"select p.id, p.filename, p.size_bytes, p.width, p.height, p.taken_at, p.processed_at, r.rating as my_rating
|
"select p.id, p.filename, p.size_bytes, p.width, p.height, p.taken_at, p.processed_at, r.rating as my_rating, v.verdict as my_verdict
|
||||||
from photos p
|
from photos p
|
||||||
left join ratings r on r.photo_id = p.id and r.share_id = $2
|
left join ratings r on r.photo_id = p.id and r.share_id = $2
|
||||||
|
left join verdicts v on v.photo_id = p.id and v.share_id = $2
|
||||||
where p.album_id = $1 and p.status = $3
|
where p.album_id = $1 and p.status = $3
|
||||||
order by coalesce(p.taken_at, p.created_at), p.filename",
|
order by coalesce(p.taken_at, p.created_at), p.filename",
|
||||||
)
|
)
|
||||||
@@ -352,6 +354,42 @@ pub async fn set_rating(
|
|||||||
Ok(Json(serde_json::json!({ "ok": true })))
|
Ok(Json(serde_json::json!({ "ok": true })))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Deserialize)]
|
||||||
|
pub struct VerdictBody {
|
||||||
|
verdict: Option<Verdict>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn set_verdict(
|
||||||
|
State(state): State<AppState>,
|
||||||
|
Path((token, photo_id)): Path<(String, Uuid)>,
|
||||||
|
jar: SignedCookieJar,
|
||||||
|
Json(body): Json<VerdictBody>,
|
||||||
|
) -> ApiResult<Json<serde_json::Value>> {
|
||||||
|
let share = share_photo(&state, &jar, &token, photo_id).await?;
|
||||||
|
match body.verdict {
|
||||||
|
None => {
|
||||||
|
sqlx::query("delete from verdicts where share_id = $1 and photo_id = $2")
|
||||||
|
.bind(share.id)
|
||||||
|
.bind(photo_id)
|
||||||
|
.execute(&state.db)
|
||||||
|
.await?;
|
||||||
|
}
|
||||||
|
Some(verdict) => {
|
||||||
|
sqlx::query(
|
||||||
|
"insert into verdicts (share_id, photo_id, verdict) values ($1, $2, $3)
|
||||||
|
on conflict (share_id, photo_id)
|
||||||
|
do update set verdict = excluded.verdict, updated_at = now()",
|
||||||
|
)
|
||||||
|
.bind(share.id)
|
||||||
|
.bind(photo_id)
|
||||||
|
.bind(verdict.as_str())
|
||||||
|
.execute(&state.db)
|
||||||
|
.await?;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Ok(Json(serde_json::json!({ "ok": true })))
|
||||||
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
pub struct TagsBody {
|
pub struct TagsBody {
|
||||||
tags: Vec<String>,
|
tags: Vec<String>,
|
||||||
|
|||||||
+9
-1
@@ -78,9 +78,13 @@ pub fn router(state: &AppState) -> Router<AppState> {
|
|||||||
)
|
)
|
||||||
.route("/api/albums/{id}/zip", post(zip::album_zip))
|
.route("/api/albums/{id}/zip", post(zip::album_zip))
|
||||||
.route("/api/albums/{id}/photos/by-hash/{sha256}", get(photos::by_hash))
|
.route("/api/albums/{id}/photos/by-hash/{sha256}", get(photos::by_hash))
|
||||||
|
.route("/api/photos/delete", post(photos::delete_many))
|
||||||
.route("/api/photos/{id}", delete(photos::delete))
|
.route("/api/photos/{id}", delete(photos::delete))
|
||||||
.route("/api/photos/{id}/reprocess", post(photos::reprocess))
|
.route("/api/photos/{id}/reprocess", post(photos::reprocess))
|
||||||
.route("/api/shares/{id}", delete(shares::delete))
|
.route(
|
||||||
|
"/api/shares/{id}",
|
||||||
|
delete(shares::delete).patch(shares::update),
|
||||||
|
)
|
||||||
.route("/api/shares/{id}/reset-lock", post(shares::reset_lock))
|
.route("/api/shares/{id}/reset-lock", post(shares::reset_lock))
|
||||||
.route_layer(middleware::from_fn_with_state(
|
.route_layer(middleware::from_fn_with_state(
|
||||||
state.clone(),
|
state.clone(),
|
||||||
@@ -100,6 +104,10 @@ pub fn router(state: &AppState) -> Router<AppState> {
|
|||||||
"/api/share/{token}/photos/{photo_id}/rating",
|
"/api/share/{token}/photos/{photo_id}/rating",
|
||||||
put(client::set_rating),
|
put(client::set_rating),
|
||||||
)
|
)
|
||||||
|
.route(
|
||||||
|
"/api/share/{token}/photos/{photo_id}/verdict",
|
||||||
|
put(client::set_verdict),
|
||||||
|
)
|
||||||
.route(
|
.route(
|
||||||
"/api/share/{token}/photos/{photo_id}/tags",
|
"/api/share/{token}/photos/{photo_id}/tags",
|
||||||
put(client::set_tags),
|
put(client::set_tags),
|
||||||
|
|||||||
+52
-11
@@ -189,28 +189,69 @@ pub async fn by_hash(
|
|||||||
photo.map(Json).ok_or_else(ApiError::not_found)
|
photo.map(Json).ok_or_else(ApiError::not_found)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// The one deletion path: delete the given photos and enqueue their S3
|
||||||
|
/// cleanup jobs in the same transaction. Prefixes come from s3::photo_prefix
|
||||||
|
/// so the key layout has a single source of truth. Returns how many photos
|
||||||
|
/// were actually deleted.
|
||||||
|
pub(super) async fn delete_with_cleanup(
|
||||||
|
tx: &mut sqlx::PgConnection,
|
||||||
|
ids: &[Uuid],
|
||||||
|
) -> Result<u64, sqlx::Error> {
|
||||||
|
let deleted: Vec<Uuid> = sqlx::query_scalar("delete from photos where id = any($1) returning id")
|
||||||
|
.bind(ids)
|
||||||
|
.fetch_all(&mut *tx)
|
||||||
|
.await?;
|
||||||
|
if deleted.is_empty() {
|
||||||
|
return Ok(0);
|
||||||
|
}
|
||||||
|
let prefixes: Vec<String> = deleted.iter().map(|id| s3::photo_prefix(*id)).collect();
|
||||||
|
sqlx::query(
|
||||||
|
"insert into jobs (kind, payload)
|
||||||
|
select $1, jsonb_build_object('prefix', p)
|
||||||
|
from unnest($2::text[]) as p",
|
||||||
|
)
|
||||||
|
.bind(JobKind::DeleteS3Prefix.as_str())
|
||||||
|
.bind(&prefixes)
|
||||||
|
.execute(&mut *tx)
|
||||||
|
.await?;
|
||||||
|
Ok(deleted.len() as u64)
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn delete(
|
pub async fn delete(
|
||||||
State(state): State<AppState>,
|
State(state): State<AppState>,
|
||||||
Path(photo_id): Path<Uuid>,
|
Path(photo_id): Path<Uuid>,
|
||||||
) -> ApiResult<Json<serde_json::Value>> {
|
) -> ApiResult<Json<serde_json::Value>> {
|
||||||
let mut tx = state.db.begin().await?;
|
let mut tx = state.db.begin().await?;
|
||||||
let deleted = sqlx::query("delete from photos where id = $1")
|
if delete_with_cleanup(&mut tx, &[photo_id]).await? == 0 {
|
||||||
.bind(photo_id)
|
|
||||||
.execute(&mut *tx)
|
|
||||||
.await?;
|
|
||||||
if deleted.rows_affected() == 0 {
|
|
||||||
return Err(ApiError::not_found());
|
return Err(ApiError::not_found());
|
||||||
}
|
}
|
||||||
jobs::enqueue(
|
|
||||||
&mut *tx,
|
|
||||||
JobKind::DeleteS3Prefix,
|
|
||||||
serde_json::json!({ "prefix": s3::photo_prefix(photo_id) }),
|
|
||||||
)
|
|
||||||
.await?;
|
|
||||||
tx.commit().await?;
|
tx.commit().await?;
|
||||||
Ok(Json(serde_json::json!({ "ok": true })))
|
Ok(Json(serde_json::json!({ "ok": true })))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[derive(Deserialize)]
|
||||||
|
pub struct DeleteManyBody {
|
||||||
|
ids: Vec<Uuid>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn delete_many(
|
||||||
|
State(state): State<AppState>,
|
||||||
|
Json(body): Json<DeleteManyBody>,
|
||||||
|
) -> ApiResult<Json<serde_json::Value>> {
|
||||||
|
if body.ids.is_empty() {
|
||||||
|
return Err(ApiError::bad_request("ids must not be empty"));
|
||||||
|
}
|
||||||
|
let mut tx = state.db.begin().await?;
|
||||||
|
let deleted = delete_with_cleanup(&mut tx, &body.ids).await?;
|
||||||
|
// Consistent with the single-photo route: deleting nothing is an error,
|
||||||
|
// not a silent success (e.g. a stale tab re-deleting already-gone photos).
|
||||||
|
if deleted == 0 {
|
||||||
|
return Err(ApiError::not_found());
|
||||||
|
}
|
||||||
|
tx.commit().await?;
|
||||||
|
Ok(Json(serde_json::json!({ "ok": true, "deleted": deleted })))
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn reprocess(
|
pub async fn reprocess(
|
||||||
State(state): State<AppState>,
|
State(state): State<AppState>,
|
||||||
Path(photo_id): Path<Uuid>,
|
Path(photo_id): Path<Uuid>,
|
||||||
|
|||||||
+63
-9
@@ -23,6 +23,8 @@ struct ShareAdminRow {
|
|||||||
created_at: DateTime<Utc>,
|
created_at: DateTime<Utc>,
|
||||||
rating_count: i64,
|
rating_count: i64,
|
||||||
tag_count: i64,
|
tag_count: i64,
|
||||||
|
accept_count: i64,
|
||||||
|
reject_count: i64,
|
||||||
}
|
}
|
||||||
|
|
||||||
fn share_json(state: &AppState, row: &ShareAdminRow) -> serde_json::Value {
|
fn share_json(state: &AppState, row: &ShareAdminRow) -> serde_json::Value {
|
||||||
@@ -38,20 +40,30 @@ fn share_json(state: &AppState, row: &ShareAdminRow) -> serde_json::Value {
|
|||||||
"created_at": row.created_at,
|
"created_at": row.created_at,
|
||||||
"rating_count": row.rating_count,
|
"rating_count": row.rating_count,
|
||||||
"tag_count": row.tag_count,
|
"tag_count": row.tag_count,
|
||||||
|
"accept_count": row.accept_count,
|
||||||
|
"reject_count": row.reject_count,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
const SHARE_COLUMNS: &str = "s.id, s.token, s.label, s.password_hash, s.allow_download,
|
// Aggregates run as laterals so each feedback table is scanned once per
|
||||||
|
// share (the verdict lateral yields both counts from a single pass).
|
||||||
|
const SHARE_SELECT: &str = "select s.id, s.token, s.label, s.password_hash, s.allow_download,
|
||||||
s.expires_at, s.locked_until, s.created_at,
|
s.expires_at, s.locked_until, s.created_at,
|
||||||
(select count(*) from ratings r where r.share_id = s.id) as rating_count,
|
rc.rating_count, tc.tag_count, vc.accept_count, vc.reject_count
|
||||||
(select count(*) from tags t where t.share_id = s.id) as tag_count";
|
from shares s
|
||||||
|
cross join lateral (select count(*) as rating_count from ratings r where r.share_id = s.id) rc
|
||||||
|
cross join lateral (select count(*) as tag_count from tags t where t.share_id = s.id) tc
|
||||||
|
cross join lateral (
|
||||||
|
select count(*) filter (where v.verdict = 'accept') as accept_count,
|
||||||
|
count(*) filter (where v.verdict = 'reject') as reject_count
|
||||||
|
from verdicts v where v.share_id = s.id) vc";
|
||||||
|
|
||||||
pub async fn list(
|
pub async fn list(
|
||||||
State(state): State<AppState>,
|
State(state): State<AppState>,
|
||||||
Path(album_id): Path<Uuid>,
|
Path(album_id): Path<Uuid>,
|
||||||
) -> ApiResult<Json<Vec<serde_json::Value>>> {
|
) -> ApiResult<Json<Vec<serde_json::Value>>> {
|
||||||
let rows: Vec<ShareAdminRow> = sqlx::query_as(&format!(
|
let rows: Vec<ShareAdminRow> = sqlx::query_as(&format!(
|
||||||
"select {SHARE_COLUMNS} from shares s where s.album_id = $1 order by s.created_at desc"
|
"{SHARE_SELECT} where s.album_id = $1 order by s.created_at desc"
|
||||||
))
|
))
|
||||||
.bind(album_id)
|
.bind(album_id)
|
||||||
.fetch_all(&state.db)
|
.fetch_all(&state.db)
|
||||||
@@ -119,11 +131,53 @@ pub async fn create(
|
|||||||
.fetch_one(&state.db)
|
.fetch_one(&state.db)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
let row: ShareAdminRow =
|
let row: ShareAdminRow = sqlx::query_as(&format!("{SHARE_SELECT} where s.id = $1"))
|
||||||
sqlx::query_as(&format!("select {SHARE_COLUMNS} from shares s where s.id = $1"))
|
.bind(share_id)
|
||||||
.bind(share_id)
|
.fetch_one(&state.db)
|
||||||
.fetch_one(&state.db)
|
.await?;
|
||||||
.await?;
|
Ok(Json(share_json(&state, &row)))
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Distinguishes an absent JSON field (keep current value) from an explicit
|
||||||
|
/// null (clear the expiry): absent → None, present → Some(inner).
|
||||||
|
fn double_option<'de, D>(de: D) -> Result<Option<Option<DateTime<Utc>>>, D::Error>
|
||||||
|
where
|
||||||
|
D: serde::Deserializer<'de>,
|
||||||
|
{
|
||||||
|
serde::Deserialize::deserialize(de).map(Some)
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Deserialize)]
|
||||||
|
pub struct UpdateShare {
|
||||||
|
allow_download: Option<bool>,
|
||||||
|
#[serde(default, deserialize_with = "double_option")]
|
||||||
|
expires_at: Option<Option<DateTime<Utc>>>,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn update(
|
||||||
|
State(state): State<AppState>,
|
||||||
|
Path(share_id): Path<Uuid>,
|
||||||
|
Json(body): Json<UpdateShare>,
|
||||||
|
) -> ApiResult<Json<serde_json::Value>> {
|
||||||
|
let updated = sqlx::query(
|
||||||
|
"update shares set
|
||||||
|
allow_download = coalesce($2, allow_download),
|
||||||
|
expires_at = case when $3 then $4 else expires_at end
|
||||||
|
where id = $1",
|
||||||
|
)
|
||||||
|
.bind(share_id)
|
||||||
|
.bind(body.allow_download)
|
||||||
|
.bind(body.expires_at.is_some())
|
||||||
|
.bind(body.expires_at.flatten())
|
||||||
|
.execute(&state.db)
|
||||||
|
.await?;
|
||||||
|
if updated.rows_affected() == 0 {
|
||||||
|
return Err(ApiError::not_found());
|
||||||
|
}
|
||||||
|
let row: ShareAdminRow = sqlx::query_as(&format!("{SHARE_SELECT} where s.id = $1"))
|
||||||
|
.bind(share_id)
|
||||||
|
.fetch_one(&state.db)
|
||||||
|
.await?;
|
||||||
Ok(Json(share_json(&state, &row)))
|
Ok(Json(share_json(&state, &row)))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user