API 接入

#!/usr/bin/env bash
set -euo pipefail
# Requires curl + jq. Set these server-side environment variables first.
: "${WEAVEBIT_API_KEY:?Set your API key}"
: "${WEAVEBIT_REQUEST_ID:?Set and persist one ID for this logical create}"
base='https://api.weavebit.com/v2'

request() {
  local path="$1" body="$2" response
  response=$(curl --silent --show-error --fail-with-body --max-time 30 \
    -X POST "$base/$path" \
    -H "Authorization: Bearer $WEAVEBIT_API_KEY" \
    -H 'Content-Type: application/json' \
    -H "Idempotency-Key: $WEAVEBIT_REQUEST_ID" \
    --data "$body") || return 1
  if ! jq -e '.code == 0' >/dev/null <<<"$response"; then
    printf 'API operation failed; inspect code and message.\n' >&2
    return 1
  fi
  printf '%s' "$response"
}

body='{"check_type":"gfw_full_domain_check","target":[{"domain":"example.com"}],"nodes":["NODE_ID_FROM_GET_NODES"]}'
# Replace the node placeholder using get_nodes; review estimate before create.
# Create can incur charges. Reuse the same body and request ID for a retry.
created=$(request task/create "$body")
batch_id=$(jq -er '.batch_id' <<<"$created")
printf 'Persist batch_id: %s\n' "$batch_id"
first=$(request task/result "$(jq -cn --arg id "$batch_id" \
  '{batch_id:$id,page:1,page_size:200}')")
pages=$(jq -er '.pagination.pages' <<<"$first")
(( pages >= 1 && pages <= 5 )) || exit 1
jq '{batch_status,datas,pagination}' <<<"$first"
for ((page=2; page<=pages; page++)); do
  request task/result "$(jq -cn --arg id "$batch_id" --argjson p "$page" \
    '{batch_id:$id,page:$p,page_size:200}')" | jq '{batch_status,datas,pagination}'
done
# One read pass, not polling. Pending/running: resume later with this batch_id.
# Retain required results before expires_at; never turn null into success.

<?php
// PHP 8+ with cURL. Set and persist these server-side environment variables.
$key = getenv('WEAVEBIT_API_KEY');
$requestId = getenv('WEAVEBIT_REQUEST_ID');
if (!$key || !$requestId) {
    throw new RuntimeException('Set API key and a persistent request ID.');
}
function api(string $path, array $body): array {
    global $key, $requestId;
    $curl = curl_init('https://api.weavebit.com/v2/' . $path);
    curl_setopt_array($curl, [
        CURLOPT_POST => true, CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT => 30, CURLOPT_CONNECTTIMEOUT => 10,
        CURLOPT_HTTPHEADER => ['Authorization: Bearer ' . $key,
            'Content-Type: application/json', 'Idempotency-Key: ' . $requestId],
        CURLOPT_POSTFIELDS => json_encode($body, JSON_THROW_ON_ERROR),
    ]);
    $raw = curl_exec($curl);
    $status = curl_getinfo($curl, CURLINFO_RESPONSE_CODE);
    curl_close($curl);
    if ($raw === false || $status < 200 || $status >= 300) {
        throw new RuntimeException('HTTP request failed; preserve creation idempotency.');
    }
    $data = json_decode($raw, true, 512, JSON_THROW_ON_ERROR);
    if (($data['code'] ?? null) !== 0) {
        throw new RuntimeException('API code: ' . ($data['code'] ?? 'missing'));
    }
    return $data;
}
$body = ['check_type' => 'gfw_full_domain_check',
    'target' => [['domain' => 'example.com']],
    'nodes' => ['NODE_ID_FROM_GET_NODES']];
// Fetch current nodes and review estimate first. Create can incur charges.
$created = api('task/create', $body);
$batchId = $created['batch_id']; // Persist this before querying results.
$first = api('task/result', ['batch_id' => $batchId, 'page' => 1, 'page_size' => 200]);
$pages = (int)$first['pagination']['pages'];
if ($pages < 1 || $pages > 5) throw new RuntimeException('Invalid page count.');
$rows = $first['datas'];
for ($page = 2; $page <= $pages; $page++) {
    $result = api('task/result', ['batch_id' => $batchId, 'page' => $page, 'page_size' => 200]);
    $rows = array_merge($rows, $result['datas']);
}
echo json_encode(['batch_id' => $batchId, 'batch_status' => $first['batch_status'],
    'datas' => $rows], JSON_PRETTY_PRINT | JSON_THROW_ON_ERROR);
