many issue

app.py

@@ -38,6 +38,7 @@ from starlette.websockets import WebSocketState
 from core.backend import AIBackend
 from services.stt import STTProcessor
 from services.streaming import ParallelTTSStreamer
+from db_view.dbapi import app as db_api_app
 
 # ── WebRTC (optional) ─────────────────────────────────────────────────────────
 try:
@@ -101,6 +102,11 @@ try:
 except Exception:
     pass
 
+try:
+    app.mount("/dbapi", db_api_app)
+except Exception:
+    pass
+
 
 @app.get("/")
 async def root():
@@ -110,6 +116,14 @@ async def root():
     return HTMLResponse("<h2>frontend/index.html not found</h2>", status_code=404)
 
 
+@app.get("/db-view")
+async def db_view():
+    db_index_path = BASE_DIR / "db_view" / "db.html"
+    if db_index_path.exists():
+        return FileResponse(str(db_index_path))
+    return HTMLResponse("<h2>db_view/db.html not found</h2>", status_code=404)
+
+
 @app.get("/health")
 async def health():
     from services.stt import _model_ready, _model_error
@@ -311,6 +325,8 @@ async def ws_voice(ws: WebSocket):
     stt = STTProcessor()
     _active_streamer: ParallelTTSStreamer | None = None
     _active_task:     asyncio.Task | None        = None
+    _utterance_q: asyncio.Queue[bytes | None] = asyncio.Queue()
+    _worker_task: asyncio.Task | None = None
 
     async def _cancel_active():
         nonlocal _active_streamer, _active_task
@@ -325,6 +341,13 @@ async def ws_voice(ws: WebSocket):
                 pass
             _active_task = None
 
+    async def _drain_utterance_queue():
+        while True:
+            try:
+                _utterance_q.get_nowait()
+            except asyncio.QueueEmpty:
+                break
+
     async def _handle_utterance(audio_bytes: bytes):
         nonlocal _active_streamer
 
@@ -368,7 +391,22 @@ async def ws_voice(ws: WebSocket):
         _active_streamer = None
         await _safe_text(ws, {"type": "end"})
 
+    async def _utterance_worker():
+        while True:
+            audio_bytes = await _utterance_q.get()
+            if audio_bytes is None:
+                break
+            try:
+                await _handle_utterance(audio_bytes)
+            except asyncio.CancelledError:
+                raise
+            except Exception as exc:
+                print(f"[VOICE] Utterance worker error: {exc}")
+                await _safe_text(ws, {"type": "error", "text": str(exc)})
+                await _safe_text(ws, {"type": "end"})
+
     try:
+        _worker_task = asyncio.create_task(_utterance_worker())
         while True:
             if not _ws_open(ws):
                 break
@@ -386,8 +424,7 @@ async def ws_voice(ws: WebSocket):
             if "bytes" in data and data["bytes"]:
                 audio_bytes = data["bytes"]
                 print(f"[VOICE] [{user_id}] Utterance: {len(audio_bytes):,} bytes")
-                await _cancel_active()
-                _active_task = asyncio.create_task(_handle_utterance(audio_bytes))
+                await _utterance_q.put(audio_bytes)
 
             elif "text" in data and data["text"]:
                 try:
@@ -404,6 +441,7 @@ async def ws_voice(ws: WebSocket):
                         await _safe_text(ws, {"type": "pong"})
                     elif t == "cancel":
                         await _cancel_active()
+                        await _drain_utterance_queue()
                         await _safe_text(ws, {"type": "end"})
                 except json.JSONDecodeError:
                     pass
@@ -414,5 +452,12 @@ async def ws_voice(ws: WebSocket):
         if "disconnect" not in str(exc).lower():
             print(f"[VOICE] Error: {exc}")
     finally:
+        await _utterance_q.put(None)
+        if _worker_task is not None and not _worker_task.done():
+            _worker_task.cancel()
+            try:
+                await _worker_task
+            except (asyncio.CancelledError, Exception):
+                pass
         await _cancel_active()
         print(f"[VOICE] [{user_id}] Handler exiting cleanly.")

core/backend.py

@@ -47,7 +47,7 @@ def get_db_path() -> str:
 
 
 def format_bd_number(num: str) -> str:
