Spaces:

Imaginephoenix
/

openenv

Runtime error

App Files Files Community

Imaginephoenix commited on Apr 3

Commit

b409c37

verified ·

1 Parent(s): 990f01b

Delete server.py

Browse files

Files changed (1) hide show

server.py +0 -621

server.py DELETED Viewed

@@ -1,621 +0,0 @@
-"""Flask server wrapper for the OpenEnv email triage environment."""
-import os
-from flask import Flask, Response, jsonify, request
-from environment import EmailTriageEnv
-from tasks import get_task_scenario_count, list_task_ids
-FRONTEND_HTML = """<!doctype html>
-<html lang="en">
-<head>
-    <meta charset="utf-8" />
-    <meta name="viewport" content="width=device-width, initial-scale=1" />
-    <title>Inbox Helper Practice</title>
-    <style>
-        @import url('https://fonts.googleapis.com/css2?family=Space+Grotesk:wght@400;600;700&family=IBM+Plex+Mono:wght@400;500&display=swap');
-        :root {
-            --bg: #f5f1e9;
-            --paper: #fffaf2;
-            --ink: #102433;
-            --accent: #ea6a2a;
-            --accent-soft: #ffd6bf;
-            --line: #d7cabb;
-            --ok: #0f7b6c;
-            --warn: #9a3a12;
-            --radius: 14px;
-        }
-        * { box-sizing: border-box; }
-        body {
-            margin: 0;
-            font-family: 'Space Grotesk', sans-serif;
-            color: var(--ink);
-            background:
-                radial-gradient(1100px 460px at -10% -20%, #f2bc9f 0%, transparent 60%),
-                radial-gradient(1100px 520px at 120% 115%, #b8d7cf 0%, transparent 62%),
-                var(--bg);
-            min-height: 100vh;
-        }
-        .wrap {
-            max-width: 1100px;
-            margin: 28px auto;
-            padding: 0 16px;
-            animation: reveal .45s ease-out;
-        }
-        @keyframes reveal {
-            from { opacity: 0; transform: translateY(10px); }
-            to { opacity: 1; transform: translateY(0); }
-        }
-        .title {
-            display: flex;
-            justify-content: space-between;
-            align-items: baseline;
-            gap: 14px;
-            margin-bottom: 14px;
-        }
-        h1 {
-            margin: 0;
-            font-size: clamp(1.5rem, 2vw, 2.2rem);
-            letter-spacing: .4px;
-        }
-        .subtitle {
-            margin: 6px 0 0;
-            font-size: .95rem;
-            opacity: .8;
-        }
-        .badge {
-            background: var(--accent-soft);
-            border: 1px solid #f2b693;
-            color: #7f2e0b;
-            padding: 6px 10px;
-            border-radius: 999px;
-            font-size: .85rem;
-            font-weight: 600;
-        }
-        .grid {
-            display: grid;
-            grid-template-columns: 1fr;
-            gap: 14px;
-        }
-        @media (min-width: 900px) {
-            .grid { grid-template-columns: 1fr 1fr; }
-            .wide { grid-column: span 2; }
-        }
-        .card {
-            background: var(--paper);
-            border: 1px solid var(--line);
-            border-radius: var(--radius);
-            padding: 14px;
-            box-shadow: 0 8px 28px rgba(16, 36, 51, 0.08);
-        }
-        .card h2 {
-            margin: 0 0 10px;
-            font-size: 1rem;
-            text-transform: uppercase;
-            letter-spacing: .08em;
-            opacity: .86;
-        }
-        .row {
-            display: flex;
-            flex-wrap: wrap;
-            gap: 8px;
-            align-items: center;
-            margin-bottom: 10px;
-        }
-        select, input, textarea, button {
-            font-family: inherit;
-            font-size: .95rem;
-        }
-        select, input, textarea {
-            width: 100%;
-            border: 1px solid #cdbba6;
-            border-radius: 10px;
-            padding: 9px 10px;
-            background: #fff;
-            color: var(--ink);
-        }
-        textarea {
-            min-height: 92px;
-            resize: vertical;
-        }
-        button {
-            border: 0;
-            border-radius: 10px;
-            padding: 9px 12px;
-            font-weight: 700;
-            background: var(--ink);
-            color: #fff;
-            cursor: pointer;
-            transition: transform .12s ease, opacity .12s ease;
-        }
-        button.secondary {
-            background: #285066;
-        }
-        button.accent {
-            background: var(--accent);
-        }
-        button:hover { transform: translateY(-1px); }
-        button:active { transform: translateY(0); opacity: .92; }
-        .status {
-            padding: 8px 10px;
-            border-radius: 10px;
-            background: #eef7f5;
-            border: 1px solid #c7e4de;
-            color: var(--ok);
-            font-weight: 600;
-            min-height: 40px;
-            display: flex;
-            align-items: center;
-        }
-        .status.error {
-            background: #fff1ea;
-            border-color: #ffc8ae;
-            color: var(--warn);
-        }
-        pre {
-            margin: 0;
-            white-space: pre-wrap;
-            background: #0f1b24;
-            color: #d9efe9;
-            border-radius: 10px;
-            padding: 12px;
-            max-height: 340px;
-            overflow: auto;
-            font-family: 'IBM Plex Mono', monospace;
-            font-size: .85rem;
-            border: 1px solid #21313f;
-        }
-        .email-block {
-            background: #fff;
-            border: 1px solid #d9ccbc;
-            border-radius: 10px;
-            padding: 12px;
-        }
-        .email-row {
-            margin-bottom: 8px;
-            font-size: .95rem;
-            line-height: 1.35;
-        }
-        .email-row strong {
-            display: inline-block;
-            min-width: 66px;
-        }
-        .help {
-            margin: 0 0 10px;
-            font-size: .9rem;
-            opacity: .8;
-        }
-    </style>
-</head>
-<body>
-    <div class="wrap">
-        <div class="title">
-            <div>
-                <h1>Inbox Helper Practice</h1>
-                <p class="subtitle">Practice deciding priority, category, and who should handle each email.</p>
-            </div>
-            <span class="badge" id="badge">connecting...</span>
-        </div>
-        <div class="grid">
-            <section class="card">
-                <h2>Start a Scenario</h2>
-                <p class="help">Pick a difficulty, then click Start.</p>
-                <div class="row">
-                    <select id="taskId">
-                        <option value="task_easy">Easy: one clear email</option>
-                        <option value="task_medium">Medium: mixed inbox</option>
-                        <option value="task_hard">Hard: high-risk complaint</option>
-                        <option value="task_production">Production: full inbox simulator</option>
-                    </select>
-                </div>
-                <div id="productionControls" style="display:none;">
-                    <div class="row">
-                        <select id="productionProfile">
-                            <option value="light">Workload: Light</option>
-                            <option value="standard" selected>Workload: Standard</option>
-                            <option value="heavy">Workload: Heavy</option>
-                        </select>
-                    </div>
-                    <div class="row">
-                        <select id="businessHoursMode">
-                            <option value="false" selected>Time Profile: 24x7 inbox</option>
-                            <option value="true">Time Profile: business hours focus</option>
-                        </select>
-                    </div>
-                    <div class="row">
-                        <select id="escalationMode">
-                            <option value="low">Escalation: Low</option>
-                            <option value="normal" selected>Escalation: Normal</option>
-                            <option value="high">Escalation: High</option>
-                        </select>
-                    </div>
-                </div>
-                <div class="row">
-                    <button class="accent" id="btnReset">Start</button>
-                    <button class="secondary" id="btnState">Check Progress</button>
-                </div>
-                <div class="status" id="status">Ready. Start a scenario.</div>
-            </section>
-            <section class="card">
-                <h2>Your Decision</h2>
-                <p class="help">Choose priority, who should handle it, and a short reason.</p>
-                <div class="row">
-                    <select id="label">
-                        <option value="urgent">Urgent</option>
-                        <option value="normal" selected>Normal</option>
-                        <option value="spam">Spam</option>
-                        <option value="archive">Archive</option>
-                    </select>
-                </div>
-                <div class="row">
-                    <input id="routeTo" placeholder="Who should handle this? (billing, safety, engineering, support)" value="general" />
-                </div>
-                <div class="row">
-                    <textarea id="summary" placeholder="Write one clear sentence with key clues from the email.">Needs review.</textarea>
-                </div>
-                <div class="row">
-                    <button id="btnStep">Send Decision</button>
-                </div>
-            </section>
-            <section class="card wide">
-                <h2>Current Email</h2>
-                <div class="email-block">
-                    <div class="email-row"><strong>Subject:</strong> <span id="mailSubject">No email loaded yet.</span></div>
-                    <div class="email-row"><strong>From:</strong> <span id="mailSender">-</span></div>
-                    <div class="email-row"><strong>Message:</strong> <span id="mailBody">Start a scenario to load an email.</span></div>
-                </div>
-            </section>
-            <section class="card wide">
-                <h2>Details (Advanced)</h2>
-                <pre id="output">Waiting for your first action...</pre>
-            </section>
-        </div>
-    </div>
-    <script>
-        const statusEl = document.getElementById('status');
-        const badgeEl = document.getElementById('badge');
-        const outEl = document.getElementById('output');
-        const mailSubjectEl = document.getElementById('mailSubject');
-        const mailSenderEl = document.getElementById('mailSender');
-        const mailBodyEl = document.getElementById('mailBody');
-        const taskIdEl = document.getElementById('taskId');
-        const productionControlsEl = document.getElementById('productionControls');
-        function setStatus(msg, isError = false) {
-            statusEl.textContent = msg;
-            statusEl.classList.toggle('error', isError);
-        }
-        function writeOutput(value) {
-            outEl.textContent = typeof value === 'string' ? value : JSON.stringify(value, null, 2);
-        }
-        function updateEmailPanel(data) {
-            if (!data || !data.observation) {
-                return;
-            }
-            const obs = data.observation;
-            mailSubjectEl.textContent = obs.subject || 'No subject';
-            mailSenderEl.textContent = obs.sender || '-';
-            mailBodyEl.textContent = obs.body || '';
-        }
-        function updateProductionControlsVisibility() {
-            const isProduction = taskIdEl.value === 'task_production';
-            productionControlsEl.style.display = isProduction ? 'block' : 'none';
-        }
-        async function postJson(path, payload) {
-            const response = await fetch(path, {
-                method: 'POST',
-                headers: { 'Content-Type': 'application/json' },
-                body: JSON.stringify(payload || {}),
-            });
-            const text = await response.text();
-            let data = text;
-            try { data = JSON.parse(text); } catch (e) {}
-            if (!response.ok) {
-                throw new Error('HTTP ' + response.status + ' - ' + text);
-            }
-            return data;
-        }
-        async function warmup() {
-            try {
-                const res = await fetch('/meta');
-                const data = await res.json();
-                badgeEl.textContent = data.status === 'ok' ? 'ready' : 'check service';
-            } catch (e) {
-                badgeEl.textContent = 'offline';
-            }
-        }
-        document.getElementById('btnReset').addEventListener('click', async () => {
-            const taskId = taskIdEl.value;
-            setStatus('Starting a new scenario...');
-            try {
-                const payload = { task_id: taskId };
-                if (taskId === 'task_production') {
-                    payload.production_profile = document.getElementById('productionProfile').value;
-                    payload.business_hours_mode = document.getElementById('businessHoursMode').value === 'true';
-                    payload.escalation_mode = document.getElementById('escalationMode').value;
-                }
-                const data = await postJson('/reset', payload);
-                setStatus('Scenario started. Read the email below.');
-                updateEmailPanel(data);
-                writeOutput(data);
-            } catch (e) {
-                setStatus('Could not start scenario. See details below.', true);
-                writeOutput(String(e));
-            }
-        });
-        document.getElementById('btnState').addEventListener('click', async () => {
-            setStatus('Checking progress...');
-            try {
-                const data = await postJson('/state', {});
-                setStatus('Progress updated.');
-                writeOutput(data);
-            } catch (e) {
-                setStatus('Could not fetch progress. See details below.', true);
-                writeOutput(String(e));
-            }
-        });
-        document.getElementById('btnStep').addEventListener('click', async () => {
-            const payload = {
-                label: document.getElementById('label').value,
-                summary: document.getElementById('summary').value,
-                route_to: document.getElementById('routeTo').value,
-            };
-            setStatus('Sending your decision...');
-            try {
-                const data = await postJson('/step', payload);
-                setStatus('Decision saved.');
-                updateEmailPanel(data);
-                writeOutput(data);
-            } catch (e) {
-                setStatus('Could not submit decision. See details below.', true);
-                writeOutput(String(e));
-            }
-        });
-        taskIdEl.addEventListener('change', updateProductionControlsVisibility);
-        updateProductionControlsVisibility();
-        warmup();
-    </script>
-</body>
-</html>
-"""
-app = Flask(__name__)
-current_env = EmailTriageEnv(task_id="task_easy")
-SCENARIO_COUNTERS = {task_id: 0 for task_id in list_task_ids()}
-DEFAULT_EVAL_SPLIT = os.getenv("OPENENV_EVAL_SPLIT", "public")
-ALLOW_CLIENT_EVAL_OVERRIDE = (
-    os.getenv("OPENENV_ALLOW_CLIENT_EVAL_OVERRIDE", "false").strip().lower() == "true"
-)
-@app.get("/")
-def root_page():
-    """Render a lightweight frontend for interacting with the environment."""
-    return Response(FRONTEND_HTML, mimetype="text/html")
-@app.get("/meta")
-def root_endpoint():
-    """Return service metadata for health checks and machine clients."""
-    return jsonify(
-        {
-            "name": "email-triage-env",
-            "status": "ok",
-            "endpoints": {
-                "reset": {"method": "POST", "path": "/reset"},
-                "step": {"method": "POST", "path": "/step"},
-                "state": {"method": "POST", "path": "/state"},
-            },
-            "scenario_pools": {
-                "public": {
-                    task_id: get_task_scenario_count(task_id, "public")
-                    for task_id in list_task_ids()
-                },
-            },
-            "eval_split": DEFAULT_EVAL_SPLIT,
-            "production_runtime_controls": {
-                "production_profile": ["light", "standard", "heavy"],
-                "business_hours_mode": [True, False],
-                "escalation_mode": ["low", "normal", "high"],
-            },
-        }
-    )
-@app.post("/reset")
-def reset_endpoint():
-    """Reset the environment with a selected task and return ResetResult JSON.
-    Returns:
-        Flask response containing reset payload.
-    """
-    global current_env
-    global SCENARIO_COUNTERS
-    payload = request.get_json(silent=True)
-    if payload is None:
-        payload = {}
-    elif not isinstance(payload, dict):
-        return jsonify({"error": "Malformed JSON payload."}), 400
-    task_id = payload.get("task_id", "task_easy")
-    if not isinstance(task_id, str):
-        return jsonify({"error": "Field 'task_id' must be a string."}), 400
-    runtime_options: dict[str, object] = {}
-    if task_id == "task_production":
-        production_profile = payload.get("production_profile", "standard")
-        if not isinstance(production_profile, str) or production_profile not in {
-            "light",
-            "standard",
-            "heavy",
-        }:
-            return (
-                jsonify(
-                    {
-                        "error": (
-                            "Field 'production_profile' must be one of "
-                            "light/standard/heavy."
-                        )
-                    }
-                ),
-                400,
-            )
-        escalation_mode = payload.get("escalation_mode", "normal")
-        if not isinstance(escalation_mode, str) or escalation_mode not in {
-            "low",
-            "normal",
-            "high",
-        }:
-            return (
-                jsonify(
-                    {
-                        "error": (
-                            "Field 'escalation_mode' must be one of "
-                            "low/normal/high."
-                        )
-                    }
-                ),
-                400,
-            )
-        business_hours_mode = payload.get("business_hours_mode", False)
-        if isinstance(business_hours_mode, str):
-            business_hours_mode = business_hours_mode.strip().lower() in {
-                "1",
-                "true",
-                "yes",
-                "on",
-            }
-        elif not isinstance(business_hours_mode, bool):
-            return jsonify({"error": "Field 'business_hours_mode' must be boolean."}), 400
-        runtime_options = {
-            "production_profile": production_profile,
-            "business_hours_mode": business_hours_mode,
-            "escalation_mode": escalation_mode,
-        }
-    if not ALLOW_CLIENT_EVAL_OVERRIDE and (
-        "eval_split" in payload or "scenario_index" in payload
-    ):
-        return jsonify(
-            {
-                "error": (
-                    "Client overrides for eval_split/scenario_index are disabled "
-                    "by server policy."
-                )
-            }
-        ), 400
-    eval_split = DEFAULT_EVAL_SPLIT
-    if ALLOW_CLIENT_EVAL_OVERRIDE:
-        requested_split = payload.get("eval_split", DEFAULT_EVAL_SPLIT)
-        if not isinstance(requested_split, str):
-            return jsonify({"error": "Field 'eval_split' must be a string."}), 400
-        eval_split = requested_split
-    requested_index = payload.get("scenario_index") if ALLOW_CLIENT_EVAL_OVERRIDE else None
-    if requested_index is not None and (not isinstance(requested_index, int) or requested_index < 0):
-        return jsonify({"error": "Field 'scenario_index' must be a non-negative integer."}), 400
-    try:
-        scenario_count = get_task_scenario_count(task_id, eval_split)
-        if requested_index is None:
-            scenario_index = SCENARIO_COUNTERS.get(task_id, 0)
-            if scenario_count > 0:
-                SCENARIO_COUNTERS[task_id] = (scenario_index + 1) % scenario_count
-        else:
-            scenario_index = requested_index
-        current_env = EmailTriageEnv(
-            task_id=task_id,
-            scenario_index=scenario_index,
-            split=eval_split,
-            runtime_options=runtime_options,
-        )
-        reset_result = current_env.reset()
-    except KeyError as error:
-        return jsonify({"error": str(error)}), 400
-    return jsonify(reset_result.model_dump())
-@app.post("/step")
-def step_endpoint():
-    """Advance environment by one action and return StepResult JSON.
-    Returns:
-        Flask response containing step payload.
-    """
-    payload = request.get_json(silent=True)
-    if payload is None:
-        return jsonify({"error": "Malformed JSON payload."}), 400
-    step_result = current_env.step(payload)
-    return jsonify(step_result.model_dump())
-@app.post("/state")
-def state_endpoint():
-    """Return read-only EnvironmentState JSON snapshot.
-    Returns:
-        Flask response containing state payload.
-    """
-    state_result = current_env.state()
-    return jsonify(state_result.model_dump())
-def main() -> None:
-    """Run the Flask app for local and script-based launches."""
-    app.run(host="0.0.0.0", port=7860)
-if __name__ == "__main__":
-    main()