Method handleToolProgress

pkg/agent/agent.go:1493–1523

handleToolProgress 处理进度事件并推送到总线

(callID, toolName string, progress float64, message string, step, total int, metadata map[string]any, etaMs int64)

// handleToolProgress 处理进度事件并推送到总线
func (a *Agent) handleToolProgress(callID, toolName string, progress float64, message string, step, total int, metadata map[string]any, etaMs int64) {
	now := time.Now()
	snapshot := types.ToolCallSnapshot{
		ID:        callID,
		Name:      toolName,
		State:     types.ToolCallStateExecuting,
		Progress:  progress,
		UpdatedAt: now,
	}

	a.mu.Lock()
	if rec, ok := a.toolRecords[callID]; ok {
		rec.Progress = progress
		rec.State = types.ToolCallStateExecuting
		rec.UpdatedAt = now
		snapshot.Arguments = rec.Input
		snapshot.StartedAt = rec.StartTime
		snapshot.UpdatedAt = rec.UpdatedAt
	}
	a.mu.Unlock()

	a.eventBus.EmitProgress(&types.ProgressToolProgressEvent{
		Call:     snapshot,
		Progress: progress,
		Message:  message,
		Step:     step,
		Total:    total,
		Metadata: metadata,
		ETA:      etaMs,
	})
}

// handleToolIntermediate 处理中间结果事件
func (a *Agent) handleToolIntermediate(callID, toolName, label string, data any) {