DeFi 모니터링 개요

// DEX 거래 흐름 구독
ws.subscribe('defi_trades', {
  protocol: 'kyberswap',
  chain: 'eth',
  min_amount_usd: 10000
}, (trade) => {
  console.log(`${trade.type}: ${trade.token_in} → ${trade.token_out}`);
});

{
  "alert_type": "liquidity_remove",
  "protocol": "kyberswap",
  "pool": "0x...",
  "threshold": {
    "type": "percentage",
    "value": 10
  },
  "notification": {
    "webhook": "https://your-server.com/webhook",
    "email": "alert@example.com"
  }
}

ws.subscribe('pool_created', {
  chain: 'sol',
  min_liquidity_usd: 10000
}, async (pool) => {
  // 토큰 안전성 확인
  const risk = await checkTokenRisk(pool.token_address);
  if (risk.score > 60) {
    notify(`신규 풀 발견: ${pool.pair_name}, 유동성: $${pool.liquidity_usd}`);
  }
});

ws.subscribe('liquidity_remove', {
  pool: '0x...',
  threshold_percentage: 10
}, (event) => {
  alert(`⚠️ 러그풀 경고: ${event.percentage}%의 유동성이 제거되었습니다`);
});

// 여러 DEX의 가격 모니터링
const prices = {};

ws.subscribe('token_price', { 
  token: 'SOL',
  dex: ['jupiter', 'raydium', 'pumpfun']
}, (data) => {
  prices[data.dex] = data.price;
  checkArbitrage(prices);
});

function checkArbitrage(prices) {
  const maxPrice = Math.max(...Object.values(prices));
  const minPrice = Math.min(...Object.values(prices));
  const spread = (maxPrice - minPrice) / minPrice;
  
  if (spread > 0.005) {  // 0.5% 스프레드
    notify(`차익거래 기회: ${spread * 100}% 스프레드`);
  }
}

async function monitorLiquidationRisk(address: string) {
  // 배포 환경이 제공하는 대출 API에 연결 (DEX 한정이 아님)
  const position = await getLendingPosition(address);

  if (position.health_factor < 1.2) {
    urgentAlert(`🚨 청산 리스크! 건전성 비율: ${position.health_factor}`);
  } else if (position.health_factor < 1.5) {
    warnAlert(`⚠️ 낮은 건전성 비율: ${position.health_factor}`);
  }
}