correlation upgrades

drb-c2-core/app/internal/incident_correlator.py

@@ -249,16 +249,33 @@ async def correlate_call(
 
         if tg_recent and is_thin_call:
             # Status/ack call — no scene data to reason about.
-            # Attach to whichever recent incident was most recently active on this TGID.
-            matched_incident = max(tg_recent, key=lambda inc: inc.get("updated_at", ""))
-            corr_debug = {
-                "corr_path": "fast/thin",
-                "corr_incident_idle_min": round(_incident_idle_minutes(matched_incident, now), 1),
-            }
-            logger.info(
-                f"Correlator fast-path (thin→last TGID incident): "
-                f"call {call_id} → {matched_incident['incident_id']}"
-            )
+            # On dispatch channels (shared backbone), apply a much tighter idle gate so
+            # a "10-4" or "Dispatch." doesn't re-activate an incident that's been quiet
+            # for an hour and then absorb the next unrelated dispatch on the same TGID.
+            if is_dispatch:
+                thin_pool = [
+                    inc for inc in tg_recent
+                    if _incident_idle_minutes(inc, now) <= settings.tg_dispatch_thin_idle_minutes
+                ]
+            else:
+                thin_pool = tg_recent
+
+            if not thin_pool:
+                logger.info(
+                    f"Correlator fast-path thin: dispatch channel idle > "
+                    f"{settings.tg_dispatch_thin_idle_minutes}min, skipping thin call {call_id}"
+                )
+            else:
+                # Attach to whichever pool incident was most recently active on this TGID.
+                matched_incident = max(thin_pool, key=lambda inc: inc.get("updated_at", ""))
+                corr_debug = {
+                    "corr_path": "fast/thin",
+                    "corr_incident_idle_min": round(_incident_idle_minutes(matched_incident, now), 1),
+                }
+                logger.info(
+                    f"Correlator fast-path (thin→last TGID incident): "
+                    f"call {call_id} → {matched_incident['incident_id']}"
+                )
         elif len(tg_recent) == 1:
             candidate = tg_recent[0]
             if _call_fits_incident(

drb-c2-core/app/internal/transcription.py

@@ -116,7 +116,7 @@ def _sync_transcribe(
         openai_client = OpenAI(api_key=settings.openai_api_key)
         with open(tmp_path, "rb") as f:
             response = openai_client.audio.transcriptions.create(
-                model="whisper-1",
+                model=settings.stt_model,
                 file=f,
                 language="en",
                 prompt=prompt,

drb-c2-core/app/internal/vocabulary_learner.py

@@ -18,7 +18,7 @@ import asyncio
 import difflib
 import json
 import random
-from datetime import datetime, timezone
+from datetime import datetime, timezone, timedelta
 from typing import Optional
 from app.internal.logger import logger
 from app.internal import firestore as fstore