Method handleMessageSend

pkg/a2a/server.go:94–191

handleMessageSend 处理 message/send 方法

(ctx context.Context, agentID string, req *JSONRPCRequest)

// handleMessageSend 处理 message/send 方法
func (s *Server) handleMessageSend(ctx context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse {
	// 解析参数
	var params MessageSendParams
	if err := parseParams(req.Params, &params); err != nil {
		return NewErrorResponse(req.ID, ErrorCodeInvalidParams, err.Error(), nil)
	}

	// 获取或创建 Task
	taskID := params.Message.TaskID
	if taskID == "" {
		taskID = generateID()
	}

	task, err := s.loadOrCreateTask(agentID, taskID, params.ContextID, params.Metadata)
	if err != nil {
		return NewErrorResponse(req.ID, ErrorCodeInternalError, err.Error(), nil)
	}

	// 添加用户消息到历史
	task.AddMessage(params.Message)

	// 更新状态为 working
	task.UpdateStatus(TaskStateWorking, nil)
	if err := s.taskStore.Save(agentID, task); err != nil {
		return NewErrorResponse(req.ID, ErrorCodeInternalError, err.Error(), nil)
	}

	// 通过 Actor 系统发送消息
	pid, exists := s.actorSystem.GetActor(agentID)
	if !exists {
		task.UpdateStatus(TaskStateFailed, &Message{
			MessageID: generateID(),
			Role:      "agent",
			Parts:     []Part{{Kind: "text", Text: "agent not found: " + agentID}},
			Kind:      "message",
		})
		if err := s.taskStore.Save(agentID, task); err != nil {
			a2aLog.Warn(ctx, "save task error", map[string]any{"error": err})
		}
		return NewErrorResponse(req.ID, ErrorCodeInternalError, "agent not found: "+agentID, nil)
	}

	// 提取文本内容
	text := extractText(params.Message.Parts)

	// 发送到 Agent Actor
	result, err := pid.Request(&agent.ChatMsg{
		Text:    text,
		Ctx:     ctx,
		ReplyTo: nil,
	}, 30*time.Second)

	if err != nil {
		// 失败
		task.UpdateStatus(TaskStateFailed, &Message{
			MessageID: generateID(),
			Role:      "agent",
			Parts:     []Part{{Kind: "text", Text: fmt.Sprintf("agent error: %v", err)}},