/** * Data access layer for Light of the Bhāgavata (LoB). * * Reads from MongoDB via Prisma, same as the rest of the app. * LoB is a prose book with no volume structure — * we use volume=0 as the sentinel for "no volumes". * * It has 48 "texts" (numbered chapters) plus 4 intro segments * (front-pages, preface, acknowledgement, the-artist). * * When the DB isn't seeded yet, falls back to reading local JSON files * from lib/jsons/books/lob/. * * Collections used: * - book_meta (via Prisma BookMeta model) * - prose_chapters (via Prisma ProseChapter model) */ import { prisma } from "@/lib/db"; import type { JsonValue } from "@prisma/client/runtime/library"; import fs from "fs"; import path from "path"; // --------------------------------------------------------------------------- // Constants // --------------------------------------------------------------------------- /** Volume sentinel for books without volumes. */ const NO_VOLUME = 0; const BOOK = "lob"; const LOB_JSON_DIR = path.join(process.cwd(), "lib", "jsons", "books", "lob"); // --------------------------------------------------------------------------- // Types // --------------------------------------------------------------------------- export type LobMeta = { book: string; title: string; author: string; year?: number; description: string; totalChapters: number; chapters: LobChapterEntry[]; }; export type LobChapterEntry = { number: number; title: string; }; export type LobIntroSegment = { slug: string; title: string; type: string; book: string; order: number; paragraphs: string[]; }; export type LobChapter = { book: string; chapter: number | null; title: string; type: string; slug?: string; paragraphs: string[]; }; /** Union type used in sidebar / table-of-contents navigation. */ export type LobSidebarItem = { /** URL-safe slug: "intro-front-pages", "1", "48", etc. */ slug: string; /** Human-readable label for the sidebar */ label: string; /** "intro-segment" | "chapter" */ type: string; /** Chapter number, or null for non-chapter items */ chapter: number | null; }; // --------------------------------------------------------------------------- // HTML sanitisation (mirrors lib/api.ts) // --------------------------------------------------------------------------- function sanitizeHtml(html: string): string { let clean = html.replace(/][\s\S]*?<\/script>/gi, ""); clean = clean.replace(/][\s\S]*?<\/style>/gi, ""); clean = clean.replace(/][\s\S]*?<\/iframe>/gi, ""); clean = clean.replace( /<\/?(?:script|style|iframe|object|embed|form|input|textarea|select|button)[^>]*>/gi, "", ); clean = clean.replace(/\s+on\w+\s*=\s*(?:"[^"]*"|'[^']*'|[^\s>]+)/gi, ""); clean = clean.replace(/href\s*=\s*"javascript:[^"]*"/gi, 'href=""'); clean = clean.replace(/href\s*=\s*'javascript:[^']*'/gi, "href=''"); return clean; } /** Normalize paragraphs — handles both native arrays and stringified JSON. */ function normalizeParagraphs(paragraphs: string[] | JsonValue): string[] { let result: string[]; if (typeof paragraphs === "string") { try { const parsed = JSON.parse(paragraphs); result = Array.isArray(parsed) ? parsed : [paragraphs]; } catch { result = [paragraphs]; } } else if (Array.isArray(paragraphs)) { result = paragraphs as string[]; } else { result = []; } return result.map(sanitizeHtml); } // --------------------------------------------------------------------------- // Local JSON helpers (fallback when DB is not seeded) // --------------------------------------------------------------------------- function readLocalJson(filePath: string): T | null { if (!fs.existsSync(filePath)) return null; try { return JSON.parse(fs.readFileSync(filePath, "utf-8")) as T; } catch { return null; } } function getLocalIntroSegments(): LobIntroSegment[] { const introDir = path.join(LOB_JSON_DIR, "intro"); if (!fs.existsSync(introDir)) return []; const results: LobIntroSegment[] = []; const files = [ "front-pages.json", "preface.json", "acknowledgement.json", "the-artist.json", ]; for (const file of files) { const filePath = path.join(introDir, file); const seg = readLocalJson(filePath); if (seg) results.push(seg); } return results.sort((a, b) => (a.order ?? 0) - (b.order ?? 0)); } function getLocalIntroSegment(rawSlug: string): LobIntroSegment | null { const filePath = path.join(LOB_JSON_DIR, "intro", `${rawSlug}.json`); return readLocalJson(filePath); } function getLocalChapter(chapterNum: number): LobChapter | null { const filePath = path.join( LOB_JSON_DIR, "chapters", String(chapterNum).padStart(2, "0") + ".json", ); return readLocalJson(filePath); } // --------------------------------------------------------------------------- // Book meta // --------------------------------------------------------------------------- /** * Book-level metadata (title, author, chapter list, etc.) */ export async function getLobMeta(): Promise { const meta = await prisma.bookMeta.findUnique({ where: { book: BOOK } }); if (meta) return meta.data as unknown as LobMeta; // Fallback to local JSON const introPath = path.join(LOB_JSON_DIR, "intro.json"); return readLocalJson(introPath); } // --------------------------------------------------------------------------- // Intro segments // --------------------------------------------------------------------------- /** * All intro segments, ordered by their `order` field. */ export async function getLobIntroSegments(): Promise { const results = await prisma.proseChapter.findMany({ where: { book: BOOK, volume: NO_VOLUME, type: "intro-segment" }, orderBy: { order: "asc" }, }); if (results.length > 0) { return results.map((doc) => ({ slug: doc.slug, title: doc.title, type: doc.type, book: doc.book, order: doc.order, paragraphs: normalizeParagraphs(doc.paragraphs), })); } // Fallback to local JSON return getLocalIntroSegments(); } /** * A single intro segment by slug. * Accepts both "intro-front-pages" (URL slug) and "front-pages" (raw slug). */ export async function getLobIntroSegment( slug: string, ): Promise { // DB stores with "intro-" prefix; accept either form const dbSlug = slug.startsWith("intro-") ? slug : `intro-${slug}`; const rawSlug = slug.startsWith("intro-") ? slug.replace(/^intro-/, "") : slug; const doc = await prisma.proseChapter.findUnique({ where: { book_volume_slug: { book: BOOK, volume: NO_VOLUME, slug: dbSlug }, }, }); if (doc) { return { slug: doc.slug, title: doc.title, type: doc.type, book: doc.book, order: doc.order, paragraphs: normalizeParagraphs(doc.paragraphs), }; } // Fallback to local JSON const local = getLocalIntroSegment(rawSlug); if (!local) return null; return { ...local, slug: dbSlug, paragraphs: local.paragraphs.map(sanitizeHtml), }; } // --------------------------------------------------------------------------- // Chapters (Texts 1–48) // --------------------------------------------------------------------------- /** * A numbered text/chapter (1–48). */ export async function getLobChapter( chapterNum: number, ): Promise { if (chapterNum < 1 || chapterNum > 48 || !Number.isInteger(chapterNum)) { return null; } const doc = await prisma.proseChapter.findUnique({ where: { book_volume_slug: { book: BOOK, volume: NO_VOLUME, slug: String(chapterNum), }, }, }); if (doc) { return { book: doc.book, chapter: doc.chapter, title: doc.title, type: doc.type, slug: doc.slug, paragraphs: normalizeParagraphs(doc.paragraphs), }; } // Fallback to local JSON const local = getLocalChapter(chapterNum); if (!local) return null; return { ...local, paragraphs: local.paragraphs.map(sanitizeHtml), }; } // --------------------------------------------------------------------------- // Unified content accessor // --------------------------------------------------------------------------- /** * Get content by URL slug. * * "intro-front-pages" → intro segment * "intro-preface" → intro segment * "intro-acknowledgement" → intro segment * "intro-the-artist" → intro segment * "1" … "48" → chapter (text) */ export async function getLobContent( slug: string, ): Promise { if (slug.startsWith("intro-")) { return getLobIntroSegment(slug); } const num = Number(slug); if (!Number.isNaN(num) && Number.isInteger(num) && num >= 1 && num <= 48) { return getLobChapter(num); } return null; } // --------------------------------------------------------------------------- // Sidebar navigation // --------------------------------------------------------------------------- /** * Build the full sidebar navigation list. * * Order: front-pages → preface → acknowledgement → the-artist → texts 1–48 */ export async function getLobSidebarItems(): Promise { const [meta, allDocs] = await Promise.all([ getLobMeta(), prisma.proseChapter.findMany({ where: { book: BOOK, volume: NO_VOLUME }, orderBy: { order: "asc" }, select: { slug: true, title: true, type: true, chapter: true, order: true }, }), ]); // If we got DB results, build from those if (meta && allDocs.length > 0) { return buildSidebarFromDocs(meta, allDocs); } // Fallback: build from local JSON return buildSidebarFromLocal(meta); } function buildSidebarFromDocs( meta: LobMeta, allDocs: { slug: string; title: string; type: string; chapter: number | null; order: number | null }[], ): LobSidebarItem[] { const items: LobSidebarItem[] = []; // Intro segments (all come before chapters; LoB has no back matter) for (const doc of allDocs) { if (doc.type === "intro-segment") { items.push({ slug: doc.slug, label: doc.title, type: "intro-segment", chapter: null, }); } } // Texts 1–48 (use meta.chapters for consistent title/ordering) for (const ch of meta.chapters) { items.push({ slug: String(ch.number), label: `Text ${ch.number}: ${ch.title}`, type: "chapter", chapter: ch.number, }); } return items; } function buildSidebarFromLocal(meta: LobMeta | null): LobSidebarItem[] { const items: LobSidebarItem[] = []; // Local intro segments (front matter only — LoB has no back matter) const introSegs = getLocalIntroSegments(); for (const seg of introSegs) { items.push({ slug: `intro-${seg.slug}`, label: seg.title, type: "intro-segment", chapter: null, }); } // Texts from meta or generate default 1-48 if (meta && meta.chapters) { for (const ch of meta.chapters) { items.push({ slug: String(ch.number), label: `Text ${ch.number}: ${ch.title}`, type: "chapter", chapter: ch.number, }); } } else { // Fallback: scan local chapter JSONs const chaptersDir = path.join(LOB_JSON_DIR, "chapters"); if (fs.existsSync(chaptersDir)) { const files = fs .readdirSync(chaptersDir) .filter((f) => f.endsWith(".json")) .sort(); for (const file of files) { const ch = readLocalJson(path.join(chaptersDir, file)); if (ch) { const num = ch.chapter ?? parseInt(file.replace(".json", ""), 10); items.push({ slug: String(num), label: `Text ${num}: ${ch.title}`, type: "chapter", chapter: num, }); } } } } return items; }