Function decodeAgentChannelReplyRequest

internal/api/core/agent_channels.go:600–638

(c *gin.Context)

}

func decodeAgentChannelReplyRequest(c *gin.Context) (decodedAgentChannelReplyRequest, error) {
	if c == nil || c.Request == nil || c.Request.Body == nil {
		return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(
			errors.New("reply request body is required"),
		)
	}
	var raw map[string]json.RawMessage
	if err := json.NewDecoder(c.Request.Body).Decode(&raw); err != nil {
		return decodedAgentChannelReplyRequest{}, fmt.Errorf("decode agent channel reply request: %w", err)
	}
	if err := contract.ValidateNoRawClaimTokenField(raw); err != nil {
		return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(err)
	}

	var req decodedAgentChannelReplyRequest
	if err := decodeRawString(raw["reply_to_message_id"], &req.ReplyToMessageID); err != nil {
		return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(fmt.Errorf("reply_to_message_id: %w", err))
	}
	if err := decodeRawString(raw["idempotency_key"], &req.IdempotencyKey); err != nil {
		return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(fmt.Errorf("idempotency_key: %w", err))
	}
	req.Body = cloneRawMessage(raw["body"])
	if len(bytes.TrimSpace(req.Body)) == 0 {
		return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(errors.New("body is required"))
	}

	if metadataRaw := bytes.TrimSpace(raw["metadata"]); len(metadataRaw) > 0 &&
		!bytes.Equal(metadataRaw, []byte("null")) &&
		!bytes.Equal(metadataRaw, []byte("{}")) {
		metadata, ok, err := decodeOptionalCoordinationMetadata(metadataRaw)
		if err != nil {
			return decodedAgentChannelReplyRequest{}, NewNetworkValidationError(fmt.Errorf("metadata: %w", err))
		}
		if ok {
			req.Metadata = metadata
		}
	}
	return req, nil
}

func decodeOptionalCoordinationMetadata(
	raw json.RawMessage,