peter
5ac30abe1f
- player YB2: keepalive pagehide beacon (api.saveProgressBeacon) so the resume position isn't lost on F5/close within 5s of the last checkpoint (mirrors Plex). - player YB4: bound consecutive unplayable items in auto-advance so an auto-advancing/loop=all queue can't spin over a run of dead videos. - downloads B6 (client): localise structured quota/edit errors centrally in api.req() via localizeDetail() + Intl.NumberFormat (fixes HU/DE + decimal sep); + 3-locale download error strings. - channels FB1: focusChannelToken bump so re-clicking the same channel re-seeds the search box; FB2: syncSubs invalidates feed/feed-count (set can change now). - config CB2: reseed the ConfigPanel draft on a key-set dataVersion + explicit post-save token, so a mid-edit refetch can't clobber an in-progress edit. - config AB3 (UI): a blank allow_empty field stores "" instead of resetting. - admin SB2/SC2: confirm + success toast on demo-whitelist remove and deny-invite (+ trilingual strings); SC1: disable only the acted-on row (pendingId), not all; SB3: pause the 1s scheduler countdown ticker while the tab is hidden. - messages CT4: only invalidate conversations/unread when the incoming-message count actually changed, not on every 20s poll; MB3 (client): react to the live unread ping (onUnread → invalidate); MC3: extract e2ee installKey (setup/unlock); CC2: hoist POLL_MS to messaging.ts; MB4: document the reload-scoped socket.
40 lines
1.8 KiB
TypeScript
40 lines
1.8 KiB
TypeScript
// Shared messaging helpers used by both the Messages page and the floating chat dock.
|
|
import { useSyncExternalStore } from "react";
|
|
import { useQuery } from "@tanstack/react-query";
|
|
import { api } from "./api";
|
|
import { isUnlocked, subscribeUnlock } from "./e2ee";
|
|
|
|
export const SYSTEM_ID = 0; // synthetic "Siftlode" system conversation partner id
|
|
|
|
// Safety-net poll interval for message queries; live updates arrive over the WebSocket.
|
|
export const POLL_MS = 20000;
|
|
|
|
// Set-once cache of partner public keys (the server is the directory; keys never change).
|
|
const pubCache = new Map<number, string>();
|
|
export async function partnerPub(partnerId: number): Promise<string> {
|
|
const cached = pubCache.get(partnerId);
|
|
if (cached) return cached;
|
|
const r = await api.messagePublicKey(partnerId);
|
|
pubCache.set(partnerId, r.public_key);
|
|
return r.public_key;
|
|
}
|
|
|
|
// Live "is secure messaging unlocked on this device" — shared so the page and the dock agree.
|
|
function useUnlocked(): boolean {
|
|
return useSyncExternalStore(subscribeUnlock, isUnlocked, isUnlocked);
|
|
}
|
|
|
|
// The SERVER is the source of truth for whether messaging is set up. Combining it with the
|
|
// local unlock state gives the real gate: "setup" if the server has no key (even if a stale
|
|
// private key lingers in this browser — setup overwrites it), "unlock" if the server has a key
|
|
// but this device hasn't unlocked it, else "ready".
|
|
export type KeyState = "loading" | "setup" | "unlock" | "ready";
|
|
export function useKeyState(): KeyState {
|
|
const unlocked = useUnlocked();
|
|
const q = useQuery({ queryKey: ["message-key"], queryFn: api.messageMyKey, staleTime: 60_000 });
|
|
if (q.isLoading && !q.data) return "loading";
|
|
if (!(q.data?.configured ?? false)) return "setup";
|
|
if (!unlocked) return "unlock";
|
|
return "ready";
|
|
}
|