24개 DEX를 스캔하는 어댑터 아키텍처

-

🌐 English

여러 DEX를 동시에 스캔하는 봇을 만들 때 가장 먼저 부딪히는 문제는, DEX마다 스왑 방식이 다르다는 것입니다. UniswapV2 계열, 집중 유동성(V3), Solidly의 ve(3,3), DODO 같은 PMM(Proactive Market Maker)... 견적 함수도, 스왑 시그니처도 전부 제각각이죠. 24개나 되는 DEX를 상대하면서 봇 코어가 각 DEX를 개별적으로 알아야 한다면, 코드는 금방 지옥이 됩니다.

해법은 고전적입니다. 어댑터 패턴.

공통 인터페이스 뒤로 차이를 숨긴다

봇 코어에게는 오직 하나의 인터페이스만 보이게 합니다. "이 풀에서 X를 넣으면 Y가 얼마 나와?"와 "실제로 스왑해 줘." 이 두 가지면 충분합니다.

interface IDEXAdapter {

    // 견적: amountIn 을 넣으면 얼마 나오는지

    function getAmountOut(

        address pool,

        address tokenIn,

        uint256 amountIn

    ) external view returns (uint256 amountOut);

    // 실행: 실제 스왑

    function swap(

        address pool,

        address tokenIn,

        uint256 amountIn,

        address to

    ) external returns (uint256 amountOut);

}

각 프로토콜은 이 인터페이스를 구현하는 자기만의 어댑터를 갖습니다.

  • UniV2Adapter — x * y = k 상수곱 공식, 견적 계산이 온체인에서 값쌈
  • V3Adapter — 집중 유동성. tick·sqrtPrice 때문에 견적을 Quoter 컨트랙트에 물어봐야 함
  • SolidlyAdapter — 안정/변동 풀 구분, ve(3,3) 수수료 구조
  • DODOAdapter — PMM. 오라클 기반 가격 곡선이라 다른 어댑터와 계산법이 전혀 다름

코어는 이 차이를 전혀 몰라도 됩니다. 그냥 adapter.getAmountOut(...)을 호출할 뿐이죠.

어댑터 등록으로 확장한다

새 DEX를 추가하는 일이 코어 수정이 되면 안 됩니다. 그래서 어댑터를 런타임에 등록합니다. 각 어댑터에 ID를 부여하고, 라우터가 ID로 조회하도록 합니다.

mapping(uint8 => address) public adapters;

function registerAdapter(uint8 id, address adapter) external onlyOwner {

    adapters[id] = adapter;

}

새 DEX가 등장하면? 어댑터 하나 배포하고, registerAdapter(24, newAdapter) 한 번. 코어 로직은 손대지 않습니다. 봇 오프체인 쪽에서도 adapterNames 맵에 이름만 추가하면 스캔 대상에 편입됩니다. 이 개방-폐쇄 구조 덕분에 24개까지 늘려도 코어는 그대로였습니다.

유동성 체크 — 함정 풀 거르기

여기가 실전에서 가장 중요한 교훈입니다. 견적상 "10% 차익"처럼 보이는 페어가 있어도, 풀에 유동성이 없으면 신기루입니다. 조금만 사도 가격이 밀려서(슬리피지) 이익이 증발하거나, 아예 상환이 불가능해집니다.

그래서 경로를 실행 후보에 올리기 전에 유동성을 먼저 검증합니다. 프로토콜마다 유동성을 재는 방법이 다르므로, 이 체크도 어댑터 계층과 짝을 이룹니다.

// 개념 예시: 스왑 규모 대비 풀 예비금(reserve)이 충분한가

func hasEnoughLiquidity(reserveIn, amountIn *big.Int) bool {

    // 진입 규모가 풀의 일정 비율을 넘으면 슬리피지가 과도 → 스킵

    // (V2 는 reserve, V3 는 활성 tick 유동성, Stable 은 곡선 구간으로 각각 판단)

    threshold := new(big.Int).Div(reserveIn, big.NewInt(50)) // 예: 풀의 2%

    return amountIn.Cmp(threshold) <= 0

}

실제로는 V2는 예비금, V3는 활성 tick의 유동성, 스테이블/Wombat류는 곡선 구간으로 각각 다르게 판단합니다. 핵심은 "견적이 좋아 보인다"와 "실제로 그 규모를 소화한다"는 별개라는 것. 이 게이트 하나가 헛발질 트랜잭션의 대부분을 걸러 줍니다.

정리

  • DEX마다 다른 스왑/견적을 하나의 어댑터 인터페이스 뒤로 숨긴다
  • 프로토콜별 어댑터(UniV2 / V3 / Solidly / PMM)가 각자 구현을 갖는다
  • 어댑터 등록 메커니즘으로 코어 수정 없이 새 DEX를 편입한다
  • 유동성 체크로 견적만 좋고 실속 없는 함정 풀을 사전에 거른다

어댑터 패턴은 교과서에 나오는 흔한 패턴이지만, 이질적인 온체인 프로토콜을 24개나 다뤄야 하는 상황에서 그 진가가 드러납니다. 확장이 코어를 건드리지 않는다 — 이게 오래 가는 봇의 조건입니다.

이 글은 교육·정보 목적이며 투자 권유가 아닙니다. DeFi 자동매매에는 원금 손실 위험이 있으며, 결과에 대한 책임은 본인에게 있습니다.

댓글

댓글 쓰기

이 블로그의 인기 게시물

