Add Redis connection debugging and SSL support with fallback

core/memory.py

@@ -1,7 +1,12 @@
 import json
 import time
+import logging
 from utils.config import config
 
+# Set up logging
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
 # Try to import redis, but handle if not available
 try:
     import redis
@@ -14,12 +19,16 @@ def get_redis_client():
     """Create and return Redis client with retry logic"""
     if not REDIS_AVAILABLE:
         return None
-        
+    
+    # Debug print to verify secrets are loaded
+    logger.info(f"[DEBUG] Redis config: {config.redis_host}:{config.redis_port} | Username: {config.redis_username or '(none)'} | Has Password: {bool(config.redis_password)}")
+    
     last_exception = None
     
     for attempt in range(config.redis_retries + 1):
         try:
             # Handle empty username/password gracefully
+            # Try with SSL first
             redis_client = redis.Redis(
                 host=config.redis_host,
                 port=config.redis_port,
@@ -27,17 +36,37 @@ def get_redis_client():
                 password=config.redis_password if config.redis_password else None,
                 decode_responses=True,
                 socket_connect_timeout=5,
-                socket_timeout=5
+                socket_timeout=5,
+                ssl=True,  # Enable TLS
+                ssl_cert_reqs=None  # Skip cert verification
             )
             # Test the connection
             redis_client.ping()
+            logger.info("Successfully connected to Redis with SSL")
             return redis_client
         except Exception as e:
-            last_exception = e
-            if attempt < config.redis_retries:
-                time.sleep(config.redis_retry_delay * (2 ** attempt))  # Exponential backoff
-            continue
-            
+            # If SSL fails, try without SSL
+            try:
+                redis_client = redis.Redis(
+                    host=config.redis_host,
+                    port=config.redis_port,
+                    username=config.redis_username if config.redis_username else None,
+                    password=config.redis_password if config.redis_password else None,
+                    decode_responses=True,
+                    socket_connect_timeout=5,
+                    socket_timeout=5
+                )
+                # Test the connection
+                redis_client.ping()
+                logger.info("Successfully connected to Redis without SSL")
+                return redis_client
+            except Exception as e2:
+                last_exception = e2
+                if attempt < config.redis_retries:
+                    time.sleep(config.redis_retry_delay * (2 ** attempt))  # Exponential backoff
+                continue
+    
+    logger.warning(f"Could not connect to Redis after {config.redis_retries + 1} attempts: {last_exception}")
     return None
 
 # Initialize Redis connection with better error handling
@@ -45,36 +74,36 @@ redis_client = None
 try:
     redis_client = get_redis_client()
     if redis_client is None and REDIS_AVAILABLE:
-        print("Warning: Could not connect to Redis - using in-memory storage")
+        logger.warning("Could not connect to Redis - using in-memory storage")
 except Exception as e:
-    print(f"Warning: Redis initialization failed: {e}")
+    logger.error(f"Redis initialization failed: {e}")
 
 def save_user_state(user_id: str, state: dict):
     """Save user state to Redis with fallback to in-memory storage"""
     global redis_client
     if not redis_client:
         # Fallback: use in-memory storage (will not persist across restarts)
-        print("Redis not available, using in-memory storage for user state")
+        logger.info("Redis not available, using in-memory storage for user state")
         return False
-        
+    
     try:
         redis_client.hset(f"user:{user_id}", mapping=state)
         return True
     except Exception as e:
-        print(f"Error saving user state: {e}")
+        logger.error(f"Error saving user state: {e}")
         return False
 
 def load_user_state(user_id: str):
     """Load user state from Redis with fallback"""
     global redis_client
     if not redis_client:
-        print("Redis not available, returning empty state")
+        logger.info("Redis not available, returning empty state")
         return {}
-        
+    
     try:
         return redis_client.hgetall(f"user:{user_id}")
     except Exception as e:
-        print(f"Error loading user state: {e}")
+        logger.error(f"Error loading user state: {e}")
         return {}
 
 def check_redis_health():

test_redis_hf.py

@@ -0,0 +1,25 @@
+import redis
+import os
+
+host = os.getenv("REDIS_HOST")
+port = int(os.getenv("REDIS_PORT", "6379"))
+username = os.getenv("REDIS_USERNAME") or None
+password = os.getenv("REDIS_PASSWORD") or None
+
+print("Connecting to Redis...")
+print(f"Host: {host}, Port: {port}, Username: {username}")
+
+try:
+    r = redis.Redis(
+        host=host,
+        port=port,
+        username=username,
+        password=password,
+        decode_responses=True,
+        socket_connect_timeout=5,
+        socket_timeout=5
+    )
+    result = r.ping()
+    print("✅ Ping successful:", result)
+except Exception as e:
+    print("❌ Redis connection failed:", e)