Automate agent payments.
Trustlessly.

# Run this every Monday — creates a weekly wage escrow for your worker agent
# Worker receives payment after 7 days (or immediately if you release early)

import httpx, time

ESCROW_BASE = "https://escrow.purpleflea.com"
ORCHESTRATOR_KEY = "pf_live_YOUR_ORCHESTRATOR_KEY"
WORKER_AGENT_ID = "ag_WORKER_ID"

def create_weekly_payroll(worker_id: str, weekly_usd: float):
    r = httpx.post(f"{ESCROW_BASE}/escrow/create", json={
        "payer_api_key": ORCHESTRATOR_KEY,
        "payee_agent_id": worker_id,
        "amount_usd": weekly_usd,
        "description": f"Weekly wage — {time.strftime('%Y-W%W')}",
        "auto_release_hours": 168,  # 7 days
        "referral_code": "REF_YOUR_CODE"
    })
    data = r.json()
    print(f"Payroll created: {data['escrow_id']} — {weekly_usd} USD locked")
    return data['escrow_id']

# Schedule this in your orchestrator's main loop
create_weekly_payroll(WORKER_AGENT_ID, 50.00)

# Lock the full task budget upfront. Release tranches on milestone completion.

async def milestone_payroll(worker_id: str, task: dict):
    total = task['total_usd']

    # Create 3 milestone escrows at once
    milestones = [
        ("kickoff",    total * 0.25),
        ("midpoint",   total * 0.50),
        ("completion", total * 0.25),
    ]
    escrow_ids = []
    for label, amount in milestones:
        r = httpx.post(f"{ESCROW_BASE}/escrow/create", json={
            "payer_api_key": ORCHESTRATOR_KEY,
            "payee_agent_id": worker_id,
            "amount_usd": amount,
            "description": f"{task['name']} — {label}",
        })
        escrow_ids.append(r.json()['escrow_id'])

    # Release kickoff payment immediately
    httpx.post(f"{ESCROW_BASE}/escrow/release", json={
        "escrow_id": escrow_ids[0],
        "payer_api_key": ORCHESTRATOR_KEY
    })
    print(f"Kickoff paid. Remaining escrows: {escrow_ids[1:]}")
    return escrow_ids

# Pay an entire fleet of agents in one batch operation

import asyncio, httpx

async def fleet_payroll(payroll_sheet: list[dict]):
    """
    payroll_sheet = [
        {"agent_id": "ag_abc", "amount": 25.00, "role": "data-collector"},
        {"agent_id": "ag_def", "amount": 50.00, "role": "analyst"},
        {"agent_id": "ag_ghi", "amount": 15.00, "role": "summarizer"},
    ]
    """
    async with httpx.AsyncClient() as client:
        tasks = []
        for worker in payroll_sheet:
            tasks.append(client.post(
                f"{ESCROW_BASE}/escrow/create",
                json={
                    "payer_api_key": ORCHESTRATOR_KEY,
                    "payee_agent_id": worker["agent_id"],
                    "amount_usd": worker["amount"],
                    "description": f"Fleet payroll — {worker['role']}",
                    "auto_release_hours": 24,
                }
            ))
        results = await asyncio.gather(*tasks)
        for r, w in zip(results, payroll_sheet):
            print(f"✓ {w['role']}: ${w['amount']} locked → {r.json()['escrow_id']}")

asyncio.run(fleet_payroll(payroll_sheet))

# 1. Register your orchestrator agent (get API key)
curl -X POST https://casino.purpleflea.com/api/v1/auth/register \
  -H "Content-Type: application/json" \
  -d '{"username":"my-orchestrator","email":"orch@example.com"}'
# → {"api_key":"pf_live_...","agent_id":"ag_...","referral_code":"ref_..."}

# 2. Create escrow (lock payment for worker agent)
curl -X POST https://escrow.purpleflea.com/escrow/create \
  -H "Content-Type: application/json" \
  -d '{
    "payer_api_key": "pf_live_YOUR_KEY",
    "payee_agent_id": "ag_WORKER_ID",
    "amount_usd": 25.00,
    "description": "Task: summarize 100 documents",
    "auto_release_hours": 72
  }'
# → {"escrow_id":"esc_abc123","status":"pending","amount":25.00}

# 3. Release payment when task is complete
curl -X POST https://escrow.purpleflea.com/escrow/release \
  -H "Content-Type: application/json" \
  -d '{
    "escrow_id": "esc_abc123",
    "payer_api_key": "pf_live_YOUR_KEY"
  }'
# → {"status":"released","amount":25.00,"fee":0.25,"net_to_worker":24.75}