한국투자증권 KIS API로 실시간 시세 받기 (WebSocket 실전)

-
🌐 English 주식 자동매매 봇의 심장은 실시간 시세 입니다. REST 폴링만으로는 초 단위 시그널을 만들 수 없습니다. 한국투자증권(KIS) 오픈API는 WebSocket으로 호가와 체결을 밀어주는데, 실전에서 부딪히는 지점들을 자동매매 봇을 만들며 정리한 노트입니다. ⚠️ 이 글은 교육·정보 제공 목적입니다. 투자 권유가 아니며, 투자 손실 책임은 본인에게 있습니다. 두 개의 TR을 구독한다 KIS 실시간에서 자주 쓰는 TR은 두 가지입니다. H0STASP0 — 실시간 호가 (매수·매도 1~10호가) H0STCNT0 — 실시간 체결가 (현재가, 시가, 전일종가, 누적거래량) 시가 기준 전략을 쓴다면 H0STCNT0 이 필수입니다. 체결 메시지 안에 시가(stck_oprc) 가 들어 있어서, 장 시작 첫 체결로 그날의 기준선을 잡을 수 있기 때문입니다. 종목당 두 TR을 구독하므로, 종목이 늘어나면 구독 건수가 빠르게 증가합니다. KIS는 한 연결에 동시 구독 한도(수십 건)가 있으니, 중복 종목은 seen 맵으로 걸러 한 번만 구독합니다. seen := make(map[string]bool) addSym := func(code string) { if code == "" || seen[code] { return // 빈 코드·중복은 skip } seen[code] = true subscribeKIS(conn, approvalKey, "H0STASP0", code) // 호가 time.Sleep(50 * time.Millisecond) subscribeKIS(conn, approvalKey, "H0STCNT0", code) // 체결 time.Sleep(50 * time.Millisecond) } 구독 사이에 짧은 sleep 을 두는 이유는, 여러 구독 프레임을 한...
자세한 내용 보기

파이썬으로 업비트 API 연동하기 — 시세 조회부터 주문까지 기초

-
🌐 English 코인 자동매매를 만들어 보려고 검색하면 대부분 "전략"부터 이야기합니다. 그런데 막상 코드를 짜려고 하면 거래소에 요청을 어떻게 보내는지 에서 먼저 막힙니다. 이 글은 그 첫 관문만 다룹니다. 파이썬으로 업비트 API에 붙어서 시세를 읽고, 잔고를 확인하고, 주문을 넣는 데까지입니다. 0. 준비물 필요한 건 두 가지뿐입니다. 파이썬 패키지 : pip install requests pyjwt — requests는 HTTP 요청 라이브러리, PyJWT는 인증 토큰을 만드는 라이브러리입니다. 업비트 API 키 : 업비트 웹사이트 → 마이페이지 → Open API 관리에서 발급합니다. 발급할 때 허용 IP를 반드시 등록 하고, 처음에는 자산조회·주문조회 권한만 켜세요. 주문 권한은 코드가 검증된 뒤에 켜도 늦지 않습니다. 발급받은 secret key는 발급 화면을 벗어나면 다시 볼 수 없습니다. 그리고 절대 소스코드에 직접 적지 마세요. 환경변수나 설정 파일로 분리합니다. import os ACCESS_KEY = os.environ["UPBIT_ACCESS_KEY"] # 실제 키는 환경변수로 SECRET_KEY = os.environ["UPBIT_SECRET_KEY"] SERVER_URL = "https://api.upbit.com" 1. 시세 조회 — 인증이 필요 없는 요청 가장 쉬운 것부터 합니다. 현재가 조회는 인증 없이 됩니다. 그냥 GET 요청 하나면 끝입니다. import requests def get_price(market="KRW-BTC"): url = f"{SERVER_URL}/v1/ticker" res = requests.get(url, params={"markets": market}, timeout=5) res.rais...
자세한 내용 보기

Go로 자동매매 신호봇 프레임워크 설계하기

-
🌐 English 자동매매 봇을 만들다 보면 전략 코드보다 주변 골격 에 시간을 더 쓰게 됩니다. 설정을 어떻게 읽지? 상태는 어디서 보지? 알림은? 이 글은 실제로 돌아가는 Go 선물 신호봇을 만들며 정리한, 재사용 가능한 프레임워크 뼈대입니다. 핵심 원칙은 하나입니다. 최소 의존성. 설정은 ini 하나, 웹은 표준 net/http , 알림은 텔레그램 REST 호출. 무거운 프레임워크 없이 단일 실행 파일로 끝냅니다. 1. 설정 로더 — config.ini 봇 파라미터는 코드가 아니라 파일에 둡니다. 재빌드 없이 값을 바꾸기 위해서죠. INI는 사람이 편집하기 쉽고 섹션으로 묶기 좋습니다. type AppConfig struct { APIKey, APISecret string Testnet bool LoopIntervalSec int NotionalPerEntry float64 Leverage int DashboardPort int DashboardKey string } func loadConfig(path string) (*AppConfig, error) { f, err := ini.Load(path) if err != nil { return nil, err } c := &AppConfig{} bi := f.Section("binance") c.APIKey = bi.Key("api_key").String() c.Testnet = bi.Key("testnet").MustBool(true) // 기본값을 안전한 쪽으로 tr := f.Section("trading") c.LoopIntervalSec = tr.Key("loop_interval_sec").MustInt(10) c.Leverage = tr.Key("l...
자세한 내용 보기