/** * Data access layer for Bhagavāner Kathā (BK). * * Reads from MongoDB via Prisma, same as the rest of the app. * BK is a simple prose book with no volume structure and no intro segments — * just 2 chapters directly. We use volume=0 as the sentinel for "no volumes". * * When the DB isn't seeded yet, falls back to reading local JSON files * from lib/jsons/books/bk/. * * 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 = "bk"; const BK_JSON_DIR = path.join(process.cwd(), "lib", "jsons", "books", "bk"); // --------------------------------------------------------------------------- // Types // --------------------------------------------------------------------------- export type BkMeta = { book: string; title: string; author: string; year?: number | null; description: string; totalChapters: number; chapters: BkChapterEntry[]; }; export type BkChapterEntry = { number: number; title: string; }; export type BkChapter = { book: string; chapter: number | null; title: string; type: string; slug?: string; paragraphs: string[]; }; /** Union type used in sidebar / table-of-contents navigation. */ export type BkSidebarItem = { /** URL-safe slug: "1", "2" */ slug: string; /** Human-readable label for the sidebar */ label: string; /** "chapter" */ type: string; /** Chapter number */ 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 getLocalChapter(chapterNum: number): BkChapter | null { const filePath = path.join( BK_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 getBkMeta(): Promise { const meta = await prisma.bookMeta.findUnique({ where: { book: BOOK } }); if (meta) return meta.data as unknown as BkMeta; // Fallback to local JSON const introPath = path.join(BK_JSON_DIR, "intro.json"); return readLocalJson(introPath); } // --------------------------------------------------------------------------- // Chapters // --------------------------------------------------------------------------- /** * A numbered chapter (1–2). */ export async function getBkChapter( chapterNum: number, ): Promise { if (chapterNum < 1 || chapterNum > 2 || !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. * * "1" … "2" → chapter */ export async function getBkContent( slug: string, ): Promise { const num = Number(slug); if (!Number.isNaN(num) && Number.isInteger(num) && num >= 1 && num <= 2) { return getBkChapter(num); } return null; } // --------------------------------------------------------------------------- // Sidebar navigation // --------------------------------------------------------------------------- /** * Build the full sidebar navigation list. * * Order: chapters 1–2 (no intro segments) */ export async function getBkSidebarItems(): Promise { const [meta, allDocs] = await Promise.all([ getBkMeta(), 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); } // Fallback: build from local JSON return buildSidebarFromLocal(meta); } function buildSidebarFromDocs(meta: BkMeta): BkSidebarItem[] { const items: BkSidebarItem[] = []; // Chapters 1–2 (use meta.chapters for consistent title/ordering) for (const ch of meta.chapters) { items.push({ slug: String(ch.number), label: `Chapter ${ch.number}: ${ch.title}`, type: "chapter", chapter: ch.number, }); } return items; } function buildSidebarFromLocal(meta: BkMeta | null): BkSidebarItem[] { const items: BkSidebarItem[] = []; // Chapters from meta or scan local chapter JSONs if (meta && meta.chapters) { for (const ch of meta.chapters) { items.push({ slug: String(ch.number), label: `Chapter ${ch.number}: ${ch.title}`, type: "chapter", chapter: ch.number, }); } } else { // Fallback: scan local chapter JSONs const chaptersDir = path.join(BK_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: `Chapter ${num}: ${ch.title}`, type: "chapter", chapter: num, }); } } } } return items; }