// One read pass. If pending/running, resume later with the stored batch_id.
// Retain results before expires_at, preserving 0, 1, and null separately.

# Python 3. Standard library only; credentials stay on your server.
import json
import os
from urllib.request import Request, urlopen

key = os.environ["WEAVEBIT_API_KEY"]
request_id = os.environ["WEAVEBIT_REQUEST_ID"]  # Persist for this logical create.

def api(path, body):
    request = Request("https://api.weavebit.com/v2/" + path,
        data=json.dumps(body).encode("utf-8"), method="POST",
        headers={"Authorization": "Bearer " + key,
                 "Content-Type": "application/json",
                 "Idempotency-Key": request_id})
    # HTTP errors raise; do not blindly retry creation with a new ID.
    with urlopen(request, timeout=30) as response:
        data = json.load(response)
    if data.get("code") != 0:
        raise RuntimeError("API code: " + str(data.get("code")))
    return data

body = {"check_type": "gfw_full_domain_check",
        "target": [{"domain": "example.com"}],
        "nodes": ["NODE_ID_FROM_GET_NODES"]}
# Replace the node placeholder and review estimate first; create can incur charges.
created = api("task/create", body)
batch_id = created["batch_id"]  # Persist this before querying results.
first = api("task/result", {"batch_id": batch_id, "page": 1, "page_size": 200})
pages = int(first["pagination"]["pages"])
if not 1 <= pages <= 5:
    raise RuntimeError("Invalid page count")
rows = list(first["datas"])
for page in range(2, pages + 1):
    result = api("task/result", {"batch_id": batch_id, "page": page, "page_size": 200})
    rows.extend(result["datas"])
print(json.dumps({"batch_id": batch_id, "batch_status": first["batch_status"],
                  "datas": rows}, indent=2))
# One read pass. If pending/running, resume later with the stored batch_id.
# Retain results before expires_at; preserve None (null), 0, and 1 separately.

// Node.js 18+. Credentials and a persistent request ID belong on your server.
const key = process.env.WEAVEBIT_API_KEY;
const requestId = process.env.WEAVEBIT_REQUEST_ID;
if (!key || !requestId) throw new Error('Set API key and a persistent request ID.');

async function api(path, body) {
  const response = await fetch(`https://api.weavebit.com/v2/${path}`, {
    method: 'POST', signal: AbortSignal.timeout(30000),
    headers: { Authorization: `Bearer ${key}`, 'Content-Type': 'application/json',
      'Idempotency-Key': requestId },
    body: JSON.stringify(body),
  });
  if (!response.ok) throw new Error(`HTTP ${response.status}; preserve creation idempotency.`);
  const data = await response.json();
  if (data.code !== 0) throw new Error(`API code: ${data.code}`);
  return data;
}
async function main() {
  const body = { check_type: 'gfw_full_domain_check',
    target: [{ domain: 'example.com' }], nodes: ['NODE_ID_FROM_GET_NODES'] };
  // Fetch current nodes and review estimate first; create can incur charges.
  const created = await api('task/create', body);
  const batchId = created.batch_id; // Persist this before querying results.
  const first = await api('task/result', { batch_id: batchId, page: 1, page_size: 200 });
  const pages = first.pagination.pages;
  if (!Number.isInteger(pages) || pages < 1 || pages > 5) throw new Error('Invalid page count');
  const rows = [...first.datas];
  for (let page = 2; page <= pages; page++) {
    const result = await api('task/result', { batch_id: batchId, page, page_size: 200 });
    rows.push(...result.datas);
  }
  console.log(JSON.stringify({ batch_id: batchId, batch_status: first.batch_status,
    datas: rows }, null, 2));
  // One read pass. If pending/running, resume later with the stored batch_id.
  // Retain results before expires_at; preserve 0, 1, and null separately.
}
main().catch(error => { console.error(error.message); process.exitCode = 1; });