enhance email normalization and add confirmation previews for appointment updates and deletions

core/backend.py

@@ -10,6 +10,7 @@ import pytz
 from datetime import datetime, timedelta
 from dotenv import load_dotenv
 import re
+import traceback
 
 from langchain_core.messages import (
     AIMessage, AIMessageChunk, HumanMessage, RemoveMessage,
@@ -58,6 +59,23 @@ def _clean_text(text: str) -> str:
     return re.sub(r"\s+", " ", (text or "").strip())
 
 
+def _normalize_email(text: str) -> str:
+    """
+    Best-effort normalizer for dictated emails like:
+      "rakib dot hedigital at gmail dot com"
+    Keeps it conservative: only applies if obvious patterns exist.
+    """
+    raw = _clean_text(text).lower()
+    if not raw:
+        return ""
+    # Common voice dictation patterns
+    raw = raw.replace(" at ", "@").replace(" dot ", ".")
+    raw = raw.replace(" underscore ", "_").replace(" dash ", "-")
+    raw = raw.replace(" minus ", "-").replace(" plus ", "+")
+    raw = raw.replace(" ", "")
+    return raw
+
+
 _DIGIT_TRANSLATION = str.maketrans({
     "০": "0",
     "১": "1",
@@ -679,7 +697,7 @@ async def book_appointment(
     visiting_date = _clean_text(visiting_date)
     visiting_day  = _clean_text(visiting_day)
     visiting_time = _clean_text(visiting_time)
-    patient_mail = _clean_text(patient_mail)
+    patient_mail = _normalize_email(patient_mail)
 
     if visiting_date:
         parsed_date = _parse_visit_date(visiting_date)
@@ -790,6 +808,7 @@ async def book_appointment(
         )
         mail_status = "\n📧 Confirmation mail sent."
     except Exception as e:
+        traceback.print_exc()
         mail_status = f"\n⚠️ Mail failed: {str(e)}"
 
     return (
@@ -818,6 +837,7 @@ async def update_appointment(
     new_doctor_name: str = "",
     new_patient_num: str = "",
     new_patient_mail: str = "",
+    confirm: bool = False,
 ) -> str:
     """
     Update an existing appointment found by phone number.
@@ -834,13 +854,14 @@ async def update_appointment(
         (or doctor_id) to select which one to update.
       - A confirmation email is REQUIRED for updates: either the existing
         appointment has an email, or provide new_patient_mail.
+      - IMPORTANT: This tool will NOT change the database unless confirm=True.
     """
     db_path = get_db_path()
     patient_num_norm = format_bd_number(patient_num)
     selector_name = _clean_text(doctor_name)
     new_doctor_name = _clean_text(new_doctor_name)
     new_patient_num = format_bd_number(new_patient_num) if new_patient_num else ""
-    new_patient_mail = _clean_text(new_patient_mail)
+    new_patient_mail = _normalize_email(new_patient_mail)
     new_visiting_date = _clean_text(new_visiting_date)
 
     parsed_date = _parse_visit_date(new_visiting_date) if new_visiting_date else None
@@ -890,7 +911,7 @@ async def update_appointment(
             else:
                 return f"No doctor found with name '{new_doctor_name}'."
 
-        # Build updated fields
+        # Build updated fields (proposal)
         updated_doctor_name = appt.get("doctor_name", "")
         updated_doctor_category = appt.get("doctor_category", "")
         updated_visiting_time = appt.get("visiting_time", "")
@@ -923,6 +944,40 @@ async def update_appointment(
         if not updated_patient_mail:
             return "Email is required to update an appointment. Please provide an email address."
 
+        # If not confirmed, return a preview only (no DB changes).
+        if not confirm:
+            preview = {
+                "success": False,
+                "needs_confirmation": True,
+                "message": (
+                    "I found your appointment. Please confirm the changes. "
+                    "If you want to keep the rest of the existing information, "
+                    "say YES and confirm."
+                ),
+                "current": {
+                    "doctor_name": appt.get("doctor_name", ""),
+                    "doctor_category": appt.get("doctor_category", ""),
+                    "patient_name": appt.get("patient_name", ""),
+                    "patient_num": appt.get("patient_num", ""),
+                    "patient_mail": appt.get("patient_mail", ""),
+                    "visiting_date": appt.get("visiting_date", ""),
+                    "visiting_day": appt.get("visiting_day", ""),
+                    "visiting_time": appt.get("visiting_time", ""),
+                },
+                "proposed": {
+                    "doctor_name": updated_doctor_name,
+                    "doctor_category": updated_doctor_category,
+                    "patient_name": appt.get("patient_name", ""),
+                    "patient_num": updated_patient_num,
+                    "patient_mail": updated_patient_mail,
+                    "visiting_date": updated_visiting_date,
+                    "visiting_day": updated_visiting_day,
+                    "visiting_time": updated_visiting_time,
+                },
+            }
+            return json.dumps(preview, ensure_ascii=False)
+
+        # Confirmed: apply update
         await db.execute(
             """UPDATE patients
                SET doctor_name = ?,
@@ -966,6 +1021,7 @@ async def update_appointment(
         )
         mail_status = "📧 Confirmation mail sent."
     except Exception as e:
+        traceback.print_exc()
         mail_status = f"⚠️ Mail failed: {str(e)}"
 
     return (
@@ -989,15 +1045,17 @@ async def delete_appointment(
     doctor_name: str = "",
     doctor_id: int = 0,
     patient_mail: str = "",
+    confirm: bool = False,
 ) -> str:
     """
     Cancel (delete) an appointment.
     Sends a confirmation email to the patient (required).
+    IMPORTANT: This tool will NOT delete anything unless confirm=True.
     """
     db_path     = get_db_path()
     patient_num = format_bd_number(patient_num)
     doctor_name = _clean_text(doctor_name)
-    patient_mail = _clean_text(patient_mail)
+    patient_mail = _normalize_email(patient_mail)
 
     async with aiosqlite.connect(db_path) as db:
         db.row_factory = aiosqlite.Row
@@ -1048,7 +1106,29 @@ async def delete_appointment(
                 "message": "Email is required to cancel an appointment. Please provide the email address.",
             }, ensure_ascii=False)
 
-        # Delete after we have all details for mail
+        if not confirm:
+            preview = {
+                "success": False,
+                "needs_confirmation": True,
+                "message": (
+                    "I found your appointment. Please confirm cancellation. "
+                    "If you want to keep the rest of the existing information, "
+                    "you don't need to provide anything else—just confirm."
+                ),
+                "current": {
+                    "doctor_name": appt.get("doctor_name", doctor_name),
+                    "doctor_category": appt.get("doctor_category", ""),
+                    "patient_name": appt.get("patient_name", ""),
+                    "patient_num": appt.get("patient_num", patient_num),
+                    "patient_mail": appt_email,
+                    "visiting_date": appt.get("visiting_date", ""),
+                    "visiting_day": appt.get("visiting_day", ""),
+                    "visiting_time": appt.get("visiting_time", ""),
+                },
+            }
+            return json.dumps(preview, ensure_ascii=False)
+
+        # Confirmed: delete after we have all details for mail
         await db.execute("DELETE FROM patients WHERE id = ?", (appt["id"],))
         await db.commit()
 
@@ -1071,6 +1151,7 @@ async def delete_appointment(
         )
         mail_status = "Confirmation mail sent."
     except Exception as e:
+        traceback.print_exc()
         mail_status = f"Mail failed: {str(e)}"
 
     return json.dumps({
@@ -1185,13 +1266,13 @@ Important update rules:
 - Ask whether to keep the rest of the existing appointment unchanged.
 - If multiple appointments exist for a phone number, ask for the doctor name to select the correct one.
 - Email is REQUIRED to update. If the existing record has no email, ask for it.
-- Only call `update_appointment` after the user confirms the change(s).
+- To avoid accidental changes: call `update_appointment` first with confirm=false to get a preview, show it to the user, then call again with confirm=true only after final confirmation.
 
 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.
 - Email is REQUIRED to cancel or update. If missing, ask for email.
-- Only call `delete_appointment` after the user confirms cancellation.
+- To avoid accidental deletion: call `delete_appointment` first with confirm=false to get a preview, show it to the user, then call again with confirm=true only after final confirmation.
 
 Do not give a normal conversational answer before the tool call.
 """

services/tts.py

@@ -45,9 +45,9 @@ def _parse_pct(text: str) -> float:
 #   Effective speed = base * (1 + pct).
 # - `ELEVENLABS_SPEED_MAX` sets the upper clamp (default 3.0). If your ElevenLabs
 #   model/voice rejects high values, lower this (e.g. 2.5).
-_ELEVEN_BASE_SPEED = float(os.getenv("ELEVENLABS_SPEED", "2.5"))
+_ELEVEN_BASE_SPEED = float(os.getenv("ELEVENLABS_SPEED", "2.8"))
 _ELEVEN_SPEED_PCT  = _parse_pct(os.getenv("ELEVENLABS_SPEED_PCT", "0%"))
-_ELEVEN_SPEED_MAX  = float(os.getenv("ELEVENLABS_SPEED_MAX", "3.0"))
+_ELEVEN_SPEED_MAX  = float(os.getenv("ELEVENLABS_SPEED_MAX", "3.5"))
 ELEVENLABS_SPEED   = _clamp(_ELEVEN_BASE_SPEED * (1.0 + _ELEVEN_SPEED_PCT), 0.5, _ELEVEN_SPEED_MAX)
 ELEVENLABS_OUTPUT_FORMAT = "mp3_22050_32"
 ELEVENLABS_STABILITY  = 0.45
@@ -93,7 +93,7 @@ def split_sentences(text: str) -> list[str]:
     return [p.strip() for p in parts if len(p.strip()) > 1]
 
 
-async def _edge_tts_stream(text: str, voice: str = EDGE_VOICE, rate: str = "+18%"):
+async def _edge_tts_stream(text: str, voice: str = EDGE_VOICE, rate: str = "+22%"):
     """
     Stream Edge-TTS audio for a single text chunk.
     Default rate is slightly faster than normal.
@@ -173,7 +173,7 @@ async def _elevenlabs_stream(
 async def text_to_speech_stream(
     text: str,
     voice: str | None = None,
-    rate: str = "+18%",
+    rate: str = "+22%",
 ):
     """
     Stream TTS audio for `text`.