Finish unit test

internal/util/util.go

@@ -1,8 +1,6 @@
 package util
 
 import (
-	"bytes"
-	"encoding/gob"
 	"encoding/json"
 	"fmt"
 	"github.com/aws/aws-sdk-go-v2/service/sqs/types"
@@ -32,22 +30,6 @@ func ConvertToString(a any) string {
 	}
 }
 
-func ConvertToBytes(a any) ([]byte, error) {
-	if a == nil {
-		return nil, nil
-	}
-	t := reflect.TypeOf(a)
-	switch t.Kind() {
-	case reflect.Struct, reflect.Map, reflect.Slice, reflect.Array, reflect.Interface:
-		return json.Marshal(a)
-	default:
-		var buffer bytes.Buffer
-		enc := gob.NewEncoder(&buffer)
-		err := enc.Encode(a)
-		return buffer.Bytes(), err
-	}
-}
-
 func GetDataType(a any) string {
 	t := reflect.TypeOf(a)
 	switch t.Kind() {

sqs/consumer_test.go

@@ -14,7 +14,7 @@ func TestReceiveMessage(t *testing.T) {
 					t.Errorf("ReceiveMessage() error = %v, wantErr %v", r, tt.wantErr)
 				}
 			}()
-			initMessageString(tt.queueUrl)
+			initMessageString()
 			initMessageStruct(tt.queueUrl)
 			d := 5 * time.Second
 			if tt.name == "failed" {
@@ -43,7 +43,7 @@ func TestSimpleReceiveMessage(t *testing.T) {
 					t.Errorf("SimpleReceiveMessage() error = %v, wantErr %v", r, tt.wantErr)
 				}
 			}()
-			initMessageString(tt.queueUrl)
+			initMessageString()
 			initMessageStruct(tt.queueUrl)
 			d := 5 * time.Second
 			if tt.name == "failed" {