UPI-GIT5 API 接入文档

curl -X POST 'https://rustupi.agiapi.top/api/link-cdk/session' \
  -H 'Content-Type: application/json' \
  -d '{"code":"LINK_CDK"}'

const BASE_URL = 'https://rustupi.agiapi.top';
const LINK_CDK = 'LINK_CDK';
const PAYMENT_PROVIDER_ID = 'foarge';

const sessionResponse = await fetch(`${BASE_URL}/api/link-cdk/session`, {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({code: LINK_CDK})
});
const session = await sessionResponse.json();
if (!sessionResponse.ok) throw new Error(session.error?.message || '会话创建失败');

const headers = {
  'Content-Type': 'application/json',
  'X-Link-CDK-Session': session.token
};

async function scopedRequest(path, options = {}) {
  const response = await fetch(`${BASE_URL}${path}`, {
    ...options,
    headers: {...headers, ...(options.headers || {})}
  });
  const data = await response.json();
  if (!response.ok) {
    throw new Error(data.error?.message || data.error || `HTTP ${response.status}`);
  }
  return {response, data};
}

// 1. 保存并登录支付平台 CDK，同时取得剩余次数。
const configured = await scopedRequest('/api/payment/configure', {
  method: 'POST',
  body: JSON.stringify({
    provider_id: PAYMENT_PROVIDER_ID,
    cdk: 'PAYMENT_CDK'
  })
});
if (!configured.data.quota_known || configured.data.quota_blocked) {
  throw new Error('支付 CDK 额度不可用');
}

// 2. 开启当前提链 CDK 租户的自动支付。
await scopedRequest('/api/payment/settings', {
  method: 'POST',
  body: JSON.stringify({
    provider_id: PAYMENT_PROVIDER_ID,
    enabled: true
  })
});

// 3. 创建提链批次。平台标识必须与上面配置的平台一致。
const batchResponse = await fetch(`${BASE_URL}/api/upi-git5/batch`, {
  method: 'POST',
  headers,
  body: JSON.stringify({
    tokens: ['ACCESS_TOKEN'],
    entry_proxies: ['socks5://HOST:PORT'],
    link_cdk: LINK_CDK,
    payment_provider_id: PAYMENT_PROVIDER_ID,
    use_promo: true,
    promo_campaign: 'plus-1-month-free'
  })
});
const batch = await batchResponse.json();
if (batchResponse.status !== 202) {
  throw new Error(batch.error?.message || batch.error || '批次创建失败');
}

// 4. 使用游标增量轮询。Map 保存本地状态，不创建任务卡片 DOM。
const paymentTerminal = new Set([
  'completed', 'failed', 'expired', 'cancelled',
  'quota_insufficient', 'submit_failed', 'tracking_failed'
]);
const jobs = new Map(batch.jobs.map(job => [job.job_id, job]));
let cursor = 0;
let snapshot;
let finished;
do {
  await new Promise(resolve => setTimeout(resolve, 3000));
  ({data: snapshot} = await scopedRequest(
    `/api/upi-git5/batch/${batch.batch_id}/progress?`
      + new URLSearchParams({
          since: String(cursor),
          result: 'compact',
          include_payment: 'true'
        }),
    {method: 'GET'}
  ));
  for (const job of snapshot.jobs) jobs.set(job.id, {...jobs.get(job.id), ...job});
  cursor = snapshot.cursor;
  finished = !snapshot.running && snapshot.payment_active === 0;
} while (!finished);

for (const job of jobs.values()) {
  console.log({
    email: job.account_email,
    link_status: job.status,
    payment_status: job.payment?.status,
    payment_order_id: job.payment?.order_id,
    payment_error: job.payment?.error
  });
}

GET /api/upi-git5/batch/BATCH_ID/progress?summary_only=true&result=none&include_payment=false
X-Link-CDK-Session: SESSION_TOKEN

{
  "batch_size": 5000,
  "completed": 3200,
  "succeeded": 2810,
  "failed": 390,
  "running": true,
  "payment_active": 146,
  "jobs": []
}