Add initial data insertion script for doctors into SQLite database

- Created a new Jupyter notebook to insert doctor data into the 'doctors' table.
- Included a list of doctors with their names, categories, visiting days, visiting times, and fees.
- Utilized aiosqlite for asynchronous database operations.

app.py

@@ -52,8 +52,8 @@ except (ImportError, RuntimeError) as _e:
 # ══════════════════════════════════════════════════════════════════════════════
 #  MODEL ROUTING CONFIG — set exactly ONE to True
 # ══════════════════════════════════════════════════════════════════════════════
-USE_GEMINI         = False
-USE_OLLAMA         = True
+USE_GEMINI         = True
+USE_OLLAMA         = False
 USE_LOCAL_FALLBACK = False
 
 _active = sum([USE_GEMINI, USE_OLLAMA, USE_LOCAL_FALLBACK])

core/backend.py

@@ -103,9 +103,12 @@ def get_bd_time() -> str:
     return json.dumps(result)
 
 @tool
-async def get_doctor_categories() -> str:
+async def get_categories_by_day(visiting_day: str = "") -> str:
     """
-    Fetch all unique doctor categories from the database.
+    Fetch unique doctor categories.
+
+    If visiting_day is provided → filter by that day
+    If empty → return all categories
     """
 
     db_path = get_db_path()
@@ -115,63 +118,82 @@ async def get_doctor_categories() -> str:
         FROM doctors
         WHERE category IS NOT NULL
           AND TRIM(category) != ''
-        ORDER BY category ASC
     """
 
+    params = []
+
+    # Optional filter
+    if visiting_day:
+        query += " AND LOWER(visiting_days) LIKE ?"
+        params.append(f"%{visiting_day.lower()}%")
+
+    query += " ORDER BY category ASC"
+
     async with aiosqlite.connect(db_path) as db:
         db.row_factory = aiosqlite.Row
-
-        cursor = await db.execute(query)
+        cursor = await db.execute(query, params)
         rows = await cursor.fetchall()
 
     categories = [row["category"] for row in rows]
 
+    if not categories:
+        return json.dumps({
+            "success": False,
+            "message": "No categories found.",
+            "data": []
+        }, ensure_ascii=False)
+
     return json.dumps({
         "success": True,
+        "visiting_day": visiting_day if visiting_day else "ALL",
         "count": len(categories),
         "data": categories
-    })
+    }, ensure_ascii=False)
 
 @tool
-async def get_doctors_by_day(
-    visiting_day: str,
-) -> str:
+async def get_doctors_by_day(visiting_day: str = "") -> str:
     """
-    Get all doctors available on a specific visiting day.
-    Example inputs:
-    - Sunday
-    - Monday
-    - Friday
+    Get doctors by visiting day.
+    If visiting_day is provided → filter by that day
+    If empty → return all doctors
+    Example:
+    - "Sunday"
+    - "Monday"
+    - ""
     """
 
     db_path = get_db_path()
 
     query = """
-    SELECT *
-    FROM doctors
-    WHERE LOWER(visiting_days) LIKE ?
+        SELECT *
+        FROM doctors
+        WHERE 1=1
     """
 
-    param = [f"%{visiting_day.lower()}%"]
+    params = []
+
+    # Optional filter
+    if visiting_day:
+        query += " AND LOWER(visiting_days) LIKE ?"
+        params.append(f"%{visiting_day.lower()}%")
 
     async with aiosqlite.connect(db_path) as db:
         db.row_factory = aiosqlite.Row
-
-        cursor = await db.execute(query, param)
+        cursor = await db.execute(query, params)
         rows = await cursor.fetchall()
 
     if not rows:
         return json.dumps({
             "success": False,
-            "message": f"No doctors found for {visiting_day}.",
+            "message": f"No doctors found for {visiting_day if visiting_day else 'ALL days'}.",
             "data": []
-        })
+        }, ensure_ascii=False)
 
     doctors = [dict(row) for row in rows]
 
     return json.dumps({
         "success": True,
-        "visiting_day": visiting_day,
+        "visiting_day": visiting_day if visiting_day else "ALL",
         "count": len(doctors),
         "data": doctors
     }, ensure_ascii=False)
@@ -271,6 +293,7 @@ async def book_appointment(
         doctor_data     = dict(doctor)
         doctor_name     = doctor_data.get("doctor_name", "Unknown")
         doctor_category = doctor_data.get("category", "Unknown")
+        visiting_time = doctor_data.get("visiting_time", "Unknown")
 
         cursor = await db.execute(
             """SELECT id FROM patients
@@ -296,7 +319,8 @@ async def book_appointment(
         f"Doctor     : {doctor_name}\n"
         f"Patient    : {patient_name}\n"
         f"Visit Date : {visiting_date}\n"
-        f"Please arrive 10 minutes early."
+        f"Visit Time : {visiting_time}\n"
+        f"Please arrive on time."
     )
     try:
         await send_mail(
@@ -317,7 +341,7 @@ async def book_appointment(
         f"Date         : {visiting_date}\n"
         f"Contact      : {patient_num}\n"
         f"━━━━━━━━━━━━━━━━━━━━━━\n"
-        f"Please arrive 10 minutes early."
+        f"Please arrive on time."
         f"{mail_status}"
     )
 
@@ -351,45 +375,36 @@ async def delete_appointment(patient_num: str, doctor_name: str) -> str:
         "message": f"Appointment with Dr. {doctor_name} deleted successfully.",
     })
 
-
 # ═══════════════════════════════════════════════════════════════════════════════
 #  SYSTEM PROMPT
 # ═══════════════════════════════════════════════════════════════════════════════
 BASE_SYSTEM = """
 You are a Doctor Appointment Assistant AI.
-
 Your job is to help users manage medical appointments.
-
 CAPABILITIES:
 - Book doctor appointments
 - Reschedule appointments
 - Cancel appointments
 - Collect patient details
-
 STRICT RULES:
 - You are NOT a doctor.
 - NEVER diagnose diseases.
 - NEVER recommend medicines or treatments.
-
 APPOINTMENT FLOW:
 1. Detect intent (book / cancel / reschedule / inquiry)
 2. Collect details
 3. Confirm all details before final booking
-
 STYLE:
 - Be short, clear, structured
-- Ask one question at a time when needed
 - Focus on completing booking
-
 LANGUAGE RULE:
 - Detect user language from latest message.
 - If English → reply English.
 - If Bangla → reply Bangla (বাংলা).
 - If Banglish → reply Bangla (বাংলা).
 - Never mix languages unless user mixes first.
-
 TOOLS:
-- Use backend tools if available for scheduling
+- Use backend tools if needed
 - Always confirm before final action
 """
 
@@ -415,14 +430,14 @@ class AIBackend:
 
         if use_gemini:
             self.llm = ChatGoogleGenerativeAI(
-                model="gemini-2.0-flash",
-                temperature=0.3,
+                model="gemini-2.5-flash",
+                temperature=0.01,
             )
         elif use_ollama:
-            self.llm = ChatOllama(model="gemma4:e4b", streaming=True, temperature=0.2)
+            self.llm = ChatOllama(model="gemma4:e4b", streaming=True, temperature=0.01)
         else:
             # Local fallback — extend as needed
-            self.llm = ChatOllama(model="gemma4:e4b", streaming=True, temperature=0.2)
+            self.llm = ChatOllama(model="gemma4:e4b", streaming=True, temperature=0.01)
 
         self.tools          = [
             search_doctor,
@@ -430,9 +445,10 @@ class AIBackend:
             get_bd_time,
             search_appointment_by_phone,
             delete_appointment,
-            get_doctor_categories,
+            get_categories_by_day,
             get_doctors_by_day
         ]
