Merge branch 'fix_delayed_sqs_messages_during_local_development' into 'main'

Add concurrency handling to debug SQS message sending

See merge request !56

sqs/sqs.go

@@ -6,10 +6,12 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/utils"
 	"io"
+	"sync"
 	"time"
 
+	"gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/utils"
+
 	"github.com/google/uuid"
 	"gitlab.bob.co.za/bob-public-utils/bobgroup-go-utils/s3"
 
@@ -108,7 +110,10 @@ func (m *Messenger) SendSQSMessage(headers map[string]string, body string, curre
 func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *string, sqsType string, isDebug bool) error {
 
 	if isDebug {
+		var wg sync.WaitGroup
+		wg.Add(1)
 		go func() {
+			defer wg.Done()
 			if msgr.DelaySeconds != nil {
 				delay := *msgr.DelaySeconds
 				time.Sleep(time.Second * time.Duration(delay))
@@ -118,6 +123,7 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
 				Post("http://127.0.0.1:3000/sqs/" + sqsType)
 		}()
 		time.Sleep(time.Second * 1)
+		wg.Wait()
 		return nil
 	}