Method handleEvent

server/handlers/remote_agent.go:308–337

handleEvent 处理事件推送

(ctx context.Context, payload json.RawMessage)

// handleEvent 处理事件推送
func (h *RemoteAgentHandler) handleEvent(ctx context.Context, payload json.RawMessage) error {
	var evt EventPayload
	if err := json.Unmarshal(payload, &evt); err != nil {
		return fmt.Errorf("failed to parse event payload: %w", err)
	}

	logging.Info(ctx, "remote_agent.event.received", map[string]any{
		"agent_id":   evt.AgentID,
		"event_type": fmt.Sprintf("%T", evt.Envelope.Event),
	})

	h.mu.RLock()
	remoteAgent, exists := h.agents[evt.AgentID]
	h.mu.RUnlock()

	if !exists {
		return fmt.Errorf("agent %s not registered", evt.AgentID)
	}

	// 推送事件到 RemoteAgent 的 EventBus
	if err := remoteAgent.PushEvent(evt.Envelope); err != nil {
		return fmt.Errorf("failed to push event: %w", err)
	}

	logging.Info(ctx, "remote_agent.event.pushed", map[string]any{
		"agent_id": evt.AgentID,
	})

	return nil
}

// handleUnregister 处理 Agent 注销
func (h *RemoteAgentHandler) handleUnregister(ctx context.Context, payload json.RawMessage) error {