Class FetchSessionIndexAdapter

src/services/session-index/fetch.ts:30–175

   WHERE mc.segment_id = segment.id ORDER BY mc.message_id LIMIT 1) as firstMessageId`

export class FetchSessionIndexAdapter implements SessionIndexAdapter {
  async generate(sessionId: string, gapThreshold: number = 1800): Promise<number> {
    const resp = await fetchWithAuth(`/_web/sessions/${sessionId}/generate-index`, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ gapThreshold }),
    })
    if (!resp.ok) throw new Error(`Failed to generate session index: ${resp.status}`)
    const result = (await resp.json()) as { sessionCount: number }
    return result.sessionCount
  }

  async generateIncremental(sessionId: string, gapThreshold: number = 1800): Promise<number> {
    const resp = await fetchWithAuth(`/_web/sessions/${sessionId}/generate-incremental-index`, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({ gapThreshold }),
    })
    if (!resp.ok) throw new Error(`Failed to generate incremental session index: ${resp.status}`)
    const result = (await resp.json()) as { sessionCount: number }
    return result.sessionCount
  }

  async hasIndex(sessionId: string): Promise<boolean> {
    const stats = await this.getStats(sessionId)
    return stats.hasIndex
  }

  async getStats(sessionId: string): Promise<SessionStats> {
    try {
      const rows = await getDataAdapter().pluginQuery<{ cnt: number }>(
        sessionId,
        'SELECT COUNT(*) as cnt FROM segment',
        []
      )
      const count = rows[0]?.cnt ?? 0
      return { hasIndex: count > 0, sessionCount: count, gapThreshold: 1800 }
    } catch {
      return { hasIndex: false, sessionCount: 0, gapThreshold: 1800 }
    }
  }

  async getAllIndexStats(): Promise<SessionIndexStatusItem[]> {
    const resp = await fetchWithAuth('/_web/sessions/index-stats')
    if (!resp.ok) return []
    return (await resp.json()) as SessionIndexStatusItem[]
  }

  async clear(sessionId: string): Promise<boolean> {
    await fetchWithAuth(`/_web/sessions/${sessionId}/clear-index`, { method: 'POST' })
    return true
  }

  async updateGapThreshold(_sessionId: string, _gapThreshold: number | null): Promise<boolean> {
    return true
  }

  async getSessions(sessionId: string): Promise<ChatSessionItem[]> {