refactor(context): add wait for summary snapshot rebuild and clean up PTY check

Author: waterbang

src/cccc/daemon/context/context_ops.py

@@ -15,6 +15,7 @@
 import json
 import logging
 import threading
+import time
 from enum import Enum
 from pathlib import Path
 from typing import Any, Dict, List, Optional, Set, Tuple
@@ -888,6 +889,21 @@ def _run() -> None:
     return True
 
 
+def _wait_for_summary_snapshot_rebuild(group_id: str, *, timeout_s: float = 1.0) -> bool:
+    gid = str(group_id or "").strip()
+    if not gid:
+        return True
+    deadline = time.monotonic() + max(0.0, float(timeout_s))
+    while True:
+        with _SUMMARY_REBUILD_LOCK:
+            in_flight = gid in _SUMMARY_REBUILD_IN_FLIGHT
+        if not in_flight:
+            return True
+        if time.monotonic() >= deadline:
+            return False
+        time.sleep(0.01)
+
+
 def _get_summary_context_fast(storage: ContextStorage, *, group_id: str) -> Dict[str, Any]:
     snapshot = storage.load_summary_snapshot()
     basis = storage.summary_basis()

src/cccc/daemon/group/group_lifecycle_ops.py

@@ -15,7 +15,6 @@
 from ...kernel.runtime import runtime_start_preflight_error
 from ...runners import headless as headless_runner
 from ...runners import pty as pty_runner
-from ...runners.platform_support import pty_support_error_message
 from ...util.conv import coerce_bool
 from ..actors.actor_profile_runtime import resolve_linked_actor_before_start
 from ..pet.review_scheduler import cancel_pet_review, request_pet_review
@@ -145,8 +144,6 @@ def handle_group_start(
                     },
                 )
             if runner_effective != "headless":
-                if not bool(getattr(pty_runner, "PTY_SUPPORTED", False)):
-                    raise RuntimeError(pty_support_error_message() or "PTY runner is not supported in this environment.")
                 try:
                     mcp_ready = bool(ensure_mcp_installed(runtime, cwd))
                 except Exception as e:

src/cccc/daemon/ops/template_ops.py

@@ -35,7 +35,7 @@
 from ...util.conv import coerce_bool
 from ..actors.actor_profile_runtime import actor_profile_ref
 from ..actors.actor_profile_store import get_actor_profile, get_actor_profile_by_ref
-from ..context.context_ops import _schedule_summary_snapshot_rebuild
+from ..context.context_ops import _schedule_summary_snapshot_rebuild, _wait_for_summary_snapshot_rebuild
 from ..messaging.delivery import THROTTLE, clear_preamble_sent
 
 
@@ -648,6 +648,10 @@ def group_template_import_replace(args: Dict[str, Any]) -> DaemonResponse:
                 _schedule_summary_snapshot_rebuild(group.group_id)
         except Exception:
             pass
+        try:
+            _wait_for_summary_snapshot_rebuild(group.group_id, timeout_s=1.0)
+        except Exception:
+            pass
 
     return DaemonResponse(
         ok=True,

src/cccc/kernel/pet_task_proposals.py

@@ -57,7 +57,8 @@ def _normalize_compare_text(value: Any) -> str:
 
 
 def _quoted_task_title(value: Any) -> str:
-    return f'"{str(value or "").replace("\"", "\\\"")}"'
+    escaped = str(value or "").replace('"', '\\"')
+    return f'"{escaped}"'
 
 
 def _build_task_proposal_message(action: Dict[str, Any]) -> str: