Upload app.py

app.py

@@ -36,8 +36,8 @@ from security.error_handler import (
     ValidationError, RateLimitError, AuthenticationError
 )
 
-# Import the learning chat system
-from learning_conversational_chat import LearningConversationalChat
+# Import the real API chat system for Hugging Face deployment
+from conversational_travel_chat_real_apis import RealAPIConversationalTravelChat
 
 # Set up logging
 logging.basicConfig(
@@ -71,15 +71,29 @@ class ProductionChatApp:
         )
         self.error_handler = ErrorHandler()
         
-        # Initialize learning chat system
-        self.learning_chat = LearningConversationalChat()
+        # Initialize real API chat system for Hugging Face
+        self.real_api_chat = RealAPIConversationalTravelChat()
         
         # Application state
         self.active_sessions = {}
         self.request_count = 0
         
+        # Check for required API keys for Hugging Face deployment
+        self._check_api_keys()
+        
         logger.info(f"Production chat app initialized in {self.config.deployment.environment.value} mode")
     
+    def _check_api_keys(self):
+        """Check for required API keys for Hugging Face deployment"""
+        required_vars = ['SERPAPI_API_KEY', 'TAVILY_API_KEY']
+        missing_vars = [var for var in required_vars if not os.getenv(var)]
+        
+        if missing_vars:
+            logger.warning(f"Missing environment variables: {missing_vars}")
+            logger.warning("The app will run with limited functionality.")
+        else:
+            logger.info("All required API keys are configured")
+    
     @handle_errors
     async def start_conversation(self, user_id: str, message: str, session_id: Optional[str] = None) -> Tuple[str, str, str]:
         """Start or continue a conversation with security checks"""
@@ -108,13 +122,9 @@ class ProductionChatApp:
         session_data["data"]["message_count"] = session_data["data"].get("message_count", 0) + 1
         session_data["last_activity"] = datetime.now()
         
-        # Process conversation
+        # Process conversation with real API chat
         try:
-            result = await self.learning_chat.start_conversation(user_id, message)
-            
-            # Use robust error handling utility to safely unpack result
-            from wanderlust_ai.utils.error_handling import handle_message_processing_result
-            response, chat_session_id = handle_message_processing_result(result)
+            response = await self.real_api_chat.process_message(user_id, message)
             
             # Update request count
             self.request_count += 1