Tasks

const API_KEY = "sk_live_abc123";
const BASE = "https://{project}.polpo.cloud/v1";

// 1. Create the task
const createRes = await fetch(`${BASE}/tasks`, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    title: "Write unit tests",
    description:
      "Write Jest unit tests for the auth module at src/server/auth.ts.",
    assignTo: "backend-dev",
    maxRetries: 2,
    expectations: [
      { criterion: "Tests cover all three endpoints" },
      { criterion: "Tests pass when run with npm test" },
    ],
    expectedOutcomes: [{ type: "file", path: "tests/auth.test.ts" }],
  }),
});
const task = await createRes.json();
console.log("Created task:", task.id);

// 2. Execute and stream output
const execRes = await fetch(`${BASE}/tasks/${task.id}/execute`, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${API_KEY}`,
    Accept: "text/event-stream",
  },
});

const reader = execRes.body.getReader();
const decoder = new TextDecoder();
while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  process.stdout.write(decoder.decode(value));
}

import requests
import json

API_KEY = "sk_live_abc123"
BASE = "https://{project}.polpo.cloud/v1"

# 1. Create the task
task = requests.post(
    f"{BASE}/tasks",
    headers={"Authorization": f"Bearer {API_KEY}"},
    json={
        "title": "Write unit tests",
        "description": "Write Jest unit tests for the auth module at src/server/auth.ts.",
        "assignTo": "backend-dev",
        "maxRetries": 2,
        "expectations": [
            {"criterion": "Tests cover all three endpoints"},
            {"criterion": "Tests pass when run with npm test"},
        ],
        "expectedOutcomes": [{"type": "file", "path": "tests/auth.test.ts"}],
    },
).json()

print(f"Created task: {task['id']}")

# 2. Execute and stream output
with requests.post(
    f"{BASE}/tasks/{task['id']}/execute",
    headers={
        "Authorization": f"Bearer {API_KEY}",
        "Accept": "text/event-stream",
    },
    stream=True,
) as res:
    for line in res.iter_lines():
        if line:
            print(line.decode())