CCXT로 그리드 봇 3분 배포하기

{
  "name": "ccxt-grid-bot",
  "version": "1.0.0",
  "type": "module",
  "scripts": {
    "start": "node index.js"
  },
  "dependencies": {
    "ccxt": "^4.4.0",
    "dotenv": "^16.4.5"
  }
}

import ccxt from 'ccxt';
import dotenv from 'dotenv';
import fs from 'fs';
import path from 'path';
 
dotenv.config();
 
// 영구 볼륨 디렉터리 보장
const DATA_DIR = path.join(process.cwd(), 'data');
if (!fs.existsSync(DATA_DIR)) {
  fs.mkdirSync(DATA_DIR, { recursive: true });
}
 
const API_KEY = process.env.BINANCE_API_KEY;
const SECRET = process.env.BINANCE_SECRET;
 
if (!API_KEY || !SECRET) {
  console.error("❌ 거래소 API 키가 환경변수에 설정되지 않았습니다!");
  process.exit(1);
}
 
// 1. 거래소 인스턴스 초기화 (CCXT Pro 웹소켓 모드)
const exchange = new ccxt.pro.binance({
  apiKey: API_KEY,
  secret: SECRET,
  enableRateLimit: true, // 거래소 초당 호출 제한 자동 준수
  options: {
    defaultType: 'spot', // 'spot'(현물) 또는 'future'(선물)
  },
});
 
const SYMBOL = 'BTC/USDT';
const GRID_STEP_PERCENT = 0.005; // 0.5% 가격 변동 시마다 매매
const ORDER_AMOUNT = 0.001;      // 1회 BTC 주문 수량
 
let lastTradedPrice = null;
let isRunning = true;
 
async function runTradingLoop() {
  console.log(`🚀 [${SYMBOL}] 실시간 호가 스트리밍 및 그리드 엔진을 시작합니다...`);
 
  while (isRunning) {
    try {
      // 2. 웹소켓 실시간 틱 데이터 수신 (폴링이 아닌 실시간 푸시)
      const ticker = await exchange.watchTicker(SYMBOL);
      const currentPrice = ticker.last;
 
      if (!lastTradedPrice) {
        lastTradedPrice = currentPrice;
        console.log(`📌 기준 시작 가격 설정: ${currentPrice} USDT`);
        continue;
      }
 
      // 가격 변동률 계산
      const priceChangeRatio = (currentPrice - lastTradedPrice) / lastTradedPrice;
 
      // 3. 그리드 하단 도달 시 매수 (저가 분할 매수)
      if (priceChangeRatio <= -GRID_STEP_PERCENT) {
        console.log(`📉 가격 하락 감지 (${(priceChangeRatio * 100).toFixed(2)}%): ${currentPrice} USDT ➔ 매수 집행`);
        await executeOrder('buy', ORDER_AMOUNT, currentPrice);
        lastTradedPrice = currentPrice;
      }
      // 4. 그리드 상단 도달 시 매도 (고가 분할 익절)
      else if (priceChangeRatio >= GRID_STEP_PERCENT) {
        console.log(`📈 가격 상승 감지 (+${(priceChangeRatio * 100).toFixed(2)}%): ${currentPrice} USDT ➔ 매도 집행`);
        await executeOrder('sell', ORDER_AMOUNT, currentPrice);
        lastTradedPrice = currentPrice;
      }
 
    } catch (error) {
      if (error instanceof ccxt.NetworkError) {
        console.warn(`네트워크 일시 지연: ${error.message}. 2초 후 자동 재시도...`);
        await new Promise((resolve) => setTimeout(resolve, 2000));
      } else if (error instanceof ccxt.InsufficientFunds) {
        console.error(`잔고 부족 오류! 거래를 일시 중지합니다: ${error.message}`);
        await new Promise((resolve) => setTimeout(resolve, 30000));
      } else {
        console.error(`예상치 못한 트레이딩 에러:`, error);
        await new Promise((resolve) => setTimeout(resolve, 5000));
      }
    }
  }
}
 
async function executeOrder(side, amount, price) {
  try {
    // 실제 주문 집행 (시장가 또는 지정가)
    const order = await exchange.createOrder(SYMBOL, 'market', side, amount);
    console.log(`✅ 주문 체결 완료: [${order.id}] ${side.toUpperCase()} ${amount} BTC (약 ${price} USDT)`);
    
    // 체결 내역 로컬 파일 기록
    const logLine = `${new Date().toISOString()},${order.id},${side},${amount},${price}\n`;
    fs.appendFileSync(path.join(DATA_DIR, 'trades.csv'), logLine);
  } catch (err) {
    console.error(`❌ 주문 실행 실패:`, err.message);
  }
}
 
// 프로세스 종료 시 우아한 종료 처리
process.on('SIGINT', async () => {
  console.log("SIGINT 종료 신호 수신. 웹소켓을 안전하게 닫습니다...");
  isRunning = false;
  await exchange.close();
  process.exit(0);
});
 
runTradingLoop();