安全與合規概述

POST /v1/kyt/address
{
  "network": "ethereum",
  "address": "0x...",
  "asset": "ETH"
}

GET /v1/kyt/addresses/{address}/risk

import { ChainStreamClient } from '@chainstream-io/sdk';

const client = new ChainStreamClient(process.env.CHAINSTREAM_ACCESS_TOKEN);

async function processDeposit(txHash, toAddress) {
  // 步骤 1：注册交易
  const transfer = await client.kyt.registerTransfer({
    network: 'ethereum',
    asset: 'ETH',
    transferReference: `deposit-${txHash}`,
    direction: 'received',
    transferTimestamp: new Date().toISOString(),
    txHash: txHash,
    outputAddress: toAddress
  });
  
  // 步骤 2：查询风险摘要
  const summary = await client.kyt.getTransferSummary(transfer.transferId);
  
  // 步骤 3：根据风险等级决策
  if (summary.rating === 'highRisk' || summary.rating === 'severe') {
    // 获取详细告警信息
    const alerts = await client.kyt.getTransferAlerts(transfer.transferId);
    await flagForReview(txHash, alerts);
    return { status: 'pending_review', alerts };
  }
  
  return { status: 'approved', rating: summary.rating };
}