Function insertFtsEntries

packages/node-runtime/src/fts/index.ts:91–106

(db: DatabaseAdapter, entries: Array<{ id: number; content: string | null }>)

 * Used during incremental import to sync new messages.
 */
export function insertFtsEntries(db: DatabaseAdapter, entries: Array<{ id: number; content: string | null }>): void {
  if (!hasFtsTable(db)) return

  const insertFts = db.prepare('INSERT INTO message_fts(rowid, content) VALUES (?, ?)')

  db.transaction(() => {
    for (const entry of entries) {
      if (entry.content) {
        const tokens = tokenizeForFts(entry.content)
        if (tokens) {
          insertFts.run(entry.id, tokens)
        }
      }
    }
  })
}

/**
 * Search messages using FTS5, returning matching rowids.