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",
  // 선택사항: `liquidity/stable.ts`의 견적 헬퍼를 직접 호출하려면
  // stable curve 모델 레이아웃을 로드합니다. 풀 수준의 스왑 / 추가 / 제거는
  // 이를 지연 로드하므로 대부분의 호출자는 이 단계를 건너뛸 수 있습니다.
});

// 일회성: 오프체인 stable-curve 헬퍼에서 사용하는 온체인 모델 데이터 레이아웃을 미리 가져옵니다.
// getStablePrice / getDxByDyBaseIn / getDyByDxBaseIn을 직접 호출할 때만 필요합니다.
// addLiquidity / removeLiquidity / swap은 이를 필요로 하지 않습니다.
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";

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

const pools = await raydium.api.fetchPoolByMintPair({
  mint1: mintA.toBase58(),
  mint2: mintB.toBase58(),
});

const stablePool = pools.find(
  (p) => p.version === 5 || p.pooltype.includes("StablePool"),
);

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

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

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

const inputAmount = new TokenAmount(toToken(stablePool.mintA), 1_000_000); // 1 USDT
const slippage = new Percent(50, 10_000); // 0.5%

// SDK의 stable-curve 헬퍼를 내부적으로 사용하여 예상 출력을 계산합니다.
const { amountOut, minAmountOut } = raydium.liquidity.computeAmountOut({
  poolInfo: stablePool,
  amountIn: inputAmount,
  mintIn:  stablePool.mintA.address,
  mintOut: stablePool.mintB.address,
  slippage,
});

console.log("예상 출력:", amountOut.toSignificant());
console.log("최소 출력:", minAmountOut.toSignificant());

// 스왑 트랜잭션을 구성하고 서명합니다.
const { transaction, execute } = await raydium.liquidity.swap({
  poolInfo: stablePool,
  amountIn:    inputAmount.raw,
  amountOut:   minAmountOut.raw,
  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";

const amountInA = new TokenAmount(toToken(stablePool.mintA), 100_000_000); // 100 USDT
const slippage  = new Percent(50, 10_000); // 0.5%

// 곡선이 이 크기의 A에 필요한 일치하는 B 금액을 계산합니다.
const { anotherAmount, minAnotherAmount } = raydium.liquidity.computePairAmount({
  poolInfo: stablePool,
  amount:   amountInA.toSignificant(),
  baseIn:   true,
  slippage,
});

const { execute } = await raydium.liquidity.addLiquidity({
  poolInfo: stablePool,
  amountInA,
  amountInB:      anotherAmount,
  otherAmountMin: 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();

const modelData = raydium.liquidity.stableLayout;

// 풀의 현재 준비금에서의 현물 가격입니다.
const price = getStablePrice(modelData, /* x */, /* y */, /* withFee */);
console.log("현물 가격:", price);

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

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

const route = await raydium.tradeV2.fetchRoutes({
  inputMint:  mintA,
  outputMint: mintB,
  amount:     new BN(1_000_000),
  slippage,
});

// route.routes[0].poolType는 최적 경로가 사용하는 프로그램을 알려줍니다.
// Stable 풀이 최적 경로의 일부일 때마다 "Stable"이 여기에 나타납니다.
console.log(route.routes[0]);

const { execute } = await raydium.tradeV2.swap({
  inputMint:    mintA,
  outputMint:   mintB,
  inputAmount:  new BN(1_000_000),
  swapResult:   route.routes[0],
  slippage,
  txVersion:    TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });