Method handleTasksCancel

pkg/a2a/server.go:216–254

handleTasksCancel 处理 tasks/cancel 方法

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

// handleTasksCancel 处理 tasks/cancel 方法
func (s *Server) handleTasksCancel(_ context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse {
	var params TasksCancelParams
	if err := parseParams(req.Params, &params); err != nil {
		return NewErrorResponse(req.ID, ErrorCodeInvalidParams, err.Error(), nil)
	}

	task, err := s.taskStore.Load(agentID, params.TaskID)
	if err != nil {
		return NewErrorResponse(req.ID, ErrorCodeTaskNotFound, err.Error(), nil)
	}

	// 检查是否可以取消
	if task.IsFinalState() {
		return NewSuccessResponse(req.ID, &TasksCancelResult{
			Success: false,
			Message: "Task is already in final state",
		})
	}

	// 设置取消信号
	s.taskStore.AddCancellation(params.TaskID)

	// 更新任务状态
	task.UpdateStatus(TaskStateCanceled, &Message{
		MessageID: generateID(),
		Role:      "agent",
		Parts:     []Part{{Kind: "text", Text: "Task canceled by request."}},
		Kind:      "message",
	})

	if err := s.taskStore.Save(agentID, task); err != nil {
		a2aLog.Warn(context.Background(), "save task error", map[string]any{"error": err})
	}

	return NewSuccessResponse(req.ID, &TasksCancelResult{
		Success: true,
		Message: "Task canceled successfully",
	})
}

// loadOrCreateTask 加载或创建任务
func (s *Server) loadOrCreateTask(agentID, taskID, contextID string, metadata Metadata) (*Task, error) {