Fix Redis Cloud SSL connection, Streamlit version compatibility, and update requirements

app.py

@@ -16,18 +16,25 @@ st.set_page_config(page_title="AI Life Coach", page_icon="🧠", layout="wide")
 # Initialize session state
 if "messages" not in st.session_state:
     st.session_state.messages = []
+
 if "last_error" not in st.session_state:
     st.session_state.last_error = ""
+
 if "last_ollama_call_success" not in st.session_state:
     st.session_state.last_ollama_call_success = None
+
 if "last_ollama_call_time" not in st.session_state:
     st.session_state.last_ollama_call_time = ""
+
 if "last_ollama_response_preview" not in st.session_state:
     st.session_state.last_ollama_response_preview = ""
+
 if "last_hf_call_success" not in st.session_state:
     st.session_state.last_hf_call_success = None
+
 if "last_hf_call_time" not in st.session_state:
     st.session_state.last_hf_call_time = ""
+
 if "last_hf_response_preview" not in st.session_state:
     st.session_state.last_hf_response_preview = ""
 
@@ -35,67 +42,68 @@ if "last_hf_response_preview" not in st.session_state:
 with st.sidebar:
     st.title("AI Life Coach")
     st.markdown("Your personal AI-powered life development assistant")
-    
+
     # Model selection
     model_options = {
         "Mistral 7B (Local)": "mistral:latest",
         "Llama 2 7B (Local)": "llama2:latest",
         "OpenChat 3.5 (Local)": "openchat:latest"
     }
-    
     selected_model_name = st.selectbox(
         "Select Model",
         options=list(model_options.keys()),
         index=0
     )
-    
     st.session_state.selected_model = model_options[selected_model_name]
-    
+
     # Ollama URL input
     st.session_state.ngrok_url = st.text_input(
         "Ollama Server URL",
         value=st.session_state.get("ngrok_url", "http://localhost:11434"),
         help="Enter the URL to your Ollama server"
     )
-    
+
     # Conversation history
     st.subheader("Conversation History")
     if st.button("Clear History"):
         st.session_state.messages = []
         st.success("History cleared!")
-    
+
     # Debug info
     with st.sidebar.expander("🔧 Debug Info"):
-        st.write(f"**OLLAMA_HOST**: `{st.session_state.ngrok_url}`")
-        st.write(f"**Selected Model**: `{st.session_state.selected_model}`")
-        st.write(f"**Fallback Mode**: {'✅ On' if config.use_fallback else '❌ Off'}")
-        st.write(f"**Redis Status**: {'✅ Healthy' if check_redis_health() else '⚠️ Unavailable'}")
-        st.write(f"**Env Detected As**: {'☁️ HF Space' if config.is_hf_space else '🏠 Local'}")
-        st.write(f"**HF Token Set**: {'✅ Yes' if config.hf_token else '❌ No'}")
+        st.write(f"**OLLAMA_HOST**: {st.session_state.ngrok_url}")
+        st.write(f"**Selected Model**: {st.session_state.selected_model}")
+        st.write(f"Fallback Mode: {'✅ On' if config.use_fallback else '❌ Off'}")
+        st.write(f"Redis Status: {'✅ Healthy' if check_redis_health() else '⚠️ Unavailable'}")
+        st.write(f"Env Detected As: {'☁️ HF Space' if config.is_hf_space else '🏠 Local'}")
+        st.write(f"HF Token Set: {'✅ Yes' if config.hf_token else '❌ No'}")
+        
         if st.session_state.last_error:
             st.warning(f"Last Error: {st.session_state.last_error}")
