fix under non-ideal site.

Author: scszcoder

agent/ec_skills/browser_use_extension/event_monitor.py

@@ -2293,6 +2293,23 @@ def _is_nonempty(value: Any) -> bool:
                 _dropped_reasons = []
                 for _item in added_items:
                     _reason = _feige_first_system_row_match(_item)
+                    if _reason and isinstance(_item, dict):
+                        _pending_marker = any(
+                            str(_item.get(k) or "").strip()
+                            for k in (
+                                "pending_timer",
+                                "unread_badge",
+                                "unread",
+                                "needs_action",
+                            )
+                        )
+                        if _pending_marker:
+                            logger.info(
+                                f"[EventMonitor] Feige filter keeping pending "
+                                f"system-looking row for thread enrichment: "
+                                f"reason={_reason!r} customer={_item.get('customer_name')!r}"
+                            )
+                            _reason = ""
                     if not _reason and isinstance(_item, dict):
                         _cust_key = _feige_normalize_customer_key(
                             str(

agent/ec_skills/browser_use_extension/extension_tools_service.py

@@ -3318,6 +3318,10 @@ async def feige_get_chat_thread(params: FeigeGetChatThreadAction, browser_sessio
   }
   function latestCustomerBubble() {
     var wrappers = Array.from(document.querySelectorAll('[data-qa-id="qa-message-warpper"]'));
+    function isTransferMarker(text) {
+      var t = String(text || '').replace(/\s+/g, '').trim();
+      return t === '转人工' || t === '转人工客服' || t === '人工客服';
+    }
     for (var i = wrappers.length - 1; i >= 0; i--) {
       var wrap = wrappers[i];
       var row = wrap.querySelector('.Ie29C7uLyEjZzd8JeS8A');
@@ -3344,6 +3348,7 @@ async def feige_get_chat_thread(params: FeigeGetChatThreadAction, browser_sessio
         }
       }
       if (!text && !hasContentImage) continue;
+      if (text && isTransferMarker(text)) continue;
       var idEl = wrap.querySelector('[data-id]');
       return {
         found: true,

agent/ec_skills/browser_use_extension/hooks/external/feige_chat/dom_assets.py

@@ -517,6 +517,10 @@ def _normalize_reply_text(text: str) -> str:
     }
     return atts;
   }
+  function _isTransferMarker(text) {
+    var t = String(text || '').replace(/\s+/g, '').trim();
+    return t === '转人工' || t === '转人工客服' || t === '人工客服';
+  }
   var wrappers = Array.from(document.querySelectorAll('[data-qa-id="qa-message-warpper"]'));
   for (var i = wrappers.length - 1; i >= 0; i--) {
     var wrap = wrappers[i];
@@ -533,6 +537,7 @@ def _normalize_reply_text(text: str) -> str:
     // a content image.  Image-only bubbles (text === '') were silently
     // dropped before this change.
     if (!text && attachments.length === 0) continue;
+    if (text && _isTransferMarker(text)) continue;
     // ── Merge attachments from immediately-prior customer bubbles ──
     // Real-world multimodal chats fire as bursts: e.g. (image, text)
     // or (text, image, text).  When the latest bubble we picked is
@@ -1435,6 +1440,41 @@ async def scrape_latest_customer_bubble(
                 break
             if _attempt == 0:
                 await _s_asyncio.sleep(0.25)
+        if not verify_ok:
+            logger.info(
+                f"[BrowserAutomation] scrape-latest-customer: active-customer "
+                f"verification mismatch after sidebar click for {customer_name!r}; "
+                "retrying click once"
+            )
+            retry_raw = await _s_eval_js(browser_session, _click_js)
+            if isinstance(retry_raw, str):
+                try:
+                    retry_data = json.loads(retry_raw)
+                except Exception:
+                    retry_data = {}
+            else:
+                retry_data = retry_raw if isinstance(retry_raw, dict) else {}
+            if retry_data.get("ok"):
+                if not retry_data.get("already_active"):
+                    await _s_asyncio.sleep(0.5)
+                for _attempt in range(3):
+                    verify_raw = await _s_eval_js(
+                        browser_session, FEIGE_ACTIVE_CUSTOMER_JS
+                    )
+                    if isinstance(verify_raw, str):
+                        try:
+                            verify_data = json.loads(verify_raw)
+                        except Exception:
+                            verify_data = {}
+                    else:
+                        verify_data = verify_raw if isinstance(verify_raw, dict) else {}
+                    verify_ok, verify_reason = verify_customer_match(
+                        verify_data, customer_name
+                    )
+                    if verify_ok:
+                        break
+                    if _attempt < 2:
+                        await _s_asyncio.sleep(0.25)
         if not verify_ok:
             logger.warning(
                 f"[BrowserAutomation] scrape-latest-customer: active-customer "

agent/ec_skills/browser_use_extension/hooks/external/feige_chat/hot_path.py

@@ -68,6 +68,7 @@
 import inspect
 import json
 import logging
+import os
 from dataclasses import dataclass, field
 from typing import Any, Callable
 
@@ -95,7 +96,13 @@
 PRE_SEND_REVERIFY_ATTEMPTS: int = 16
 PRE_SEND_REVERIFY_INTERVAL_S: float = 0.075
 POST_SEND_TAB_RESTORE_SLEEP_S: float = 0.3
-HOT_PATH_TOOL_TIMEOUT_S: float = 4.0
+try:
+    HOT_PATH_TOOL_TIMEOUT_S: float = max(
+        1.0,
+        float(os.getenv("ECAN_HOT_PATH_TOOL_TIMEOUT_S", "8.0")),
+    )
+except Exception:
+    HOT_PATH_TOOL_TIMEOUT_S = 8.0
 
 
 @dataclass

agent/ec_skills/browser_use_extension/hooks/external/feige_chat/hot_path_v2.py

@@ -49,6 +49,7 @@
 import asyncio
 import json
 import logging
+import os
 from dataclasses import dataclass, field
 from typing import Any, Callable, Protocol, runtime_checkable
 
@@ -86,7 +87,13 @@
 PRE_SEND_REVERIFY_ATTEMPTS: int = 16
 PRE_SEND_REVERIFY_INTERVAL_S: float = 0.075
 POST_SEND_TAB_RESTORE_SLEEP_S: float = 0.3
-HOT_PATH_TOOL_TIMEOUT_S: float = 4.0
+try:
+    HOT_PATH_TOOL_TIMEOUT_S: float = max(
+        1.0,
+        float(os.getenv("ECAN_HOT_PATH_TOOL_TIMEOUT_S", "8.0")),
+    )
+except Exception:
+    HOT_PATH_TOOL_TIMEOUT_S = 8.0
 ACTIVE_CUSTOMER_EVAL_TIMEOUT_S: float = 0.75
 SOURCE_TURN_EVAL_TIMEOUT_S: float = 1.0
 

agent/ec_skills/browser_use_extension/hooks/external/feige_chat/pre_dispatch_enrich.py

@@ -457,6 +457,26 @@ async def enrich_item(
         )
         _row_hit = _first_row_match(item)
         if _row_hit:
+            _pending_marker = any(
+                str(item.get(k) or "").strip()
+                for k in (
+                    "pending_timer",
+                    "unread_badge",
+                    "unread",
+                    "needs_action",
+                )
+            )
+            if typing_lock_sidebar_only and _pending_marker:
+                logger.info(
+                    f"[BrowserAutomation] {log_tag} system-looking pending "
+                    f"row deferred while typing lock is active for "
+                    f"cust={customer_key!r} reason={_row_hit!r}"
+                )
+                return EnrichResult(
+                    skip=True,
+                    skip_reason="typing_lock_active",
+                    scraped_msg_id="",
+                )
             logger.info(
                 f"[BrowserAutomation] {log_tag} system-message filter "
                 f"SKIP for cust={customer_key!r} reason={_row_hit!r}"

agent/ec_skills/build_node.py

@@ -240,6 +240,7 @@ def _normalize_dispatch_identity_key(raw_id: str) -> str:
 def _stale_input_has_undelivered_response_text(
     stale_input: Any,
     new_event_type: str,
+    previous_hot_path_type: str = "",
 ) -> tuple[bool, str, str]:
     """Detect if a soon-to-be-cleared ``state["input"]`` carries a Q&A
     worker reply that HOT-PATH-B has not yet typed into Feige.
@@ -273,6 +274,14 @@ def _stale_input_has_undelivered_response_text(
     """
     if new_event_type == "chat_message":
         return False, "", ""
+    if previous_hot_path_type in {
+        "action_failed",
+        "configurable",
+        "dedup_skip",
+        "stale_reply_drop",
+        "system_reply_drop",
+    }:
+        return False, "", ""
     if not stale_input:
         return False, "", ""
     try:
@@ -7215,10 +7224,19 @@ def _deep_merge(a: dict, b: dict) -> dict:
         # non-chat_message resume here would silently drop the reply.
         # Restore it so HOT-PATH-B's ``state["input"]`` payload-source
         # fallback can pick it up on the next BA invocation.
+        _prev_hot_path_type = ""
+        if isinstance(state.get("result"), dict):
+            _prev_llm_result = state["result"].get("llm_result")
+            if isinstance(_prev_llm_result, dict):
+                _prev_hot_path_type = str(
+                    _prev_llm_result.get("hot_path_type") or ""
+                )
         try:
             _preserve, _undeliv_cust, _undeliv_resp = (
                 _stale_input_has_undelivered_response_text(
-                    _stale_input, _rp_event_type
+                    _stale_input,
+                    _rp_event_type,
+                    previous_hot_path_type=_prev_hot_path_type,
                 )
             )
             if _preserve:

agent/ec_skills/node_runtime/frontdesk_dispatch.py

@@ -323,9 +323,10 @@ def _build_deferred_result(
     *,
     reason: str,
     detail: str = "",
+    retry: bool = False,
 ) -> dict:
     payload = {
-        "all_done": True,
+        "all_done": not retry,
         "work_done": False,
         "hot_path": True,
         "hot_path_type": "pre_dispatch_deferred",
@@ -337,6 +338,8 @@ def _build_deferred_result(
     }
     if detail:
         payload["detail"] = detail
+    if retry:
+        payload["retry_pending"] = True
     return {
         "final": json.dumps(payload, ensure_ascii=False),
         "history": f"{cfg.history_prefix}:deferred:{reason}",
@@ -505,6 +508,14 @@ def _pick_first(item: dict, keys: list[str]) -> str:
             # duplicate worker invocations and racing replies.
             "identity_key": str(item.get("identity_key") or ""),
         }
+        for pending_key in (
+            "pending_timer",
+            "unread_badge",
+            "unread",
+            "needs_action",
+        ):
+            if pending_key in item:
+                entry[pending_key] = item.get(pending_key)
         for extra_key in cfg.assignment_extra_fields:
             ek = str(extra_key)
             if ek and ek not in entry and ek in item:
@@ -908,7 +919,7 @@ def _release_inflight_on_early_exit(reason: str) -> None:
         if enrich.skip:
             skip_reason = enrich.skip_reason or "unspecified"
             _release_inflight_on_early_exit(f"enrich_skip:{skip_reason}")
-            if skip_reason == "typing_lock_active":
+            if skip_reason in {"typing_lock_active", "active_customer_mismatch"}:
                 return "", "", _TYPING_LOCK_ACTIVE_SENTINEL
             return opened_row, "", ""
         scraped_msg_id = enrich.scraped_msg_id
@@ -1025,19 +1036,21 @@ def _build_result_payload(
     opened_rows: list[str],
     assigned_rows: list[str],
     failure_rows: list[str],
+    deferred_rows: list[str] | None = None,
 ) -> dict:
     """Final result dict returned to the caller when dispatch ran
     (even partially).  Matches the shape of the legacy inline
     ``_maybe_run_frontdesk_dispatch_fastpath`` return.
     """
-    return {
-        "all_done": True,
+    deferred_rows = deferred_rows or []
+    payload = {
+        "all_done": not bool(deferred_rows),
         "work_result": {
             cfg.fastpath_marker: True,
             "visible_session_count": len(actionable),
             "opened_count": len(opened_rows),
             "assigned_count": len(assigned_rows),
-            "last_action_succeeded": not bool(failure_rows),
+            "last_action_succeeded": not bool(failure_rows or deferred_rows),
             "no_customers": False,
         },
         "opened_sessions": opened_rows,
@@ -1049,6 +1062,28 @@ def _build_result_payload(
             else f"{cfg.log_tag} completed with failures"
         ),
     }
+    if deferred_rows:
+        payload["work_done"] = False
+        payload["hot_path"] = True
+        payload["hot_path_type"] = "pre_dispatch_deferred"
+        payload["reason"] = "feige_focus_contention"
+        payload["retry_pending"] = True
+        payload["deferred_sessions"] = deferred_rows
+        payload["work_result"]["deferred_count"] = len(deferred_rows)
+        payload["message"] = (
+            f"{cfg.log_tag} partially completed; "
+            f"{len(deferred_rows)} row(s) deferred"
+        )
+    return payload
+
+
+def _deferred_row_label(item: dict) -> str:
+    return str(
+        item.get("session_id")
+        or item.get("customer_name")
+        or item.get("customer_id")
+        or _TYPING_LOCK_ACTIVE_SENTINEL
+    )
 
 
 # ───────────────────────────── orchestrator ───────────────────────────────
@@ -1256,6 +1291,7 @@ async def _run_with_lock_held(
     opened_rows: list[str] = []
     assigned_rows: list[str] = []
     failure_rows: list[str] = []
+    deferred_rows: list[str] = []
     for item in actionable:
         opened, assigned, failure = await _dispatch_one_item(
             item,
@@ -1272,23 +1308,45 @@ async def _run_with_lock_held(
         if assigned:
             assigned_rows.append(assigned)
         if failure:
-            failure_rows.append(failure)
+            if failure == _TYPING_LOCK_ACTIVE_SENTINEL:
+                deferred_rows.append(_deferred_row_label(item))
+            else:
+                failure_rows.append(failure)
 
     if not opened_rows and not assigned_rows and not failure_rows:
+        if deferred_rows:
+            return _build_deferred_result(
+                cfg,
+                reason="feige_focus_contention",
+                detail=f"{len(deferred_rows)} row(s) deferred",
+                retry=True,
+            )
         return None
 
-    payload = _build_result_payload(cfg, actionable, opened_rows, assigned_rows, failure_rows)
+    payload = _build_result_payload(
+        cfg,
+        actionable,
+        opened_rows,
+        assigned_rows,
+        failure_rows,
+        deferred_rows,
+    )
     logger.info(
         f"[BrowserAutomation] {cfg.log_tag} completed: "
         f"visible={len(actionable)} opened={len(opened_rows)} "
-        f"assigned={len(assigned_rows)} failures={len(failure_rows)}"
+        f"assigned={len(assigned_rows)} failures={len(failure_rows)} "
+        f"deferred={len(deferred_rows)}"
     )
     # Signal any concurrently-running LLM invocation to stop — it would
     # just duplicate work.
     assigned_sessions = dispatch_state.setdefault("assigned_sessions", {})
-    if assigned_rows or (not failure_rows and assigned_sessions):
+    if not deferred_rows and (assigned_rows or (not failure_rows and assigned_sessions)):
         setattr(session, cfg.flag_attr, True)
     return {
         "final": json.dumps(payload, ensure_ascii=False),
-        "history": cfg.history_prefix,
+        "history": (
+            f"{cfg.history_prefix}:deferred:feige_focus_contention"
+            if deferred_rows
+            else cfg.history_prefix
+        ),
     }

mcp_tools_schema.json

@@ -1,5 +1,5 @@
 {
-  "generated_at": "2026-05-07T00:08:34.478751",
+  "generated_at": "2026-05-07T16:58:33.055493",
   "total_tools": 132,
   "tools": [
     {