Fix session management serialization and update Ollama URL

.env

@@ -1,21 +1,6 @@
-# Hugging Face Settings
-HF_TOKEN=your_huggingface_token_here
-HF_API_ENDPOINT_URL=https://api-inference.huggingface.co/v1/
-USE_FALLBACK=false
-
-# API Keys
-TAVILY_API_KEY=your_tavily_api_key_here
-OPENWEATHER_API_KEY=your_openweather_api_key_here
-NASA_API_KEY=your_nasa_api_key_here
-
-# Redis Configuration
-REDIS_HOST=localhost
-REDIS_PORT=6379
-REDIS_USERNAME=
-REDIS_PASSWORD=
-REDIS_RETRIES=3
-REDIS_RETRY_DELAY=1
-
-# Model Configuration - Use the exact model name from Ollama
+# Ollama Configuration
+OLLAMA_HOST=https://7bcc180dffd1.ngrok-free.app
 LOCAL_MODEL_NAME=mistral:latest
-OLLAMA_HOST=https://ace32bd59aef.ngrok-free.app
+
+# Fallback Settings
+USE_FALLBACK=false

core/session.py

@@ -13,7 +13,6 @@ class SessionManager:
     
     def __init__(self, session_timeout: int = 3600):
         """Initialize session manager
-        
         Args:
             session_timeout: Session timeout in seconds (default: 1 hour)
         """
@@ -21,10 +20,8 @@ class SessionManager:
 
     def get_session(self, user_id: str) -> Dict[str, Any]:
         """Retrieve user session data
-        
         Args:
             user_id: Unique identifier for the user
-            
         Returns:
             Dictionary containing session data
         """
@@ -33,13 +30,24 @@ class SessionManager:
             if not state:
                 logger.info(f"Creating new session for user {user_id}")
                 return self._create_new_session()
-
+            
             # Check if session has expired
             last_activity = float(state.get('last_activity', 0))
             if time.time() - last_activity > self.session_timeout:
                 logger.info(f"Session expired for user {user_id}, creating new session")
                 return self._create_new_session()
-
+            
+            # Deserialize complex data types
+            for key, value in state.items():
+                if isinstance(value, str):
+                    try:
+                        # Try to parse as JSON for lists/dicts
+                        if value.startswith('[') or value.startswith('{'):
+                            state[key] = json.loads(value)
+                    except (json.JSONDecodeError, TypeError):
+                        # Keep as string if not valid JSON
+                        pass
+            
             return state
         except Exception as e:
             logger.error(f"Error retrieving session for user {user_id}: {e}")
@@ -47,11 +55,9 @@ class SessionManager:
 
     def update_session(self, user_id: str, data: Dict[str, Any]) -> bool:
         """Update user session data
-        
         Args:
             user_id: Unique identifier for the user
             data: Data to update in the session
-            
         Returns:
             Boolean indicating success
         """
@@ -63,8 +69,18 @@ class SessionManager:
             session.update(data)
             session['last_activity'] = time.time()
             
+            # Convert complex data types to strings for Redis
+            redis_data = {}
+            for key, value in session.items():
+                if isinstance(value, (list, dict)):
+                    redis_data[key] = json.dumps(value)
+                elif isinstance(value, (int, float, str, bool)):
+                    redis_data[key] = value
+                else:
+                    redis_data[key] = str(value)
+            
             # Save updated session
-            result = save_user_state(user_id, session)
+            result = save_user_state(user_id, redis_data)
             if result:
                 logger.debug(f"Successfully updated session for user {user_id}")
             else:
@@ -77,10 +93,8 @@ class SessionManager:
 
     def clear_session(self, user_id: str) -> bool:
         """Clear user session data
-        
         Args:
             user_id: Unique identifier for the user
-            
         Returns:
             Boolean indicating success
         """
@@ -95,7 +109,6 @@ class SessionManager:
 
     def _create_new_session(self) -> Dict[str, Any]:
         """Create a new session with default values
-        
         Returns:
             Dictionary containing new session data
         """

quick_system_test.py

