Add mutex for teardown synchronization and validate service port range

kong2kic/kong2kic_test.go

@@ -10,6 +10,7 @@ import (
 	"path/filepath"
 	"regexp"
 	"strings"
+	"sync"
 	"testing"
 	"time"
 
@@ -266,7 +267,14 @@ func setupTestingEnvironmentWithVersion(
 	return env, kongAddon, nil
 }
 
+// Mutex to avoid race condition on ~/.kube/config file
+var teardownMutex sync.Mutex
+
 func teardownEnvironment(ctx context.Context, t *testing.T, env environment.Environment) {
+	// Lock the mutex to ensure only one teardown process at a time
+	teardownMutex.Lock()
+	defer teardownMutex.Unlock()
+
 	t.Logf("cleaning up environment %s and cluster %s", env.Name(), env.Cluster().Name())
 	require.NoError(t, env.Cleanup(ctx))
 }

kong2kic/route.go

@@ -99,6 +99,10 @@ func createIngressPaths(
 			},
 		}
 		if servicePort != nil {
+			// check that the port is within the valid range
+			if *servicePort > 65535 || *servicePort < 0 {
+				log.Fatalf("Port %d is not within the valid range. Please provide a port between 0 and 65535.\n", *servicePort)
+			}
 			backend.Service.Port.Number = int32(*servicePort)
 		}
 		paths = append(paths, k8snetv1.HTTPIngressPath{

kong2kic/service.go

@@ -65,6 +65,10 @@ func createK8sService(service *file.FService, upstreams []file.FUpstream) *k8sco
 
 	// Set the service port
 	if service.Port != nil {
+		// check that the port is within the valid range
+		if *service.Port > 65535 || *service.Port < 0 {
+			log.Fatalf("Port %d is not within the valid range. Please provide a port between 0 and 65535.\n", *service.Port)
+		}
 		servicePort := k8scorev1.ServicePort{
 			Protocol:   protocol,
 			Port:       int32(*service.Port),