from codex_local_sdk import CodexLocalClient

from codex_local_sdk import CodexLocalClient

client = CodexLocalClient(codex_bin="codex.cmd")

from codex_local_sdk import CodexExecRequest, CodexLocalClient, SandboxMode

client = CodexLocalClient()
result = client.run(
    CodexExecRequest(
        prompt="Summarize this repo in 5 bullets.",
        model="gpt-5.3-codex",
        reasoning_effort="medium",
        sandbox=SandboxMode.READ_ONLY,
    ),
    timeout_seconds=120,
)
print(result.final_message)

from codex_local_sdk import CodexLocalClient

client = CodexLocalClient()

# Convenience wrapper forwards to CodexExecRequest fields.
client.run_prompt(
    "Draft a migration plan.",
    model="gpt-5.3-codex",
    reasoning_effort="high",
)

session, _ = client.start_thread("Start a new task thread", json_output=True)

# Resume APIs expose reasoning and extra CLI passthrough args too.
follow_up = client.resume(
    prompt="Continue with implementation checklist.",
    session_id=session.session_id,
    last=False,
    json_output=True,
    reasoning_effort="medium",
    extra_args=("--config", "codex.toml"),
)

import asyncio
from codex_local_sdk import CodexExecRequest, CodexLocalClient


async def main() -> None:
    client = CodexLocalClient()

    result = await client.run_async(
        CodexExecRequest(prompt="Summarize this repository."),
        timeout_seconds=120,
    )
    print(result.final_message)

    live = await client.run_live_async(
        CodexExecRequest(prompt="Stream event types", json_output=True)
    )
    async for event in live.iter_events():
        print(event.type)
    final = await live.wait()
    print(final.turn_status)


asyncio.run(main())

from codex_local_sdk import CodexExecRequest, CodexLocalClient, RetryPolicy

client = CodexLocalClient(
    retry_policy=RetryPolicy(
        max_attempts=3,
        initial_backoff_seconds=0.5,
        backoff_multiplier=2.0,
        max_backoff_seconds=4.0,
        retry_on_exit_codes=None,      # retry any non-zero exit code
        jitter_ratio=0.2,              # +/-20% jitter
        max_total_retry_seconds=10.0,  # cap total retry window
        retry_on_timeouts=True,
    )
)

result = client.run(CodexExecRequest(prompt="Do work"), timeout_seconds=30)

from codex_local_sdk import CodexLocalClient, JsonFileSessionStore

store = JsonFileSessionStore(".codex_sessions.json")
client = CodexLocalClient(session_store=store)

session, _ = client.start_thread(
    "Create an initial plan",
    session_name="repo-plan",
    timeout_seconds=120,
)

result = client.resume(
    "Continue with concrete tasks",
    session_name="repo-plan",
    last=False,
    json_output=True,
    timeout_seconds=120,
)

record = client.get_session_record("repo-plan")
print(session.session_id, result.turn_status, record.turn_count if record else None)

from codex_local_sdk import CodexClientEvent, CodexExecRequest, CodexLocalClient


def on_event(event: CodexClientEvent) -> None:
    print(event.type, event.operation, event.attempt, event.return_code)


client = CodexLocalClient(event_hook=on_event)
client.run(CodexExecRequest(prompt="Analyze repo"), timeout_seconds=60)

schema = {
    "type": "object",
    "properties": {"project_name": {"type": "string"}},
    "required": ["project_name"],
    "additionalProperties": False,
}

result = client.run_with_schema(
    prompt="Extract project metadata.",
    schema=schema,
    output_json_path="project_metadata.json",
    timeout_seconds=120,
)