Method getToolMetrics

packages/memos-core/src/storage/sqlite.ts:726–806

(minutes: number, fromMs?: number, toMs?: number)

  }

  getToolMetrics(minutes: number, fromMs?: number, toMs?: number): {
    tools: string[];
    series: Array<{ minute: string; [tool: string]: number | string }>;
    aggregated: Array<{ tool: string; totalCalls: number; avgMs: number; p95Ms: number; errorCount: number }>;
  } {
    const since = fromMs ?? (Date.now() - minutes * 60 * 1000);
    const until = toMs ?? Date.now();

    const rows = this.db.prepare(
      `SELECT tool_name,
              duration_ms,
              success,
              strftime('%Y-%m-%d %H:%M', called_at/1000, 'unixepoch', 'localtime') as minute_key
       FROM tool_calls
       WHERE called_at >= ? AND called_at <= ?
       ORDER BY called_at`,
    ).all(since, until) as Array<{ tool_name: string; duration_ms: number; success: number; minute_key: string }>;

    const toolSet = new Set<string>();
    const minuteMap = new Map<string, Map<string, { total: number; count: number }>>();
    const aggMap = new Map<string, { durations: number[]; errors: number }>();

    for (const r of rows) {
      toolSet.add(r.tool_name);

      if (!aggMap.has(r.tool_name)) aggMap.set(r.tool_name, { durations: [], errors: 0 });
      const agg = aggMap.get(r.tool_name)!;
      agg.durations.push(r.duration_ms);
      if (!r.success) agg.errors++;

      if (!minuteMap.has(r.minute_key)) minuteMap.set(r.minute_key, new Map());
      const toolMap = minuteMap.get(r.minute_key)!;
      if (!toolMap.has(r.tool_name)) toolMap.set(r.tool_name, { total: 0, count: 0 });
      const entry = toolMap.get(r.tool_name)!;
      entry.total += r.duration_ms;
      entry.count++;
    }

    const tools = Array.from(toolSet).sort();

    const allMinutes: string[] = [];
    if (minutes > 0) {
      const startMinute = new Date(since);
      startMinute.setSeconds(0, 0);
      const now = new Date();
      for (let t = startMinute.getTime(); t <= now.getTime(); t += 60000) {
        const d = new Date(t);
        const pad = (n: number) => String(n).padStart(2, "0");
        allMinutes.push(`${d.getFullYear()}-${pad(d.getMonth() + 1)}-${pad(d.getDate())} ${pad(d.getHours())}:${pad(d.getMinutes())}`);
      }
    }

    const series = allMinutes.map((m) => {
      const entry: { minute: string; [tool: string]: number | string } = { minute: m };
      const toolMap = minuteMap.get(m);
      for (const t of tools) {
        const data = toolMap?.get(t);
        entry[t] = data ? Math.round(data.total / data.count) : 0;