@@ -0,0 +1,88 @@
+import sys
+from pathlib import Path
+
+# Add project root to path
+project_root = Path(__file__).parent
+sys.path.append(str(project_root))
+
+from core.redis_client import redis_client
+import requests
+import json
+
+def quick_test():
+    """Quick test of core components"""
+    print("=== Quick System Test ===")
+    print()
+    
+    # Test 1: Redis
+    print("1. Testing Redis...")
+    try:
+        client = redis_client.get_client()
+        if client and client.ping():
+            print("✅ Redis connection successful")
+            
+            # Test data storage
+            test_data = {
+                "name": "test_user",
+                "messages": json.dumps([]),  # Convert list to string
+                "created_at": "2025-09-08"
+            }
+            
+            result = client.hset("test:user:123", mapping=test_data)
+            retrieved = client.hgetall("test:user:123")
+            client.delete("test:user:123")
+            
+            if retrieved:
+                print("✅ Redis data storage working")
+            else:
+                print("❌ Redis data storage failed")
+        else:
+            print("❌ Redis connection failed")
+    except Exception as e:
+        print(f"❌ Redis test failed: {e}")
+    
+    print()
+    
+    # Test 2: Ollama
+    print("2. Testing Ollama...")
+    try:
+        ollama_url = "https://7bcc180dffd1.ngrok-free.app"
+        headers = {
+            "ngrok-skip-browser-warning": "true",
+            "User-Agent": "AI-Life-Coach-Test"
+        }
+        
+        # Test model listing
+        response = requests.get(f"{ollama_url}/api/tags", headers=headers, timeout=10)
+        if response.status_code == 200:
+            print("✅ Ollama model listing successful")
+            
+            # Test chat
+            payload = {
+                "model": "mistral:latest",
+                "messages": [{"role": "user", "content": "Hello!"}],
+                "stream": False
+            }
+            
+            chat_response = requests.post(
+                f"{ollama_url}/api/chat",
+                headers=headers,
+                json=payload,
+                timeout=30
+            )
+            
+            if chat_response.status_code == 200:
+                print("✅ Ollama chat successful")
+            else:
+                print(f"❌ Ollama chat failed: {chat_response.status_code}")
+        else:
+            print(f"❌ Ollama connection failed: {response.status_code}")
+            
+    except Exception as e:
+        print(f"❌ Ollama test failed: {e}")
+    
+    print()
+    print("🎉 Quick test completed!")
+
+if __name__ == "__main__":
+    quick_test()

test_full_system.py

@@ -0,0 +1,105 @@
+import sys
+from pathlib import Path
+
+# Add project root to path
+project_root = Path(__file__).parent
+sys.path.append(str(project_root))
+
+from core.redis_client import redis_client
+from core.session import session_manager
+from core.llm import send_to_ollama
+import os
+
+def test_full_system():
+    """Test the complete AI Life Coach system"""
+    print("=== AI Life Coach Full System Test ===")
+    print()
+    
+    # Test 1: Redis Connection
+    print("Test 1: Redis Connection")
+    try:
+        client = redis_client.get_client()
+        if client:
+            result = client.ping()
+            print(f"✅ Redis ping successful: {result}")
+            
+            # Test set/get
+            client.set('system_test_key', 'system_test_value')
+            value = client.get('system_test_key')
+            client.delete('system_test_key')
+            
+            if value == 'system_test_value':
+                print("✅ Redis set/get operations working")
+            else:
+                print("❌ Redis set/get operations failed")
+        else:
+            print("❌ Redis client is None")
+            return False
+    except Exception as e:
+        print(f"❌ Redis test failed: {e}")
+        return False
+    
+    print()
+    
+    # Test 2: Session Management
+    print("Test 2: Session Management")
+    try:
+        session = session_manager.get_session("test_user")
+        print("✅ Session creation successful")
+        
+        # Test session update
+        result = session_manager.update_session("test_user", {"test": "data"})
+        if result:
+            print("✅ Session update successful")
+        else:
+            print("❌ Session update failed")
+        
+        # Clean up
+        session_manager.clear_session("test_user")
+        print("✅ Session cleanup successful")
+            
+    except Exception as e:
+        print(f"❌ Session management test failed: {e}")
+        return False
+    
+    print()
+    
+    # Test 3: Ollama Integration
+    print("Test 3: Ollama Integration")
+    try:
+        conversation_history = [
+            {"role": "user", "content": "Hello! Please introduce yourself briefly."}
+        ]
+        
+        ollama_url = "https://7bcc180dffd1.ngrok-free.app"
+        model_name = "mistral:latest"
+        
+        response = send_to_ollama(
+            "Hello! Please introduce yourself briefly.",
+            conversation_history,
+            ollama_url,
+            model_name
+        )
+        
+        if response:
+            print("✅ Ollama integration successful")
+            print(f"Response: {response[:100]}{'...' if len(response) > 100 else ''}")
+        else:
+            print("❌ Ollama integration failed - no response")
+            
+    except Exception as e:
+        print(f"❌ Ollama integration test failed: {e}")
+        return False
+    
+    print()
+    print("🎉 All system tests passed!")
+    print("Your AI Life Coach is ready to use!")
+    return True
+
+if __name__ == "__main__":
+    success = test_full_system()
+    if success:
+        print("\n✅ System is fully operational!")
+    else:
+        print("\n❌ System has issues that need attention!")
+        sys.exit(1)