보안 및 컴플라이언스 개요

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) {
  // Step 1: Register transfer
  const transfer = await client.kyt.registerTransfer({
    network: 'ethereum',
    asset: 'ETH',
    transferReference: `deposit-${txHash}`,
    direction: 'received',
    transferTimestamp: new Date().toISOString(),
    txHash: txHash,
    outputAddress: toAddress
  });
  
  // Step 2: Query risk summary
  const summary = await client.kyt.getTransferSummary(transfer.transferId);
  
  // Step 3: Make decision based on risk level
  if (summary.rating === 'highRisk' || summary.rating === 'severe') {
    // Get detailed alerts
    const alerts = await client.kyt.getTransferAlerts(transfer.transferId);
    await flagForReview(txHash, alerts);
    return { status: 'pending_review', alerts };
  }
  
  return { status: 'approved', rating: summary.rating };
}