AI 代理支付：自主加密货币交易

async function requestPayment(userId: string, amount: number, orderId: string) {
  const collection = await xpay.createCollection({
    amount,
    symbol: 'USDT',
    chain: 'TRON',
    orderId,
    uid: userId,
  });

  return {
    depositAddress: collection.data.address,
    expiresAt: collection.data.expiredTime,
    checkoutUrl: collection.data.paymentUrl,
  };
}

app.post('/webhook', (req, res) => {
  const event = xpay.parseWebhook(JSON.stringify(req.body), req.body.sign, req.body.timestamp.toString());

  if (event?.notifyType === 'ORDER_SUCCESS') {
    const data = event.data as any;
    await unlockService(data.orderId, data.actualAmount);
  }

  res.status(200).send('ok');
});

async function payComputeProvider(providerAddress: string, amount: number, jobId: string) {
  const payout = await xpay.createPayout({
    amount,
    symbol: 'USDT',
    chain: 'ETH',
    orderId: `compute-${jobId}`,
    receiveAddress: providerAddress,
    uid: 'ai-agent-01',
  });

  return payout.data.orderId;
}

Agent A  ──POST /v1/order/createCollection──▶  网关  ──返回充值地址──▶  Agent A
                                                                             │
                                                                             │ 将充值地址发送给 Agent B
                                                                             ▼
Agent B  ──发送 USDT 到地址──────────────▶  区块链  ──扫描器检测──▶  网关
                                                                             │
                                                                             │ ORDER_SUCCESS Webhook
                                                                             ▼
Agent A  ──接收 Webhook──▶  履行协议

┌─────────────────────────────────────────────────┐
│                   您的服务器                      │
│                                                   │
│  ┌──────────┐     ┌─────────────┐               │
│  │  Agent A  │────▶│ XPayLabs    │               │
│  │ (买方)    │◀───│ SDK / API   │               │
│  └──────────┘     └──────┬──────┘               │
│                          │                       │
│  ┌──────────┐            │   ┌───────────────┐  │
│  │  Agent B  │───────────┘   │  Webhook      │  │
│  │ (卖方)    │───────────────│  端点         │  │
│  └──────────┘               └───────────────┘  │
│                          │                       │
│                   ┌──────▼──────┐               │
│                   │  区块链     │               │
│                   │  扫描器     │               │
│                   └─────────────┘               │
└─────────────────────────────────────────────────┘

# 环境变量——切勿提交到 git
XPAYLABS_MERCHANT_TOKEN=your-merchant-token
XPAYLABS_API_SECRET=your-api-secret
XPAYLABS_GATEWAY_URL=http://gateway:180

async function waitForConfirmation(orderId: string, maxWaitMs = 120000): Promise<boolean> {
  const start = Date.now();

  while (Date.now() - start < maxWaitMs) {
    const status = await xpay.getOrderStatus(orderId);
    const s = status.data?.status;

    if (s === 'SUCCESS') return true;
    if (s === 'EXPIRED' || s === 'FAILED') return false;

    await new Promise(r => setTimeout(r, 3000));
  }

  return false;
}

const balance = await xpay.getMerchantBalance('USDT');
console.log(`可用：${balance.data?.balance}，冻结：${balance.data?.frozenBalance}`);