chore: fix tests

Author: cisse21

enterprise/reporting/error_index/error_index_reporting_test.go

@@ -2,6 +2,7 @@ package error_index
 
 import (
 	"context"
+	"fmt"
 	"testing"
 	"time"
 
@@ -536,7 +537,7 @@ func TestErrorIndexReporter(t *testing.T) {
 
 		c := config.New()
 		c.Set("ErrorIndex.storage.Bucket", minioResource.BucketName)
-		c.Set("ErrorIndex.storage.Endpoint", minioResource.Endpoint)
+		c.Set("ErrorIndex.storage.Endpoint", fmt.Sprintf("http://%s", minioResource.Endpoint))
 		c.Set("ErrorIndex.storage.AccessKey", minioResource.AccessKeyID)
 		c.Set("ErrorIndex.storage.SecretAccessKey", minioResource.AccessKeySecret)
 		c.Set("ErrorIndex.storage.S3ForcePathStyle", true)

gateway/gateway_test.go

@@ -2709,7 +2709,7 @@ func TestLeakyUploader(t *testing.T) {
 		require.NoError(t, err)
 
 		// create a test gateway with leaky uploader enabled
-		gw, cleanupFn := createTestGatewayWithLeakyUploader(t, minioContainer.Endpoint, minioContainer.AccessKeyID, minioContainer.AccessKeySecret)
+		gw, cleanupFn := createTestGatewayWithLeakyUploader(t, fmt.Sprintf("http://%s", minioContainer.Endpoint), minioContainer.AccessKeyID, minioContainer.AccessKeySecret)
 		t.Cleanup(cleanupFn)
 
 		// Prepare invalid JSON payload

integration_test/reporting_error_index/reporting_error_index_test.go

@@ -759,7 +759,7 @@ func runRudderServer(
 	config.Set("Gateway.enableSuppressUserFeature", false)
 
 	config.Set("ErrorIndex.storage.Bucket", minioResource.BucketName)
-	config.Set("ErrorIndex.storage.Endpoint", minioResource.Endpoint)
+	config.Set("ErrorIndex.storage.Endpoint", fmt.Sprintf("http://%s", minioResource.Endpoint))
 	config.Set("ErrorIndex.storage.AccessKey", minioResource.AccessKeyID)
 	config.Set("ErrorIndex.storage.SecretAccessKey", minioResource.AccessKeySecret)
 	config.Set("ErrorIndex.storage.S3ForcePathStyle", true)

processor/internal/transformer/destination_transformer/embedded/warehouse/uploader_test.go

@@ -2,6 +2,7 @@ package warehouse
 
 import (
 	"context"
+	"fmt"
 	"strconv"
 	"strings"
 	"testing"
@@ -31,7 +32,7 @@ func TestTransformer_CompareResponsesAndUpload(t *testing.T) {
 	c := config.New()
 	c.Set("Warehouse.Transformer.Sampling.maxLoggedEvents", maxLoggedEvents)
 	c.Set("Warehouse.Transformer.Sampling.Bucket", minioResource.BucketName)
-	c.Set("Warehouse.Transformer.Sampling.Endpoint", minioResource.Endpoint)
+	c.Set("Warehouse.Transformer.Sampling.Endpoint", fmt.Sprintf("http://%s", minioResource.Endpoint))
 	c.Set("Warehouse.Transformer.Sampling.AccessKey", minioResource.AccessKeyID)
 	c.Set("Warehouse.Transformer.Sampling.SecretAccessKey", minioResource.AccessKeySecret)
 	c.Set("Warehouse.Transformer.Sampling.S3ForcePathStyle", true)

processor/ut_mirroring_test.go

@@ -175,7 +175,7 @@ func TestUTMirroring(t *testing.T) {
 		conf.Set("Processor.userTransformationMirroring.fireAndForget", strconv.FormatBool(fireAndForget))
 		// conf.Set("USER_TRANSFORM_MIRROR_URL", "TODO")
 		conf.Set("UTSampling.Bucket", minioContainer.BucketName)
-		conf.Set("UTSampling.Endpoint", minioContainer.Endpoint)
+		conf.Set("UTSampling.Endpoint", fmt.Sprintf("http://%s", minioContainer.Endpoint))
 		conf.Set("UTSampling.AccessKeyId", minioContainer.AccessKeyID)
 		conf.Set("UTSampling.AccessKey", minioContainer.AccessKeySecret)
 		conf.Set("UTSampling.S3ForcePathStyle", "true")

regulation-worker/cmd/main_test.go

@@ -77,7 +77,7 @@ func TestRegulationWorkerFlow(t *testing.T) {
 		"accessKey":        minioResource.AccessKeySecret,
 		"enableSSE":        false,
 		"prefix":           "some-prefix",
-		"endPoint":         minioResource.Endpoint,
+		"endPoint":         fmt.Sprintf("http://%s", minioResource.Endpoint),
 		"s3ForcePathStyle": true,
 		"disableSSL":       true,
 		"region":           minioResource.Region,

warehouse/slave/worker_job_test.go

@@ -170,7 +170,7 @@ func TestSlaveJob(t *testing.T) {
 			"accessKeyID":      minioResource.AccessKeyID,
 			"accessKey":        minioResource.AccessKeyID,
 			"secretAccessKey":  minioResource.AccessKeySecret,
-			"endPoint":         minioResource.Endpoint,
+			"endPoint":         fmt.Sprintf("http://%s", minioResource.Endpoint),
 			"forcePathStyle":   true,
 			"s3ForcePathStyle": true,
 			"disableSSL":       true,