Update backend.py

backend.py

@@ -1,21 +1,16 @@
-# ==========================================
-# FinTalk - Backend (llama-cpp + GPT summary)
-# ==========================================
-
 import os
 import re
 from typing import Dict
 from llama_cpp import Llama
 from openai import OpenAI
 import edge_tts
-import pyttsx3
 import asyncio
 import reportlab
 from huggingface_hub import hf_hub_download
   
 
 # -----------------------------------------------------
-# 1) MODEL YOLU (GGUF) - KENDİ YOLUNU YAZ
+# 1) MODEL YOLU (GGUF)
 # -----------------------------------------------------
 MODEL_REPO = "QuantFactory/Llama-3-8B-Instruct-Finance-RAG-GGUF"
 MODEL_FILE = "Llama-3-8B-Instruct-Finance-RAG.Q4_K_S.gguf"  
@@ -192,81 +187,30 @@ def export_to_pdf(result: dict, filename="FinTalk_Report.pdf"):
     story.append(Paragraph("<i>Generated by FinTalk – AI Economic Roundtable</i>", styles["Normal"]))
     doc.build(story)
 
-try:
-    import edge_tts
-    USE_EDGE = True
-except Exception:
-    from gtts import gTTS
-    USE_EDGE = False
-
-import asyncio
-import time
-
-import asyncio
-import time
 
 def generate_tts_files(result):
-    """
-    FinTalk TTS sistemi:
-    - edge_tts varsa ve çalışıyorsa kullanır
-    - aksi halde pyttsx3'e düşer (offline)
-    """
     try:
-        import edge_tts
-        EDGE_AVAILABLE = True
-        print("🎧 edge-tts algılandı (yüksek kalite)")
-    except Exception:
-        EDGE_AVAILABLE = False
-        print("🎙️ edge-tts yok, offline moda geçiliyor")
+        pipe = pipeline("text-to-speech", model="facebook/fastspeech2-en-ljspeech")
+        print("🎙️ Offline TTS modeli yüklendi (FastSpeech2)")
+    except Exception as e:
+        print("⚠️ TTS modeli yüklenemedi:", e)
+        return
+
+    texts = {
+        "moderator_intro": result["moderator_intro"],
+        "bullish_view": result["bullish_view"],
+        "bearish_view": result["bearish_view"],
+        "moderator_wrap": result["moderator_wrap"]
+    }
 
-    if EDGE_AVAILABLE:
+    for key, text in texts.items():
         try:
-            async def edge_generate():
-                voices = {
-                    "moderator_intro": "en-US-AriaNeural",
-                    "bullish_view": "en-US-GuyNeural",
-                    "bearish_view": "en-GB-LibbyNeural",
-                    "moderator_wrap": "en-US-AriaNeural",
-                }
-                for key, voice in voices.items():
-                    text = result[key]
-                    filename = f"{key}.mp3"
-                    try:
-                        communicate = edge_tts.Communicate(text, voice=voice, rate="+0%")
-                        await communicate.save(filename)
-                        print(f"✅ {filename} oluşturuldu (edge-tts)")
-                    except Exception as e:
-                        print(f"edge-tts hatası ({key}): {e}")
-                        raise  # bir kez hata olursa offline'e geçelim
-                    await asyncio.sleep(1)
-
-            asyncio.run(edge_generate())
-            return  # edge tts çalıştıysa burada bitiriyoruz
-
+            print(f"🔊 {key} ses üretiliyor...")
+            audio_output = pipe(text)
+            audio = audio_output["audio"]
+            filename = f"{key}.wav"
+            sf.write(filename, audio, samplerate=16000)
+            print(f"✅ {filename} oluşturuldu (transformers offline)")
+            time.sleep(1)
         except Exception as e:
-            print(f"⚠️ edge-tts başarısız, offline TTS'e geçiliyor: {e}")
-
-    # fallback: pyttsx3 (offline, garantili)
-    import pyttsx3
-    engine = pyttsx3.init()
-    voices_local = engine.getProperty("voices")
-    for key in ["moderator_intro", "bullish_view", "bearish_view", "moderator_wrap"]:
-        voice_id = voices_local[0].id if voices_local else None
-        engine.setProperty("voice", voice_id)
-        filename = f"{key}.mp3"
-        engine.save_to_file(result[key], filename)
-        engine.runAndWait()
-        print(f"✅ {filename} oluşturuldu (pyttsx3 offline)")
-        time.sleep(1)
-
-
-# -----------------------------------------------------
-# 8) Hızlı Test
-# -----------------------------------------------------
-if __name__ == "__main__":
-    topic = input("What's discussion topic ?\n>")
-    result = fintalk_discussion(topic)
-    result["topic"] = topic
-    export_to_pdf(result)
-    asyncio.run(generate_tts_files(result))
-    
+            print(f"TTS hatası ({key}):", e)