Stable AMM 코드 데모

npm install @raydium-io/raydium-sdk-v2 @solana/web3.js @solana/spl-token

import { Raydium, TxVersion } from "@raydium-io/raydium-sdk-v2";
import { Connection, Keypair, clusterApiUrl } from "@solana/web3.js";
import BN from "bn.js";
import bs58 from "bs58";

const connection = new Connection(clusterApiUrl("mainnet-beta"));
const owner = Keypair.fromSecretKey(bs58.decode(process.env.PRIVATE_KEY!));

const raydium = await Raydium.load({ connection, owner, cluster: "mainnet" });

// Stable 풀 견적을 위해 필수입니다. initLayout()은 온체인
// ModelDataInfo 조회 테이블을 raydium.liquidity.stableLayout으로 가져옵니다.
await raydium.liquidity.initLayout();

const isStable =
  pool.version === 5 ||
  pool.pooltype.includes("StablePool"); // SDK가 내부적으로 이 문자열 검사를 사용합니다

// 또는 프로그램 ID로:
const STABLE_AMM_PROGRAM_ID = "5quBtoiQqxF9Jv6KYKctB59NT3gtJD2Y65kdnB1Uev3h";
const isStableByProgram = pool.programId === STABLE_AMM_PROGRAM_ID;

import { PublicKey } from "@solana/web3.js";
import type { ApiV3PoolInfoStandardItem } from "@raydium-io/raydium-sdk-v2";

// 예제로 사용할 두 가지 일반적인 민트
const mintA = new PublicKey("Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB"); // USDT — reference/program-addresses 참조
const mintB = new PublicKey("EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"); // USDC

// fetchPoolByMints는 페이지 처리된 봉투를 반환합니다: { count, data, hasNextPage }
const res = await raydium.api.fetchPoolByMints({
  mint1: mintA.toBase58(),
  mint2: mintB.toBase58(),
});

const stablePool = res.data.find(
  (p) => p.version === 5 || p.pooltype.includes("StablePool"),
) as ApiV3PoolInfoStandardItem | undefined;

if (!stablePool) {
  throw new Error("이 민트 쌍에 대한 Stable 풀이 없습니다");
}

console.log("Stable 풀 ID:", stablePool.id);
console.log("Stable 풀 programId:", stablePool.programId);
console.log("TVL:", stablePool.tvl);

import BN from "bn.js";

const amountIn = new BN(1_000_000); // 1 USDT (6 decimals), 원시 단위

// 라이브 리저브 + 상태. 메인넷에서는 getAmmPoolKeys(poolId)에서 poolKeys를
// getRpcPoolInfo(poolId)에서 리저브를 가져올 수도 있습니다.
const rpcData  = await raydium.liquidity.getRpcPoolInfo(stablePool.id);
const poolKeys = await raydium.liquidity.getAmmPoolKeys(stablePool.id);

const out = raydium.liquidity.computeAmountOut({
  poolInfo: {
    ...stablePool,
    baseReserve:  rpcData.baseReserve,
    quoteReserve: rpcData.quoteReserve,
    status:       rpcData.status.toNumber(),
    version:      5, // 5 = Stable; 곡선 분기가 이것으로 선택됩니다
  },
  amountIn,
  mintIn:  stablePool.mintA.address,
  mintOut: stablePool.mintB.address,
  slippage: 0.005, // 일반 숫자: 0.005 = 0.5% (범위 1 ~ 0.0001)
});

// amountOut / minAmountOut은 TokenAmount가 아닌 원시 단위의 BN입니다.
console.log("예상 출력:", out.amountOut.toString());
console.log("최소 출력:", out.minAmountOut.toString());

// 스왑 트랜잭션을 빌드하고 서명합니다. `inputMint`는 필수입니다. 없으면
// SDK가 풀의 어느 쪽을 판매하는지 알 수 없습니다.
const { transaction, execute } = await raydium.liquidity.swap({
  poolInfo:  stablePool,
  poolKeys,
  amountIn,
  amountOut: out.minAmountOut, // out.amountOut는 슬리피지 전 수치입니다
  inputMint: stablePool.mintA.address,
  fixedSide: "in",
  txVersion: TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });
console.log("Stable 스왑 tx:", txId);

import { Percent, TokenAmount, toToken } from "@raydium-io/raydium-sdk-v2";
import Decimal from "decimal.js";

const inputAmount = "100"; // 100 USDT, 인간 단위 — computePairAmount는 십진수 문자열을 사용합니다

