结果查询GET

# 按幂等键查询
curl "https://api.tokentosea.com/v1/results/$REQUEST_KEY" \
  -H "Authorization: Bearer $TOKENTOSEA_API_KEY"

# 按结果 ID 查询
curl "https://api.tokentosea.com/v1/tasks/result_9a1d…" \
  -H "Authorization: Bearer $TOKENTOSEA_API_KEY"

# 重新获取下载链接
curl "https://api.tokentosea.com/v1/assets/asset_…/download-url" \
  -H "Authorization: Bearer $TOKENTOSEA_API_KEY"

import os
import time

import requests

API = "https://api.tokentosea.com/v1"
HEADERS = {"Authorization": "Bearer " + os.environ["TOKENTOSEA_API_KEY"]}
PENDING = {"planned", "sending", "streaming", "upstream_pending", "billing", "archiving", "needs_review"}


def wait_for(request_key: str, interval_s: float = 5, timeout_s: float = 1800) -> dict:
    """轮询直到成功或失败；needs_review 会继续等待人工核对。"""
    deadline = time.monotonic() + timeout_s
    while time.monotonic() < deadline:
        response = requests.get(f"{API}/results/{request_key}", headers=HEADERS, timeout=30)
        if response.status_code == 404:
            raise LookupError("没有该键的已受理调用")
        response.raise_for_status()
        result = response.json()
        if result["status"] not in PENDING:
            return result
        time.sleep(interval_s)
    raise TimeoutError("仍在处理，稍后用同一个键继续查询")


def fresh_url(asset_id: str) -> str:
    response = requests.get(f"{API}/assets/{asset_id}/download-url", headers=HEADERS, timeout=30)
    response.raise_for_status()
    return response.json()["url"]

const API = 'https://api.tokentosea.com/v1';
const headers = { Authorization: `Bearer ${process.env.TOKENTOSEA_API_KEY}` };
const PENDING = new Set(['planned', 'sending', 'streaming', 'upstream_pending', 'billing', 'archiving', 'needs_review']);
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

/** 轮询直到成功或失败；needs_review 会继续等待人工核对。 */
export async function waitFor(requestKey, { intervalMs = 5000, timeoutMs = 1_800_000 } = {}) {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const response = await fetch(`${API}/results/${requestKey}`, { headers });
    if (response.status === 404) throw new Error('没有该键的已受理调用');
    if (!response.ok) throw new Error(`HTTP ${response.status}: ${await response.text()}`);
    const result = await response.json();
    if (!PENDING.has(result.status)) return result;
    await sleep(intervalMs);
  }
  throw new Error('仍在处理，稍后用同一个键继续查询');
}

export async function freshUrl(assetId) {
  const response = await fetch(`${API}/assets/${assetId}/download-url`, { headers });
  if (!response.ok) throw new Error(`HTTP ${response.status}: ${await response.text()}`);
  return (await response.json()).url;
}