wehub-resource-sync
4b6817381b
CI (OpenClaw E2E) / openclaw test (push) Has been cancelled
CI / coverage-report (push) Has been cancelled
CI / test-kubernetes (push) Has been cancelled
CI / should-run-thorough (push) Has been cancelled
CI / test-thorough (cloudwatch-demo) (push) Has been cancelled
CI / test-thorough (flink-ecs) (push) Has been cancelled
CI / test-thorough (upstream-lambda) (push) Has been cancelled
CI / test-thorough (prefect-ecs-fargate) (push) Has been cancelled
Release / build-binaries (zip, opensre.exe, onefile, windows-latest, windows-x64) (push) Has been cancelled
Benchmark image — build + push to ECR (any adapter) / build + push (push) Has been cancelled
CI / quality (ubuntu-latest) (push) Has been cancelled
CI / test (tools-runtime) (push) Has been cancelled
CI / test (e2e-general) (push) Has been cancelled
CI / test (cli-runtime) (push) Has been cancelled
CI / test (e2e-provider-and-openclaw) (push) Has been cancelled
CI / test (integrations-and-misc) (push) Has been cancelled
Release / verify (push) Has been cancelled
Release / build-python-dist (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, macos-15-intel, darwin-x64) (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, macos-latest, darwin-arm64) (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, ubuntu-22.04, linux-x64) (push) Has been cancelled
Release / publish-release (push) Has been cancelled
Release / publish-main-release (push) Has been cancelled
Interactive Shell Live (PR + post-merge) / turn-checks (no-LLM) (push) Has been cancelled
CodeQL / Analyze (python) (push) Has been cancelled
Interactive Shell Live (PR + post-merge) / turn-live shard ${{ matrix.shard_index }} (push) Has been cancelled
Release / prepare (push) Has been cancelled
Release / build-binaries (tar.gz, opensre, onedir, ubuntu-22.04-arm, linux-arm64) (push) Has been cancelled
Synthetic Deterministic Tests / Synthetic offline (deterministic) (push) Has been cancelled
55 lines
1.8 KiB
Python
55 lines
1.8 KiB
Python
"""Non-interactive initial-input replay for REPL startup."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from rich.console import Console
|
|
|
|
from platform.analytics.repl_context import bound_repl_turn_context
|
|
from surfaces.interactive_shell.session import Session
|
|
from surfaces.interactive_shell.ui.banner import render_banner
|
|
from surfaces.interactive_shell.ui.input_prompt.rendering import render_submitted_prompt
|
|
from surfaces.interactive_shell.utils.telemetry import PromptRecorder
|
|
|
|
_TURN_KIND = "agent"
|
|
|
|
|
|
def run_initial_input(
|
|
initial_input: str,
|
|
session: Session,
|
|
) -> int:
|
|
# Imported lazily so importing this module during REPL boot (main.py imports
|
|
# ``run_initial_input`` at top) does not pull the harness/turn-execution
|
|
# stack into the base import path when there is no initial input to replay.
|
|
from surfaces.interactive_shell.runtime.shell_turn_execution import execute_shell_turn
|
|
|
|
console = Console(
|
|
highlight=False,
|
|
force_terminal=True,
|
|
color_system="truecolor",
|
|
legacy_windows=False,
|
|
)
|
|
render_banner(console)
|
|
for line in initial_input.splitlines():
|
|
stripped = line.strip()
|
|
if not stripped:
|
|
continue
|
|
render_submitted_prompt(console, session, stripped)
|
|
recorder = PromptRecorder.start(session=session, text=stripped, turn_kind=_TURN_KIND)
|
|
with bound_repl_turn_context(
|
|
session_id=session.session_id,
|
|
turn_kind=_TURN_KIND,
|
|
prompt_turn_id=recorder.turn_id if recorder is not None else None,
|
|
):
|
|
execute_shell_turn(
|
|
stripped,
|
|
session,
|
|
console,
|
|
recorder=recorder,
|
|
confirm_fn=None,
|
|
is_tty=False,
|
|
)
|
|
return 0
|
|
|
|
|
|
__all__ = ["run_initial_input"]
|