hq/bpist-squalk-forum
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Reconnect the relay after a network drop

Browse source
This commit is contained in:
dtonon 2026-09-25 11:53:05 +02:00
parent c370a87f12
commit 19e63fda9f
1 changed files with 25 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

28
src/lib/relay.ts
View file

@ -10,7 +10,29 @@ import { auth } from "$lib/auth.svelte";
// persists so the handshake happens once rather than per request. Auth is // persists so the handshake happens once rather than per request. Auth is
// scoped to the forum relay — external relays (profiles, search) are never // scoped to the forum relay — external relays (profiles, search) are never
// authenticated against. // authenticated against.
const pool = new SimplePool(); // Reconnection keeps the live subscriptions (chat, notifications) alive
// across a network drop: the library re-sends them with `since` moved past
// the last event seen, so what arrived meanwhile is replayed.
const pool = new SimplePool({ enableReconnect: true });
// The library retries after a 10s backoff and gives up after one failed
// attempt while still offline, so reconnect as soon as the network or the
// tab is back, and keep a shorter backoff for drops in between.
const FAST_BACKOFF = [1000, 2000, 5000, 10000];
async function forumRelay(): Promise<AbstractRelay> {
const relay = await pool.ensureRelay(RELAY_URL);
relay.resubscribeBackoff = FAST_BACKOFF;
return relay;
}
function touchForumRelay() {
forumRelay().catch(() => {});
}
if (typeof document !== "undefined") {
document.addEventListener("visibilitychange", () => {
if (!document.hidden) touchForumRelay();
});
window.addEventListener("online", touchForumRelay);
}
// Scoped to the forum relay — external relays (profiles, search) are never // Scoped to the forum relay — external relays (profiles, search) are never
// authenticated against. Re-evaluated on every connection, so it picks up a // authenticated against. Re-evaluated on every connection, so it picks up a
@ -42,7 +64,7 @@ export async function ensureForumReady(): Promise<void> {
if (!signer) return; // anonymous: only public groups are visible anyway if (!signer) return; // anonymous: only public groups are visible anyway
let relay: AbstractRelay; let relay: AbstractRelay;
try { try {
relay = await pool.ensureRelay(RELAY_URL); relay = await forumRelay();
} catch { } catch {
return; // connection failed; the caller's own query surfaces the error return; // connection failed; the caller's own query surfaces the error
} }
@ -98,7 +120,7 @@ export function subscribeForum(
// membership probe. Never close it — the pool owns its lifecycle. // membership probe. Never close it — the pool owns its lifecycle.
export async function ensureForumRelay(): Promise<AbstractRelay> { export async function ensureForumRelay(): Promise<AbstractRelay> {
await ensureForumReady(); await ensureForumReady();
return pool.ensureRelay(RELAY_URL); return forumRelay();
} }
// Drop the forum connection so the next use reconnects and re-runs the AUTH // Drop the forum connection so the next use reconnects and re-runs the AUTH