Update audio_routes.py

audio_routes.py

@@ -141,15 +141,111 @@ async def get_tts_status():
         }
     }
 
-# ===================== STT Endpoints (Future) =====================
+# ===================== STT Endpoints =====================
 @router.post("/stt/transcribe")
 async def transcribe_audio(request: STTRequest):
-    """Transcribe audio to text - to be implemented"""
-    # TODO: Implement when STT factory is ready
-    raise HTTPException(
-        status_code=501,
-        detail="STT transcription not yet implemented"
-    )
+    """Transcribe audio to text"""
+    try:
+        from stt_factory import STTFactory
+        from stt_interface import STTConfig
+        import base64
+        
+        # Create STT provider
+        stt_provider = STTFactory.create_provider()
+        
+        if not stt_provider or not stt_provider.supports_realtime():
+            log_warning("📵 STT disabled or doesn't support transcription")
+            raise HTTPException(
+                status_code=503,
+                detail="STT service not available"
+            )
+        
+        # Get config
+        cfg = ConfigProvider.get()
+        stt_config = cfg.global_config.stt_provider.settings
+        
+        # Decode audio data
+        audio_bytes = base64.b64decode(request.audio_data)
+        
+        # Create STT config
+        config = STTConfig(
+            language=request.language or stt_config.get("language", "tr-TR"),
+            sample_rate=16000,
+            encoding=request.format.upper() if request.format else "WEBM_OPUS",
+            enable_punctuation=stt_config.get("enable_punctuation", True),
+            enable_word_timestamps=False,
+            model=stt_config.get("model", "latest_long"),
+            use_enhanced=stt_config.get("use_enhanced", True),
+            single_utterance=True,
+            interim_results=False
+        )
+        
+        # Start streaming session
+        await stt_provider.start_streaming(config)
+        
+        # Process audio
+        transcription = ""
+        confidence = 0.0
+        
+        try:
+            async for result in stt_provider.stream_audio(audio_bytes):
+                if result.is_final:
+                    transcription = result.text
+                    confidence = result.confidence
+                    break
+        finally:
+            # Stop streaming
+            await stt_provider.stop_streaming()
+        
+        log_info(f"✅ STT transcription completed: '{transcription[:50]}...'")
+        
+        return {
+            "text": transcription,
+            "confidence": confidence,
+            "language": request.language,
+            "provider": stt_provider.get_provider_name()
+        }
+        
+    except HTTPException:
+        raise
+    except Exception as e:
+        log_error("❌ STT transcription error", e)
+        raise HTTPException(
+            status_code=500,
+            detail=f"Transcription failed: {str(e)}"
+        )
+
+@router.get("/stt/languages")
+async def get_stt_languages():
+    """Get supported STT languages"""
+    try:
+        from stt_factory import STTFactory
+        
+        stt_provider = STTFactory.create_provider()
+        
+        if not stt_provider:
+            return {
+                "languages": [],
+                "provider": "none",
+                "enabled": False
+            }
+        
+        languages = stt_provider.get_supported_languages()
+        
+        return {
+            "languages": languages,
+            "provider": stt_provider.get_provider_name(),
+            "enabled": True
+        }
+        
+    except Exception as e:
+        log_error("❌ Error getting STT languages", e)
+        return {
+            "languages": [],
+            "provider": "error",
+            "enabled": False,
+            "error": str(e)
+        }
 
 @router.get("/stt/status")
 async def get_stt_status():