-        
-        # Ollama API Call Tracking
-        if st.session_state.last_ollama_call_success is not None:
-            status_icon = "✅ Success" if st.session_state.last_ollama_call_success else "❌ Failed"
-            st.write(f"**Last Ollama Call**: {status_icon}")
-            st.write(f"**At**: {st.session_state.last_ollama_call_time}")
-            if st.session_state.last_ollama_response_preview:
-                st.code(st.session_state.last_ollama_response_preview[:200] + ("..." if len(st.session_state.last_ollama_response_preview) > 200 else ""), language="text")
-        
-        # Hugging Face API Call Tracking
-        if st.session_state.last_hf_call_success is not None:
-            status_icon = "✅ Success" if st.session_state.last_hf_call_success else "❌ Failed"
-            st.write(f"**Last HF Call**: {status_icon}")
-            st.write(f"**At**: {st.session_state.last_hf_call_time}")
-            if st.session_state.last_hf_response_preview:
-                st.code(st.session_state.last_hf_response_preview[:200] + ("..." if len(st.session_state.last_hf_response_preview) > 200 else ""), language="text")
-        
-        # Manual Refresh Button
-        if st.button("🔄 Refresh Ollama Status"):
-            from services.ollama_monitor import check_ollama_status
-            status = check_ollama_status()
-            st.toast(f"Ollama Status: {'Running' if status['running'] else 'Unavailable'}", icon="📡")
+
+    # Ollama API Call Tracking
+    if st.session_state.last_ollama_call_success is not None:
+        status_icon = "✅ Success" if st.session_state.last_ollama_call_success else "❌ Failed"
+        st.write(f"Last Ollama Call: {status_icon}")
+        st.write(f"At: {st.session_state.last_ollama_call_time}")
+        if st.session_state.last_ollama_response_preview:
+            st.code(st.session_state.last_ollama_response_preview[:200] + ("..." if len(st.session_state.last_ollama_response_preview) > 200 else ""), language="text")
+
+    # Hugging Face API Call Tracking
+    if st.session_state.last_hf_call_success is not None:
+        status_icon = "✅ Success" if st.session_state.last_hf_call_success else "❌ Failed"
+        st.write(f"Last HF Call: {status_icon}")
+        st.write(f"At: {st.session_state.last_hf_call_time}")
+        if st.session_state.last_hf_response_preview:
+            st.code(st.session_state.last_hf_response_preview[:200] + ("..." if len(st.session_state.last_hf_response_preview) > 200 else ""), language="text")
+
+    # Manual Refresh Button
+    if st.button("🔄 Refresh Ollama Status"):
+        from services.ollama_monitor import check_ollama_status
+        status = check_ollama_status()
+        # Fix for Streamlit version - replace st.toast with compatible function
+        status_text = f"Ollama Status: {'Running' if status['running'] else 'Unavailable'}"
+        st.sidebar.info(status_text)
 
 # Main chat interface
 st.title("🧠 AI Life Coach")
@@ -115,7 +123,6 @@ with col1:
         placeholder="Type your message here...",
         label_visibility="collapsed"
     )
-
 with col2:
     send_button = st.button("Send", key="send_message_button", use_container_width=True)
 
@@ -123,37 +130,34 @@ if send_button and user_input.strip():
     # Display user message
     with st.chat_message("user"):
         st.markdown(user_input)
-    
+
     # Add user message to history
     st.session_state.messages.append({"role": "user", "content": user_input})
-    
+
     # Reset error state
     st.session_state.last_error = ""
-    
+
     # Get conversation history
     user_session = session_manager.get_session("default_user")
     conversation = user_session.get("conversation", [])
     conversation_history = conversation[-5:]  # Last 5 messages
     conversation_history.append({"role": "user", "content": user_input})
-    
+
     # Send to backend
     with st.chat_message("assistant"):
         with st.spinner("AI Coach is thinking..."):
             ai_response = None
             backend_used = ""
             error_msg = ""
-            
+
             # Try Ollama first if not falling back
             if not config.use_fallback:
                 try:
                     ai_response = send_to_ollama(
-                        user_input,
-                        conversation_history,
-                        st.session_state.ngrok_url,
-                        st.session_state.selected_model
+                        user_input, conversation_history,
+                        st.session_state.ngrok_url, st.session_state.selected_model
                     )
                     backend_used = "Ollama"
-                    
                     # Capture success metadata
                     st.session_state.last_ollama_call_success = True
                     st.session_state.last_ollama_call_time = str(datetime.utcnow())
@@ -164,13 +168,12 @@ if send_button and user_input.strip():
                     st.session_state.last_ollama_call_success = False
                     st.session_state.last_ollama_call_time = str(datetime.utcnow())
                     st.session_state.last_ollama_response_preview = str(e)[:200]
-            
-            # Fallback to Hugging Face
+
+            # Fallback to Hugging Face if not ai_response and config.hf_token
             if not ai_response and config.hf_token:
                 try:
                     ai_response = send_to_hf(user_input, conversation_history)
                     backend_used = "Hugging Face"
-                    
                     # Capture success metadata
                     st.session_state.last_hf_call_success = True
                     st.session_state.last_hf_call_time = str(datetime.utcnow())
@@ -181,23 +184,20 @@ if send_button and user_input.strip():
                     st.session_state.last_hf_call_success = False
                     st.session_state.last_hf_call_time = str(datetime.utcnow())
                     st.session_state.last_hf_response_preview = str(e)[:200]
-            
+
             if ai_response:
                 st.markdown(f"{ai_response}")
-                
                 # Update conversation history
                 conversation.append({"role": "user", "content": user_input})
                 conversation.append({"role": "assistant", "content": ai_response})
