Method PushEvent

pkg/agent/remote_agent.go:78–133

PushEvent 接收远程事件并推送到本地 EventBus 这是 RemoteAgent 的核心方法,用于接收来自远程进程的事件

(envelope types.AgentEventEnvelope)

// PushEvent 接收远程事件并推送到本地 EventBus
// 这是 RemoteAgent 的核心方法,用于接收来自远程进程的事件
func (r *RemoteAgent) PushEvent(envelope types.AgentEventEnvelope) error {
	if envelope.Event == nil {
		return errors.New("event is nil")
	}

	// 根据事件类型推送到对应的通道
	if ev, ok := envelope.Event.(types.EventType); ok {
		channel := ev.Channel()

		switch channel {
		case types.ChannelProgress:
			r.eventBus.EmitProgress(envelope.Event)
		case types.ChannelControl:
			r.eventBus.EmitControl(envelope.Event)
		case types.ChannelMonitor:
			r.eventBus.EmitMonitor(envelope.Event)
		default:
			remoteAgentLog.Warn(context.Background(), "remote_agent.unknown_channel", map[string]any{
				"agent_id": r.id,
				"channel":  string(channel),
			})
		}

		// 更新状态
		r.updateStateFromEvent(envelope.Event)
	} else if eventMap, ok := envelope.Event.(map[string]any); ok {
		// 处理从 JSON 反序列化的事件（map[string]any 类型）
		// 从事件 map 中推断 channel
		channel := r.inferChannelFromEventMap(eventMap)

		switch types.AgentChannel(channel) {
		case types.ChannelProgress:
			r.eventBus.EmitProgress(envelope.Event)
		case types.ChannelControl:
			r.eventBus.EmitControl(envelope.Event)
		case types.ChannelMonitor:
			r.eventBus.EmitMonitor(envelope.Event)
		default:
			// 默认发送到 Progress 通道
			r.eventBus.EmitProgress(envelope.Event)
		}

		remoteAgentLog.Debug(context.Background(), "remote_agent.event_pushed", map[string]any{
			"agent_id": r.id,
			"channel":  channel,
			"event":    eventMap,
		})
	} else {
		remoteAgentLog.Warn(context.Background(), "remote_agent.unknown_event_type", map[string]any{
			"agent_id":   r.id,
			"event_type": fmt.Sprintf("%T", envelope.Event),
		})
	}

	return nil
}

// inferChannelFromEventMap 从事件 map 中推断通道类型