|
| 1 | +from __future__ import annotations |
| 2 | + |
| 3 | +from collections.abc import AsyncIterator |
| 4 | +from contextlib import asynccontextmanager |
| 5 | +from typing import TYPE_CHECKING, Any |
| 6 | + |
| 7 | +from .agent_runtime import AgentRuntime |
| 8 | +from .models import SnapshotOptions |
| 9 | +from .tools import ToolRegistry |
| 10 | + |
| 11 | +if TYPE_CHECKING: # pragma: no cover - type hints only |
| 12 | + from playwright.async_api import Page |
| 13 | + |
| 14 | + from .tracing import Tracer |
| 15 | +else: # pragma: no cover - avoid optional runtime imports |
| 16 | + Page = Any # type: ignore |
| 17 | + Tracer = Any # type: ignore |
| 18 | + |
| 19 | + |
| 20 | +class SentienceDebugger: |
| 21 | + """ |
| 22 | + Verifier-only sidecar wrapper around AgentRuntime. |
| 23 | + """ |
| 24 | + |
| 25 | + def __init__(self, runtime: AgentRuntime) -> None: |
| 26 | + self.runtime = runtime |
| 27 | + self._step_open = False |
| 28 | + |
| 29 | + @classmethod |
| 30 | + def attach( |
| 31 | + cls, |
| 32 | + page: Page, |
| 33 | + tracer: Tracer, |
| 34 | + snapshot_options: SnapshotOptions | None = None, |
| 35 | + sentience_api_key: str | None = None, |
| 36 | + tool_registry: ToolRegistry | None = None, |
| 37 | + ) -> SentienceDebugger: |
| 38 | + runtime = AgentRuntime.from_playwright_page( |
| 39 | + page=page, |
| 40 | + tracer=tracer, |
| 41 | + snapshot_options=snapshot_options, |
| 42 | + sentience_api_key=sentience_api_key, |
| 43 | + tool_registry=tool_registry, |
| 44 | + ) |
| 45 | + return cls(runtime=runtime) |
| 46 | + |
| 47 | + def begin_step(self, goal: str, step_index: int | None = None) -> str: |
| 48 | + self._step_open = True |
| 49 | + return self.runtime.begin_step(goal, step_index=step_index) |
| 50 | + |
| 51 | + async def end_step(self, **kwargs: Any) -> dict[str, Any]: |
| 52 | + self._step_open = False |
| 53 | + return await self.runtime.emit_step_end(**kwargs) |
| 54 | + |
| 55 | + @asynccontextmanager |
| 56 | + async def step(self, goal: str, step_index: int | None = None) -> AsyncIterator[None]: |
| 57 | + self.begin_step(goal, step_index=step_index) |
| 58 | + try: |
| 59 | + yield |
| 60 | + finally: |
| 61 | + await self.end_step() |
| 62 | + |
| 63 | + async def snapshot(self, **kwargs: Any): |
| 64 | + return await self.runtime.snapshot(**kwargs) |
| 65 | + |
| 66 | + def check(self, predicate, label: str, required: bool = False): |
| 67 | + if not self._step_open: |
| 68 | + self.begin_step(f"verify:{label}") |
| 69 | + return self.runtime.check(predicate, label, required=required) |
0 commit comments