-                
                 # Update session using the correct method
                 user_session["conversation"] = conversation
                 session_manager.update_session("default_user", user_session)
-                
                 # Add assistant response to history
                 st.session_state.messages.append({"role": "assistant", "content": ai_response})
             else:
                 st.error("Failed to get response from both providers.")
                 st.session_state.last_error = error_msg or "No response from either provider"
-    
+
     # Clear input by forcing rerun
     st.experimental_rerun()

core/redis_client.py

@@ -24,91 +24,44 @@ class RedisClient:
             self._connect()
     
     def _connect(self):
-        """Establish Redis connection with proper error handling"""
+        """Establish Redis connection with proper error handling for Redis Cloud"""
         logger.info(f"Attempting Redis connection with:")
         logger.info(f"  Host: {config.redis_host}")
         logger.info(f"  Port: {config.redis_port}")
         logger.info(f"  Username: {'SET' if config.redis_username else 'NOT SET'}")
         logger.info(f"  Password: {'SET' if config.redis_password else 'NOT SET'}")
-        logger.info(f"  Disable SSL: {config.redis_disable_ssl}")
         
         if not config.redis_host or config.redis_host == "localhost":
             logger.info("Redis not configured, skipping connection")
             return None
 
-        # If SSL is explicitly disabled, try non-SSL only
-        if config.redis_disable_ssl:
-            try:
-                host, port = self._parse_host_port(config.redis_host, config.redis_port)
-                logger.info(f"Connecting to Redis at {host}:{port} (SSL disabled)")
-                
-                self._redis_client = redis.Redis(
-                    host=host,
-                    port=port,
-                    username=config.redis_username or None,
-                    password=config.redis_password or None,
-                    decode_responses=True,
-                    socket_connect_timeout=5,
-                    socket_timeout=5,
-                    retry_on_timeout=True,
-                    health_check_interval=30
-                )
-                
-                self._redis_client.ping()
-                logger.info("Successfully connected to Redis without SSL")
-                return
-            except Exception as e:
-                logger.error(f"Non-SSL connection failed: {e}")
-                self._redis_client = None
-                return
-
-        # Try SSL connection first (default for Redis Cloud)
         try:
             host, port = self._parse_host_port(config.redis_host, config.redis_port)
-            logger.info(f"Connecting to Redis at {host}:{port} with SSL")
+            logger.info(f"Connecting to Redis Cloud at {host}:{port} with SSL")
             
+            # Redis Cloud specific connection settings
             self._redis_client = redis.Redis(
                 host=host,
                 port=port,
-                username=config.redis_username or None,
-                password=config.redis_password or None,
+                username=config.redis_username if config.redis_username else "default",
+                password=config.redis_password,
                 decode_responses=True,
-                socket_connect_timeout=5,
-                socket_timeout=5,
+                socket_connect_timeout=10,
+                socket_timeout=10,
                 ssl=True,
-                ssl_cert_reqs=None,  # Skip cert verification for Redis Cloud
-                retry_on_timeout=True,
-                health_check_interval=30
+                ssl_cert_reqs=None,  # Important for Redis Cloud
+                health_check_interval=30,
+                retry_on_timeout=True
             )
             
+            # Test connection
             self._redis_client.ping()
-            logger.info("Successfully connected to Redis with SSL")
+            logger.info("Successfully connected to Redis Cloud with SSL")
             return
             
         except Exception as e:
-            logger.warning(f"SSL connection failed: {e}, trying without SSL")
-            try:
-                host, port = self._parse_host_port(config.redis_host, config.redis_port)
-                
-                self._redis_client = redis.Redis(
-                    host=host,
-                    port=port,
-                    username=config.redis_username or None,
-                    password=config.redis_password or None,
-                    decode_responses=True,
-                    socket_connect_timeout=5,
-                    socket_timeout=5,
-                    retry_on_timeout=True,
-                    health_check_interval=30
-                )
-                
-                self._redis_client.ping()
-                logger.info("Successfully connected to Redis without SSL")
-                return
-                
-            except Exception as e2:
-                logger.error(f"Could not connect to Redis: {e2}")
-                self._redis_client = None
+            logger.error(f"Redis Cloud SSL connection failed: {e}")
+            self._redis_client = None
     
     def _parse_host_port(self, host_string: str, default_port: int) -> tuple:
         """Parse host and port from host string"""

requirements.txt

@@ -1,4 +1,4 @@
-streamlit==1.24.0
+streamlit>=1.28.0
 fastapi==0.95.0
 uvicorn==0.21.1
 redis==5.0.3