Live product image updates as assistant speaks (latest-mention wins)

app.py

@@ -531,12 +531,11 @@ def _detect_colors_in_text(text_norm: str) -> set[str]:
     return found
 
 def find_main_product_in_text(text: str) -> dict | None:
-    """Sorguda gecen ANA urunu bul (stok XML duserse fallback olarak kullanilir).
-    Distinctive token kurallari:
-    - Uzun kelimeler (>=4 karakter, ornek: 'marlin', 'domane') ZORUNLU
-    - Model numaralari (1-2 basamakli sayilar: '4', '5', '6') ZORUNLU
-    - Yil benzeri 4-basamakli sayilar (2026) optional
-    TUM zorunlu tokenlar metinde gecmeli."""
+    """Metinde gecen ANA urunu bul. ZORUNLU tokenlar:
+    - 4+ karakter kelimeler (marlin, domane, emonda)
+    - 1-2 basamakli sayilar (model numaralari: 4, 5, 6)
+    Birden fazla urun gecerse, METINDE EN SON gecen kazanir
+    (asistan konustukca son bahsedilen urune gecisin)."""
     try:
         idx = _ensure_index()
         if not idx:
@@ -544,7 +543,7 @@ def find_main_product_in_text(text: str) -> dict | None:
         text_norm = _norm(text)
 
         best = None
-        best_score = 0
+        best_last_pos = -1
         for p in idx["products"]:
             if p['is_variant']:
                 continue
@@ -555,12 +554,20 @@ def find_main_product_in_text(text: str) -> dict | None:
             ]
             if not mandatory:
                 continue
-            if not all(t in text_norm for t in mandatory):
+            # Tum mandatory tokenlar metinde olmali
+            positions = []
+            ok = True
+            for t in mandatory:
+                pos = text_norm.rfind(t)
+                if pos < 0:
+                    ok = False
+                    break
+                positions.append(pos)
+            if not ok:
                 continue
-            # Tie-break: daha fazla token eslesen daha spesifik
-            score = sum(1 for t in tokens if t in text_norm)
-            if score > best_score:
-                best_score = score
+            last_pos = max(positions)
+            if last_pos > best_last_pos:
+                best_last_pos = last_pos
                 best = p
         return _public_view(best)
     except Exception:
@@ -669,7 +676,13 @@ async def realtime_relay(client_ws: WebSocket):
 
             # Asistan transkripti per-response birikir, response.done'da urun aramasi yapilir
             # current_main_link: en son gosterilen ana urun (varyant aramasi icin scope)
-            transcript_buf = {"text": "", "tool_link": None, "current_main_link": None}
+            transcript_buf = {
+                "text": "",
+                "tool_link": None,
+                "current_main_link": None,
+                "last_shown_in_response": None,
+                "last_check_len": 0,
+            }
 
             async def openai_to_client():
                 try:
@@ -694,18 +707,41 @@ async def realtime_relay(client_ws: WebSocket):
                         elif evt_type in ("input_audio_buffer.speech_started", "input_audio_buffer.speech_stopped", "input_audio_buffer.committed", "response.created"):
                             logger.info(f"[Realtime] {evt_type}")
 
-                        # Yeni response basladiginda transkript buffer'i sifirla
+                        # Yeni response basladiginda transkript ve live state sifirla
+                        # tool_link KULLANICI YENI TURNE GECINCE sifirlanir (asagida)
                         if evt_type == "response.created":
                             transcript_buf["text"] = ""
+                            transcript_buf["last_shown_in_response"] = None
+                            transcript_buf["last_check_len"] = 0
+
+                        # Kullanici yeni soru sormaya basladi — yeni turn
+                        if evt_type == "input_audio_buffer.speech_started":
                             transcript_buf["tool_link"] = None
 
-                        # Asistan ses transkripti — fragmanlari biriktir
+                        # Asistan ses transkripti — fragmanlari biriktir + LIVE urun tespiti
                         if evt_type in ("response.audio_transcript.delta",
                                         "response.output_audio_transcript.delta",
                                         "response.output_text.delta"):
                             d = data.get("delta", "")
                             if isinstance(d, str):
                                 transcript_buf["text"] += d
+                                # Her ~80 char'da bir tara (perf icin throttle)
+                                if len(transcript_buf["text"]) - transcript_buf["last_check_len"] >= 80:
+                                    transcript_buf["last_check_len"] = len(transcript_buf["text"])
+                                    live_p = find_main_product_in_text(transcript_buf["text"])
+                                    if live_p and live_p.get("image"):
+                                        live_link = live_p.get("link")
+                                        if live_link != transcript_buf["last_shown_in_response"]:
+                                            transcript_buf["last_shown_in_response"] = live_link
+                                            transcript_buf["current_main_link"] = live_link
+                                            logger.info(f"[product/live] {live_p['name']}")
+                                            try:
+                                                await client_ws.send_text(json.dumps({
+                                                    "type": "product.show",
+                                                    "product": live_p,
+                                                }))
+                                            except Exception:
+                                                pass
 
                         # response.done — sadece RENK OVERRIDE icin transkript kullanilir.
                         # Yeni ana urun gosterimi tamamen TOOL CAGRISINA birakilir (GPT'ye guven).
@@ -756,6 +792,7 @@ async def realtime_relay(client_ws: WebSocket):
                                     transcript_buf["tool_link"] = product.get("link") or product_link
                                     if product.get("link"):
                                         transcript_buf["current_main_link"] = product["link"]
+                                        transcript_buf["last_shown_in_response"] = product["link"]
                                     try:
                                         await client_ws.send_text(json.dumps({
                                             "type": "product.show",