Tool API

import { randomUUID } from 'node:crypto';

const BASE = 'https://conigma-tool-server-production.up.railway.app';
const headers = { Authorization: `Bearer ${process.env.CONNIE_API_KEY}`, 'Content-Type': 'application/json' };

/** Run a tool and wait for its outcome. Reuse `key` if you retry after a lost response. */
async function runTool(toolId, input, key = randomUUID()) {
  let response = await fetch(`${BASE}/api/tool/${encodeURIComponent(toolId)}`, {
    method: 'POST',
    headers: { ...headers, 'Idempotency-Key': key },
    body: JSON.stringify({ input }),
  });
  let operation = await response.json();
  while (response.status === 202) {
    await new Promise((resolve) => setTimeout(resolve, 2000));
    response = await fetch(`${BASE}/api/tool-invocations/${operation.invocationId}`, { headers });
    operation = await response.json();
  }
  if (operation.ok && operation.resultRef) {
    // Results over 1 MiB are fetched separately.
    response = await fetch(`${BASE}/api/tool-invocations/${operation.invocationId}?result=full`, { headers });
    operation = await response.json();
  }
  return operation; // { ok, status, result | error, billing: { chargedCredits, items } }
}

const outcome = await runTool('instagram-profiles-collect-by-url', { url: 'https://www.instagram.com/nasa' });
console.log(outcome.ok ? outcome.result : outcome.error.message, `(${outcome.billing?.chargedCredits ?? 0} credits)`);

import os, time, uuid, requests

BASE = "https://conigma-tool-server-production.up.railway.app"
HEADERS = {"Authorization": f"Bearer {os.environ['CONNIE_API_KEY']}"}

def run_tool(tool_id, tool_input, key=None):
    """Run a tool and wait for its outcome. Reuse `key` if you retry after a lost response."""
    key = key or str(uuid.uuid4())
    r = requests.post(f"{BASE}/api/tool/{requests.utils.quote(tool_id, safe='')}",
                      headers={**HEADERS, "Idempotency-Key": key}, json={"input": tool_input}, timeout=60)
    operation = r.json()
    while r.status_code == 202:
        time.sleep(2)
        r = requests.get(f"{BASE}/api/tool-invocations/{operation['invocationId']}", headers=HEADERS, timeout=30)
        operation = r.json()
    if operation.get("ok") and operation.get("resultRef"):
        r = requests.get(f"{BASE}/api/tool-invocations/{operation['invocationId']}?result=full", headers=HEADERS, timeout=60)
        operation = r.json()
    return operation

outcome = run_tool("instagram-profiles-collect-by-url", {"url": "https://www.instagram.com/nasa"})
print(outcome["result"] if outcome["ok"] else outcome["error"]["message"])