Function createDb

src/services/session-index/fetch.test.ts:17–45

()

import type { DataAdapter } from '../data/types'

function createDb(): Database.Database {
  const db = new Database(':memory:')
  db.exec(`
    CREATE TABLE segment (
      id INTEGER PRIMARY KEY,
      start_ts INTEGER,
      end_ts INTEGER,
      message_count INTEGER,
      summary TEXT
    );
    CREATE TABLE message_context (
      message_id INTEGER,
      segment_id INTEGER,
      topic_id INTEGER
    );
  `)
  const insSeg = db.prepare('INSERT INTO segment (id, start_ts, end_ts, message_count, summary) VALUES (?, ?, ?, ?, ?)')
  insSeg.run(1, 100, 200, 3, null)
  insSeg.run(2, 300, 400, 2, 'summary-2')

  // 故意打乱插入顺序，验证 firstMessageId 取的是 message_id 最小值
  const insCtx = db.prepare('INSERT INTO message_context (message_id, segment_id, topic_id) VALUES (?, ?, NULL)')
  insCtx.run(11, 1)
  insCtx.run(10, 1)
  insCtx.run(12, 1)
  insCtx.run(31, 2)
  insCtx.run(30, 2)
  return db
}

function registerSqliteDataAdapter(db: Database.Database): void {
  const fake = {