Run coding agents from your own tools: plan, then implement

export PRIZED_API_KEY=dcp_…
API=https://api.prized.dev/api/v1
AUTH="Authorization: Bearer $PRIZED_API_KEY"
EDGE=$(curl -s "$API/me" -H @<(echo "$AUTH") | jq -r .edge.url)

curl -s -X POST "$EDGE/v1/box/mango/exec" -H @<(echo "$AUTH") -H "Content-Type: application/json" -d '{"command":"git -C ~/code/myproject worktree add -b plan-1 ~/code/myproject-plan-1","timeoutSeconds":120}' | jq '{exitCode, stderr}'

curl -s -X POST "$EDGE/v1/box/mango/prompts" -H @<(echo "$AUTH") -H "Content-Type: application/json" -d '{"provider":"claude","model":"opus","prompt":"Add rate limiting to the login endpoint. Run the tests, then commit.","cwd":"code/myproject-plan-1","auto":true}' | jq '.run | {id, status}'

prized prompt mango --provider claude --model opus --cwd code/myproject-plan-1 --auto --detach - < item.md

prized prompt mango --provider claude --model opus --cwd code/myproject "Plan this change as one pull request per item. Write the plan to plan.md as a Markdown list, one line per item starting with '- '. Change nothing else."

prized cp mango:code/myproject/plan.md plan.md

import json, os, re, sys, threading, urllib.error, urllib.request
from http.server import BaseHTTPRequestHandler, HTTPServer
from standardwebhooks import Webhook

AUTH = {"Authorization": "Bearer " + os.environ["PRIZED_API_KEY"], "Content-Type": "application/json"}
REPO = os.environ.get("REPO", "code/myproject")  # the repo's folder on the box, under your home

class NoRedirect(urllib.request.HTTPRedirectHandler):
    def redirect_request(self, *args):  # urllib would resend the key to wherever a redirect points
        return None  # so a 3xx raises HTTPError instead

def call(url, body=None):
    req = urllib.request.Request(url, json.dumps(body).encode() if body else None, AUTH)
    try:  # a long wait: a box in deep sleep takes minutes to wake
        with urllib.request.build_opener(NoRedirect).open(req, timeout=600) as r:
            return json.load(r)
    except urllib.error.HTTPError as e:
        raise RuntimeError(f"{url}: {e.code} {e.read().decode()}") from None

def start(plan_file, notify_url, first=1):
    edge = call("https://api.prized.dev/api/v1/me")["edge"]["url"] + "/v1/box/" + os.environ["BOX"]
    items = [line[2:].strip() for line in open(plan_file) if line.startswith("- ")]
    for n, item in list(enumerate(items, 1))[first - 1:]:
        name = f"plan-{n}-" + re.sub(r"[^a-z0-9]+", "-", item.lower())[:30].strip("-")  # branch and folder
        tree = f"{REPO}-{name}"
        made = call(f"{edge}/exec", {"command": f"test -d ~/{tree} || git -C ~/{REPO} worktree add -b {name} ~/{tree}", "timeoutSeconds": 120})
        if made["exitCode"] != 0:
            raise RuntimeError(made["stderr"])
        prompt = f"{item}\n\nYou are in a git worktree on branch {name}. Run the tests, then commit."
        run = call(f"{edge}/prompts", {"provider": "claude", "model": "opus", "prompt": prompt,
                                        "cwd": tree, "auto": True, "notify": notify_url})["run"]
        print(f"{name}: {run['id']}")

class Receiver(BaseHTTPRequestHandler):
    seen = set()  # a retried delivery keeps its event id

    def do_POST(self):
        body = self.rfile.read(int(self.headers["Content-Length"]))
        try:
            data = self.hook.verify(body, dict(self.headers))["data"]
        except Exception:
            return self.send_error(401)
        self.send_response(204)
        self.end_headers()
        if data["run"]["id"] and data["eventId"] not in self.seen:  # id is null for a queued prompt that never ran
            self.seen.add(data["eventId"])
            threading.Thread(target=report, args=(data["run"], data["links"])).start()

def report(run, links):
    try:  # a run's events can be read while its box runs
        count = call(links["run"])["run"]["eventCount"]
        events = call(f"{links['events']}?after={max(count - 20, 0)}")["events"]
        said = [e["text"] for e in events if e.get("text")][-1:]  # the agent's last words
    except Exception as e:
        said = [f"(could not read the run: {e})"]
    print(run["id"], run["status"], *said, flush=True)

if __name__ == "__main__":
    try:
        if sys.argv[1] == "start":
            start(sys.argv[2], sys.argv[3], int(sys.argv[4]) if len(sys.argv) > 4 else 1)
        else:
            Receiver.hook = Webhook(os.environ["PRIZED_WEBHOOK_SECRET"])
            HTTPServer(("", int(sys.argv[2])), Receiver).serve_forever()
    except RuntimeError as e:
        sys.exit(str(e))

- Add a subtract(a, b) function to calc.py, with a test.
- Add a multiply(a, b) function to calc.py, with a test.
- Add a README.md that says what calc.py does and how to run the tests.

pip install standardwebhooks

PRIZED_WEBHOOK_SECRET=whsec_… python orchestrate.py serve 8080

BOX=mango python orchestrate.py start plan.md https://hooks.example.com/prized

git worktree remove ../myproject-plan-1-add-a-subtract-a-b-function-to
git branch -D plan-1-add-a-subtract-a-b-function-to