Interface ToolDataProvider

packages/tools/src/types.ts:155–205

 * - WorkerDataProvider: 通过 workerManager IPC 调用 Worker 线程
 */
export interface ToolDataProvider {
  // === 基础查询 ===
  searchMessages(
    keywords: string[],
    options?: { timeFilter?: ToolTimeRange; limit?: number; senderId?: number }
  ): Promise<SearchMessagesResult>

  deepSearchMessages(
    keywords: string[],
    options?: { timeFilter?: ToolTimeRange; limit?: number; senderId?: number }
  ): Promise<SearchMessagesResult>

  getSearchMessageContext(messageIds: number[], contextBefore: number, contextAfter: number): Promise<RawMessage[]>

  getRecentMessages(options?: { timeFilter?: ToolTimeRange; limit?: number }): Promise<SearchMessagesResult>

  getMessageContext(messageIds: number[], contextSize: number): Promise<RawMessage[]>

  // === 聊天概览 ===
  getChatOverview(topN?: number): Promise<ChatOverviewResult | null>

  // === 成员相关 ===
  getMembers(): Promise<MemberInfo[]>

  getMemberStats(options?: { timeFilter?: ToolTimeRange; top?: number }): Promise<MemberStatItem[]>

  getMemberNameHistory(memberId: number): Promise<NameHistoryItem[]>

  // === 时间统计 ===
  getTimeStats(type: 'hourly' | 'weekday' | 'daily', options?: { timeFilter?: ToolTimeRange }): Promise<unknown[]>

  // === 段落相关 ===
  getSegmentMessages(segmentId: number, limit?: number): Promise<SegmentMessagesResult | null>

  getSegmentSummaries(options?: { limit?: number; timeFilter?: ToolTimeRange }): Promise<SegmentSummaryItem[]>

  // === 对话查询 ===
  getConversationBetween(
    memberId1: number,
    memberId2: number,
    timeFilter?: ToolTimeRange,
    limit?: number
  ): Promise<ConversationResult>

  // === SQL ===
  executeSql(sql: string): Promise<unknown>

  executeParameterizedSql<T = Record<string, unknown>>(query: string, params: Record<string, unknown>): Promise<T[]>

  getSchema(): Promise<SchemaTableInfo[]>
}

// ==================== Semantic Search Tool ====================