-    num = num.strip().replace(" ", "")
+    num = _normalize_digits(num).replace(" ", "")
     if num.startswith("01") and len(num) == 11:
         return "+88" + num
     if num.startswith("8801"):
@@ -59,6 +59,34 @@ def _clean_text(text: str) -> str:
     return re.sub(r"\s+", " ", (text or "").strip())
 
 
+_DIGIT_TRANSLATION = str.maketrans({
+    "০": "0",
+    "১": "1",
+    "২": "2",
+    "৩": "3",
+    "৪": "4",
+    "৫": "5",
+    "৬": "6",
+    "৭": "7",
+    "৮": "8",
+    "৯": "9",
+    "٠": "0",
+    "١": "1",
+    "٢": "2",
+    "٣": "3",
+    "٤": "4",
+    "٥": "5",
+    "٦": "6",
+    "٧": "7",
+    "٨": "8",
+    "٩": "9",
+})
+
+
+def _normalize_digits(text: str) -> str:
+    return _clean_text(text).translate(_DIGIT_TRANSLATION)
+
+
 DAY_ALIASES = {
     "sunday": "Sunday",
     "monday": "Monday",
@@ -76,6 +104,16 @@ DAY_ALIASES = {
     "শনিবার": "Saturday",
 }
 
+BOOKING_CONFIRM_WORDS = (
+    "জি", "ঠিক আছে", "ঠিক", "হ্যাঁ", "yes", "okay", "ok", "তথ্য ঠিক", "সব ঠিক",
+)
+
+TOOL_INTENT_WORDS = (
+    "book", "booking", "appointment", "অ্যাপয়েন্ট", "অ্যাপয়েন্টমেন্ট", "বুক",
+    "slot", "স্লট", "available", "availability", "ডাক্তার", "doctor", "দেখাতে",
+    "কেনসেল", "cancel", "বাতিল", "delete", "খালি", "কোন ডাক্তার",
+)
+
 SPECIALTY_ALIASES = {
     "চক্ষু": ["ophthalmologist", "eye specialist", "eye doctor", "ophthalmology", "eye"],
     "আই": ["ophthalmologist", "eye specialist", "eye doctor", "ophthalmology", "eye"],
@@ -192,6 +230,58 @@ def _parse_visit_date(text: str) -> Optional[str]:
     return None
 
 
+def _message_text(content) -> str:
+    if isinstance(content, str):
+        return content
+    if isinstance(content, list):
+        parts: list[str] = []
+        for item in content:
+            if isinstance(item, dict):
+                if item.get("type") == "text":
+                    parts.append(str(item.get("text", "")))
+                elif "text" in item:
+                    parts.append(str(item.get("text", "")))
+            else:
+                parts.append(str(item))
+        return _clean_text(" ".join(parts))
+    return _clean_text(str(content))
+
+
+def _last_human_text(messages) -> str:
+    for message in reversed(messages):
+        if isinstance(message, HumanMessage):
+            return _message_text(message.content)
+    return ""
+
+
+def _previous_ai_text(messages) -> str:
+    seen_human = False
+    for message in reversed(messages):
+        if isinstance(message, HumanMessage) and not seen_human:
+            seen_human = True
+            continue
+        if seen_human and isinstance(message, AIMessage):
+            return _message_text(message.content)
+    return ""
+
+
+def _has_tool_calls(message: AIMessage) -> bool:
+    tool_calls = getattr(message, "tool_calls", None)
+    if tool_calls:
+        return True
+    additional_kwargs = getattr(message, "additional_kwargs", {}) or {}
+    return bool(additional_kwargs.get("tool_calls"))
+
+
+def _looks_like_tool_turn(text: str) -> bool:
+    lowered = _clean_text(text).lower()
+    if not lowered:
+        return False
+    return any(token.lower() in lowered for token in TOOL_INTENT_WORDS) or any(
+        token.lower() in lowered for token in BOOKING_CONFIRM_WORDS
+    )
+
+
 def send_sms(to_number: str, message: str) -> None:
     client = Client(os.getenv("TWILIO_ACCOUNT_SID"), os.getenv("TWILIO_AUTH_TOKEN"))
     client.messages.create(
@@ -490,7 +580,7 @@ async def book_appointment(
         patient_age:   Age of the patient (e.g. "32").
         patient_num:   Contact phone number of the patient.
         visiting_date: Date of visit in YYYY-MM-DD format or natural text.
-        patient_mail:  Mail address for confirmation mail.
+        patient_mail:  Optional mail address for confirmation mail.
     """
     db_path     = get_db_path()
     patient_num = format_bd_number(patient_num)
@@ -499,14 +589,15 @@ async def book_appointment(
     doctor_name = _clean_text(doctor_name)
     category    = _clean_text(category)
     visiting_date = _clean_text(visiting_date)
+    patient_mail = _clean_text(patient_mail)
     parsed_date = _parse_visit_date(visiting_date)
     if parsed_date:
         visiting_date = parsed_date
 
-    if not patient_name or not patient_age or not patient_num or not visiting_date or not patient_mail:
+    if not patient_name or not patient_age or not patient_num or not visiting_date:
         return (
             "Missing booking details. Need patient name, age, phone number, "
-            "visit date, and email."
+            "and visit date."
         )
 
     async with aiosqlite.connect(db_path) as db:
@@ -561,7 +652,7 @@ async def book_appointment(
         )
         await db.commit()
 
-    # Mail SMS confirmation
+    # Mail confirmation is optional. Book first, then try to send email if available.
     mail_message = (
         f"Doctor     : {doctor_name}\n"
         f"Patient    : {patient_name}\n"
@@ -569,15 +660,19 @@ async def book_appointment(
         f"Visit Time : {visiting_time}\n"
         f"Please arrive on time."
     )
-    try:
-        await send_mail(
-            to_mail=patient_mail,
-            subject="✅ Appointment Confirmed!",
-            body=mail_message,
-        )
-        mail_status = "\n📧 Mail confirmation sent."
-    except Exception as e:
-        mail_status = f"\n⚠️ Mail failed: {str(e)}"
+    mail_status = ""
+    if patient_mail:
+        try:
+            await send_mail(
+                to_mail=patient_mail,
+                subject="✅ Appointment Confirmed!",
+                body=mail_message,
+            )
+            mail_status = "\n📧 Mail confirmation sent."
+        except Exception as e:
+            mail_status = f"\n⚠️ Mail failed: {str(e)}"
+    else:
+        mail_status = "\n📧 No email provided, so email confirmation was skipped."
 
     return (
         f"✅ Appointment Booked!\n"
@@ -609,20 +704,47 @@ async def delete_appointment(patient_num: str, doctor_name: str = "", doctor_id:
             if row:
                 doctor_name = row["doctor_name"]
 
-        cursor = await db.execute(
-            """SELECT * FROM patients
-               WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
-            (patient_num, doctor_name),
-        )
-        if not await cursor.fetchone():
-            return json.dumps({"success": False, "message": "No matching appointment found."})
+        if doctor_name:
+            cursor = await db.execute(
+                """SELECT * FROM patients
+                   WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
+                (patient_num, doctor_name),
+            )
+            row = await cursor.fetchone()
+            if not row:
+                return json.dumps({"success": False, "message": "No matching appointment found."})
 
-        await db.execute(
-            """DELETE FROM patients
-               WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
-            (patient_num, doctor_name),
-        )
-        await db.commit()
+            await db.execute(
+                """DELETE FROM patients
+                   WHERE patient_num = ? AND LOWER(doctor_name) = LOWER(?)""",
+                (patient_num, doctor_name),
+            )
+            await db.commit()
+        else:
+            cursor = await db.execute(
+                """SELECT * FROM patients
+                   WHERE patient_num = ?
+                   ORDER BY visiting_date ASC, id ASC""",
+                (patient_num,),
+            )
+            rows = await cursor.fetchall()
+            if not rows:
+                return json.dumps({"success": False, "message": "No matching appointment found."})
+            if len(rows) > 1:
+                return json.dumps({
+                    "success": False,
+                    "message": "Multiple appointments found. Please specify the doctor name to cancel.",
+                    "count": len(rows),
+                    "data": [dict(row) for row in rows],
+                }, ensure_ascii=False)
+
+            await db.execute(
+                """DELETE FROM patients
+                   WHERE id = ?""",
+                (rows[0]["id"],),
+            )
+            await db.commit()
+            doctor_name = rows[0]["doctor_name"] or doctor_name
 
     return json.dumps({
         "success": True,
@@ -660,6 +782,9 @@ TOOL RULES:
 - Use `book_appointment` only after identifying the doctor and required patient details.
 - Never invent `doctor_id`. Get it from tool results or resolve by doctor_name/category.
 - If the user gives a Bangla date like "আগামীকাল" or "পরশু", convert it to a real date before booking.
+- Do not block booking on email. If email is missing, book the appointment and skip email confirmation.
+- If the user already provided name, age, phone, and date and then confirms, call `book_appointment` immediately.
+- If the user asks to cancel and only gives a phone number, cancel the single matching appointment if there is exactly one.
 
 LANGUAGE RULE:
 - Respond in the user’s language.
@@ -684,6 +809,27 @@ SUMMARY_SYSTEM = (
     "Use this memory for continuity. Do not repeat it unless asked."
 )
 
+FORCED_TOOL_SYSTEM = """
+The previous assistant turn failed to use a tool even though the user intent is clear.
+
+You must now choose the correct tool instead of answering in prose:
+- Use `find_doctors` or `search_doctor` for doctor/specialty/availability questions.
+- Use `get_doctors_by_day` or `get_categories_by_day` for day-based availability.
+- Use `book_appointment` when the user is confirming a booking.
+- Use `delete_appointment` when the user is cancelling a booking.
+
+Important booking rules:
+- Email is optional. If the user did not provide email, book without it.
+- If the user already gave name, age, phone, and visit date, do not ask for those again.
+- If the user has already confirmed the details, book immediately.
+
+Important cancellation rules:
+- If the user gave only a phone number and there is exactly one matching appointment, cancel it directly.
+- If multiple appointments match, ask only for the doctor name.
+
+Do not give a normal conversational answer before the tool call.
+"""
+
 
 # ═══════════════════════════════════════════════════════════════════════════════
 #  AGENT
@@ -788,6 +934,36 @@ class AIBackend:
             "messages": [RemoveMessage(id=m.id) for m in messages[:-2]],
         }
 
+    def _should_retry_tool_call(self, state: ChatState, response: AIMessage) -> bool:
+        if _has_tool_calls(response):
+            return False
+
+        messages = state["messages"]
+        latest_user = _last_human_text(messages)
+        previous_ai = _previous_ai_text(messages)
+
+        if not _looks_like_tool_turn(latest_user):
+            return False
+
+        previous_ai_lower = previous_ai.lower()
+        booking_clues = (
+            "name", "patient", "age", "phone", "email", "নাম", "বয়স", "ফোন", "ইমেইল",
+        )
+        cancellation_clues = (
+            "cancel", "বাতিল", "delete", "cancel করার", "কেনসেল", "appointment", "অ্যাপয়েন্ট",
+        )
+
+        if any(clue in latest_user.lower() for clue in booking_clues):
+            return True
+        if any(clue in previous_ai_lower for clue in booking_clues):
+            return True
+        if any(clue in latest_user.lower() for clue in cancellation_clues):
+            return True
+        if any(clue in previous_ai_lower for clue in cancellation_clues):
+            return True
+
+        return True
+
     # ── Chat node ──────────────────────────────────────────────────────────────
     async def chat_node(self, state: ChatState):
         """
@@ -813,6 +989,15 @@ class AIBackend:
 
         response = await self.llm_with_tools.ainvoke(full_messages)
 
+        if self._should_retry_tool_call(state, response):
+            retry_messages = full_messages + [
+                AIMessage(content=_message_text(response.content)),
+                SystemMessage(content=FORCED_TOOL_SYSTEM),
+            ]
+            retry_response = await self.llm_with_tools.ainvoke(retry_messages)
+            if _has_tool_calls(retry_response):
+                response = retry_response
+
         print(f"[AI]: {str(response.content)[:200]}")
         print(">>>>>>>>>> CHAT NODE END <<<<<<<<<<")
         return {"messages": [response]}

db_view/db.html

@@ -121,7 +121,7 @@
   </div>
 
   <script>
-    const API_BASE = "http://127.0.0.1:8000";
+    const API_BASE = new URL('/dbapi', window.location.origin).toString().replace(/\/$/, '');
 
     function showTab(tabIndex) {
       const doctorsTab = document.getElementById('doctors-tab');

db_view/dbapi.py

@@ -10,6 +10,7 @@ from pydantic import BaseModel
 import aiosqlite
 import uvicorn
 import os
+from pathlib import Path
 from typing import List
 
 app = FastAPI(title="Doctor-Patient API")
@@ -25,7 +26,7 @@ app.add_middleware(
 # ===========================================================
 
 # Database connection
-DB_PATH = os.path.join(os.getcwd(), "core/daa.db")
+DB_PATH = str(Path(__file__).resolve().parent.parent / "core" / "daa.db")
 
 # Pydantic Models for Response
 class Doctor(BaseModel):

frontend/script.js

@@ -101,6 +101,7 @@ let brainRestartTimer = null;
 let brainAutoRestartTimer = null;
 let brainPendingAudio = null;
 let voicePendingPackets = [];
+let brainLastResponse = '';
 
 // ─── Recording state ──────────────────────────────────────────────────────────
 let micStream = null;
@@ -319,6 +320,7 @@ function onVoiceMsg(ev) {
       aiTxt = '';
       _setCaption('');
       _brainSetSttBubble(msg.text);
+      if (brainMode) _brainSetTtsBubble(brainLastResponse || '', false);
       _brainModeSetSearch(true);
       appendThinking();
       setState('processing');
@@ -332,7 +334,8 @@ function onVoiceMsg(ev) {
       }
       _removeThinking();
       _setCaption(aiTxt + msg.token);
-      _brainSetTtsBubble(aiTxt + msg.token);
+      brainLastResponse = aiTxt + msg.token;
+      _brainSetTtsBubble(brainLastResponse);
       _brainModeSetSearch(true);
       if (!brainMode) {
         if (!aiEl) {
@@ -350,6 +353,7 @@ function onVoiceMsg(ev) {
     case 'end':
       _renderAiText(true);
       _removeThinking();
+      if (brainMode) brainLastResponse = aiTxt || brainLastResponse;
       aiEl = null;
       aiTxt = '';
       _setCaption('');
@@ -509,7 +513,7 @@ function _done() {
   isProcessing = false;
   isRecordingLocked = false;
   _brainModeSetSearch(false);
-  _brainSetTtsBubble('', false);
+  _brainSetTtsBubble(brainLastResponse || '', false);
   _inFlight = 0;
   _vizQ();
   micBtn.disabled = false;
@@ -1012,7 +1016,7 @@ function setBrainMode(on) {
   if (voiceCaption) voiceCaption.textContent = '';
   if (brainMode) {
     brainBubbleSttText.textContent = 'Listening…';
-    brainBubbleTtsText.textContent = 'Waiting…';
+    brainBubbleTtsText.textContent = brainLastResponse || 'Waiting…';
     brainVoiceActive = true;
     sidebarEl.classList.add('collapsed');
     sidebarToggle.textContent = '›';
@@ -1035,7 +1039,7 @@ function setBrainMode(on) {
     sidebarToggle.textContent = '‹';
     _brainModeSetSearch(false);
     _brainSetSttBubble('');
-    _brainSetTtsBubble('');
+    _brainSetTtsBubble('', false);
   }
 }
 
@@ -1055,8 +1059,8 @@ function _brainSetTtsBubble(text, active = true) {
   if (!brainBubbleTts || !brainBubbleTtsText) return;
   const value = (text || '').trim();
   brainBubbleTtsText.textContent = value || 'Waiting…';
-  brainBubbleTts.classList.toggle('active', active || !!value);
-  brainBubbleTts.classList.toggle('speaking', active || !!value);
+  brainBubbleTts.classList.toggle('active', !!value || !!active);
+  brainBubbleTts.classList.toggle('speaking', !!active);
 }
 
 function _brainResumeListening() {

frontend/style.css

@@ -653,8 +653,8 @@ button {
 /* ── Brain mode ───────────────────────────────────────────────────────────── */
 .brain-stage {
   display: none;
-  width: min(var(--max-chat), calc(100% - 32px));
-  margin: 16px auto 0;
+  width: min(560px, calc(100% - 24px));
+  margin: 14px auto 0;
   flex: 1;
   align-items: center;
   justify-content: center;
@@ -663,13 +663,13 @@ button {
 
 .brain-shell {
   position: relative;
-  width: min(760px, 100%);
-  height: min(62vh, 620px);
-  border-radius: 32px;
+  width: min(560px, 100%);
+  height: min(74vh, 760px);
+  border-radius: 40px;
   background:
-    radial-gradient(circle at 50% 45%, rgba(100, 181, 255, 0.18), transparent 18%),
-    radial-gradient(circle at 50% 55%, rgba(139, 92, 246, 0.12), transparent 38%),
-    radial-gradient(circle at 50% 50%, rgba(15, 23, 42, 0.92), rgba(5, 7, 13, 0.98) 72%);
+    radial-gradient(circle at 50% 40%, rgba(100, 181, 255, 0.18), transparent 20%),
+    radial-gradient(circle at 50% 62%, rgba(139, 92, 246, 0.14), transparent 38%),
+    radial-gradient(circle at 50% 50%, rgba(15, 23, 42, 0.96), rgba(5, 7, 13, 1) 74%);
   border: 1px solid rgba(255, 255, 255, 0.08);
   box-shadow: var(--shadow);
   overflow: hidden;
@@ -680,21 +680,23 @@ button {
   inset: 0;
   z-index: 3;
   pointer-events: none;
+  padding: 18px;
 }
 
 .brain-bubble {
   position: absolute;
-  width: min(280px, 42vw);
-  max-width: 320px;
-  min-height: 96px;
-  padding: 14px 16px;
-  border-radius: 22px;
+  width: min(320px, calc(100% - 36px));
+  min-height: 102px;
+  padding: 16px 18px;
+  border-radius: 24px;
   border: 1px solid rgba(255, 255, 255, 0.08);
-  background: rgba(8, 12, 20, 0.82);
+  background:
+    linear-gradient(180deg, rgba(255, 255, 255, 0.06), rgba(255, 255, 255, 0.03)),
+    rgba(8, 12, 20, 0.82);
   backdrop-filter: blur(18px);
   box-shadow: 0 18px 50px rgba(0, 0, 0, 0.35);
   transform: translateY(8px) scale(0.96);
-  opacity: 0.72;
+  opacity: 0.78;
   transition: transform 0.25s ease, opacity 0.25s ease, border-color 0.25s ease, box-shadow 0.25s ease;
 }
 
@@ -719,8 +721,8 @@ button {
 }
 
 .brain-bubble-text {
-  font-size: 15px;
-  line-height: 1.55;
+  font-size: 16px;
+  line-height: 1.6;
   color: var(--text);
   min-height: 40px;
   white-space: pre-wrap;
@@ -728,13 +730,13 @@ button {
 }
 
 .brain-bubble-stt {
-  left: 24px;
-  top: 24px;
+  left: 18px;
+  top: 18px;
 }
 
 .brain-bubble-tts {
-  right: 24px;
-  bottom: 24px;
+  right: 18px;
+  bottom: 18px;
 }
 
 .brain-bubble.active {
@@ -1064,6 +1066,10 @@ body.brain-mode .brain-shell {
     inset 0 0 0 1px rgba(255, 255, 255, 0.03);
 }
 
+body.brain-mode .brain-bubble.active {
+  transform: translateY(0) scale(1);
+}
+
 body.brain-mode .brain-pulse {
   border-color: rgba(100, 181, 255, 0.35);
 }
@@ -1128,7 +1134,7 @@ body.brain-mode .brain-stage[data-state='speaking'] .brain-node {
   }
 
   .brain-shell {
-    height: min(56vh, 520px);
+    height: min(68vh, 620px);
   }
 }
 
@@ -1176,7 +1182,12 @@ body.brain-mode .brain-stage[data-state='speaking'] .brain-node {
   }
 
   .brain-shell {
-    height: 50vh;
-    border-radius: 24px;
+    width: 100%;
+    height: 64vh;
+    border-radius: 28px;
+  }
+
+  .brain-bubble {
+    width: calc(100% - 30px);
   }
 }

services/tts.py

@@ -16,7 +16,7 @@ import os, re, asyncio
 
 load_dotenv()
 
-USE_ELEVENLABS       = True
+USE_ELEVENLABS       = False
 EDGE_VOICE           = "bn-BD-NabanitaNeural"
 ELEVENLABS_API_KEY   = os.getenv("ELEVENLABS_API_KEY", "")
 ELEVENLABS_VOICE_ID  = os.getenv("ELEVENLABS_VOICE_ID", "21m00Tcm4TlvDq8ikWAM")