[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_172":-5,"_175":176,"_177":178},"routes/shell",{"_42":43,"_171":-5,"_172":-5,"_173":174},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":32,"_42":43,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":32,"_50":51,"_52":53,"_54":32,"_55":-7,"_56":-7,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","src/lib/account-sync.ts","oid","8855c1bb3a3e91d8ca5c7d65b5f9eca8904d86aa","size",10360,"commit","1958d30e3a543467d9bde2bd0c4873bc4f0f11f0","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { emptyLibrary, mergeLibraries, parseSeriesLibrary, storageKeys, type SeriesLibrary } from './library';\nimport { noConsent, parseAdultConsent, type AdultConsent } from './adult';\n\nexport interface AccountUser { id: string; username: string; displayName: string; avatarUrl: string }\nexport interface AccountState {\n user: AccountUser | null; status: string; ready: boolean; needsLogin: boolean; canImport: boolean;\n /** The reader's own age claim. Account-scoped when signed in, browser-scoped otherwise. */\n consent: AdultConsent;\n}\ninterface Snapshot { userId: string; library: SeriesLibrary; revision: number }\ninterface Cache { library: SeriesLibrary; base: SeriesLibrary; revision: number }\nconst equal = (a: unknown, b: unknown) => JSON.stringify(a) === JSON.stringify(b);\n\n/** Reapply only local edits to a fresh server copy. Absence is an edit too, so\n * unfollows and removed reads cannot be resurrected by another device's snapshot. */\nexport function rebaseLibrary(base: SeriesLibrary, local: SeriesLibrary, remote: SeriesLibrary): SeriesLibrary {\n function rebase(before: Record, after: Record, latest: Record): Record {\n const result = { ...latest };\n for (const key of new Set([...Object.keys(before), ...Object.keys(after)])) {\n if (equal(before[key], after[key])) continue;\n if (Object.hasOwn(after, key)) result[key] = after[key]; else delete result[key];\n }\n return result;\n }\n return { version: 2, series: rebase(base.series, local.series, remote.series), books: rebase(base.books, local.books, remote.books) };\n}\n\nexport class AccountSync {\n state: AccountState = { user: null, status: 'Checking sign-in…', ready: false, needsLogin: false, canImport: false, consent: noConsent() };\n private csrf = '';\n private cache: Cache | null = null;\n private guest = emptyLibrary();\n private pending: Promise | null = null;\n private disposed = false;\n private timer?: ReturnType;\n constructor(private basePath: string, private storage: Storage,\n private changed: (state: AccountState, library?: SeriesLibrary) => void, private fetcher: typeof fetch = fetch) {}\n private report(status: string, library?: SeriesLibrary) {\n if (this.disposed) return;\n this.state = { ...this.state, status };\n this.changed(this.state, library);\n }\n private key() { return `${storageKeys.library}:account:${this.state.user!.id}`; }\n private persist() {\n if (this.cache && this.state.user) this.storage.setItem(this.key(), JSON.stringify(this.cache));\n }\n private async request(route: string, init?: RequestInit): Promise {\n return this.fetcher(`${this.basePath}/${route}`, { ...init, credentials: 'same-origin', cache: 'no-store',\n signal: AbortSignal.timeout(15_000), headers: { 'Content-Type': 'application/json', 'X-CSRF-Token': this.csrf, ...init?.headers } });\n }\n async start(guest: SeriesLibrary, guestConsent: AdultConsent = noConsent()): Promise {\n this.guest = guest;\n // Applied up front so an unreachable session endpoint leaves the reader in guest mode with\n // their own claim, rather than with no claim at all.\n this.state = { ...this.state, consent: guestConsent };\n try {\n const response = await this.request('api/session/');\n if (!response.ok) throw new Error('unavailable');\n const { user, csrf, consent } = await response.json() as { user: AccountUser | null; csrf: string | null; consent?: unknown };\n if (this.disposed) return;\n this.csrf = csrf ?? '';\n this.state = { user, ready: true, needsLogin: false, status: '', consent: user ? parseAdultConsent(consent) : guestConsent,\n canImport: !!user && !!(Object.keys(guest.books).length || Object.keys(guest.series).length) };\n if (!user) { this.report('Saved in this browser'); return; }\n // A claim made in this browser moments ago came from the same reader, so carry it up\n // instead of asking again. The server still recomputes the unlock from the date.\n if (!this.state.consent.birthDate && guestConsent.birthDate) {\n try { await this.saveConsent(guestConsent); } catch { /* the gate stays shut, which is the safe direction */ }\n }\n if (this.disposed) return;\n let cached: Cache | null = null;\n try {\n const raw = JSON.parse(this.storage.getItem(this.key()) ?? 'null');\n if (raw && parseSeriesLibrary(raw.library) && parseSeriesLibrary(raw.base) && Number.isSafeInteger(raw.revision)) cached = raw;\n } catch { /* A corrupt cache must never become an empty upload. */ }\n this.cache = cached;\n this.report('Syncing…', cached?.library ?? emptyLibrary());\n await this.sync();\n } catch {\n this.state = { ...this.state, ready: true };\n this.report('Sign-in unavailable · library saved in this browser');\n }\n }\n save(library: SeriesLibrary) {\n if (!this.state.user) {\n this.guest = library;\n this.storage.setItem(storageKeys.library, JSON.stringify(library));\n return;\n }\n if (!this.cache) throw new Error('Wait for your account library to load before editing.');\n this.cache.library = library;\n this.persist();\n this.report('Changes saved on this device · syncing…');\n clearTimeout(this.timer);\n this.timer = setTimeout(() => { void this.sync(); }, 400);\n }\n canEdit() { return !this.state.user || this.cache !== null; }\n /** The age claim is account state, not library content: it is written straight through\n * rather than merged, because there is nothing to reconcile between two devices — the\n * reader's date of birth is the same on both. */\n async saveConsent(next: AdultConsent): Promise {\n const requested = parseAdultConsent(next);\n if (!this.state.user) {\n this.storage.setItem(storageKeys.adult, JSON.stringify(requested));\n this.state = { ...this.state, consent: requested };\n this.report(this.state.status);\n return requested;\n }\n const response = await this.request('api/adult/', { method: 'PUT', body: JSON.stringify({ consent: requested }) });\n if (response.status === 401 || response.status === 403) { this.expired(); throw new Error('signed out'); }\n if (!response.ok) throw new Error('consent save failed');\n // The server's answer is authoritative: it may refuse an unlock this device asked for.\n const saved = parseAdultConsent((await response.json() as { consent?: unknown }).consent);\n if (this.disposed) return saved;\n this.state = { ...this.state, consent: saved };\n this.report(this.state.status);\n return saved;\n }\n importGuest() {\n if (!this.cache) return;\n const library = mergeLibraries(this.cache.library, this.guest);\n this.save(library);\n this.state = { ...this.state, canImport: false };\n this.report('Adding browser library…', library);\n }\n async sync(): Promise {\n if (!this.state.user || this.state.needsLogin || this.disposed) return;\n if (this.pending) return this.pending;\n this.pending = this.performSync().finally(() => { this.pending = null; });\n return this.pending;\n }\n private async performSync() {\n try {\n const response = await this.request('api/library/');\n if (response.status === 401) { this.expired(); return; }\n if (!response.ok) throw new Error('unavailable');\n let remote = await response.json() as Snapshot;\n if (remote.userId !== this.state.user?.id) { this.expired(); return; }\n if (!parseSeriesLibrary(remote.library) || !Number.isSafeInteger(remote.revision)) throw new Error('invalid response');\n if (this.disposed) return;\n if (!this.cache) this.cache = { ...remote, base: remote.library };\n for (let attempt = 0; attempt < 4; attempt++) {\n // Fold changes from another tab into this tab before touching the server.\n try {\n const other = JSON.parse(this.storage.getItem(this.key()) ?? 'null') as Cache | null;\n if (other && parseSeriesLibrary(other.library) && parseSeriesLibrary(other.base) && other.revision >= this.cache.revision) {\n this.cache.library = rebaseLibrary(this.cache.base, this.cache.library, other.library);\n }\n } catch { /* Current in-memory changes remain available. */ }\n const merged = rebaseLibrary(this.cache.base, this.cache.library, remote.library);\n this.cache = { library: merged, base: remote.library, revision: remote.revision };\n this.persist();\n this.report('Syncing…', merged);\n if (equal(merged, remote.library)) { this.report('Library synced'); return; }\n // Svelte state may contain proxies; serialize the JSON model to detach it.\n const sent = JSON.parse(JSON.stringify(merged)) as SeriesLibrary;\n const saved = await this.request('api/library/', { method: 'PUT', body: JSON.stringify({ library: sent, revision: remote.revision }) });\n if (saved.status === 401 || saved.status === 403) { this.expired(); return; }\n if (!saved.ok && saved.status !== 409) throw new Error('save failed');\n remote = await saved.json() as Snapshot;\n if (remote.userId !== this.state.user?.id) { this.expired(); return; }\n if (this.disposed) return;\n if (saved.ok) {\n this.cache = { library: rebaseLibrary(sent, this.cache.library, remote.library), base: remote.library, revision: remote.revision };\n this.persist();\n }\n }\n throw new Error('busy');\n } catch {\n this.report(this.cache ? 'Sync paused · changes kept on this device' : 'Could not load your account library · retry sync');\n }\n }\n private expired() {\n this.state = { ...this.state, needsLogin: true };\n this.report('Session expired · sign in again to sync');\n }\n async logout(): Promise {\n await this.sync();\n if (this.cache && !equal(this.cache.library, this.cache.base)) {\n this.report('Sync your pending changes before signing out.'); return false;\n }\n try {\n const response = await this.request('auth/logout/', { method: 'POST' });\n if (!response.ok && response.status !== 401) throw new Error('logout failed');\n return true;\n } catch { this.report('Sign-out failed · please retry'); return false; }\n }\n dispose() { this.disposed = true; clearTimeout(this.timer); }\n}\n","editable",false,"branch","documentNavigation","repo","iamnbutler/shelfgoblin","repoId","5cd9c661-f631-4f6f-8ba4-fd4d736e1cce","ownerId","user:1714999","organization","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers",1,"watching","pinned","notify","views",[127,128,129,130,131,132,133,134,135,136,137,138,139],"navigation",{"_57":58,"_86":87,"_88":89,"_90":91,"_92":93,"_94":95,"_96":97},"sources",[],"viewer","meta",{"_78":79,"_80":81,"_82":83,"_44":32,"_84":14,"_85":32,"_50":51,"_52":53},"branches",[73,74,75,76,14,77],"tags",[72],"cloneUrl","https://git.nexthub.sh/iamnbutler/shelfgoblin.git","catalog-contract-v1.0.0","chore/activate-catalog-worker","codex/compact-navigation","codex/login-d1","feat/quality-research-index","refactor/catalog-consumer","description","Shelf Goblin — discover LitRPG audiobooks, follow series, and track your library.","owner","iamnbutler","section","","head","empty","pins",[109,110,111],"documents",{"_106":107,"_108":51},"code",{"_103":104,"_105":51},"automations",{"_100":101,"_102":-5},"delivery",{"_98":51,"_99":-5},"tag","qZL1HNr33mhBASaxT9aAulkTqQf","releases","applications","workflows",3,"deployments","commits",121,"changes","counts",{},"total",{"_112":105,"_114":125,"_15":105,"_116":126,"_55":118,"_119":32,"_120":118,"_121":51},{"_112":122,"_114":123,"_15":122,"_116":124,"_55":118,"_119":32,"_120":118,"_121":51},{"_112":113,"_114":115,"_15":113,"_116":117,"_55":118,"_119":32,"_120":118,"_121":51},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_112":105,"_114":125,"_15":105,"_116":170,"_55":118,"_119":32,"_120":118},{"_112":122,"_114":123,"_15":122,"_116":169,"_55":118,"_119":32,"_120":118},{"_112":113,"_114":115,"_15":113,"_116":168,"_55":118,"_119":32,"_120":118},{"_112":165,"_114":166,"_15":165,"_116":167,"_55":32,"_119":32,"_120":118},{"_112":162,"_114":163,"_15":162,"_116":164,"_55":32,"_119":32,"_120":118},{"_112":100,"_114":160,"_15":92,"_116":161,"_55":32,"_119":32,"_120":118},{"_112":102,"_114":157,"_15":158,"_116":159,"_55":32,"_119":32,"_120":118},{"_112":98,"_114":155,"_15":98,"_116":156,"_55":32,"_119":32,"_120":118},{"_112":151,"_114":152,"_15":153,"_116":154,"_55":32,"_119":32,"_120":118},{"_112":88,"_114":149,"_15":88,"_116":150,"_55":32,"_119":32,"_120":32},{"_112":146,"_114":147,"_15":146,"_116":148,"_55":32,"_119":32,"_120":32},{"_112":143,"_114":144,"_15":143,"_116":145,"_55":32,"_119":32,"_120":32},{"_112":140,"_114":141,"_15":140,"_116":142,"_55":32,"_119":32,"_120":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794663184572,"sidebar","expanded"]