From 4da014e9240a01197ac16e9cb1496db0dcefc474 Mon Sep 17 00:00:00 2001
From: okinrev <okin.tcs@gmail.com>
Date: Sun, 7 Dec 2025 14:28:55 +0100
Subject: [PATCH] fix(redis,rabbitmq): clean dev/lab behavior

---
 veza-backend-api/internal/config/config.go | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/veza-backend-api/internal/config/config.go b/veza-backend-api/internal/config/config.go
index 1e79371b2..ee14ef3c5 100644
--- a/veza-backend-api/internal/config/config.go
+++ b/veza-backend-api/internal/config/config.go
@@ -173,7 +173,7 @@ func NewConfig() (*Config, error) {
 	}
 
 	// Initialiser Redis
-	config.RedisClient, err = initRedis(config.RedisURL)
+	config.RedisClient, err = initRedis(config.RedisURL, logger)
 	if err != nil {
 		logger.Error("Failed to initialize Redis", zap.Error(err))
 		return nil, err
@@ -357,12 +357,15 @@ func (c *Config) SetupMiddleware(router *gin.Engine) {
 }
 
 // initRedis initialise la connexion Redis
-func initRedis(redisURL string) (*redis.Client, error) {
+func initRedis(redisURL string, logger *zap.Logger) (*redis.Client, error) {
 	opts, err := redis.ParseURL(redisURL)
 	if err != nil {
 		return nil, err
 	}
 
+	// Configurer un logger filtré pour Redis pour éviter les warnings "maint_notifications"
+	redis.SetLogger(&filteredRedisLogger{logger: logger})
+
 	client := redis.NewClient(opts)
 
 	// Test de connexion
@@ -375,6 +378,19 @@ func initRedis(redisURL string) (*redis.Client, error) {
 	return client, nil
 }
 
+// filteredRedisLogger est un wrapper pour filtrer les logs de Redis
+type filteredRedisLogger struct {
+	logger *zap.Logger
+}
+
+func (l *filteredRedisLogger) Printf(ctx context.Context, format string, v ...interface{}) {
+	msg := fmt.Sprintf(format, v...)
+	if strings.Contains(msg, "maint_notifications") {
+		return // Ignorer ce warning spécifique en mode auto-discovery
+	}
+	l.logger.Debug("Redis internal", zap.String("message", msg))
+}
+
 // initDatabaseWithRetry initialise la connexion à la base de données avec des tentatives de retry
 func initDatabaseWithRetry(databaseURL string, maxRetries int, retryInterval time.Duration, logger *zap.Logger) (*database.Database, error) {
 	dbConfig := &database.Config{