Cloudflare Bridges¶

from bernstein.bridges.base import BridgeConfig, SpawnRequest
from bernstein.bridges.cloudflare import CloudflareBridge

config = BridgeConfig(
    bridge_type="cloudflare",
    endpoint="https://bernstein-agent.myaccount.workers.dev",
    api_key="cf_token_...",
    extra={
        "account_id": "abc123",
        "worker_name": "bernstein-agent",
    },
)

bridge = CloudflareBridge(config)
status = await bridge.spawn(SpawnRequest(
    agent_id="agent-001",
    prompt="Add input validation to all API endpoints",
    model="sonnet",
    role="backend",
    effort="high",
))

# Poll status
current = await bridge.status("agent-001")

# Fetch logs
logs = await bridge.logs("agent-001", tail=100)

# Cancel if needed
await bridge.cancel("agent-001")

from bernstein.bridges.base import BridgeConfig, SpawnRequest
from bernstein.bridges.cloudflare_workflow import CloudflareWorkflowBridge

config = BridgeConfig(
    bridge_type="cloudflare-workflow",
    api_key="cf_token_...",
    extra={
        "account_id": "abc123",
        "worker_name": "bernstein-agent",
    },
)

bridge = CloudflareWorkflowBridge(config)

# Dispatch a workflow
status = await bridge.spawn(SpawnRequest(
    agent_id="task-42",
    prompt="Refactor the auth module",
    model="opus",
    role="architect",
))

# Check detailed workflow status
wf_status = await bridge.get_workflow_status("task-42")
print(wf_status.current_step)   # WorkflowStep.EXECUTE
print(wf_status.retries_used)   # 0

# Approve a workflow waiting at the approval gate
await bridge.approve("task-42")

from bernstein.bridges.base import BridgeConfig, SpawnRequest
from bernstein.bridges.cloudflare_sandbox import CloudflareSandboxBridge

config = BridgeConfig(
    bridge_type="cloudflare-sandbox",
    endpoint="https://api.cloudflare.com",
    api_key="cf_token_...",
    extra={
        "account_id": "abc123",
        "sandbox_type": "container",
        "max_memory_mb": 256,
        "max_execution_seconds": 600,
        "r2_bucket": "bernstein-workspaces",
    },
)

bridge = CloudflareSandboxBridge(config)

status = await bridge.spawn(SpawnRequest(
    agent_id="agent-sandbox-01",
    prompt="Run the test suite and fix failures",
    model="sonnet",
    role="qa",
))

# List files modified in the sandbox (for selective R2 download)
artifacts = await bridge.download_artifacts("sandbox-id-from-metadata")

from bernstein.bridges.browser_rendering import BrowserConfig, BrowserRenderingBridge

browser = BrowserRenderingBridge(BrowserConfig(
    account_id="abc123",
    api_token="cf_token_...",
))

# Render a page and extract content
page = await browser.render("https://example.com", screenshot=True)
print(page.title)
print(page.content[:500])
print(page.links)

# Scrape structured data
data = await browser.scrape(
    "https://example.com",
    selector=".article",
    attributes=["text", "href"],
)

# Take a full-page screenshot (returns PNG bytes)
png = await browser.screenshot("https://example.com", full_page=True)

# Generate a PDF
pdf_bytes = await browser.pdf("https://docs.example.com")

# Execute JavaScript
result = await browser.execute_script(
    "https://example.com",
    "return document.querySelectorAll('a').length",
)

(".git", "__pycache__", "node_modules", ".venv", "*.pyc", ".sdd/runtime", ".sdd/logs")

from pathlib import Path
from bernstein.bridges.r2_sync import R2Config, R2WorkspaceSync

sync = R2WorkspaceSync(R2Config(
    account_id="abc123",
    api_token="cf_token_...",
))

# Upload workspace before agent runs
manifest = await sync.upload(
    workdir=Path("/path/to/project"),
    workspace_id="task-123",
)
print(f"Uploaded {manifest.file_count} files, {manifest.total_bytes} bytes")

# Download modified files after agent completes
result = await sync.download(
    workdir=Path("/path/to/project"),
    workspace_id="task-123",
)
print(f"Downloaded {result.files_downloaded} changed files")
print(f"Changed: {result.files_changed}")

# Clean up after task completion
await sync.cleanup(workspace_id="task-123")