Method GetTaskStatus

pkg/a2a/handler.go:214–299

GetTaskStatus 获取任务状态的便捷端点 GET /a2a/{agentId}/tasks/{taskId}

(c *gin.Context)

// GetTaskStatus 获取任务状态的便捷端点
// GET /a2a/{agentId}/tasks/{taskId}
func (h *Handler) GetTaskStatus(c *gin.Context) {
	ctx := c.Request.Context()
	agentID := c.Param("agentId")
	taskID := c.Param("taskId")

	if agentID == "" || taskID == "" {
		c.JSON(http.StatusBadRequest, gin.H{
			"success": false,
			"error": gin.H{
				"code":    "bad_request",
				"message": "Missing agentId or taskId parameter",
			},
		})
		return
	}

	logging.Info(ctx, "a2a.get_task_status", map[string]any{
		"agent_id": agentID,
		"task_id":  taskID,
	})

	// 构造 tasks/get JSON-RPC 请求
	params := TasksGetParams{
		TaskID: taskID,
	}
	paramsJSON, _ := json.Marshal(params)

	req := &JSONRPCRequest{
		JSONRPC: "2.0",
		ID:      taskID, // 使用 taskID 作为请求 ID
		Method:  "tasks/get",
		Params:  paramsJSON,
	}

	resp := h.server.HandleRequest(ctx, agentID, req)

	if resp.Error != nil {
		var statusCode int
		switch resp.Error.Code {
		case -32602: // Invalid params
			statusCode = http.StatusBadRequest
		case -32001: // Task not found
			statusCode = http.StatusNotFound
		default:
			statusCode = http.StatusInternalServerError
		}

		c.JSON(statusCode, gin.H{
			"success": false,
			"error": gin.H{
				"code":    resp.Error.Message,
				"message": fmt.Sprintf("%v", resp.Error.Data),
			},
		})
		return
	}

	// 解析任务响应