spsays-training/lib/bk.ts

/**
 * 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(/<script[\s>][\s\S]*?<\/script>/gi, "");
  clean = clean.replace(/<style[\s>][\s\S]*?<\/style>/gi, "");
  clean = clean.replace(/<iframe[\s>][\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<T>(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<BkChapter>(filePath);
}

// ---------------------------------------------------------------------------
// Book meta
// ---------------------------------------------------------------------------

/**
 * Book-level metadata (title, author, chapter list, etc.)
 */
export async function getBkMeta(): Promise<BkMeta | null> {
  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<BkMeta>(introPath);
}

// ---------------------------------------------------------------------------
// Chapters
// ---------------------------------------------------------------------------

/**
 * A numbered chapter (1–2).
 */
export async function getBkChapter(
  chapterNum: number,
): Promise<BkChapter | null> {
  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<BkChapter | null> {
  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<BkSidebarItem[]> {
  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<BkChapter>(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;
}