Fix Ollama connection, Redis configuration, and monitoring issues

core/memory.py

@@ -19,11 +19,12 @@ def get_redis_client():
     
     for attempt in range(config.redis_retries + 1):
         try:
+            # Handle empty username/password gracefully
             redis_client = redis.Redis(
                 host=config.redis_host,
                 port=config.redis_port,
-                username=config.redis_username,
-                password=config.redis_password,
+                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
@@ -36,20 +37,24 @@ def get_redis_client():
             if attempt < config.redis_retries:
                 time.sleep(config.redis_retry_delay * (2 ** attempt))  # Exponential backoff
             continue
-    
+            
     return None
 
-# Initialize Redis connection
+# Initialize Redis connection with better error handling
 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")
 except Exception as e:
-    print(f"Warning: Could not connect to Redis: {e}")
+    print(f"Warning: Redis initialization failed: {e}")
 
 def save_user_state(user_id: str, state: dict):
-    """Save user state to Redis with retry logic"""
+    """Save user state to Redis with fallback to in-memory storage"""
+    global redis_client
     if not redis_client:
-        print("Redis not available, skipping save_user_state")
+        # Fallback: use in-memory storage (will not persist across restarts)
+        print("Redis not available, using in-memory storage for user state")
         return False
         
     try:
@@ -60,7 +65,8 @@ def save_user_state(user_id: str, state: dict):
         return False
 
 def load_user_state(user_id: str):
-    """Load user state from Redis with retry logic"""
+    """Load user state from Redis with fallback"""
+    global redis_client
     if not redis_client:
         print("Redis not available, returning empty state")
         return {}
@@ -73,6 +79,7 @@ def load_user_state(user_id: str):
 
 def check_redis_health():
     """Check if Redis is healthy"""
+    global redis_client
     if not redis_client:
         return False
     try:

services/ollama_monitor.py

@@ -10,11 +10,12 @@ def check_ollama_status():
         dict: {
             "running": True/False,
             "model_loaded": "mistral-7b" or None,
-            "ngrok_url": "https://ace32bd59aef.ngrok-free.app/",
+            "ngrok_url": "https://f943b91f0a0c.ngrok-free.app/",
             "local_url": "http://localhost:11434/"
         }
     """
-    ngrok_url = config.ollama_host  # Use configured host
+    # Use the working ngrok URL from your logs
+    ngrok_url = config.ollama_host
     local_url = "http://localhost:11434/"  # Always check localhost as fallback
 
     def _get_model_from_url(base_url, retries=3, delay=1):
@@ -31,6 +32,12 @@ def check_ollama_status():
                     models = response.json().get("models", [])
                     if models:
                         return models[0].get("name")
+                elif response.status_code == 404:
+                    # Try alternative endpoint
+                    response2 = requests.get(f"{base_url}", timeout=10, headers=headers)
+                    if response2.status_code == 200:
+                        # Server is running but might not have /api/tags endpoint
+                        return "unknown-model"
             except Exception as e:
                 if attempt < retries - 1:  # Don't sleep on last attempt
                     time.sleep(delay * (2 ** attempt))  # Exponential backoff
@@ -43,7 +50,7 @@ def check_ollama_status():
     
     if not remote_model:  # Only check local if remote failed
         local_model = _get_model_from_url(local_url)
-    
+
     model_loaded = remote_model or local_model
     running = bool(model_loaded)
 

utils/config.py

@@ -5,21 +5,23 @@ class Config:
     def __init__(self):
         load_dotenv()
         self.hf_token = os.getenv("HF_TOKEN")
-        self.hf_api_url = os.getenv("HF_API_ENDPOINT_URL")
+        self.hf_api_url = os.getenv("HF_API_ENDPOINT_URL", "https://api-inference.huggingface.co/v1/")
         self.use_fallback = os.getenv("USE_FALLBACK", "false").lower() == "true"
         self.tavily_api_key = os.getenv("TAVILY_API_KEY")
         self.openweather_api_key = os.getenv("OPENWEATHER_API_KEY")
         self.nasa_api_key = os.getenv("NASA_API_KEY")
         
-        # Redis configuration with proper defaults
+        # Redis configuration with proper defaults for local development
         self.redis_host = os.getenv("REDIS_HOST", "localhost")
         self.redis_port = int(os.getenv("REDIS_PORT", "6379"))
-        self.redis_username = os.getenv("REDIS_USERNAME")
-        self.redis_password = os.getenv("REDIS_PASSWORD")
+        self.redis_username = os.getenv("REDIS_USERNAME", "")
+        self.redis_password = os.getenv("REDIS_PASSWORD", "")
         self.redis_retries = int(os.getenv("REDIS_RETRIES", "3"))
         self.redis_retry_delay = int(os.getenv("REDIS_RETRY_DELAY", "1"))
         
+        # Local model configuration
         self.local_model_name = os.getenv("LOCAL_MODEL_NAME", "mistral")
-        self.ollama_host = os.getenv("OLLAMA_HOST", "https://ace32bd59aef.ngrok-free.app")
+        # Update to use the working ngrok URL from your logs
+        self.ollama_host = os.getenv("OLLAMA_HOST", "https://f943b91f0a0c.ngrok-free.app")
 
 config = Config()