Function handler

packages/tools/src/definitions/retrieve-chat-evidence.ts:338–453

(params: Record<string, unknown>, context: ToolExecutionContext)

}

async function handler(params: Record<string, unknown>, context: ToolExecutionContext): Promise<ToolResult> {
  const locale = context.locale
  const query = typeof params.query === 'string' ? params.query.trim() : ''
  const criteria = typeof params.criteria === 'string' && params.criteria.trim() ? params.criteria.trim() : undefined
  const keywords = Array.isArray(params.keywords)
    ? (params.keywords.filter((k) => typeof k === 'string' && k.trim()) as string[])
    : []
  const requestedMode: EvidenceRetrievalMode =
    params.mode === 'hybrid' || params.mode === 'semantic' || params.mode === 'keyword' || params.mode === 'auto'
      ? params.mode
      : 'auto'

  const service = context.semanticIndexService
  const semanticAvailable = !!service && (await service.canSearch(context.sessionId))
  const rangeMs = parseEvidenceTimeRange(params, context)

  const { mode, warnings } = resolveMode(requestedMode, semanticAvailable, keywords.length > 0)
  if (!criteria) warnings.add('criteria_missing')

  const runSemantic = mode === 'semantic' || mode === 'hybrid'
  const runKeyword = mode === 'keyword' || mode === 'hybrid'

  let semanticRan = false
  let keywordRan = false
  const semanticCandidates: EvidenceCandidate[] = []
  let keywordCandidates: EvidenceCandidate[] = []

  // 语义路径：service 内按 chunk 时间范围过滤；工具层再按 startTime/endTime 兜底过滤
  if (runSemantic) {
    if (!service || !semanticAvailable) {
      warnings.add('semantic_unavailable')
    } else {
      const result = await service.searchForTool(context.sessionId, query, {
        maxResults: clampMaxResults(params.max_results),
        preprocessConfig: context.preprocessConfig,
        ownerPlatformId: context.ownerPlatformId,
        locale,
        maxResultTokens: context.maxToolResultTokens,
        timeFilter: rangeMs,
      })
      semanticRan = true
      if (!result.available) {
        warnings.add('semantic_unavailable')
      } else {
        if (result.partial) warnings.add('semantic_partial')
        for (const s of result.sources) {
          const startMs = parseIsoMs(s.startTime)
          const endMs = parseIsoMs(s.endTime) ?? startMs
          if (rangeMs && startMs != null && endMs != null && !overlapsTimeRangeMs(startMs, endMs, rangeMs)) continue
          const evidenceText = stripLineTimestamps(s.text || s.snippet)
          semanticCandidates.push({
            messageId: s.startMessageId,
            startMessageId: s.startMessageId,
            endMessageId: s.endMessageId,
            timestamp: startMs ?? 0,
            rangeStartMs: startMs ?? 0,
            rangeEndMs: endMs ?? startMs ?? 0,
            snippet: evidenceText,