scripts and project updated to ssl mode

Author: hasirciogluhq

Dockerfile.test

@@ -0,0 +1,12 @@
+FROM --platform=linux/arm64 alpine:latest
+
+WORKDIR /app
+
+# Copy the locally built binary
+COPY xdatabase-proxy .
+
+# Expose the port
+EXPOSE 1881
+
+# Run the binary
+CMD ["./xdatabase-proxy"]

kubernetes/overlays/test/database-patch.yaml

@@ -0,0 +1,14 @@
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: xdatabase-proxy
+spec:
+  template:
+    spec:
+      containers:
+        - name: xdatabase-proxy
+          image: ghcr.io/hasirciogli/xdatabase-proxy-local-test:latest
+          imagePullPolicy: Never
+          env:
+            - name: NAMESPACE
+              value: test

kubernetes/overlays/test/kustomization.yaml

@@ -7,4 +7,4 @@ resources:
   - ../../base
 
 patches:
-  - path: test-image-patch.yaml
+  - path: database-patch.yaml

kubernetes/overlays/test/test-image-patch.yaml

@@ -56,12 +56,12 @@ func main() {
 	// Setup health check endpoints (!!!CURRENTLY NOT USED!!!)
 	setupHealthChecks()
 
-	proxy, err := postgresql.NewPostgresProxy(1881, "local-test")
+	proxy, err := postgresql.NewPostgresProxy("local-test")
 	if err != nil {
 		log.Fatalf("Failed to create PostgreSQL proxy: %v", err)
 	}
 
-	go proxy.Start(1881)
+	go proxy.Start(1881, "", "")
 
 	// Wait for termination signal
 	sigChan := make(chan os.Signal, 1)

main.go

@@ -275,3 +275,24 @@ func (k *K8sClient) WatchDatabaseServices(ctx context.Context, callback func([]S
 
 	return nil
 }
+
+func (k *K8sClient) GetSecret(namespace string, name string) (*corev1.Secret, error) {
+	return k.clientset.CoreV1().Secrets(namespace).Get(context.Background(), name, metav1.GetOptions{})
+}
+
+func (k *K8sClient) UpsertSecret(namespace string, name string, data map[string][]byte) error {
+	secret := &corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      name,
+			Namespace: namespace,
+		},
+		Data: data,
+	}
+
+	_, err := k.clientset.CoreV1().Secrets(namespace).Create(context.Background(), secret, metav1.CreateOptions{})
+	if err != nil {
+		return fmt.Errorf("failed to create secret: %v", err)
+	}
+
+	return nil
+}