입금 리스크 체크 통합

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

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

async function registerDeposit(deposit) {
  // KYT 분석을 위해 트랜스퍼 등록
  const response = await client.kyt.registerTransfer({
    network: deposit.network,        // 'bitcoin', 'ethereum', 'Solana'
    asset: deposit.asset,            // 'BTC', 'ETH', 'SOL'
    transferReference: deposit.txHash, // 트랜잭션 해시
    direction: 'received'            // 입금 = received
  });

  return response.transferId;
}

async function getTransferRisk(transferId) {
  // 리스크 평가가 포함된 트랜스퍼 요약 조회
  const summary = await client.kyt.getTransferSummary(transferId);

  // 알림이 있는 경우 상세 조회
  const alerts = await client.kyt.getTransferAlerts(transferId);

  // 직접 노출 정보 조회
  const exposures = await client.kyt.getTransferDirectExposure(transferId);

  return {
    summary,
    alerts,
    exposures
  };
}

async function evaluateDeposit(deposit) {
  // 입금 등록
  const transferId = await registerDeposit(deposit);

  // 리스크 평가 조회
  const { summary, alerts, exposures } = await getTransferRisk(transferId);

  // 알림에 따라 리스크 레벨 판단
  const hasHighRiskAlert = alerts.some(
    alert => alert.severity === 'high' || alert.severity === 'critical'
  );
  const hasMediumRiskAlert = alerts.some(
    alert => alert.severity === 'medium'
  );

  // 리스크에 따라 처리
  if (hasHighRiskAlert) {
    return rejectDeposit(deposit, alerts);
  }

  if (hasMediumRiskAlert) {
    return queueForReview(deposit, alerts);
  }

  return approveDeposit(deposit);
}

function approveDeposit(deposit) {
  console.log(`✅ 입금 승인: ${deposit.txHash}`);
  // 사용자 계정에 입금
  return { status: 'approved', deposit };
}

function queueForReview(deposit, alerts) {
  console.log(`⚠️ 입금 검토 대기: ${deposit.txHash}`);
  // 컴플라이언스 팀에 알림
  return { status: 'pending_review', deposit, alerts };
}

function rejectDeposit(deposit, alerts) {
  console.log(`❌ 입금 거부: ${deposit.txHash}`);
  // 로그 기록 및 알림
  return { status: 'rejected', deposit, alerts };
}

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

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

class DepositRiskChecker {
  async checkDeposit(deposit) {
    try {
      // 1단계: 트랜스퍼 등록
      const { transferId } = await client.kyt.registerTransfer({
        network: deposit.network,
        asset: deposit.asset,
        transferReference: deposit.txHash,
        direction: 'received'
      });

      console.log(`📝 트랜스퍼 등록: ${transferId}`);

      // 2단계: 리스크 평가 조회
      const summary = await client.kyt.getTransferSummary(transferId);
      const alerts = await client.kyt.getTransferAlerts(transferId);

      console.log(`📊 리스크 평가 완료`);
      console.log(`   알림: ${alerts.length}건`);

      // 3단계: 판정
      return this.makeDecision(deposit, summary, alerts);

    } catch (error) {
      console.error(`❌ 입금 체크 오류: ${error.message}`);
      // 오류 시 수동 검토로 전환
      return { status: 'pending_review', reason: 'system_error' };
    }
  }

  makeDecision(deposit, summary, alerts) {
    const criticalAlerts = alerts.filter(a => a.severity === 'critical');
    const highAlerts = alerts.filter(a => a.severity === 'high');
    const mediumAlerts = alerts.filter(a => a.severity === 'medium');

    if (criticalAlerts.length > 0 || highAlerts.length > 0) {
      return {
        status: 'rejected',
        reason: 'high_risk_detected',
        alerts: [...criticalAlerts, ...highAlerts]
      };
    }

    if (mediumAlerts.length > 0) {
      return {
        status: 'pending_review',
        reason: 'medium_risk_detected',
        alerts: mediumAlerts
      };
    }

    return {
      status: 'approved',
      reason: 'low_risk'
    };
  }
}

// 사용 방법
const checker = new DepositRiskChecker();

const deposit = {
  network: 'Solana',
  asset: 'SOL',
  txHash: '39z5QAprVrzaFzfHu1JHPgBf9dSqYdNYhH31d3PEd4hWiWL1LML7qCct5MHGxaRAgjjj1nC3XUyLwtzGQmYqUk4y:address'
};

const result = await checker.checkDeposit(deposit);
console.log('판정 결과:', result);