Class FetchAIAdapter

src/services/ai/fetch.ts:27–232

const NOT_AVAILABLE_WEB = 'This feature is not available in web mode'

export class FetchAIAdapter implements AIAdapter {
  // ===== 对话管理 =====
  async getAIChat(aiChatId: string): Promise<AIChat | null> {
    try {
      return await get<AIChat>(`/ai/chats/${aiChatId}`)
    } catch {
      return null
    }
  }

  async getAIChats(sessionId: string): Promise<AIChat[]> {
    return get<AIChat[]>(`/ai/chats?sessionId=${encodeURIComponent(sessionId)}`)
  }

  async createAIChat(sessionId: string, title: string | undefined, assistantId: string): Promise<AIChat> {
    return post<AIChat>('/ai/chats', { sessionId, title, assistantId })
  }

  async updateAIChatTitle(aiChatId: string, title: string): Promise<boolean> {
    return put<boolean>(`/ai/chats/${aiChatId}/title`, { title })
  }

  async deleteAIChat(aiChatId: string): Promise<boolean> {
    return del<boolean>(`/ai/chats/${aiChatId}`)
  }

  // ===== 消息 =====
  async getMessages(aiChatId: string): Promise<AIMessage[]> {
    return get<AIMessage[]>(`/ai/chats/${aiChatId}/messages`)
  }

  async addMessage(
    aiChatId: string,
    role: AIMessageRole,
    content: string,
    dataKeywords?: string[],
    dataMessageCount?: number,
    contentBlocks?: ContentBlock[],
    tokenUsage?: TokenUsageData
  ): Promise<AIMessage> {
    return post<AIMessage>(`/ai/chats/${aiChatId}/messages`, {
      role,
      content,
      dataKeywords,
      dataMessageCount,
      contentBlocks,
      tokenUsage,
    })
  }

  async deleteMessagesFrom(aiChatId: string, messageId: string): Promise<void> {
    return post<void>(`/ai/chats/${aiChatId}/messages/${messageId}/delete-from`, {})
  }

  async forkAIChat(sourceAIChatId: string, upToMessageId: string, title?: string): Promise<AIChat> {
    return post<AIChat>(`/ai/chats/${sourceAIChatId}/fork`, { upToMessageId, title })
  }