From 5a931fb293ecc5d0a9d92646bcab8d7a0299a324 Mon Sep 17 00:00:00 2001
From: Alex Jones <alexsimonjones@gmail.com>
Date: Tue, 1 Aug 2023 18:56:29 +0100
Subject: [PATCH] chore: operator debug

Signed-off-by: Alex Jones <alexsimonjones@gmail.com>
---
 controllers/k8sgpt_controller.go |  7 ++++---
 pkg/client/client.go             | 13 +++++++++++++
 pkg/resources/results.go         |  4 +++-
 3 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/controllers/k8sgpt_controller.go b/controllers/k8sgpt_controller.go
index 75e55b23..96e562f4 100644
--- a/controllers/k8sgpt_controller.go
+++ b/controllers/k8sgpt_controller.go
@@ -159,6 +159,8 @@ func (r *K8sGPTReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
 			k8sgptReconcileErrorCount.Inc()
 			return r.finishReconcile(err, false)
 		}
+		// Log address
+		fmt.Printf("K8sGPT address: %s\n", address)
 
 		k8sgptClient, err := kclient.NewClient(address)
 		if err != nil {
@@ -216,7 +218,6 @@ func (r *K8sGPTReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctr
 				return r.finishReconcile(err, false)
 
 			}
-
 			// Update metrics
 			if operation == resources.CreatedResult {
 				k8sgptNumberOfResultsByType.With(prometheus.Labels{
@@ -291,13 +292,13 @@ func (r *K8sGPTReconciler) finishReconcile(err error, requeueImmediate bool) (ct
 		if requeueImmediate {
 			interval = 0
 		}
-		fmt.Printf("Finished Reconciling K8sGPT with error: %s\n", err.Error())
+		fmt.Printf("Finished Reconciling k8sGPT with error: %s\n", err.Error())
 		return ctrl.Result{Requeue: true, RequeueAfter: interval}, err
 	}
 	interval := ReconcileSuccessInterval
 	if requeueImmediate {
 		interval = 0
 	}
-	fmt.Println("Finished Reconciling K8sGPT")
+	fmt.Println("Finished Reconciling k8sGPT")
 	return ctrl.Result{Requeue: true, RequeueAfter: interval}, nil
 }
diff --git a/pkg/client/client.go b/pkg/client/client.go
index a9189b5b..6d3cb327 100644
--- a/pkg/client/client.go
+++ b/pkg/client/client.go
@@ -17,7 +17,9 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"net"
 	"os"
+	"time"
 
 	rpc "buf.build/gen/go/k8sgpt-ai/k8sgpt/grpc/go/schema/v1/schemav1grpc"
 	schemav1 "buf.build/gen/go/k8sgpt-ai/k8sgpt/protocolbuffers/go/schema/v1"
@@ -64,6 +66,17 @@ func GenerateAddress(ctx context.Context, cli client.Client, k8sgptConfig *v1alp
 		}
 		address = fmt.Sprintf("%s:%d", svc.Spec.ClusterIP, svc.Spec.Ports[0].Port)
 	}
+
+	fmt.Printf("Creating new client for %s\n", address)
+	// Test if the port is open
+	conn, err := net.DialTimeout("tcp", address, 1*time.Second)
+	if err != nil {
+		return "", err
+	}
+
+	fmt.Printf("Connection established between %s and localhost with time out of %d seconds.\n", address, int64(1))
+	fmt.Printf("Remote Address : %s \n", conn.RemoteAddr().String())
+
 	return address, nil
 }
 
diff --git a/pkg/resources/results.go b/pkg/resources/results.go
index 02c56599..21e8be09 100644
--- a/pkg/resources/results.go
+++ b/pkg/resources/results.go
@@ -2,6 +2,7 @@ package resources
 
 import (
 	"context"
+	"fmt"
 	"reflect"
 	"strings"
 
@@ -62,6 +63,7 @@ func CreateOrUpdateResult(ctx context.Context, c client.Client, res v1alpha1.Res
 		if err := c.Create(ctx, &res); err != nil {
 			return NoOpResult, err
 		}
+		fmt.Printf("Created result %s\n", res.Name)
 		return CreatedResult, nil
 	}
 	if len(existing.Spec.Error) == len(res.Spec.Error) && reflect.DeepEqual(res.Labels, existing.Labels) {
@@ -79,6 +81,6 @@ func CreateOrUpdateResult(ctx context.Context, c client.Client, res v1alpha1.Res
 	if err := c.Status().Update(ctx, &existing); err != nil {
 		return NoOpResult, err
 	}
-
+	fmt.Printf("Updated result %s\n", res.Name)
 	return UpdatedResult, nil
 }