test

Author: aphralG

internal/watcher/health/health_watcher_service.go

@@ -202,22 +202,6 @@ func (hw *HealthWatcherService) compareHealth(currentHealth map[string]*mpi.Inst
 	defer hw.healthWatcherMutex.Unlock()
 
 	if len(currentHealth) != len(hw.cache) {
-		for _, i := range hw.cache {
-			slog.Info("Health of Instance Current")
-			slog.Info("Instance ID", "", i.GetInstanceId())
-			slog.Info("Instance Status", "", i.GetInstanceHealthStatus())
-			slog.Info("Instance Description", "", i.GetDescription())
-		}
-
-		slog.Info("======================")
-		for _, i := range currentHealth {
-			slog.Info("Health of Instance New")
-			slog.Info("Instance ID", "", i.GetInstanceId())
-			slog.Info("Instance Status", "", i.GetInstanceHealthStatus())
-			slog.Info("Instance Description", "", i.GetDescription())
-		}
-		slog.Info("Len of cache different in health watcher cache")
-
 		return true
 	}
 

internal/watcher/instance/instance_watcher_service.go

@@ -181,7 +181,6 @@ func (iw *InstanceWatcherService) checkForUpdates(
 
 	for _, newInstance := range instancesToParse {
 		instanceType := newInstance.GetInstanceMeta().GetInstanceType()
-		slog.Info("================================================== ")
 		slog.InfoContext(
 			newCtx,
 			"Parsing instance config",

internal/watcher/watcher_plugin.go

@@ -170,16 +170,15 @@ func (w *Watcher) handleConfigApplySuccess(ctx context.Context, msg *bus.Message
 
 	slog.Info("handleConfigApplySuccess start")
 	w.watcherMutex.Lock()
-	// defer w.watcherMutex.Unlock()
 	w.instancesWithConfigApplyInProgress = slices.DeleteFunc(
 		w.instancesWithConfigApplyInProgress,
 		func(element string) bool {
 			return element == instanceID
 		},
 	)
 	w.fileWatcherService.SetEnabled(true)
-
 	w.watcherMutex.Unlock()
+
 	w.instanceWatcherService.ReparseConfig(ctx, instanceID)
 	slog.Info("handleConfigApplySuccess done")
 }
@@ -223,9 +222,7 @@ func (w *Watcher) monitorWatchers(ctx context.Context) {
 		case message := <-w.nginxConfigContextChannel:
 			newCtx := context.WithValue(ctx, logger.CorrelationIDContextKey, message.CorrelationID)
 			w.watcherMutex.Lock()
-			slog.Info("============= Nginx Config Context Channel")
 			if !slices.Contains(w.instancesWithConfigApplyInProgress, message.NginxConfigContext.InstanceID) {
-				slog.Info("============= Nginx Config Context update")
 				slog.DebugContext(
 					newCtx,
 					"Updated NGINX config context",
@@ -244,7 +241,6 @@ func (w *Watcher) monitorWatchers(ctx context.Context) {
 				)
 			}
 			w.watcherMutex.Unlock()
-			slog.Info("============= Nginx Config Unlock")
 		case message := <-w.instanceHealthChannel:
 			newCtx := context.WithValue(ctx, logger.CorrelationIDContextKey, message.CorrelationID)
 			w.messagePipe.Process(newCtx, &bus.Message{