// 곡선이 이 크기의 A에 필요한 일치하는 B 금액을 계산합니다.
// 참고: computePairAmount의 slippage는 Percent입니다 (computeAmountOut의 것과 달리).
const r = raydium.liquidity.computePairAmount({
  poolInfo: stablePool,
  amount:   inputAmount,
  baseIn:   true,
  slippage: new Percent(50, 10_000), // 0.5%
});

const { execute } = await raydium.liquidity.addLiquidity({
  poolInfo: stablePool,
  poolKeys,
  amountInA: new TokenAmount(
    toToken(stablePool.mintA),
    new Decimal(inputAmount).mul(10 ** stablePool.mintA.decimals).toFixed(0),
  ),
  amountInB: new TokenAmount(
    toToken(stablePool.mintB),
    new Decimal(r.maxAnotherAmount.toExact()).mul(10 ** stablePool.mintB.decimals).toFixed(0),
  ),
  otherAmountMin: r.minAnotherAmount,
  fixedSide:      "a",
  txVersion:      TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });
console.log("유동성 추가 tx:", txId);

import {
  getStablePrice,
  getDxByDyBaseIn,
  getDyByDxBaseIn,
} from "@raydium-io/raydium-sdk-v2";

// 이들을 사용하기 전에 initLayout()을 한 번 호출해야 합니다 (온체인
// `ModelDataInfo` PDA를 SDK의 StableLayout 캐시로 로드합니다).
await raydium.liquidity.initLayout();

// initLayout()은 StableLayout 인스턴스를 채웁니다. 아래 세 헬퍼가
// 기대하는 일반 데이터 객체는 인스턴스가 아닌 `stableModelData` 게터입니다.
const modelData = raydium.liquidity.stableLayout.stableModelData;

// 리저브는 일반 숫자로 인간 단위로 전달됩니다 (BN이 아님, 원시 단위 아님).
const coinReserve = 1_200_000; // 풀의 코인 쪽 리저브
const pcReserve   = 1_150_000; // 풀의 pc 쪽 리저브

// 풀의 현재 리저브에서의 현물 가격. 네 번째 인수는 `baseCoin`입니다:
// true는 coin-per-pc를 반환하고, false는 역수를 반환합니다.
const price = getStablePrice(modelData, coinReserve, pcReserve, true);
console.log("현물 가격:", price);

// 견적: dx 입력이 주어졌을 때 얼마나 많은 dy 출력인가 (수수료 미적용)?
const dyOut = getDyByDxBaseIn(modelData, coinReserve, pcReserve, 1_000);

// 견적: dy 출력 목표가 주어졌을 때 필요한 dx 입력은 얼마인가?
const dxIn  = getDxByDyBaseIn(modelData, coinReserve, pcReserve, 1_000);

import { Router } from "@raydium-io/raydium-sdk-v2";

const poolData = await raydium.tradeV2.fetchRoutePoolBasicInfo(); // 이를 캐시하세요
const routes   = raydium.tradeV2.getAllRoute({ inputMint: mintA, outputMint: mintB, ...poolData });
const ctx      = await raydium.tradeV2.fetchSwapRoutesData({ routes, inputMint: mintA, outputMint: mintB });
const quotes   = raydium.tradeV2.getAllRouteComputeAmountOut({ /* ...ctx, amount, slippage, ... */ });

const best = quotes[0]; // 최적 우선 정렬
if (!best) throw new Error("스왑 경로를 찾을 수 없습니다");

// best.poolInfoList 항목은 `version`을 포함합니다. 5는 경로의 Stable 풀을 표시합니다.
console.log(best.routeType, best.poolInfoList.map((p) => p.version));

const poolKeys = await raydium.tradeV2.computePoolToPoolKeys({
  pools: best.poolInfoList,
  ammRpcData:  ctx.ammPoolsRpcInfo,
  clmmRpcData: ctx.clmmPoolsRpcInfo,
});

const { execute } = await raydium.tradeV2.swap({
  routeProgram: Router,
  swapInfo:     best,
  swapPoolKeys: poolKeys,
  ownerInfo:    { associatedOnly: true, checkCreateATAOwner: true },
  txVersion:    TxVersion.V0,
});

// tradeV2.swap은 여러 트랜잭션을 반환할 수 있습니다. 첫 번째는 중간 ATA를 생성합니다.
const { txIds } = await execute({ sequentially: true });