+
         self.tool_node      = ToolNode(self.tools)
         self.llm_with_tools = self.llm.bind_tools(self.tools)
 

frontend/index.html

@@ -98,7 +98,7 @@
     </div>
 
     <!-- System Status -->
-    <div class="status-panel">
+    <!-- <div class="status-panel">
       <div class="status-row">
         <span class="status-label">System</span>
         <span class="status-badge badge-green" id="sys-status">Ready</span>
@@ -115,7 +115,7 @@
         <span class="status-label">TTS</span>
         <span class="status-badge badge-green" id="tts-status">Edge TTS</span>
       </div>
-    </div>
+    </div> -->
 
     <div class="sidebar-divider"></div>
 

frontend/script.js

@@ -1,29 +1,4 @@
-/**
- * script.js — Production Bangla Voice AI Frontend
- *
- * FIXES APPLIED:
- *  FIX-1. PORT: WS_BASE was hardcoded to :8679 — changed to :8679 (uvicorn default).
- *         This was the PRIMARY cause of "no backend logs" — WebSocket never connected.
- *
- *  FIX-2. CHAT STREAMING: sendText() now uses the VOICE WS with llm_token events
- *         instead of the chat WS, giving real-time streaming + TTS for chat mode too.
- *         The separate chatWS endpoint is kept as a fallback (text-only mode).
- *
- *  FIX-3. THINKING BUBBLE: appendThinking() shows an animated "..." bubble while
- *         waiting for the first LLM token. Removed when first token arrives.
- *
- *  FIX-4. _cancelled RESET: _cancelled is now reset to false on every sendText()
- *         call so previous voice cancellations don't block chat audio.
- *
- *  FIX-5. CHAT WS STREAMING: onChatMsg now handles llm_token events from the chat
- *         endpoint, showing incremental text just like voice mode.
- *
- *  FIX-6. LOGGING: Added console.log for every WS event for easier debugging.
- *
- *  FIX-7. SEND FORMAT: chat WS payload now always includes user_id.
- *
- * All other logic (VAD, audio playback, reconnect, init overlay) preserved.
- */
+
 
 'use strict';
 
@@ -76,28 +51,22 @@ const USER_ID = (() => {
 })();
 
 // ─── WebSocket base URL ────────────────────────────────────────────────────────
-// FIX-1: Was :8679 — corrected to :8679 (uvicorn/FastAPI default port).
-// If your server runs on a different port, update the number below.
 const WS_BASE = 'http://127.0.0.1:8679';
-//   location.hostname === 'localhost' || location.hostname === '127.0.0.1'
-//     ? `http://${location.hostname}:8679` // ← FIXED: was 8679
-//     : `http://${location.host}`;
+console.log('[Boot] WS base:', WS_BASE);
 
-console.log('WebSocket base URL:', WS_BASE); // FIX-6: log WS base URL for debugging
-
-// ─── WS state ─────────────────────────────────────────────────────────────────
+// ─── WS handles ───────────────────────────────────────────────────────────────
 let chatWS = null;
 let voiceWS = null;
-
 let _chatRetry = 0;
 let _voiceRetry = 0;
 let _chatRetryTimer = null;
 let _voiceRetryTimer = null;
 
 // ─── VAD / recording settings ─────────────────────────────────────────────────
-let SILENCE_MS = 450; // was 1000 (too slow)
-let SILENCE_DB = -38; // slightly more sensitive
+let SILENCE_MS = 1200; // BUG-FIX-B: was 450 ms
+let SILENCE_DB = -38;
 const VAD_MS = 80;
+const MIN_SPEECH_MS = 400; // discard noise bursts shorter than this
 
 // ─── Playback state ───────────────────────────────────────────────────────────
 let _ctx = null;
@@ -105,6 +74,7 @@ let _schedEnd = 0;
 let _endTimer = null;
 let _cancelled = false;
 let _inFlight = 0;
+let _ttsPlaying = false;
 
 // ─── Recording state ──────────────────────────────────────────────────────────
 let micStream = null;
@@ -115,14 +85,17 @@ let audioChunks = [];
 let isListening = false;
 let isSpeaking = false;
 let isProcessing = false;
+let isRecordingLocked = false;
 let silenceTimer = null;
 let vadInt = null;
 let vizInt = null;
+let _speechStartMs = 0;
+let _recorderMime = 'audio/webm';
 
 // ─── AI streaming bubble state ────────────────────────────────────────────────
-let aiEl = null; // current AI message div
-let aiTxt = ''; // accumulated raw markdown for this turn
-let thinkingEl = null; // FIX-3: "..." thinking bubble
+let aiEl = null;
+let aiTxt = '';
+let thinkingEl = null;
 
 // ─── Latency timestamps ───────────────────────────────────────────────────────
 let tSend = 0,
@@ -131,7 +104,7 @@ let tSend = 0,
   tTts = 0;
 
 // ═══════════════════════════════════════════════════════════════════════════════
