Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 README.md # Example This example shows how the SDK's API interfaces can be used by your code instead of the concrete service client type directly. Using this pattern allows you to mock out your code's usage of the SDK's service client for testing. # Usage Use the `go test` tool to verify the `Queue` type's `GetMessages` function correctly unmarshals the SQS message responses. `go test -tags example ifaceExample.go`	413 B	2025-05-25 12:27
📄 ifaceExample.go //go:build example // +build example package main import ( "encoding/json" "fmt" "os" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/sqs" "github.com/aws/aws-sdk-go/service/sqs/sqsiface" ) func main() { if len(os.Args) < 2 { fmt.Fprintln(os.Stderr, "Queue URL required.") os.Exit(1) } sess := session.Must(session.NewSession()) q := Queue{ Client: sqs.New(sess), URL: os.Args[1], } msgs, err := q.GetMessages(20) if err != nil { fmt.Fprintln(os.Stderr, err.Error()) os.Exit(1) } fmt.Println("Messages:") for _, msg := range msgs { fmt.Printf("%s>%s: %s\n", msg.From, msg.To, msg.Msg) } } // Queue provides the ability to handle SQS messages. type Queue struct { Client sqsiface.SQSAPI URL string } // Message is a concrete representation of the SQS message type Message struct { From string `json:"from"` To string `json:"to"` Msg string `json:"msg"` } // GetMessages returns the parsed messages from SQS if any. If an error // occurs that error will be returned. func (q *Queue) GetMessages(waitTimeout int64) ([]Message, error) { params := sqs.ReceiveMessageInput{ QueueUrl: aws.String(q.URL), } if waitTimeout > 0 { params.WaitTimeSeconds = aws.Int64(waitTimeout) } resp, err := q.Client.ReceiveMessage(&params) if err != nil { return nil, fmt.Errorf("failed to get messages, %v", err) } msgs := make([]Message, len(resp.Messages)) for i, msg := range resp.Messages { parsedMsg := Message{} if err := json.Unmarshal([]byte(aws.StringValue(msg.Body)), &parsedMsg); err != nil { return nil, fmt.Errorf("failed to unmarshal message, %v", err) } msgs[i] = parsedMsg } return msgs, nil }	1.69 KB	2025-05-25 12:27
📄 ifaceExample_test.go //go:build example // +build example package main import ( "fmt" "testing" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/service/sqs" "github.com/aws/aws-sdk-go/service/sqs/sqsiface" ) type mockedReceiveMsgs struct { sqsiface.SQSAPI Resp sqs.ReceiveMessageOutput } func (m mockedReceiveMsgs) ReceiveMessage(in sqs.ReceiveMessageInput) (sqs.ReceiveMessageOutput, error) { // Only need to return mocked response output return &m.Resp, nil } func TestQueueGetMessage(t testing.T) { cases := []struct { Resp sqs.ReceiveMessageOutput Expected []Message }{ { // Case 1, expect parsed responses Resp: sqs.ReceiveMessageOutput{ Messages: []sqs.Message{ {Body: aws.String(`{"from":"user_1","to":"room_1","msg":"Hello!"}`)}, {Body: aws.String(`{"from":"user_2","to":"room_1","msg":"Hi user_1 :)"}`)}, }, }, Expected: []Message{ {From: "user_1", To: "room_1", Msg: "Hello!"}, {From: "user_2", To: "room_1", Msg: "Hi user_1 :)"}, }, }, { // Case 2, not messages returned Resp: sqs.ReceiveMessageOutput{}, Expected: []Message{}, }, } for i, c := range cases { q := Queue{ Client: mockedReceiveMsgs{Resp: c.Resp}, URL: fmt.Sprintf("mockURL_%d", i), } msgs, err := q.GetMessages(20) if err != nil { t.Fatalf("%d, unexpected error, %v", i, err) } if a, e := len(msgs), len(c.Expected); a != e { t.Fatalf("%d, expected %d messages, got %d", i, e, a) } for j, msg := range msgs { if a, e := msg, c.Expected[j]; a != e { t.Errorf("%d, expected %v message, got %v", i, e, a) } } } }	1.57 KB	2025-05-25 12:27

Terminal