feat: Integrate Topic Extraction service into API lifecycle, enhancing initialization and health check reporting. Update routes and logging for improved visibility of topic extraction functionality.

main.py

@@ -55,10 +55,12 @@ def cleanup_on_exit():
 stance_model_manager = None
 kpa_model_manager = None
 generate_model_manager = None
+topic_service = None
 try:
     from services.stance_model_manager import stance_model_manager
     from services.label_model_manager import kpa_model_manager 
     from services.generate_model_manager import generate_model_manager 
+    from services.topic_service import topic_service
     logger.info("✓ Gestionnaires de modèles importés")
 except ImportError as e:
     logger.warning(f"⚠ Impossible d'importer les gestionnaires de modèles: {e}")
@@ -103,6 +105,18 @@ async def lifespan(app: FastAPI):
         logger.error(f"✗ Failed to load Generation model: {str(e)}")
         logger.error("⚠️  Generation endpoints will not work!")
     
+    # Initialize Topic Extraction service (uses Groq LLM)
+    if topic_service and GROQ_API_KEY:
+        try:
+            logger.info("Initializing Topic Extraction service (Groq LLM)...")
+            topic_service.initialize()
+            logger.info("✓ Topic Extraction service initialized")
+        except Exception as e:
+            logger.error(f"✗ Failed to initialize Topic Extraction service: {str(e)}")
+            logger.error("⚠️  Topic extraction endpoints will not work!")
+    elif not GROQ_API_KEY:
+        logger.warning("⚠ GROQ_API_KEY not configured. Topic extraction service will not be available.")
+    
     logger.info("✓ API startup complete")
     logger.info("https://nlp-debater-project-fastapi-backend-models.hf.space/docs")
     
@@ -149,7 +163,11 @@ async def lifespan(app: FastAPI):
     logger.info(f"  STT Model: {GROQ_STT_MODEL}")
     logger.info(f"  TTS Model: {GROQ_TTS_MODEL}")
     logger.info(f"  Chat Model: {GROQ_CHAT_MODEL}")
+    logger.info(f"  Topic Extraction: {'Initialized' if (topic_service and topic_service.initialized) else 'Not initialized'}")
+    logger.info(f"  Voice Chat: {'Available' if GROQ_API_KEY else 'Disabled (no GROQ_API_KEY)'}")
     logger.info(f"  MCP: {'Activé' if MCP_ENABLED else 'Désactivé'}")
+    if MCP_ENABLED:
+        logger.info(f"    - Tools: detect_stance, match_keypoint_argument, transcribe_audio, generate_speech, generate_argument, extract_topic, voice_chat, health_check")
     logger.info("="*60)
     
     yield
@@ -262,12 +280,21 @@ async def health():
             "stt": GROQ_STT_MODEL if GROQ_API_KEY else "disabled",
             "tts": GROQ_TTS_MODEL if GROQ_API_KEY else "disabled",
             "chat": GROQ_CHAT_MODEL if GROQ_API_KEY else "disabled",
+            "topic_extraction": "initialized" if (topic_service and hasattr(topic_service, 'initialized') and topic_service.initialized) else "not initialized",
+            "voice_chat": "available" if GROQ_API_KEY else "disabled",
             "stance_model": "loaded" if (stance_model_manager and hasattr(stance_model_manager, 'model_loaded') and stance_model_manager.model_loaded) else "not loaded",
             "kpa_model": "loaded" if (kpa_model_manager and hasattr(kpa_model_manager, 'model_loaded') and kpa_model_manager.model_loaded) else "not loaded",
+            "generate_model": "loaded" if (generate_model_manager and hasattr(generate_model_manager, 'model_loaded') and generate_model_manager.model_loaded) else "not loaded",
             "mcp": "enabled" if MCP_ENABLED else "disabled"
         },
         "endpoints": {
-            "mcp": "/api/v1/mcp" if MCP_ENABLED else "disabled"
+            "mcp": "/api/v1/mcp" if MCP_ENABLED else "disabled",
+            "topic_extraction": "/api/v1/topic/extract",
+            "voice_chat": "/voice-chat/voice or /voice-chat/text",
+            "mcp_tools": {
+                "extract_topic": "/api/v1/mcp/tools/extract-topic",
+                "voice_chat": "/api/v1/mcp/tools/voice-chat"
+            } if MCP_ENABLED else "disabled"
         }
     }
     return health_status
@@ -285,13 +312,22 @@ async def not_found_handler(request, exc):
         "GET /health": "Health check",
         "POST /api/v1/stt/": "Speech to text",
         "POST /api/v1/tts/": "Text to speech",
-        "POST /voice-chat/voice": "Voice chat"
+        "POST /voice-chat/voice": "Voice chat (audio input)",
+        "POST /voice-chat/text": "Voice chat (text input)",
+        "POST /api/v1/topic/extract": "Extract topic from text"
     }
     if MCP_ENABLED:
         endpoints.update({
             "GET /api/v1/mcp/health": "Health check MCP",
             "GET /api/v1/mcp/tools": "Liste outils MCP",
-            "POST /api/v1/mcp/tools/call": "Appel d'outil MCP"
+            "POST /api/v1/mcp/tools/call": "Appel d'outil MCP",
+            "POST /api/v1/mcp/tools/extract-topic": "Extract topic (MCP tool)",
+            "POST /api/v1/mcp/tools/voice-chat": "Voice chat (MCP tool)",
+            "POST /api/v1/mcp/tools/detect-stance": "Detect stance (MCP tool)",
+            "POST /api/v1/mcp/tools/match-keypoint": "Match keypoint (MCP tool)",
+            "POST /api/v1/mcp/tools/transcribe-audio": "Transcribe audio (MCP tool)",
+            "POST /api/v1/mcp/tools/generate-speech": "Generate speech (MCP tool)",
+            "POST /api/v1/mcp/tools/generate-argument": "Generate argument (MCP tool)"
         })
     return {
         "error": "Not Found",