-//  INIT OVERLAY — 2-gate: both WS-ready AND stage animations done
+//  INIT OVERLAY
 // ═══════════════════════════════════════════════════════════���═══════════════════
 
 const STAGES = [
@@ -165,7 +138,6 @@ function _tryClose() {
 
 function boot() {
   initWebSockets();
-
   STAGES.forEach(({ id, text, at, pct }, i) => {
     setTimeout(() => {
       if (i > 0) _stageDone(STAGES[i - 1].id);
@@ -175,7 +147,6 @@ function boot() {
       initBar.style.width = pct + '%';
     }, at);
   });
-
   setTimeout(
     () => {
       _stageDone(STAGES[STAGES.length - 1].id);
@@ -184,8 +155,6 @@ function boot() {
     },
     STAGES[STAGES.length - 1].at + 650,
   );
-
-  // Hard failsafe: 8 s max regardless of WS state
   setTimeout(() => {
     if (!_initClosed) {
       _wsGate = _stageGate = true;
@@ -203,11 +172,11 @@ function _stageDone(id) {
 }
 
 // ═══════════════════════════════════════════════════════════════════════════════
-//  WEBSOCKETS — silent auto-reconnect, exponential backoff
+//  WEBSOCKETS
 // ═══════════════════════════════════════════════════════════════════════════════
 
-function _backoff(retries) {
-  return Math.min(1000 * Math.pow(2, retries), 16000);
+function _backoff(r) {
+  return Math.min(1000 * Math.pow(2, r), 16000);
 }
 
 function _setSysStatus(online) {
@@ -217,76 +186,59 @@ function _setSysStatus(online) {
     'status-badge ' + (online ? 'badge-green' : 'badge-yellow');
 }
 
-// ── Chat WS ────────────────────────────────────────────────────────────────────
 function _connectChat() {
   if (chatWS && chatWS.readyState <= WebSocket.OPEN) return;
-
   chatWS = new WebSocket(`${WS_BASE}/ws/chat`);
-
   chatWS.onopen = () => {
     _chatRetry = 0;
-    console.log('[Chat WS] connected to', `${WS_BASE}/ws/chat`); // FIX-6
-  };
-
-  chatWS.onerror = (e) => {
-    console.error('[Chat WS] error:', e); // FIX-6
+    console.log('[Chat WS] connected');
   };
-
+  chatWS.onerror = (e) => console.error('[Chat WS] error:', e);
   chatWS.onclose = (ev) => {
-    console.log(`[Chat WS] closed (${ev.code}), retry #${_chatRetry + 1}`);
+    console.log(`[Chat WS] closed (${ev.code})`);
     clearTimeout(_chatRetryTimer);
     _chatRetryTimer = setTimeout(() => {
       _chatRetry++;
       _connectChat();
     }, _backoff(_chatRetry));
   };
-
   chatWS.onmessage = onChatMsg;
 }
 
-// ── Voice WS ────────────────────────────────────────────────────────────────────
 function _connectVoice() {
   if (voiceWS && voiceWS.readyState <= WebSocket.OPEN) return;
-
   voiceWS = new WebSocket(`${WS_BASE}/ws/voice`);
   voiceWS.binaryType = 'arraybuffer';
 
   voiceWS.onopen = () => {
     _voiceRetry = 0;
-    console.log(
-      '[Voice WS] connected to',
-      `${WS_BASE}/ws/voice`,
-      'uid:',
-      USER_ID,
-    ); // FIX-6
+    console.log('[Voice WS] connected, uid:', USER_ID);
     voiceWS.send(JSON.stringify({ type: 'init', user_id: USER_ID }));
     _setSysStatus(true);
     _wsGate = true;
     _tryClose();
   };
-
-  voiceWS.onerror = (e) => {
-    console.error('[Voice WS] error:', e); // FIX-6
-  };
-
+  voiceWS.onerror = (e) => console.error('[Voice WS] error:', e);
   voiceWS.onclose = (ev) => {
-    console.log(`[Voice WS] closed (${ev.code}), retry #${_voiceRetry + 1}`);
+    console.log(`[Voice WS] closed (${ev.code})`);
     _setSysStatus(false);
-
     if (!_initClosed) {
       _wsGate = true;
       _tryClose();
     }
-
-    if (isListening) stopListening();
-
+    if (isListening || isSpeaking || isProcessing) {
+      _teardownMicHardware();
+      _resetVoiceState();
+      setState('ready');
+      setMic('off');
+      micBtn.disabled = false;
+    }
     clearTimeout(_voiceRetryTimer);
     _voiceRetryTimer = setTimeout(() => {
       _voiceRetry++;
       _connectVoice();
     }, _backoff(_voiceRetry));
   };
-
   voiceWS.onmessage = onVoiceMsg;
 }
 
@@ -295,8 +247,7 @@ function initWebSockets() {
   _connectVoice();
 }
 
-// ── Chat WS handler ────────────────────────────────────────────────────────────
-// FIX-5: Now handles llm_token for streaming, not just full 'chat' message
+// ── Chat WS handler ───────────────────────────────────────────────────────────
 function onChatMsg(ev) {
   let msg;
   try {
@@ -304,18 +255,16 @@ function onChatMsg(ev) {
   } catch {
     return;
   }
-
-  console.log('[Chat WS] msg:', msg.type); // FIX-6
+  console.log('[Chat WS]', msg.type);
 
   switch (msg.type) {
     case 'llm_token':
-      // FIX-5: streaming token support for chat WS
       if (!msg.token) break;
       if (tLlm === 0) {
         tLlm = Date.now();
         if (tSend > 0) mLlm.textContent = tLlm - tSend + ' ms';
       }
-      _removeThinking(); // FIX-3: remove "..." bubble on first token
+      _removeThinking();
       if (!aiEl) {
         aiEl = document.createElement('div');
         aiEl.className = 'message ai';
@@ -330,9 +279,8 @@ function onChatMsg(ev) {
       break;
 
     case 'chat':
-      // Fallback: backend sent full response at once (non-streaming mode)
       if (!msg.text) break;
-      _removeThinking(); // FIX-3
+      _removeThinking();
       if (!aiEl) {
         aiEl = document.createElement('div');
         aiEl.className = 'message ai';
@@ -347,7 +295,7 @@ function onChatMsg(ev) {
       break;
 
     case 'end':
-      _removeThinking(); // FIX-3: safety cleanup
+      _removeThinking();
       if (aiEl && aiTxt) {
         aiEl.innerHTML =
           typeof marked !== 'undefined'
@@ -364,7 +312,7 @@ function onChatMsg(ev) {
       break;
 
     case 'error':
-      _removeThinking(); // FIX-3
+      _removeThinking();
       appendMsg('⚠️ ' + msg.text, 'system');
       aiEl = null;
       aiTxt = '';
@@ -374,9 +322,10 @@ function onChatMsg(ev) {
   }
 }
 
-// ── Voice WS handler ───────────────────────────────────────────────────────────
+// ── Voice WS handler ──────────────────────────────────────────────────────────
 function onVoiceMsg(ev) {
   if (ev.data instanceof ArrayBuffer) {
+    _ttsPlaying = true;
     enqueueAudio(ev.data);
     return;
   }
@@ -387,22 +336,21 @@ function onVoiceMsg(ev) {
   } catch {
     return;
   }
-
-  console.log('[Voice WS] msg:', msg.type); // FIX-6
+  console.log('[Voice WS]', msg.type);
 
   switch (msg.type) {
     case 'init_ack':
-      console.log('[Voice WS] user_id ack:', msg.user_id);
+      console.log('[Voice WS] ack uid:', msg.user_id);
       break;
 
     case 'stt':
       tStt = Date.now();
       if (tSend > 0) mStt.textContent = tStt - tSend + ' ms';
-      _removeThinking(); // FIX-3
+      _removeThinking();
       appendMsg('🎤 ' + msg.text, 'user');
       aiEl = null;
       aiTxt = '';
-      appendThinking(); // FIX-3: show "..." while LLM runs
+      appendThinking();
       setState('processing');
       break;
 
@@ -412,7 +360,7 @@ function onVoiceMsg(ev) {
         tLlm = Date.now();
         if (tStt > 0) mLlm.textContent = tLlm - tStt + ' ms';
       }
-      _removeThinking(); // FIX-3: remove on first token
+      _removeThinking();
       if (!aiEl) {
         aiEl = document.createElement('div');
         aiEl.className = 'message ai';
@@ -434,22 +382,25 @@ function onVoiceMsg(ev) {
             : aiTxt.replace(/\n/g, '<br>');
         chatBox.scrollTop = chatBox.scrollHeight;
       }
-      _removeThinking(); // FIX-3
+      _removeThinking();
       aiEl = null;
       aiTxt = '';
       if (tSend > 0) mTotal.textContent = Date.now() - tSend + ' ms';
       tSend = tStt = tLlm = tTts = 0;
-      _scheduleEnd();
       isProcessing = false;
+      // BUG-FIX-C: schedule _done() to fire after TTS audio drains.
+      // If no TTS audio arrived (_schedEnd == 0), _done fires in ~300 ms.
+      _scheduleEnd();
       break;
 
     case 'error':
-      _removeThinking(); // FIX-3
+      _removeThinking();
       appendMsg('⚠️ ' + msg.text, 'system');
       aiEl = null;
       aiTxt = '';
       isProcessing = false;
-      setState(isListening ? 'listening' : 'ready');
+      // BUG-FIX-C: unconditionally unlock on error
+      _done();
       break;
 
     case 'pong':
@@ -460,7 +411,7 @@ function onVoiceMsg(ev) {
   }
 }
 
-// ─── FIX-3: Thinking bubble helpers ──────────────────────────────────────────
+// ─── Thinking bubble ──────────────────────────────────────────────────────────
 function appendThinking() {
   if (thinkingEl) return;
   thinkingEl = document.createElement('div');
@@ -470,7 +421,6 @@ function appendThinking() {
   chatBox.appendChild(thinkingEl);
   chatBox.scrollTop = chatBox.scrollHeight;
 }
-
 function _removeThinking() {
   if (thinkingEl) {
     thinkingEl.remove();
@@ -479,7 +429,7 @@ function _removeThinking() {
 }
 
 // ═══════════════════════════════════════════════════════════════════════════════
-//  AUDIO PLAYBACK — gapless Web Audio API
+//  AUDIO PLAYBACK
 // ═════════════════════���═════════════════════════════════════════════════════════
 
 function _ctxEnsure() {
@@ -501,7 +451,7 @@ async function enqueueAudio(buf) {
   try {
     decoded = await ctx.decodeAudioData(buf.slice(0));
   } catch (e) {
-    console.warn('[Audio] decode:', e.message);
+    console.warn('[Audio] decode error:', e.message);
     _inFlight = Math.max(0, _inFlight - 1);
     _vizQ();
     return;
@@ -521,7 +471,6 @@ async function enqueueAudio(buf) {
   const src = ctx.createBufferSource();
   src.buffer = decoded;
   src.connect(ctx.destination);
-
   const now = ctx.currentTime;
   const start = Math.max(now + 0.01, _schedEnd);
   src.start(start);
@@ -547,24 +496,35 @@ function _scheduleEnd() {
   clearTimeout(_endTimer);
   const ctx = _ctx;
   if (!ctx || ctx.state === 'closed') {
-    _done();
+    // No audio context — unlock immediately
+    setTimeout(_done, 300);
     return;
   }
-  const wait = Math.max(0, (_schedEnd - ctx.currentTime) * 1000) + 280;
-  _endTimer = setTimeout(() => {
-    if (!_cancelled) _done();
-  }, wait);
+  const remainingMs = Math.max(0, (_schedEnd - ctx.currentTime) * 1000);
+  // BUG-FIX-C: always call _done regardless of _cancelled — we must
+  // release the lock. Use a minimal delay when no audio was scheduled.
+  _endTimer = setTimeout(_done, remainingMs + 300);
 }
 
+/**
+ * _done — returns system to fully idle state.
+ * ALWAYS unlocks the mic. Never auto-restarts recording.
+ */
 function _done() {
+  _ttsPlaying = false;
   isProcessing = false;
+  isRecordingLocked = false;
   _inFlight = 0;
   _vizQ();
-  setState(isListening ? 'listening' : 'ready');
+  micBtn.disabled = false;
+  setState('ready');
+  setMic('off');
+  console.log('[Voice] Idle — ready for next manual press');
 }
 
 function stopAllAudio() {
   _cancelled = true;
+  _ttsPlaying = false;
   clearTimeout(_endTimer);
   _endTimer = null;
   _schedEnd = 0;
@@ -587,58 +547,28 @@ textInput.addEventListener('keydown', (e) => {
 
 function sendText() {
   const text = textInput.value.trim();
-  console.log('Send button clicked, text:', text); // FIX-6
   if (!text || isProcessing) return;
-
   appendMsg(text, 'user');
   textInput.value = '';
-
-  // FIX-4: always reset _cancelled before new turn so previous voice
-  // cancel doesn't block chat audio playback
   _cancelled = false;
   isProcessing = true;
   tSend = Date.now();
-  tLlm = 0;
-  tTts = 0;
+  tLlm = tTts = 0;
   aiEl = null;
   aiTxt = '';
-
   setState('processing');
-  appendThinking(); // FIX-3: show "..." bubble immediately
-
-  console.log('[Chat] sending:', text); // FIX-6
-
-  // Try voice WS first (gives streaming tokens + TTS audio)
-  // Fall back to chat WS for text-only response
-  if (voiceWS && voiceWS.readyState === WebSocket.OPEN) {
-    // Send as a text query over voice WS — backend will handle it
-    // We need to send it as JSON text (not binary) to trigger chat path
-    // Since voice WS only handles binary audio + control JSON,
-    // we route text queries through the dedicated chat WS.
-    _sendViaChat(text);
-  } else {
-    _sendViaChat(text);
-  }
+  appendThinking();
+  _sendViaChat(text);
 }
 
 function _sendViaChat(text) {
-  // FIX-7: always include user_id in payload
   const payload = JSON.stringify({ user_id: USER_ID, user_query: text });
-  console.log(
-    '[Chat WS] sending payload, readyState:',
-    chatWS ? chatWS.readyState : 'null',
-  );
-
   if (chatWS && chatWS.readyState === WebSocket.OPEN) {
     chatWS.send(payload);
   } else {
-    // Queue with retry until connected
     const _retry = () => {
-      if (chatWS && chatWS.readyState === WebSocket.OPEN) {
-        chatWS.send(payload);
-      } else {
-        setTimeout(_retry, 300);
-      }
+      if (chatWS && chatWS.readyState === WebSocket.OPEN) chatWS.send(payload);
+      else setTimeout(_retry, 300);
     };
     _retry();
   }
@@ -649,17 +579,33 @@ function _sendViaChat(text) {
 // ═══════════════════════════════════════════════════════════════════════════════
 
 micBtn.onclick = async () => {
-  if (isListening) stopListening();
-  else await startListening();
+  if (isRecordingLocked || isProcessing) {
+    console.log('[Mic] Ignored — system busy');
+    return;
+  }
+  if (isListening) {
+    _teardownMicHardware();
+    _resetVoiceState();
+    setState('ready');
+    setMic('off');
+  } else {
+    await startListening();
+  }
 };
 
 stopBtn.onclick = () => {
   stopAllAudio();
-  isProcessing = false;
-  setState(isListening ? 'listening' : 'ready');
+  if (isListening || isSpeaking) _teardownMicHardware();
+  _resetVoiceState();
+  setState('ready');
+  setMic('off');
+  micBtn.disabled = false;
 };
 
+// ── startListening ────────────────────────────────────────────────────────────
 async function startListening() {
+  if (isListening || isProcessing || isRecordingLocked) return;
+
   _ctxEnsure();
 
   try {
@@ -673,7 +619,7 @@ async function startListening() {
       },
     });
   } catch (err) {
-    console.error('[Mic]', err);
+    console.error('[Mic] getUserMedia failed:', err);
     appendMsg('⚠️ মাইক্রোফোন অ্যাক্সেস দেওয়া হয়নি।', 'system');
     return;
   }
@@ -686,80 +632,145 @@ async function startListening() {
   src.connect(analyser);
 
   isListening = true;
+  audioChunks = [];
+
   setMic('listening');
   setState('listening');
   voiceViz.classList.add('active');
 
   vadInt = setInterval(vadTick, VAD_MS);
   vizInt = setInterval(vizTick, 60);
+
+  console.log('[Mic] Listening started');
 }
 
-function stopListening() {
+// ── _teardownMicHardware ──────────────────────────────────────────────────────
+// Stops hardware: intervals, recorder (silenced), mic tracks, AudioContext.
+// IMPORTANT: does NOT clear audioChunks — caller's onstop captures them first.
+function _teardownMicHardware() {
   clearInterval(vadInt);
   clearInterval(vizInt);
   clearTimeout(silenceTimer);
   vadInt = vizInt = silenceTimer = null;
 
-  if (isSpeaking) discardRecorder();
-  stopAllAudio();
+  // Silence callbacks so no onstop logic fires after forced teardown
+  if (mediaRecorder && mediaRecorder.state !== 'inactive') {
+    mediaRecorder.ondataavailable = () => {};
+    mediaRecorder.onstop = () => {};
+    mediaRecorder.stop();
+  }
+  mediaRecorder = null;
 
   micStream?.getTracks().forEach((t) => t.stop());
-  analyserCtx?.close().catch(() => {});
-  micStream = analyserCtx = analyser = null;
+  micStream = null;
+
+  if (analyserCtx && analyserCtx.state !== 'closed') {
+    analyserCtx.close().catch(() => {});
+  }
+  analyserCtx = null;
+  analyser = null;
 
-  isListening = isSpeaking = isProcessing = false;
-  setMic('off');
-  setState('ready');
   voiceViz.classList.remove('active');
   vizBars.forEach((b) => (b.style.height = '4px'));
+
+  console.log('[Mic] Hardware torn down');
 }
 
-// ── VAD ────────────────────────────────────────────────────────────────────────
+// ── _resetVoiceState ──────────────────────────────────────────────────────────
+function _resetVoiceState() {
+  isListening = false;
+  isSpeaking = false;
+  isProcessing = false;
+  isRecordingLocked = false;
+  _ttsPlaying = false;
+  _speechStartMs = 0;
+  audioChunks = [];
+}
+
+// ── VAD tick ──────────────────────────────────────────────────────────────────
 function vadTick() {
   if (!analyser) return;
+  if (_ttsPlaying) return; // mute during TTS playback
+  if (isProcessing || isRecordingLocked) return; // hard lock
+
   const buf = new Float32Array(analyser.frequencyBinCount);
   analyser.getFloatTimeDomainData(buf);
-
-  let s = 0;
-  for (let i = 0; i < buf.length; i++) s += buf[i] * buf[i];
-  const db = 20 * Math.log10(Math.sqrt(s / buf.length) || 1e-10);
+  let sum = 0;
+  for (let i = 0; i < buf.length; i++) sum += buf[i] * buf[i];
+  const db = 20 * Math.log10(Math.sqrt(sum / buf.length) || 1e-10);
   const speech = db > SILENCE_DB;
 
   if (speech) {
-    if (isProcessing) {
-      stopAllAudio();
-      isProcessing = false;
-    }
     clearTimeout(silenceTimer);
     silenceTimer = null;
 
     if (!isSpeaking) {
+      if (mediaRecorder && mediaRecorder.state !== 'inactive') return; // duplicate guard
       isSpeaking = true;
+      _speechStartMs = Date.now();
       _cancelled = false;
       _ctxEnsure();
       startRecorder();
       setMic('recording');
       setState('recording');
+      console.log('[VAD] Speech detected — recording');
     }
   } else {
     if (isSpeaking && !silenceTimer) {
-      silenceTimer = setTimeout(() => {
-        silenceTimer = null;
-        isSpeaking = false;
-        isProcessing = true;
-        _cancelled = false;
-        tSend = Date.now();
-        tLlm = 0;
-        tTts = 0;
-        stopRecorder();
-        setMic('processing');
-        setState('processing');
-      }, SILENCE_MS);
+      silenceTimer = setTimeout(_onSilenceTimeout, SILENCE_MS);
     }
   }
 }
 
-// ── Viz tick ───────────────────────────────────────────────────────────────────
+// ── _onSilenceTimeout ────────────────────────────────────��────────────────────
+function _onSilenceTimeout() {
+  silenceTimer = null;
+
+  const speechDuration = Date.now() - _speechStartMs;
+  if (speechDuration < MIN_SPEECH_MS) {
+    console.log(
+      `[VAD] Too short (${speechDuration} ms) — discard & resume listening`,
+    );
+    isSpeaking = false;
+    discardRecorder();
+    // BUG-FIX-D: restart intervals so listening continues
+    if (isListening && !vadInt) {
+      vadInt = setInterval(vadTick, VAD_MS);
+      vizInt = setInterval(vizTick, 60);
+    }
+    setMic('listening');
+    setState('listening');
+    return;
+  }
+
+  console.log(
+    `[VAD] Silence after ${speechDuration} ms — finalising utterance`,
+  );
+
+  // Stop VAD before stopRecorder so no new speech detection during processing
+  clearInterval(vadInt);
+  clearInterval(vizInt);
+  vadInt = vizInt = null;
+
+  // Lock state BEFORE stopRecorder (onstop may fire almost immediately)
+  isSpeaking = false;
+  isListening = false;
+  isProcessing = true;
+  isRecordingLocked = true;
+  _cancelled = false;
+
+  tSend = Date.now();
+  tLlm = 0;
+  tTts = 0;
+
+  micBtn.disabled = true;
+  setMic('processing');
+  setState('processing');
+
+  stopRecorder(); // → triggers onstop asynchronously
+}
+
+// ── Viz tick ──────────────────────────────────────────────────────────────────
 function vizTick() {
   if (!analyser) return;
   const data = new Uint8Array(analyser.frequencyBinCount);
@@ -771,56 +782,132 @@ function vizTick() {
   });
 }
 
-// ── MediaRecorder ──────────────────────────────────────────────────────────────
+// ── MediaRecorder ─────────────────────────────────────────────────────────────
 function startRecorder() {
   if (!micStream) return;
+  if (mediaRecorder && mediaRecorder.state !== 'inactive') {
+    console.warn('[Recorder] Duplicate startRecorder() — ignored');
+    return;
+  }
+
   audioChunks = [];
-  const mime = MediaRecorder.isTypeSupported('audio/webm;codecs=opus')
+  _recorderMime = MediaRecorder.isTypeSupported('audio/webm;codecs=opus')
     ? 'audio/webm;codecs=opus'
     : 'audio/webm';
 
-  mediaRecorder = new MediaRecorder(micStream, { mimeType: mime });
+  try {
+    mediaRecorder = new MediaRecorder(micStream, { mimeType: _recorderMime });
+  } catch (err) {
+    console.error('[Recorder] Creation failed:', err);
+    isSpeaking = false;
+    setMic('listening');
+    setState('listening');
+    return;
+  }
+
   mediaRecorder.ondataavailable = (e) => {
-    if (e.data.size > 0) audioChunks.push(e.data);
+    if (e.data && e.data.size > 0) audioChunks.push(e.data);
   };
+
+  /**
+   * onstop handler
+   *
+   * BUG-FIX-A: Capture audioChunks into a LOCAL variable as the very
+   * first action, before any teardown or async work. Then clear the
+   * module-level audioChunks. _teardownMicHardware() does NOT touch
+   * audioChunks, so the local copy is safe.
+   *
+   * Old (broken) order:
+   *   1. _fullMicTeardown()   ← set audioChunks = [] HERE
+   *   2. new Blob(audioChunks) ← always empty!
+   *
+   * New (correct) order:
+   *   1. const captured = audioChunks.slice()  ← copy before anything
+   *   2. audioChunks = []                       ← clear module ref
+   *   3. _teardownMicHardware()                 ← safe, chunks are local
+   *   4. new Blob(captured)                     ← has actual audio data
+   */
   mediaRecorder.onstop = async () => {
-    if (!audioChunks.length) {
-      isProcessing = false;
-      if (isListening) setState('listening');
-      return;
-    }
-    const blob = new Blob(audioChunks, { type: mime });
+    // ── 1. Capture chunks locally (MUST be first) ──────────────────────────
+    const captured = audioChunks.slice();
     audioChunks = [];
-    const buf = await blob.arrayBuffer();
+
+    // ── 2. Tear down mic hardware (safe — captured is local) ───────────────
+    _teardownMicHardware();
+    setMic('off');
+
     console.log(
-      `[VAD] sending ${buf.byteLength.toLocaleString()} bytes to voice WS`,
+      `[Recorder] onstop: ${captured.length} chunk(s), ${captured
+        .reduce((s, c) => s + c.size, 0)
+        .toLocaleString()} bytes total`,
     );
 
+    // ── 3. Validate ────────────────────────────────────────────────────────
+    if (!captured.length) {
+      console.warn('[Recorder] No audio chunks — possible threshold issue');
+      appendMsg(
+        '⚠️ কোনো অডিও রেকর্ড হয়নি। Silence threshold কম���য়ে দেখুন।',
+        'system',
+      );
+      _resetVoiceState();
+      setState('ready');
+      micBtn.disabled = false;
+      return;
+    }
+
+    // ── 4. Build ArrayBuffer ───────────────────────────────────────────────
+    const blob = new Blob(captured, { type: _recorderMime });
+    let buf;
+    try {
+      buf = await blob.arrayBuffer();
+    } catch (err) {
+      console.error('[Recorder] arrayBuffer() error:', err);
+      _resetVoiceState();
+      setState('ready');
+      setMic('off');
+      micBtn.disabled = false;
+      return;
+    }
+
+    console.log(`[VAD] → voice WS: ${buf.byteLength.toLocaleString()} bytes`);
+
+    // ── 5. Send to backend ─────────────────────────────────────────────────
     if (voiceWS && voiceWS.readyState === WebSocket.OPEN) {
-      appendThinking(); // FIX-3: show thinking while STT runs
+      appendThinking();
       voiceWS.send(buf);
+      // isProcessing + isRecordingLocked stay true until _done() fires
     } else {
-      console.warn('[VAD] voice WS not open — dropping utterance');
-      isProcessing = false;
-      if (isListening) setState('listening');
+      console.warn('[VAD] Voice WS not open — utterance dropped');
+      appendMsg('⚠️ সার্ভারের সাথে সংযোগ নেই — আবার চেষ্টা করুন।', 'system');
+      _resetVoiceState();
+      setState('ready');
+      setMic('off');
+      micBtn.disabled = false;
     }
   };
+
   mediaRecorder.start();
+  console.log('[Recorder] Started, mime:', _recorderMime);
 }
 
 function stopRecorder() {
-  if (mediaRecorder && mediaRecorder.state !== 'inactive') mediaRecorder.stop();
-  mediaRecorder = null;
+  if (mediaRecorder && mediaRecorder.state !== 'inactive') {
+    mediaRecorder.stop(); // triggers onstop asynchronously
+  }
 }
 
 function discardRecorder() {
-  if (!mediaRecorder || mediaRecorder.state === 'inactive') return;
+  if (!mediaRecorder || mediaRecorder.state === 'inactive') {
+    audioChunks = [];
+    return;
+  }
   mediaRecorder.ondataavailable = () => {};
   mediaRecorder.onstop = () => {
     audioChunks = [];
   };
   mediaRecorder.stop();
   mediaRecorder = null;
+  audioChunks = [];
 }
 
 // ═══════════════════════════════════════════════════════════════════════════════
@@ -845,7 +932,7 @@ const MIC_MAP = {
   off: { cls: 'mic-off', label: 'Voice শুরু করুন', icon: '🎤' },
   listening: {
     cls: 'mic-listening',
-    label: 'শুনছি… (বন্ধ করতে ক্লিক)',
+    label: 'শুনছি… (বাতিল করতে ক্লিক)',
     icon: '🟢',
   },
   recording: { cls: 'mic-recording', label: 'বলছেন…', icon: '🔴' },
@@ -872,14 +959,12 @@ function appendMsg(text, who) {
   return d;
 }
 
-// ── Clear chat ────────────────────────────────────────────────────────────────
 clearBtn.onclick = () => {
   chatBox.innerHTML = '';
-  thinkingEl = null; // FIX-3: reset reference after clear
+  thinkingEl = null;
   appendMsg('চ্যাট পরিষ্কার করা হয়েছে।', 'system');
 };
 
-// ── Sidebar ───────────────────────────────────────────────────────────────────
 sidebarToggle.onclick = () => {
   sidebarEl.classList.toggle('collapsed');
   sidebarToggle.textContent = sidebarEl.classList.contains('collapsed')
@@ -888,7 +973,6 @@ sidebarToggle.onclick = () => {
 };
 mobileMenuBtn.onclick = () => sidebarEl.classList.toggle('mobile-open');
 
-// ── Settings sliders ──────────────────────────────────────────────────────────
 sThreshold.value = SILENCE_DB;
 sThresholdVal.textContent = SILENCE_DB + ' dB';
 sThreshold.oninput = () => {
@@ -905,12 +989,11 @@ sTimeout.oninput = () => {
 
 sVoice.onchange = () => appendMsg('🔊 TTS voice: ' + sVoice.value, 'system');
 
-// ── Queue animation ───────────────────────────────────────────────────────────
 setInterval(() => {
   if (_inFlight > 0) _vizQ();
 }, 140);
 
 // ═════════════════════════════════════════════════════════════════════════════���═
-//  START
+//  BOOT
 // ═══════════════════════════════════════════════════════════════════════════════
 boot();

tmp.ipynb

@@ -0,0 +1,164 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": 1,
+   "id": "5cbff6ce",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "import aiosqlite, json\n",
+    "async with aiosqlite.connect('core/daa.db') as conn:\n",
+    "    doctors_data = [\n",
+    "        ('Dr. Ahmed Hasan', 'Cardiologist', json.dumps(['Saturday', 'Monday', 'Thursday']), '5 PM - 9 PM', 1200),\n",
+    "        ('Dr. Nusrat Jahan', 'Neurologist', json.dumps(['Sunday', 'Tuesday', 'Wednesday']), '4 PM - 8 PM', 1500),\n",
+    "        ('Dr. Tanvir Islam', 'Orthopedics', json.dumps(['Saturday', 'Tuesday', 'Friday']), '6 PM - 10 PM', 1000),\n",
+    "        ('Dr. Farzana Rahman', 'Gastrologist', json.dumps(['Sunday', 'Monday', 'Thursday']), '10 AM - 2 PM', 900),\n",
+    "        ('Dr. Mahmudul Karim', 'Cardiologist', json.dumps(['Monday', 'Wednesday', 'Saturday']), '3 PM - 7 PM', 800),\n",
+    "\n",
+    "        ('Dr. Sabiha Noor', 'Neurologist', json.dumps(['Saturday', 'Sunday', 'Tuesday']), '9 AM - 1 PM', 700),\n",
+    "        ('Dr. Rakib Hossain', 'Orthopedics', json.dumps(['Sunday', 'Wednesday', 'Thursday']), '5 PM - 9 PM', 850),\n",
+    "        ('Dr. Imran Kabir', 'Gastrologist', json.dumps(['Saturday', 'Monday', 'Tuesday']), '7 PM - 10 PM', 1300),\n",
+    "        ('Dr. Tania Sultana', 'Cardiologist', json.dumps(['Monday', 'Thursday', 'Friday']), '11 AM - 3 PM', 950),\n",
+    "        ('Dr. Faisal Ahmed', 'Neurologist', json.dumps(['Saturday', 'Wednesday', 'Thursday']), '6 PM - 9 PM', 600),\n",
+    "\n",
+    "        ('Dr. Sharmin Akter', 'Orthopedics', json.dumps(['Sunday', 'Tuesday', 'Friday']), '2 PM - 6 PM', 1400),\n",
+    "        ('Dr. Rezaul Karim', 'Gastrologist', json.dumps(['Monday', 'Wednesday', 'Thursday']), '5 PM - 8 PM', 1600),\n",
+    "        ('Dr. Jannatul Ferdous', 'Cardiologist', json.dumps(['Saturday', 'Tuesday', 'Wednesday']), '4 PM - 7 PM', 1100),\n",
+    "        ('Dr. Arif Hossain', 'Neurologist', json.dumps(['Sunday', 'Thursday', 'Monday']), '5 PM - 9 PM', 1000),\n",
+    "        ('Dr. Sadia Islam', 'Orthopedics', json.dumps(['Saturday', 'Wednesday', 'Tuesday']), '10 AM - 1 PM', 500),\n",
+    "\n",
+    "        ('Dr. Kamrul Hasan', 'Gastrologist', json.dumps(['Monday', 'Thursday', 'Saturday']), '6 PM - 10 PM', 1700),\n",
+    "        ('Dr. Mehnaz Chowdhury', 'Cardiologist', json.dumps(['Sunday', 'Tuesday', 'Thursday']), '9 AM - 12 PM', 650),\n",
+    "        ('Dr. Shahriar Alam', 'Neurologist', json.dumps(['Saturday', 'Monday', 'Wednesday']), '3 PM - 7 PM', 1450),\n",
+    "        ('Dr. Tamanna Rahim', 'Orthopedics', json.dumps(['Tuesday', 'Thursday', 'Friday']), '4 PM - 8 PM', 900),\n",
+    "        ('Dr. Nayeem Islam', 'Gastrologist', json.dumps(['Sunday', 'Wednesday', 'Saturday']), '5 PM - 8 PM', 2000),\n",
+    "\n",
+    "        ('Dr. Arafat Hossain', 'Cardiologist', json.dumps(['Saturday', 'Monday', 'Tuesday']), '5 PM - 9 PM', 1200),\n",
+    "        ('Dr. Hridoy Islam', 'Neurologist', json.dumps(['Sunday', 'Thursday', 'Wednesday']), '4 PM - 8 PM', 1500),\n",
+    "        ('Dr. Mahin Rahman', 'Orthopedics', json.dumps(['Saturday', 'Wednesday', 'Friday']), '6 PM - 10 PM', 1000),\n",
+    "        ('Dr. Sazzad Hossain', 'Gastrologist', json.dumps(['Sunday', 'Tuesday', 'Thursday']), '10 AM - 2 PM', 900),\n",
+    "        ('Dr. Iftekhar Alam', 'Cardiologist', json.dumps(['Monday', 'Thursday', 'Saturday']), '3 PM - 7 PM', 800),\n",
+    "\n",
+    "        ('Dr. Tanvir Mahmud', 'Neurologist', json.dumps(['Saturday', 'Tuesday', 'Wednesday']), '9 AM - 1 PM', 700),\n",
+    "        ('Dr. Omar Faruk', 'Orthopedics', json.dumps(['Sunday', 'Wednesday', 'Thursday']), '5 PM - 9 PM', 850),\n",
+    "        ('Dr. Abdullah Al Mamun', 'Gastrologist', json.dumps(['Saturday', 'Monday', 'Friday']), '7 PM - 10 PM', 1300),\n",
+    "        ('Dr. Shahadat Hossain', 'Cardiologist', json.dumps(['Monday', 'Thursday', 'Tuesday']), '11 AM - 3 PM', 950),\n",
+    "        ('Dr. Mahfuzur Rahman', 'Neurologist', json.dumps(['Saturday', 'Thursday', 'Sunday']), '6 PM - 9 PM', 600),\n",
+    "\n",
+    "        ('Dr. Alif Islam', 'Orthopedics', json.dumps(['Sunday', 'Tuesday', 'Wednesday']), '2 PM - 6 PM', 1400),\n",
+    "        ('Dr. Nabil Ahmed', 'Gastrologist', json.dumps(['Monday', 'Wednesday', 'Thursday']), '5 PM - 8 PM', 1600),\n",
+    "        ('Dr. Rafiq Hasan', 'Cardiologist', json.dumps(['Saturday', 'Tuesday', 'Friday']), '4 PM - 7 PM', 1100),\n",
+    "        ('Dr. Samiul Islam', 'Neurologist', json.dumps(['Sunday', 'Thursday', 'Monday']), '5 PM - 9 PM', 1000),\n",
+    "        ('Dr. Towhidur Rahman', 'Orthopedics', json.dumps(['Saturday', 'Wednesday', 'Tuesday']), '10 AM - 1 PM', 500),\n",
+    "\n",
+    "        ('Dr. Kawsar Ahmed', 'Gastrologist', json.dumps(['Monday', 'Thursday', 'Saturday']), '6 PM - 10 PM', 1700),\n",
+    "        ('Dr. Imtiaz Hossain', 'Cardiologist', json.dumps(['Sunday', 'Tuesday', 'Wednesday']), '9 AM - 12 PM', 650),\n",
+    "        ('Dr. Masud Rana', 'Neurologist', json.dumps(['Saturday', 'Monday', 'Thursday']), '3 PM - 7 PM', 1450),\n",
+    "        ('Dr. Nazmul Hasan', 'Orthopedics', json.dumps(['Tuesday', 'Thursday', 'Friday']), '4 PM - 8 PM', 900),\n",
+    "        ('Dr. Sajib Islam', 'Gastrologist', json.dumps(['Sunday', 'Wednesday', 'Monday']), '5 PM - 8 PM', 2000),\n",
+    "\n",
+    "        ('Dr. Rakib Uddin', 'Cardiologist', json.dumps(['Saturday', 'Monday', 'Thursday']), '5 PM - 9 PM', 1200),\n",
+    "        ('Dr. Jewel Rana', 'Neurologist', json.dumps(['Sunday', 'Thursday', 'Tuesday']), '4 PM - 8 PM', 1500),\n",
+    "        ('Dr. Arman Hossain', 'Orthopedics', json.dumps(['Saturday', 'Wednesday', 'Friday']), '6 PM - 10 PM', 1000),\n",
+    "        ('Dr. Tanmoy Islam', 'Gastrologist', json.dumps(['Sunday', 'Tuesday', 'Thursday']), '10 AM - 2 PM', 900),\n",
+    "        ('Dr. Saiful Islam', 'Cardiologist', json.dumps(['Monday', 'Thursday', 'Wednesday']), '3 PM - 7 PM', 800),\n",
+    "\n",
+    "        ('Dr. Mithun Hasan', 'Neurologist', json.dumps(['Saturday', 'Tuesday', 'Friday']), '9 AM - 1 PM', 700),\n",
+    "        ('Dr. Shuvo Ahmed', 'Orthopedics', json.dumps(['Sunday', 'Wednesday', 'Thursday']), '5 PM - 9 PM', 850),\n",
+    "        ('Dr. Farid Hasan', 'Gastrologist', json.dumps(['Saturday', 'Monday', 'Tuesday']), '7 PM - 10 PM', 1300),\n",
+    "        ('Dr. Al Amin', 'Cardiologist', json.dumps(['Monday', 'Thursday', 'Friday']), '11 AM - 3 PM', 950),\n",
+    "        ('Dr. Rashedul Islam', 'Neurologist', json.dumps(['Saturday', 'Thursday', 'Wednesday']), '6 PM - 9 PM', 600),\n",
+    "\n",
+    "        ('Dr. Ayaan Rahman', 'Dentist', json.dumps(['Sunday', 'Tuesday']), '10:00 AM - 02:00 PM', 800),\n",
+    "        ('Dr. Meher Islam', 'Eye Specialist', json.dumps(['Monday', 'Wednesday']), '11:00 AM - 03:00 PM', 1200),\n",
+    "        ('Dr. Samiul Karim', 'Child Specialist', json.dumps(['Friday', 'Saturday']), '09:00 AM - 01:00 PM', 1000),\n",
+    "        ('Dr. Nabila Ahmed', 'Dentist', json.dumps(['Sunday', 'Thursday']), '04:00 PM - 08:00 PM', 900),\n",
+    "        ('Dr. Tanvir Hossain', 'Eye Specialist', json.dumps(['Tuesday', 'Thursday']), '10:00 AM - 01:00 PM', 1100),\n",
+    "        ('Dr. Farzana Chowdhury', 'Child Specialist', json.dumps(['Monday', 'Friday']), '02:00 PM - 06:00 PM', 950),\n",
+    "        ('Dr. Rafiq Hasan', 'Dentist', json.dumps(['Wednesday', 'Saturday']), '12:00 PM - 04:00 PM', 850),\n",
+    "        ('Dr. Jannat Karim', 'Eye Specialist', json.dumps(['Sunday', 'Monday']), '09:00 AM - 12:00 PM', 1300),\n",
+    "        ('Dr. Imran Ali', 'Child Specialist', json.dumps(['Tuesday', 'Friday']), '03:00 PM - 07:00 PM', 1000),\n",
+    "        ('Dr. Sumaiya Noor', 'Dentist', json.dumps(['Thursday', 'Saturday']), '10:00 AM - 02:00 PM', 800),\n",
+    "\n",
+    "        ('Dr. Arif Uddin', 'Eye Specialist', json.dumps(['Monday', 'Thursday']), '11:00 AM - 03:00 PM', 1250),\n",
+    "        ('Dr. Nadia Sultana', 'Child Specialist', json.dumps(['Sunday', 'Wednesday']), '09:00 AM - 01:00 PM', 980),\n",
+    "        ('Dr. Mahmud Rahman', 'Dentist', json.dumps(['Tuesday', 'Friday']), '04:00 PM - 08:00 PM', 870),\n",
+    "        ('Dr. Laila Akter', 'Eye Specialist', json.dumps(['Wednesday', 'Saturday']), '10:00 AM - 02:00 PM', 1150),\n",
+    "        ('Dr. Shafiq Hasan', 'Child Specialist', json.dumps(['Monday', 'Thursday']), '02:00 PM - 06:00 PM', 1020),\n",
+    "        ('Dr. Nayeem Islam', 'Dentist', json.dumps(['Sunday', 'Tuesday']), '09:00 AM - 12:00 PM', 820),\n",
+    "        ('Dr. Amina Rahman', 'Eye Specialist', json.dumps(['Friday', 'Saturday']), '12:00 PM - 04:00 PM', 1400),\n",
+    "        ('Dr. Rakib Hossain', 'Child Specialist', json.dumps(['Tuesday', 'Wednesday']), '10:00 AM - 01:00 PM', 990),\n",
+    "        ('Dr. Tania Sultana', 'Dentist', json.dumps(['Thursday', 'Friday']), '03:00 PM - 07:00 PM', 860),\n",
+    "        ('Dr. Anik Das', 'Eye Specialist', json.dumps(['Sunday', 'Wednesday']), '11:00 AM - 03:00 PM', 1200),\n",
+    "\n",
+    "        ('Dr. Priya Roy', 'Child Specialist', json.dumps(['Monday', 'Saturday']), '09:00 AM - 01:00 PM', 1050),\n",
+    "        ('Dr. Kamal Uddin', 'Dentist', json.dumps(['Tuesday', 'Thursday']), '02:00 PM - 06:00 PM', 780),\n",
+    "        ('Dr. Sabina Yasmin', 'Eye Specialist', json.dumps(['Wednesday', 'Friday']), '10:00 AM - 02:00 PM', 1350),\n",
+    "        ('Dr. Sohel Rana', 'Child Specialist', json.dumps(['Sunday', 'Tuesday']), '04:00 PM - 08:00 PM', 970),\n",
+    "        ('Dr. Nusrat Jahan', 'Dentist', json.dumps(['Monday', 'Friday']), '11:00 AM - 03:00 PM', 890),\n",
+    "\n",
+    "        ('Dr. Mahfuz Alam', 'Eye Specialist', json.dumps(['Thursday', 'Saturday']), '09:00 AM - 12:00 PM', 1250),\n",
+    "        ('Dr. Shanta Akter', 'Child Specialist', json.dumps(['Tuesday', 'Friday']), '01:00 PM - 05:00 PM', 1000),\n",
+    "        ('Dr. Imtiaz Khan', 'Dentist', json.dumps(['Sunday', 'Wednesday']), '10:00 AM - 02:00 PM', 840),\n",
+    "        ('Dr. Farid Hasan', 'Eye Specialist', json.dumps(['Monday', 'Thursday']), '03:00 PM - 07:00 PM', 1180),\n",
+    "        ('Dr. Rina Begum', 'Child Specialist', json.dumps(['Wednesday', 'Saturday']), '09:00 AM - 01:00 PM', 990),\n",
+    "\n",
+    "        ('Dr. Ashikur Rahman', 'Dentist', json.dumps(['Tuesday', 'Friday']), '12:00 PM - 04:00 PM', 870),\n",
+    "        ('Dr. Monira Sultana', 'Eye Specialist', json.dumps(['Sunday', 'Thursday']), '10:00 AM - 02:00 PM', 1300),\n",
+    "        ('Dr. Hasan Mahmud', 'Child Specialist', json.dumps(['Monday', 'Wednesday']), '02:00 PM - 06:00 PM', 1010),\n",
+    "        ('Dr. Shakil Ahmed', 'Dentist', json.dumps(['Friday', 'Saturday']), '09:00 AM - 12:00 PM', 800),\n",
+    "        ('Dr. Tahmina Akhter', 'Eye Specialist', json.dumps(['Tuesday', 'Thursday']), '04:00 PM - 08:00 PM', 1250),\n",
+    "\n",
+    "        ('Dr. Rifat Hossain', 'Child Specialist', json.dumps(['Sunday', 'Monday']), '11:00 AM - 03:00 PM', 980),\n",
+    "        ('Dr. Sadiya Islam', 'Dentist', json.dumps(['Wednesday', 'Friday']), '10:00 AM - 02:00 PM', 860),\n",
+    "        ('Dr. Farhan Karim', 'Eye Specialist', json.dumps(['Saturday', 'Tuesday']), '01:00 PM - 05:00 PM', 1400),\n",
+    "        ('Dr. Nargis Begum', 'Child Specialist', json.dumps(['Thursday', 'Friday']), '09:00 AM - 12:00 PM', 990),\n",
+    "        ('Dr. Zubair Rahman', 'Dentist', json.dumps(['Monday', 'Saturday']), '03:00 PM - 07:00 PM', 900),\n",
+    "\n",
+    "        ('Dr. Iftekhar Alam', 'Eye Specialist', json.dumps(['Sunday', 'Tuesday']), '10:00 AM - 01:00 PM', 1200),\n",
+    "        ('Dr. Shabnam Akter', 'Child Specialist', json.dumps(['Wednesday', 'Thursday']), '02:00 PM - 06:00 PM', 970),\n",
+    "        ('Dr. Arman Hossain', 'Dentist', json.dumps(['Friday', 'Monday']), '11:00 AM - 03:00 PM', 830),\n",
+    "        ('Dr. Mehzabin Noor', 'Eye Specialist', json.dumps(['Tuesday', 'Saturday']), '09:00 AM - 01:00 PM', 1350),\n",
+    "        ('Dr. Rakib Hasan', 'Child Specialist', json.dumps(['Sunday', 'Friday']), '04:00 PM - 08:00 PM', 1000)\n",
+    "        ]\n",
+    "\n",
+    "    await conn.executemany(\"\"\"\n",
+    "    INSERT INTO doctors (doctor_name, category, visiting_days, visiting_time, visiting_money)\n",
+    "    VALUES (?, ?, ?, ?, ?)\n",
+    "    \"\"\", doctors_data)\n",
+    "\n",
+    "    await conn.commit()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "444a1052",
+   "metadata": {},
+   "outputs": [],
+   "source": []
+  }
+ ],
+ "metadata": {
+  "kernelspec": {
+   "display_name": "langgraph",
+   "language": "python",
+   "name": "python3"
+  },
+  "language_info": {
+   "codemirror_mode": {
+    "name": "ipython",
+    "version": 3
+   },
+   "file_extension": ".py",
+   "mimetype": "text/x-python",
+   "name": "python",
+   "nbconvert_exporter": "python",
+   "pygments_lexer": "ipython3",
+   "version": "3.13.13"
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 5
+}