Skip to content

Commit

Permalink
add 1 smoke test
Browse files Browse the repository at this point in the history
  • Loading branch information
kojisaikiAtSony committed Apr 26, 2024
1 parent 031e67e commit 06db0ee
Show file tree
Hide file tree
Showing 2 changed files with 63 additions and 0 deletions.
10 changes: 10 additions & 0 deletions smoke_tests/fixtures/requests.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,16 @@ import (
"github.com/Admiral-Piett/goaws/app/models"
)

var CreateQueuesRequestBodyXML = struct {
Action string `xml:"Action"`
Version string `xml:"Version"`
QueueName string `xml:"QueueName"`
}{
Action: "CreateQueue",
Version: "2012-11-05",
QueueName: "new-queue-1",
}

var ListQueuesRequestBodyXML = struct {
Action string `xml:"Action"`
Version string `xml:"Version"`
Expand Down
53 changes: 53 additions & 0 deletions smoke_tests/sqs_send_message_test.go
Original file line number Diff line number Diff line change
@@ -1 +1,54 @@
package smoke_tests

import (
"context"
"testing"

af "github.com/Admiral-Piett/goaws/app/fixtures"
"github.com/Admiral-Piett/goaws/app/utils"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/service/sqs"
"github.com/stretchr/testify/assert"
)

func Test_SendMessageV1_json_no_attributes(t *testing.T) {
server := generateServer()
defer func() {
server.Close()
utils.ResetResources()
}()

sdkConfig, _ := config.LoadDefaultConfig(context.TODO())
sdkConfig.BaseEndpoint = aws.String(server.URL)
sqsClient := sqs.NewFromConfig(sdkConfig)
sdkResponse, _ := sqsClient.CreateQueue(context.TODO(), &sqs.CreateQueueInput{
QueueName: &af.QueueName,
})
targetQueueUrl := sdkResponse.QueueUrl

// TODO: I tried invoke without awssdk but there was an unexpected/unknown error on Xml.Decode on CreateQueue API logic...
// e := httpexpect.Default(t, server.URL)
// r := e.POST("/").
// WithForm(sf.CreateQueuesRequestBodyXML).
// Expect().
// Status(http.StatusOK).
// Body().Raw()
// r2 := models.CreateQueueResponse{}
// xml.Unmarshal([]byte(r), &r2)
// targetQueueUrl := r2.Result.QueueUrl

// Target test
targetMessageBody := "Test_SendMessageV1_json_no_attributes"
// sdkConfig, _ := config.LoadDefaultConfig(context.TODO())
// sdkConfig.BaseEndpoint = aws.String(server.URL)
// sqsClient := sqs.NewFromConfig(sdkConfig)
sendMessageOutput, _ := sqsClient.SendMessage(context.TODO(), &sqs.SendMessageInput{
QueueUrl: targetQueueUrl,
MessageBody: &targetMessageBody,
})

assert.NotNil(t, sendMessageOutput.MessageId)

// TODO: Assert message count in queue with GetQueueAttributes API
}

0 comments on commit 06db0ee

Please sign in to comment.