트랜잭션 요청은 지갑이 서버와 통신하여 모든 솔라나 트랜잭션을 구성할 수 있도록 함으로써 인터랙티브 결제 플로우를 가능하게 합니다. 이를 통해 NFT 민팅, 동적 가격 책정, 다단계 DeFi 트랜잭션 및 커스텀 비즈니스 로직과 같은 고급 사용 사례를 구현할 수 있습니다.
개요
트랜잭션 요청은 다음 URL 형식을 따릅니다:
solana:<server-endpoint-url>
지갑은 엔드포인트에 두 개의 HTTP 요청을 보냅니다:
- GET 요청 - 결제 정보(레이블, 아이콘) 조회
- POST 요청 - 서명할 트랜잭션 가져오기
기본 설정
1. 의존성 설치
pnpm add @solana/pay@beta @solana/kit @solana-program/system \@solana/kit-plugin-rpc @solana/kit-plugin-payer @solana/kit-plugin-instruction-plan
2. API 엔드포인트 생성
GET 및 POST 요청을 모두 처리하는 API 엔드포인트를 설정합니다:
// pages/api/pay.ts (Next.js) or similar endpointimport { address, createNoopSigner, lamports } from "@solana/kit";import { getTransferSolInstruction } from "@solana-program/system";import { createMerchantClient } from "@solana/pay";const MERCHANT_WALLET = address(process.env.MERCHANT_WALLET);export default async function handler(req, res) {if (req.method === "GET") {return handleGet(req, res);}if (req.method === "POST") {return handlePost(req, res);}return res.status(405).json({ error: "Method not allowed" });}// GET request handlerasync function handleGet(req, res) {const label = "My Store";const icon = "https://mystore.com/icon.png";res.status(200).json({label,icon});}// POST request handlerasync function handlePost(req, res) {try {const { account } = req.body;if (!account) {return res.status(400).json({ error: "Missing account parameter" });}const buyerAddress = address(account);// Create the merchant client for building the transactionconst merchant = createMerchantClient({rpcUrl: process.env.SOLANA_RPC_URL});// Build transfer instruction (createNoopSigner because the wallet signs later)const instruction = getTransferSolInstruction({source: createNoopSigner(buyerAddress),destination: MERCHANT_WALLET,amount: lamports(100_000_000n) // 0.1 SOL});// Build a base64-encoded transactionconst transaction = merchant.pay.buildTransaction(buyerAddress, [instruction]);res.status(200).json({transaction,message: "Thanks for your purchase!"});} catch (error) {console.error("Transaction creation error:", error);res.status(500).json({ error: "Failed to create transaction" });}}
3. 결제 URL 생성
트랜잭션 요청 URL을 생성합니다:
import { encodeURL } from "@solana/pay";// Your API endpointconst apiUrl = "https://yoursite.com/api/pay";// Create transaction request URLconst url = encodeURL({link: new URL(apiUrl)});console.log(url.toString());// Output: solana:https://yoursite.com/api/pay
지갑 측: 트랜잭션 요청 가져오기
지갑 측에서는 fetchTransaction를 사용하여 트랜잭션 요청 URL에서 트랜잭션을
조회하고 서명합니다:
import { createWalletClient } from "@solana/pay";const wallet = createWalletClient({rpcUrl: "https://api.mainnet-beta.solana.com",payer: myWalletSigner});// Parse the Solana Pay URLconst parsed = wallet.pay.parseURL(url);if ("link" in parsed) {// This is a transaction request — fetch the transaction from the serverconst transaction = await wallet.pay.fetchTransaction(myWalletSigner.address,parsed.link);// Sign and send the transaction...}
고급 예제
SPL 토큰 결제
USDC 결제를 위한 트랜잭션을 생성합니다:
import { address } from "@solana/kit";import {fetchMint,findAssociatedTokenPda,getTransferCheckedInstruction,TOKEN_PROGRAM_ADDRESS} from "@solana-program/token";async function createTokenPaymentInstruction(rpc, buyer, amount) {const USDC_MINT = address("EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v");// Get mint info for decimalsconst mint = await fetchMint(rpc, USDC_MINT);// Derive associated token accountsconst [buyerATA] = await findAssociatedTokenPda({owner: buyer,tokenProgram: TOKEN_PROGRAM_ADDRESS,mint: USDC_MINT});const [merchantATA] = await findAssociatedTokenPda({owner: MERCHANT_WALLET,tokenProgram: TOKEN_PROGRAM_ADDRESS,mint: USDC_MINT});// Calculate token amount with decimalsconst tokenAmount = BigInt(Math.round(amount * 10 ** mint.data.decimals));return getTransferCheckedInstruction({source: buyerATA,mint: USDC_MINT,destination: merchantATA,authority: buyer,amount: tokenAmount,decimals: mint.data.decimals});}
할인이 적용된 동적 가격 책정
고객 데이터를 기반으로 동적 가격 책정 구현:
async function handlePost(req, res) {const { account } = req.body;const buyer = address(account);// Check if customer holds discount NFTconst hasDiscountNFT = await checkForDiscountNFT(buyer);// Calculate dynamic pricelet price = 10; // $10 base priceif (hasDiscountNFT) {price = price * 0.8; // 20% discount}const merchant = createMerchantClient({rpcUrl: process.env.SOLANA_RPC_URL});const instruction = await createTokenPaymentInstruction(merchant.rpc,buyer,price);const transaction = merchant.pay.buildTransaction(buyer, [instruction]);const message = hasDiscountNFT? `20% discount applied! Total: $${price.toFixed(2)}`: `Total: $${price.toFixed(2)}`;res.status(200).json({ transaction, message });}
주문 관리 통합
기존 주문 시스템과 통합:
import { address, AccountRole, createNoopSigner, lamports } from "@solana/kit";// Enhanced POST handler with order managementasync function handlePost(req, res) {const { account } = req.body;const { orderId } = req.query;if (!orderId) {return res.status(400).json({ error: "Missing order ID" });}// Get order detailsconst order = await db.orders.findById(orderId);if (!order || order.status !== "pending") {return res.status(400).json({ error: "Invalid order" });}const buyer = address(account);// Create payment instruction (createNoopSigner because the wallet signs later)const instruction = getTransferSolInstruction({source: createNoopSigner(buyer),destination: MERCHANT_WALLET,amount: lamports(BigInt(Math.round(order.total * 1e9)))});// Add reference for tracking (accounts is readonly, so spread into a new instruction)const withRef = {...instruction,accounts: [...(instruction.accounts ?? []),{address: address(order.referenceKey),role: AccountRole.READONLY}]};const merchant = createMerchantClient({ rpcUrl: process.env.SOLANA_RPC_URL });const transaction = merchant.pay.buildTransaction(buyer, [withRef]);// Update order statusawait db.orders.update(orderId, {status: "processing",walletAddress: account});res.status(200).json({transaction,message: `Order ${order.id} - ${order.items.length} items`});}
결제 검증
완료된 거래 검증:
import { address } from "@solana/kit";import { createMerchantClient } from "@solana/pay";const merchant = createMerchantClient({rpcUrl: "https://api.mainnet-beta.solana.com"});async function validatePayment(reference, recipient, amount) {try {const found = await merchant.pay.findReference(reference);// findReference only locates a signature mentioning the reference address.// validateTransfer checks recipient, amount, and token match.await merchant.pay.validateTransfer(found.signature, {recipient,amount,reference});return {success: true,signature: found.signature};} catch (error) {console.error("Payment validation error:", error);}return { success: false };}
오류 처리
강력한 오류 처리 구현:
async function handlePost(req, res) {try {const { account } = req.body;if (!account) {return res.status(400).json({error: "Missing account parameter",code: "MISSING_ACCOUNT"});}let buyer;try {buyer = address(account);} catch {return res.status(400).json({error: "Invalid account address",code: "INVALID_ACCOUNT"});}const instruction = getTransferSolInstruction({source: createNoopSigner(buyer),destination: MERCHANT_WALLET,amount: lamports(100_000_000n)});const merchant = createMerchantClient({rpcUrl: process.env.SOLANA_RPC_URL});const transaction = merchant.pay.buildTransaction(buyer, [instruction]);res.status(200).json({transaction,message: "Payment ready"});} catch (error) {console.error("Transaction request error:", error);res.status(500).json({error: "Internal server error",code: "INTERNAL_ERROR"});}}
모범 사례
보안
- 모든 입력 매개변수 검증
- 서버 측에서만 금액 계산
- 모든 엔드포인트에 HTTPS 사용
- 속도 제한 구현
- 민감한 데이터 안전하게 저장
성능
- 자주 액세스하는 데이터 캐싱
- 연결 풀링 사용
- 요청 타임아웃 구현
- 결제 확인을 위해 웹훅 사용 고려
사용자 경험
- 명확한 오류 메시지 제공
- 거래 진행 상황 표시
- 네트워크 문제 우아하게 처리
- 거래 재시도 지원
Is this page helpful?