Method HandleBatchJSONRPC

pkg/a2a/handler.go:137–210

HandleBatchJSONRPC 处理批量 JSON-RPC 2.0 请求 POST /a2a/{agentId}/batch

(c *gin.Context)

// HandleBatchJSONRPC 处理批量 JSON-RPC 2.0 请求
// POST /a2a/{agentId}/batch
func (h *Handler) HandleBatchJSONRPC(c *gin.Context) {
	ctx := c.Request.Context()
	agentID := c.Param("agentId")

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

	// 解析批量请求
	var requests []JSONRPCRequest
	if err := c.ShouldBindJSON(&requests); err != nil {
		c.JSON(http.StatusBadRequest, &JSONRPCResponse{
			JSONRPC: "2.0",
			ID:      nil,
			Error: &RPCError{
				Code:    -32700, // Parse error
				Message: "Invalid JSON was received",
				Data:    err.Error(),
			},
		})
		return
	}

	if len(requests) == 0 {
		c.JSON(http.StatusBadRequest, &JSONRPCResponse{
			JSONRPC: "2.0",
			ID:      nil,
			Error: &RPCError{
				Code:    -32600, // Invalid Request
				Message: "Empty batch request",
			},
		})
		return
	}

	logging.Info(ctx, "a2a.batch_jsonrpc_request", map[string]any{
		"agent_id": agentID,
		"count":    len(requests),
	})

	// 处理每个请求
	responses := make([]*JSONRPCResponse, 0, len(requests))
	for _, req := range requests {
		if req.JSONRPC != "2.0" {
			responses = append(responses, &JSONRPCResponse{
				JSONRPC: "2.0",
				ID:      req.ID,
				Error: &RPCError{
					Code:    -32600,
					Message: "Invalid JSON-RPC version, must be '2.0'",
				},