Missions

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

// 1. Create the mission
const createRes = await fetch(`${BASE}/missions`, {
  method: "POST",
  headers: {
    Authorization: `Bearer ${API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    name: "code-review-pipeline",
    prompt: "Review the latest PR and provide feedback.",
    qualityThreshold: 4.0,
    tasks: [
      {
        title: "Analyze code changes",
        description: "Review the diff for the latest PR.",
        assignTo: "code-reviewer",
      },
      {
        title: "Write review summary",
        description: "Compile the analysis into a structured review summary.",
        assignTo: "tech-lead",
        dependsOn: ["Analyze code changes"],
      },
    ],
    team: {
      name: "review-team",
      volatile: true,
      agents: [
        {
          name: "code-reviewer",
          role: "Senior code reviewer",
          model: "anthropic/claude-sonnet-4-5",
        },
        {
          name: "tech-lead",
          role: "Technical lead",
          model: "anthropic/claude-sonnet-4-5",
        },
      ],
    },
  }),
});
const mission = await createRes.json();
console.log("Created mission:", mission.id);

// 2. Execute and stream events
const execRes = await fetch(`${BASE}/missions/${mission.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

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

# 1. Create the mission
mission = requests.post(
    f"{BASE}/missions",
    headers={"Authorization": f"Bearer {API_KEY}"},
    json={
        "name": "code-review-pipeline",
        "prompt": "Review the latest PR and provide feedback.",
        "qualityThreshold": 4.0,
        "tasks": [
            {
                "title": "Analyze code changes",
                "description": "Review the diff for the latest PR.",
                "assignTo": "code-reviewer",
            },
            {
                "title": "Write review summary",
                "description": "Compile the analysis into a structured review summary.",
                "assignTo": "tech-lead",
                "dependsOn": ["Analyze code changes"],
            },
        ],
        "team": {
            "name": "review-team",
            "volatile": True,
            "agents": [
                {
                    "name": "code-reviewer",
                    "role": "Senior code reviewer",
                    "model": "anthropic/claude-sonnet-4-5",
                },
                {
                    "name": "tech-lead",
                    "role": "Technical lead",
                    "model": "anthropic/claude-sonnet-4-5",
                },
            ],
        },
    },
).json()

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

# 2. Execute and stream events
with requests.post(
    f"{BASE}/missions/{mission['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())