[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_171":-5,"_174":175,"_176":177},"routes/shell",{"_41":42,"_170":-5,"_171":-5,"_172":173},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":52,"_53":32,"_54":-7,"_55":-7,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70},"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/library.ts","oid","d73d7c6f21700f8c2b003527aae6bf6ea391d162","size",18407,"commit","1958d30e3a543467d9bde2bd0c4873bc4f0f11f0","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","import { defaultFilters, normalizeIdentity, type CatalogBook, type ReaderFilters } from './catalog.js';\nimport { mainlineWorks, seriesGaps, workHasAudio, workRelease, workReleased, type CatalogSeries, type CatalogWork } from './series.js';\nimport { isAudioCoverageCurrent } from './audio-coverage.js';\n\nexport const storageKeys = {\n\tlegacyLibrary: 'litrpg-hub:library:v1',\n\tlibrary: 'litrpg-hub:library:v2',\n\tfilters: 'litrpg-hub:filters:v1',\n\t/** Signed-out readers only. A signed-in reader's age claim lives on their account. */\n\tadult: 'litrpg-hub:adult:v1'\n} as const;\n\nexport type ShelfStatus = 'want' | 'reading' | 'read' | 'paused';\nexport const shelfLabels: Record = { want: 'Want to read', reading: 'Listening', read: 'Read', paused: 'On hold' };\nexport interface ShelfEntry {\n\tstatus: ShelfStatus; rating: number | null; updatedAt: string;\n\t/** Which volume this was recorded against, independent of whatever id held it at the time.\n\t * Work ids are re-minted as the catalog is enriched; this survives that. */\n\twork?: { series: string; number: number | null };\n}\n/** Keyed by work id, and by edition id for anything saved before series existed. */\nexport type Library = Record;\n\nconst reservedId = (id: string) => ['__proto__', 'constructor', 'prototype'].includes(id);\n/** Source edition ids are not always ASIN shaped, so allow the punctuation stable ids use\n * while still refusing keys that would reach Object.prototype. */\nconst safeId = (id: string) => /^[A-Za-z0-9._:-]{1,128}$/.test(id) && !reservedId(id);\n\nexport function parseLibrary(value: unknown): Library {\n\tif (!value || typeof value !== 'object' || Array.isArray(value)) return {};\n\tconst result: Library = {};\n\tfor (const [id, entry] of Object.entries(value)) {\n\t\tif (!entry || typeof entry !== 'object' || !Object.hasOwn(shelfLabels, entry.status) || !safeId(id)) continue;\n\t\tconst hint = entry.work;\n\t\t// Volume numbers are not always integers — 0.5 prequels and 10.5 novellas are common.\n\t\tconst validHint = hint && typeof hint === 'object' && typeof hint.series === 'string' && safeId(hint.series)\n\t\t\t&& (hint.number === null || hint.number === undefined || Number.isFinite(hint.number));\n\t\tresult[id] = {\n\t\t\tstatus: entry.status,\n\t\t\trating: Number.isInteger(entry.rating) && entry.rating >= 1 && entry.rating <= 5 ? entry.rating : null,\n\t\t\tupdatedAt: typeof entry.updatedAt === 'string' && Number.isFinite(Date.parse(entry.updatedAt)) ? entry.updatedAt : new Date().toISOString(),\n\t\t\t...(validHint ? { work: { series: hint.series as string, number: (hint.number ?? null) as number | null } } : {})\n\t\t};\n\t}\n\treturn result;\n}\nexport function parseFilters(value: unknown): ReaderFilters {\n\tconst result = { ...defaultFilters };\n\tif (!value || typeof value !== 'object') return result;\n\tfor (const key of Object.keys(result) as (keyof ReaderFilters)[]) {\n\t\tconst v = (value as Record)[key];\n\t\tif (typeof v === 'boolean') result[key] = v;\n\t}\n\treturn result;\n}\n\nexport interface SeriesLibrary { version: 2; series: Record; books: Library }\nexport const emptyLibrary = (): SeriesLibrary => ({ version: 2, series: {}, books: {} });\n\nexport function parseSeriesLibrary(value: unknown): SeriesLibrary | null {\n\tif (!value || typeof value !== 'object' || Array.isArray(value)) return null;\n\tconst data = value as Partial;\n\tif (data.version !== 2 || !data.series || typeof data.series !== 'object' || Array.isArray(data.series) || !data.books || typeof data.books !== 'object' || Array.isArray(data.books)) return null;\n\tconst result = emptyLibrary();\n\tresult.books = parseLibrary(data.books);\n\tfor (const [id, entry] of Object.entries(data.series)) {\n\t\tif (safeId(id) && entry && typeof entry.followedAt === 'string' && Number.isFinite(Date.parse(entry.followedAt))) result.series[id] = { followedAt: entry.followedAt };\n\t}\n\treturn result;\n}\n\nconst allWorkIds = (work: CatalogWork) => [work.id, work.bookId, ...work.editionIds];\n\n/** The id `groupSeries` synthesises before a series has canonical works. Generated, never\n * parsed, so a series id containing hyphens can't be misread. */\nconst legacyWorkId = (seriesId: string, number: number | null, title: string) =>\n\t`work-legacy-${seriesId}-${number ?? ''}-${normalizeIdentity(title.split(':')[0]).slice(0, 70)}`;\n\n/** Enriching a series re-mints its work ids, which strands progress saved under the old ones.\n * Re-home any entry that no longer resolves: first by the provenance hint on the entry, then\n * by regenerating the synthesized ids this app would have produced for the series' former\n * names. Matching is always series + volume number, so unrelated books never merge. */\nfunction rehomeOrphans(record: SeriesLibrary, catalog: CatalogSeries[], catalogBooks?: ReadonlyMap): SeriesLibrary {\n\tif (!catalog.length) return record;\n\tconst resolvable = new Set();\n\tfor (const s of catalog) for (const w of s.works) for (const id of allWorkIds(w)) resolvable.add(id);\n\tconst orphans = Object.keys(record.books).filter((id) => !resolvable.has(id));\n\tif (!orphans.length) return record;\n\n\tconst synthesized = new Map();\n\tfor (const series of catalog) {\n\t\tconst names = [series.id, ...series.aliases];\n\t\tfor (const work of series.works) {\n\t\t\t// The id was built from the EDITION's title and number. Enrichment may since have\n\t\t\t// retitled or renumbered the work, so regenerate from the editions too.\n\t\t\tconst titles = new Set([work.title]);\n\t\t\tconst numbers = new Set([work.number]);\n\t\t\tfor (const id of catalogBooks ? [work.bookId, ...work.editionIds] : []) {\n\t\t\t\tconst book = catalogBooks!.get(id);\n\t\t\t\tif (!book) continue;\n\t\t\t\ttitles.add(book.title);\n\t\t\t\tnumbers.add(book.seriesNumber);\n\t\t\t}\n\t\t\tfor (const name of names) for (const title of titles) for (const number of numbers) {\n\t\t\t\tif (number != null) synthesized.set(legacyWorkId(name, number, title), { series, work });\n\t\t\t}\n\t\t}\n\t}\n\t/** Mirrors `workIndex`'s reconciliation: an audiobook the exporter left out of every work\n\t * still resolves by series + volume number, so progress saved against its id is adopted\n\t * rather than left depending on every call site remembering a fallback. */\n\tconst byCatalogBook = (id: string) => {\n\t\tconst book = catalogBooks?.get(id);\n\t\tif (!book || book.edition !== 'audiobook' || book.seriesNumber == null) return undefined;\n\t\tconst series = catalog.find((s) => s.id === book.seriesKey || s.aliases.includes(book.seriesKey));\n\t\tconst work = series?.works.find((w) => w.number === book.seriesNumber);\n\t\treturn series && work ? { series, work } : undefined;\n\t};\n\tconst byHint = (hint: ShelfEntry['work']) => {\n\t\tif (!hint) return undefined;\n\t\tconst series = catalog.find((s) => s.id === hint.series || s.aliases.includes(hint.series));\n\t\tconst work = series?.works.find((w) => w.number === hint.number);\n\t\treturn series && work ? { series, work } : undefined;\n\t};\n\n\tconst books = { ...record.books };\n\tfor (const id of orphans) {\n\t\tconst entry = books[id];\n\t\tconst target = byHint(entry.work) ?? synthesized.get(id) ?? byCatalogBook(id);\n\t\tif (!target) continue;\n\t\tconst existing = books[target.work.id];\n\t\tif (!existing || Date.parse(entry.updatedAt) >= Date.parse(existing.updatedAt)) {\n\t\t\tbooks[target.work.id] = { ...entry, work: { series: target.series.id, number: target.work.number } };\n\t\t}\n\t\t// Only ids this app synthesised are dropped. Real source ids stay as aliases forever.\n\t\tif (id.startsWith('work-legacy-')) delete books[id];\n\t}\n\treturn { ...record, books };\n}\n\n/** Keep edition-keyed history intact; new actions are saved against stable work IDs.\n * The v1 record is never written to again, so it stays a usable backup. */\nexport function migrateLibrary(legacy: Library, catalog: CatalogSeries[], current: SeriesLibrary | null = null, books?: ReadonlyMap): SeriesLibrary {\n\tconst result = current ? { ...current, series: { ...current.series }, books: { ...current.books } } : { ...emptyLibrary(), books: { ...legacy } };\n\tif (!current) {\n\t\t// Anything already tracked implies the reader cares about the series it belongs to.\n\t\tfor (const series of catalog) {\n\t\t\tconst stamps = series.works.flatMap((w) => allWorkIds(w).flatMap((id) => (legacy[id] ? [legacy[id].updatedAt] : []))).sort();\n\t\t\tif (stamps.length) result.series[series.id] = { followedAt: stamps[0] };\n\t\t}\n\t\treturn rehomeOrphans(result, catalog, books);\n\t}\n\tfor (const [id, entry] of Object.entries(result.series)) {\n\t\tconst canonical = catalog.find((s) => s.id === id || s.aliases.includes(id));\n\t\tif (!canonical || canonical.id === id) continue;\n\t\tconst existing = result.series[canonical.id];\n\t\tresult.series[canonical.id] = existing && existing.followedAt < entry.followedAt ? existing : entry;\n\t\tdelete result.series[id];\n\t}\n\treturn rehomeOrphans(result, catalog, books);\n}\n\n/** Progress recorded against any edition of a work counts for the work. The most recent entry\n * wins whichever id holds it, so an imported read against an old ASIN is not shadowed by a\n * staler entry on the canonical work id. The canonical id only breaks ties. */\nexport function workEntry(library: SeriesLibrary, work: CatalogWork): ShelfEntry | undefined {\n\tlet best: ShelfEntry | undefined;\n\tfor (const id of allWorkIds(work)) {\n\t\tconst entry = library.books[id];\n\t\tif (!entry) continue;\n\t\tif (!best) { best = entry; continue; }\n\t\tconst newer = Date.parse(entry.updatedAt) - Date.parse(best.updatedAt);\n\t\tif (newer > 0 || (newer === 0 && id === work.id)) best = entry;\n\t}\n\treturn best;\n}\nexport const isFollowing = (library: SeriesLibrary, seriesId: string): boolean => !!library.series[seriesId];\n\nexport function followSeries(library: SeriesLibrary, seriesId: string, follow = true, now = new Date().toISOString()): SeriesLibrary {\n\tconst next = { ...library, series: { ...library.series } };\n\tif (follow) next.series[seriesId] ??= { followedAt: now };\n\t// Unfollowing only drops the subscription. Read history and ratings stay put.\n\telse delete next.series[seriesId];\n\treturn next;\n}\n\nexport function setWorkStatus(library: SeriesLibrary, series: CatalogSeries, work: CatalogWork, status: ShelfStatus | '', now = new Date().toISOString()): SeriesLibrary {\n\tconst next = followSeries(library, series.id, !!status || isFollowing(library, series.id), now);\n\tnext.books = { ...library.books };\n\tif (status) next.books[work.id] = { status, rating: workEntry(library, work)?.rating ?? null, updatedAt: now, work: { series: series.id, number: work.number } };\n\t// Explicitly clearing progress removes all edition aliases for this work, preventing an old read from reappearing.\n\telse for (const id of allWorkIds(work)) delete next.books[id];\n\treturn next;\n}\nexport function setWorkRating(library: SeriesLibrary, series: CatalogSeries, work: CatalogWork, rating: number, now = new Date().toISOString()): SeriesLibrary {\n\tconst next = followSeries(library, series.id, true, now);\n\tnext.books = { ...library.books, [work.id]: { status: workEntry(library, work)?.status ?? 'read', rating: rating >= 1 && rating <= 5 ? Math.round(rating) : null, updatedAt: now, work: { series: series.id, number: work.number } } };\n\treturn next;\n}\n\n/** Bulk action covers released audiobooks only. Announced volumes are left alone. */\nexport function markSeriesRead(library: SeriesLibrary, series: CatalogSeries, at = new Date().toISOString(), now = new Date().toISOString()): SeriesLibrary {\n\tlet result = followSeries(library, series.id, true, now);\n\tfor (const work of series.works) if (workReleased(series, work, at) && workEntry(result, work)?.status !== 'read') result = setWorkStatus(result, series, work, 'read', now);\n\treturn result;\n}\n\n/** Readers almost always find this app part-way through a series they have been listening to\n * for years. Recording \"I'm through Book 7\" in one action is the difference between adopting\n * the library and abandoning it. Only released audiobooks up to and including the chosen\n * volume are touched; anything after it, and any unnumbered side entry, is left alone. */\nexport function markReadThrough(library: SeriesLibrary, series: CatalogSeries, work: CatalogWork, at = new Date().toISOString(), now = new Date().toISOString()): SeriesLibrary {\n\tconst mainline = mainlineWorks(series);\n\tconst cutoff = mainline.findIndex((w) => w.id === work.id);\n\tif (cutoff < 0) return setWorkStatus(library, series, work, 'read', now);\n\tlet result = followSeries(library, series.id, true, now);\n\tfor (const w of mainline.slice(0, cutoff + 1)) {\n\t\tif (workReleased(series, w, at) && workEntry(result, w)?.status !== 'read') result = setWorkStatus(result, series, w, 'read', now);\n\t}\n\treturn result;\n}\n\nexport type SeriesState = 'caught-up' | 'caught-up-partial' | 'in-progress' | 'not-started';\nexport interface SeriesProgress {\n\tread: number; total: number; remaining: number; undated: number; upcoming: number;\n\tgaps: number[]; caughtUp: boolean; nextUnread: CatalogWork | null; side: { read: number; total: number };\n\t/** Reviewed audio coverage is present AND still current, re-checked at render time. */\n\tsourceComplete: boolean;\n\t/** Everything the catalog knows about is read, but something is unresolved. */\n\tunresolved: string[]; state: SeriesState;\n}\n/** \"Up to date\" is a claim about the reader, and it is only made on reviewed evidence that the\n * audiobook list itself is complete and still fresh. Coverage carries its own expiry, so it is\n * re-checked here rather than trusted as exported: a `current: true` shipped last month is not\n * timeless. `now` may be a plain date, in which case coverage can never be current — a\n * date-only caller cannot establish freshness, and guessing would be the false positive.\n * Scheduled audio is never counted as unread. */\nexport function seriesProgress(library: SeriesLibrary, series: CatalogSeries, now = new Date().toISOString()): SeriesProgress {\n\tconst today = now.slice(0, 10);\n\tconst mainline = mainlineWorks(series);\n\tconst isRead = (w: CatalogWork) => workEntry(library, w)?.status === 'read';\n\tconst release = (w: CatalogWork) => workRelease(series, w, now);\n\tconst coverage = series.audioCoverage;\n\tconst coverageCurrent = isAudioCoverageCurrent(coverage, now);\n\tconst byId = new Map(series.works.map((w) => [w.id, w]));\n\t// A verified release we cannot resolve to a work is unread by definition: we have no record.\n\tconst unmatched = coverageCurrent ? coverage!.releasedWorkIds.filter((id) => !byId.has(id)).length : 0;\n\t// A work current coverage does not vouch for must not inherit its old catalogued date.\n\t// A print/ebook-only volume is rightly absent from an AUDIO bibliography, so its absence\n\t// is not a gap in the coverage.\n\tconst unvouched = coverageCurrent ? mainline.filter((w) => workHasAudio(w) && release(w).state === 'unknown').length : 0;\n\n\tconst available = mainline.filter((w) => release(w).state === 'released');\n\tconst read = available.filter(isRead).length;\n\tconst undated = coverageCurrent ? 0 : mainline.filter((w) => release(w).state === 'unknown' && !isRead(w)).length;\n\tconst upcoming = mainline.filter((w) => release(w).state === 'scheduled').length;\n\tconst gaps = coverageCurrent ? [] : seriesGaps(series);\n\tconst mainlineIds = new Set(mainline.map((w) => w.id));\n\tconst side = series.works.filter((w) => !mainlineIds.has(w.id) && release(w).state === 'released');\n\tconst sideRead = side.filter(isRead).length;\n\n\tconst unresolved = coverageCurrent\n\t\t? [\n\t\t\t...(unmatched ? [`${unmatched} audiobook${unmatched === 1 ? ' is' : 's are'} missing from this list`] : []),\n\t\t\t...(unvouched ? [`${unvouched} book${unvouched === 1 ? ' here has' : 's here have'} not been confirmed as an audiobook`] : [])\n\t\t]\n\t\t: [\n\t\t\t...(gaps.length ? [`Book ${gaps.join(', ')} ${gaps.length === 1 ? 'is' : 'are'} missing from this list`] : []),\n\t\t\t...(undated ? [`${undated} audiobook${undated === 1 ? ' has' : 's have'} no confirmed release date`] : []),\n\t\t\t...(side.length - sideRead ? [`${side.length - sideRead} side entr${side.length - sideRead === 1 ? 'y is' : 'ies are'} unread`] : []),\n\t\t\t'This list may be incomplete'\n\t\t];\n\n\tconst finished = available.length > 0 && read === available.length;\n\tconst caughtUp = coverageCurrent && !unresolved.length && finished;\n\treturn {\n\t\tread, total: available.length, remaining: available.length - read, undated, upcoming, gaps,\n\t\tcaughtUp, nextUnread: available.find((w) => !isRead(w)) ?? null,\n\t\tside: { read: sideRead, total: side.length }, sourceComplete: coverageCurrent, unresolved,\n\t\tstate: finished\n\t\t\t? caughtUp ? 'caught-up' : 'caught-up-partial'\n\t\t\t: read > 0 || series.works.some((w) => workEntry(library, w)?.status === 'reading') ? 'in-progress' : 'not-started'\n\t};\n}\n\nexport interface LibraryExport { version: 2; exportedAt: string; library: SeriesLibrary }\nexport const libraryExport = (library: SeriesLibrary, exportedAt = new Date().toISOString()): LibraryExport => ({ version: 2, exportedAt, library });\n\n/** Accepts both the original shelf export and the series export. */\nexport function parseLibraryExport(value: unknown, catalog: CatalogSeries[], books?: ReadonlyMap): SeriesLibrary | null {\n\tif (!value || typeof value !== 'object') return null;\n\tconst data = value as { version?: unknown; library?: unknown };\n\t// Canonicalise and re-home: the exporting machine's work ids may predate an enrichment.\n\tif (data.version === 2) { const parsed = parseSeriesLibrary(data.library); return parsed && migrateLibrary({}, catalog, parsed, books); }\n\tif (data.version === 1 && data.library && typeof data.library === 'object') return migrateLibrary(parseLibrary(data.library), catalog, null, books);\n\treturn null;\n}\n\n/** Later edits win per book; a series stays followed from the earliest date either side knows. */\nexport function mergeLibraries(base: SeriesLibrary, incoming: SeriesLibrary): SeriesLibrary {\n\tconst result: SeriesLibrary = { version: 2, series: { ...base.series }, books: { ...base.books } };\n\tfor (const [id, entry] of Object.entries(incoming.series)) {\n\t\tconst existing = result.series[id];\n\t\tresult.series[id] = existing && existing.followedAt < entry.followedAt ? existing : entry;\n\t}\n\tfor (const [id, entry] of Object.entries(incoming.books)) {\n\t\tconst existing = result.books[id];\n\t\tif (!existing || Date.parse(entry.updatedAt) >= Date.parse(existing.updatedAt)) result.books[id] = entry;\n\t}\n\treturn result;\n}\n","editable",false,"branch","documentNavigation","repo","iamnbutler/shelfgoblin","repoId","5cd9c661-f631-4f6f-8ba4-fd4d736e1cce","ownerId","user:1714999","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",0,"watchers",1,"watching","pinned","notify","views",[126,127,128,129,130,131,132,133,134,135,136,137,138],"navigation",{"_56":57,"_85":86,"_87":88,"_89":90,"_91":92,"_93":94,"_95":96},"sources",[],"viewer","meta",{"_77":78,"_79":80,"_81":82,"_43":32,"_83":14,"_84":32,"_49":50,"_51":52},"branches",[72,73,74,75,14,76],"tags",[71],"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",[108,109,110],"documents",{"_105":106,"_107":50},"code",{"_102":103,"_104":50},"automations",{"_99":100,"_101":-5},"delivery",{"_97":50,"_98":-5},"tag","qZL1HNr33mhBASaxT9aAulkTqQf","releases","applications","workflows",3,"deployments","commits",121,"changes","counts",{},"total",{"_111":104,"_113":124,"_15":104,"_115":125,"_54":117,"_118":32,"_119":117,"_120":50},{"_111":121,"_113":122,"_15":121,"_115":123,"_54":117,"_118":32,"_119":117,"_120":50},{"_111":112,"_113":114,"_15":112,"_115":116,"_54":117,"_118":32,"_119":117,"_120":50},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_111":104,"_113":124,"_15":104,"_115":169,"_54":117,"_118":32,"_119":117},{"_111":121,"_113":122,"_15":121,"_115":168,"_54":117,"_118":32,"_119":117},{"_111":112,"_113":114,"_15":112,"_115":167,"_54":117,"_118":32,"_119":117},{"_111":164,"_113":165,"_15":164,"_115":166,"_54":32,"_118":32,"_119":117},{"_111":161,"_113":162,"_15":161,"_115":163,"_54":32,"_118":32,"_119":117},{"_111":99,"_113":159,"_15":91,"_115":160,"_54":32,"_118":32,"_119":117},{"_111":101,"_113":156,"_15":157,"_115":158,"_54":32,"_118":32,"_119":117},{"_111":97,"_113":154,"_15":97,"_115":155,"_54":32,"_118":32,"_119":117},{"_111":150,"_113":151,"_15":152,"_115":153,"_54":32,"_118":32,"_119":117},{"_111":87,"_113":148,"_15":87,"_115":149,"_54":32,"_118":32,"_119":32},{"_111":145,"_113":146,"_15":145,"_115":147,"_54":32,"_118":32,"_119":32},{"_111":142,"_113":143,"_15":142,"_115":144,"_54":32,"_118":32,"_119":32},{"_111":139,"_113":140,"_15":139,"_115":141,"_54":32,"_118":32,"_119":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794435388692,"sidebar","expanded"]