Method forwardAgentEvents

pkg/desktop/desktop.go:522–599

forwardAgentEvents subscribes to agent events and forwards them to the frontend

(ag *agent.Agent, agentID string)

// forwardAgentEvents subscribes to agent events and forwards them to the frontend
func (a *App) forwardAgentEvents(ag *agent.Agent, agentID string) {
	eventCh := ag.Subscribe([]types.AgentChannel{
		types.ChannelProgress,
		types.ChannelControl,
	}, nil)

	for envelope := range eventCh {
		var event *FrontendEvent

		switch e := envelope.Event.(type) {
		case *types.ProgressTextChunkEvent:
			event = &FrontendEvent{
				Type:    EventTypeTextChunk,
				AgentID: agentID,
				Data:    map[string]string{"delta": e.Delta},
			}

		case *types.ProgressToolStartEvent:
			event = &FrontendEvent{
				Type:    EventTypeToolStart,
				AgentID: agentID,
				Data: map[string]any{
					"call_id":   e.Call.ID,
					"name":      e.Call.Name,
					"arguments": e.Call.Arguments,
				},
			}

		case *types.ProgressToolEndEvent:
			event = &FrontendEvent{
				Type:    EventTypeToolEnd,
				AgentID: agentID,
				Data: map[string]any{
					"call_id": e.Call.ID,
					"name":    e.Call.Name,
					"result":  e.Call.Result,
					"error":   e.Call.Error,
				},
			}

		case *types.ProgressToolProgressEvent:
			event = &FrontendEvent{
				Type:    EventTypeToolProgress,
				AgentID: agentID,
				Data: map[string]any{
					"call_id":  e.Call.ID,
					"progress": e.Progress,
					"message":  e.Message,
				},
			}

		case *types.ControlPermissionRequiredEvent:
			event = &FrontendEvent{
				Type:    EventTypeApprovalRequired,
				AgentID: agentID,
				Data: map[string]any{
					"call_id":   e.Call.ID,
					"name":      e.Call.Name,