Function handler

packages/tools/src/definitions/response-time-analysis.ts:24–103

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

}

async function handler(params: Record<string, unknown>, context: ToolExecutionContext): Promise<ToolResult> {
  const { locale } = context
  const isZh = isChineseLocale(locale)
  const days = (params.days as number) || 30
  const topN = (params.top_n as number) || 10

  const sql = `
    SELECT msg.sender_id, COALESCE(m.group_nickname, m.account_name) AS name, msg.ts
    FROM message msg
    JOIN member m ON msg.sender_id = m.id
    WHERE msg.type = 0
      AND msg.ts > unixepoch('now', '-' || @days || ' days')
    ORDER BY msg.ts ASC
  `
  const rows = await context.dataProvider!.executeParameterizedSql<MsgRow>(sql, { days })
  if (!rows || rows.length < 2) {
    const text = isZh
      ? '该时间范围内消息不足，无法分析响应时间'
      : 'Not enough messages in this time range to analyze response time'
    return { content: text, data: null }
  }

  const responseTimes = new Map<number, { name: string; times: number[] }>()

  for (let i = 1; i < rows.length; i++) {
    const prev = rows[i - 1]
    const curr = rows[i]
    if (curr.sender_id === prev.sender_id) continue

    const gap = curr.ts - prev.ts
    if (gap < 5 || gap > 1800) continue

    if (!responseTimes.has(curr.sender_id)) {
      responseTimes.set(curr.sender_id, { name: curr.name, times: [] })
    }
    responseTimes.get(curr.sender_id)!.times.push(gap)
  }

  const stats = [...responseTimes.entries()]
    .map(([id, { name, times }]) => {
      times.sort((a, b) => a - b)
      const avg = Math.round(times.reduce((s, t) => s + t, 0) / times.length)
      const median = times[Math.floor(times.length / 2)]
      return { id, name, avgSeconds: avg, medianSeconds: median, responseCount: times.length }
    })
    .filter((s) => s.responseCount >= 3)
    .sort((a, b) => a.medianSeconds - b.medianSeconds)
    .slice(0, topN)

  if (stats.length === 0) {
    const text = isZh ? '没有足够的响应数据进行分析' : 'Not enough response data for analysis'
    return { content: text, data: null }
  }

  const formatTime = (s: number) => {
    if (s < 60) return isZh ? `${s}秒` : `${s}s`
    const m = Math.floor(s / 60)
    const sec = s % 60