SQS unit tests - faking data

[ymwjbxxq]

Hello,

I have my old code:

            let request = InvalidationRequest::builder()
                .brand(request.brand.clone())
                .slug(pk.clone())
                .build();

            self.sqs_client
                .as_ref()
                .unwrap()
                .send_message()
                .queue_url(&self.sqs_url)
                .message_body(&serde_json::to_string(&request)?)
                .send()
                .await?;

The unit tests was working until the new libs updates
from aws-sdk-sqs = "0.29" to aws-sdk-sqs = "1.10.0"

let sqs =  http::Request::builder()
            .header("content-type", "application/x-www-form-urlencoded")
            .uri(http::uri::Uri::from_static(
                "https://sqs.eu-central-1.amazonaws.com/",
            ))
let request = sqs
            .body(SdkBody::from(
                    r#"Action=SendMessage&Version=2012-11-05&QueueUrl=some-sqs&MessageBody=%7B%22slug%22%3A%22slug%22%2C%22brand%22%3A%22brand%22%7D"#,
            ))?;

let response = Response::builder()
            .status(200)
            .body(SdkBody::from(
                r#"
<SendMessageResponse>
    <SendMessageResult>
        <MD5OfMessageBody>fafb00f5732ab283681e124bf8747ed1</MD5OfMessageBody>
        <MD5OfMessageAttributes>3ae8f24a165a8cedc005670c81a27295</MD5OfMessageAttributes>
        <MessageId>5fea7756-0ea4-451a-a703-a558b933e274</MessageId>
    </SendMessageResult>
    <ResponseMetadata>
        <RequestId>27daac76-34dd-47df-bd01-1f6e873584a0</RequestId>
    </ResponseMetadata>
</SendMessageResponse>
                "#,
            ))?;

This code is not working anymore with the error:

<error: invalid value object>

The API reference is still talking about application/x-www-form-urlencoded
https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-making-api-requests-xml.html

But now JSON is also supported, so I am not sure if I have to change the header or if I need to change the payload.

Even if I pass a simple JSON, the error stays the same.

Any idea?

[ymwjbxxq]

I made it

let sqs =   http::Request::builder()
           .header("content-type", "application/x-amz-json-1.0")
            .uri(http::uri::Uri::from_static(
                "https://sqs.eu-central-1.amazonaws.com/",
            ));
 let request = request
            .body(SdkBody::from(
                r#"{
                  "QueueUrl":"some-sqs",
                  "MessageBody":"{\"slug\":\"slug\",\"brand\":\"brand\"}"
                }"#,
            ))?;

let response = Response::builder()
            .status(200)
            .body(SdkBody::from(
                r#"
<SendMessageResponse>
    <SendMessageResult>
        <MD5OfMessageBody>fafb00f5732ab283681e124bf8747ed1</MD5OfMessageBody>
        <MD5OfMessageAttributes>3ae8f24a165a8cedc005670c81a27295</MD5OfMessageAttributes>
        <MessageId>5fea7756-0ea4-451a-a703-a558b933e274</MessageId>
    </SendMessageResult>
    <ResponseMetadata>
        <RequestId>27daac76-34dd-47df-bd01-1f6e873584a0</RequestId>
    </ResponseMetadata>
</SendMessageResponse>
                "#,
            ))?;

[github-actions[bot]]

Hello! Reopening this discussion to make it searchable.