Function initLocalDatabase

packages/core/src/db/db-core.ts:741–788

()

  return dbInitPromise;
}
export async function initLocalDatabase(): Promise<void> {
  if (localDbInitialized) return;
  if (localDbInitPromise) return localDbInitPromise;

  localDbInitPromise = (async () => {
    await runSerializedDbTask(async () => {
      if (localDbInitialized) return;

      const database = await getLocalDB();

      await database.execute(`
    CREATE TABLE IF NOT EXISTS chunks (
      id TEXT PRIMARY KEY,
      book_id TEXT NOT NULL,
      chapter_index INTEGER NOT NULL,
      chapter_title TEXT NOT NULL DEFAULT '',
      content TEXT NOT NULL,
      token_count INTEGER NOT NULL DEFAULT 0,
      start_cfi TEXT,
      end_cfi TEXT,
      segment_cfis TEXT,
      embedding BLOB,
      updated_at INTEGER NOT NULL DEFAULT 0
    )
  `);

      try {
        await database.execute(
          "ALTER TABLE chunks ADD COLUMN updated_at INTEGER NOT NULL DEFAULT 0",
        );
      } catch {
        // Column already exists on upgraded installs.
      }

      // Create indexes
      await database.execute("CREATE INDEX IF NOT EXISTS idx_chunks_book ON chunks(book_id)");

      localDbInitialized = true;

      // Migrate data from main DB to local DB on first run
      await migrateDataToLocalDB();
    });
  })().finally(() => {
    localDbInitPromise = null;
  });

  return localDbInitPromise;
}

/** Migrate chunks from main DB to local DB (one-time) */
async function migrateDataToLocalDB(): Promise<void> {