Update app.py

app.py

@@ -2,14 +2,15 @@ import os
 from fastapi import FastAPI, Request
 from pinecone import Pinecone
 from groq import Groq
-import httpx # For sending messages back to Telegram
+import httpx 
+import re
 
 # 1. Configuration & Clients
 # Use Hugging Face Secrets for these!
 PINECONE_API_KEY = os.environ.get("PINECONE_API_KEY")
 GROQ_API_KEY = os.environ.get("GROQ_API_KEY")
 TELEGRAM_TOKEN = os.environ.get("TELEGRAM_TOKEN")
-TELEGRAM_URL = f"https://api.telegram.org/bot{TELEGRAM_TOKEN}/sendMessage"
+TELEGRAM_URL = f"https://149.154.167.220/bot{TELEGRAM_TOKEN}/sendMessage"
 
 EMBED_MODEL= os.environ.get("EMBED_MODEL")
 GROQ_MODEL = os.environ.get("GROQ_MODEL")
@@ -21,6 +22,11 @@ groq_client = Groq(api_key=GROQ_API_KEY)
 
 app = FastAPI()
 
+def clean_ai_response(text: str):
+    # إزالة كل ما بين وسمي <think> و </think> بما في ذلك الوسوم نفسها
+    cleaned_text = re.sub(r'<think>.*?</think>', '', text, flags=re.DOTALL)
+    return cleaned_text.strip()
+
 # 2. The Core AI Logic
 async def get_ai_response(user_query: str):
     # Vectorize query using Pinecone Inference
@@ -39,8 +45,7 @@ async def get_ai_response(user_query: str):
     
     retrieved_context = "\n".join([res.metadata['original_text'] for res in search_results.matches])
 
-    # Construct the System Prompt
-    # We use facts from the profile: Islamic banking, based in Mukalla [cite: 15, 6]
+    
     prompt = f"""
     {PROMPT}
     
@@ -55,10 +60,11 @@ async def get_ai_response(user_query: str):
         messages=[{"role": "user", "content": prompt}],
         model=GROQ_MODEL,
         temperature=0.1,
-        max_completion_tokens=600,
+        max_completion_tokens=800,
         top_p=0.9,
     )
-    return completion.choices[0].message.content
+    ai_response = completion.choices[0].message.content
+    return clean_ai_response(ai_response)
 
 # 3. The Webhook Endpoint
 @app.post("/webhook")
@@ -72,16 +78,15 @@ async def telegram_webhook(request: Request):
         if user_text:
             # Get the intelligent response
             ai_answer = await get_ai_response(user_text)
-            print("1----------TELEGRAM_TOKEN:", TELEGRAM_TOKEN)
-            print("2---------TELEGRAM_URL:", TELEGRAM_URL)
             # Send back to Telegram
-            async with httpx.AsyncClient(verify=False) as client:
+            async with httpx.AsyncClient() as client:
                 await client.post(
-                    f"https://149.154.167.220/bot{TELEGRAM_TOKEN}/sendMessage",
+                    TELEGRAM_URL,
                     headers={"Host": "api.telegram.org"},
                     json={
                         "chat_id": chat_id,
-                        "text": ai_answer
+                        "text": ai_answer,
+                        "parse_mode": "Markdown"
                     }
                 )