블록체인 입출금 시스템 구현기

유저 가입
  └── 유저 전용 입금 주소 발급 (코인별 1개)
 
입금 흐름
  └── 데몬: 주기적으로 블록체인 API 폴링 (Solana → Alchemy, BTC/ETH → CryptoAPIs)
        └── 플랫폼 지갑 또는 유저 주소의 트랜잭션 조회
              └── 수신 주소 → 유저 매핑
                    └── 이미 처리된 시그니처(txId)인지 확인 (멱등성)
                          └── 신규이면 유저 잔액 증가 + 입금 이력 저장
 
출금 흐름
  └── 유저 출금 요청 → Pending 상태로 DB 저장
        └── 데몬: 주기적으로 Pending 출금 조회
              └── 블록체인 API로 실제 전송
                    └── txId(signature) 저장, 상태 Complete/Failed 갱신

유저 A → SOL 입금 주소: AbCD...XyZ  /  BTC 입금 주소: bc1q...
유저 B → SOL 입금 주소: EfGH...WvU  /  BTC 입금 주소: bc1p...

interface UserWallet {
  userId: string;
  symbol: 'SOL' | 'BTC' | 'ETH' | 'USDT';
  depositAddress: string;  // 유저 전용 입금 주소
  balance: Decimal;
}

// Alchemy Solana API: 주소에 연관된 트랜잭션 시그니처 목록 조회
const response = await alchemy.core.getSignaturesForAddress(
  depositAddress,
  { limit: 50 }
);
// response: [{ signature, slot, blockTime, confirmationStatus, ... }, ...]

const tx = await alchemy.core.getTransaction(signature);

function extractSolDeposit(tx: SolanaTransaction, depositAddress: string): Decimal | null {
  const accountIndex = tx.transaction.message.accountKeys
    .findIndex(key => key.toString() === depositAddress);
 
  if (accountIndex === -1) return null;
 
  const pre = tx.meta.preBalances[accountIndex];   // lamports
  const post = tx.meta.postBalances[accountIndex]; // lamports
  const diff = post - pre;
 
  if (diff <= 0) return null;  // 입금이 아닌 경우
  return new Decimal(diff).dividedBy(1e9);  // lamports → SOL
}

function extractSplDeposit(tx: SolanaTransaction, depositAddress: string, mint: string) {
  const pre = tx.meta.preTokenBalances
    .find(b => b.owner === depositAddress && b.mint === mint);
  const post = tx.meta.postTokenBalances
    .find(b => b.owner === depositAddress && b.mint === mint);
 
  const preAmount = new Decimal(pre?.uiTokenAmount.uiAmountString ?? '0');
  const postAmount = new Decimal(post?.uiTokenAmount.uiAmountString ?? '0');
  const diff = postAmount.minus(preAmount);
 
  return diff.greaterThan(0) ? diff : null;
}

@Injectable()
export class DepositScheduler {
  @Cron('0 */5 * * * *')   // 5분마다 — 메인 코인
  async detectSolDeposits() { ... }
 
  @Cron('0 */7 * * * *')   // 7분마다
  async detectBitcoinDeposits() { ... }
 
  @Cron('0 */8 * * * *')   // 8분마다
  async detectEthereumDeposits() { ... }
 
  @Cron('0 */9 * * * *')   // 9분마다
  async detectUsdtDeposits() { ... }
}

async processAllSolDeposits() {
  const wallets = await this.userWalletRepo.findAllBySymbol('SOL');
 
  for (const wallet of wallets) {
    const signatures = await alchemy.core.getSignaturesForAddress(
      wallet.depositAddress,
      { limit: 50 }
    );
 
    for (const { signature } of signatures) {
      await this.handleSolDeposit(wallet, signature);
    }
  }
}

async handleSolDeposit(wallet: UserWallet, signature: string): Promise<void> {
  // 이미 처리된 시그니처인지 확인
  const exists = await this.depositRepo.existsBySignatureAndWallet(
    signature, wallet.id
  );
  if (exists) return;
 
  const tx = await alchemy.core.getTransaction(signature);
  if (!tx || tx.meta?.err) return;  // 실패한 트랜잭션 스킵
 
  const amount = extractSolDeposit(tx, wallet.depositAddress);
  if (!amount) return;  // 이 주소로 들어온 금액이 없으면 스킵
 
  // 잔액 증가 + 입금 이력 저장 (DB 트랜잭션으로 묶음)
  await this.dataSource.transaction(async manager => {
    wallet.balance = wallet.balance.plus(amount);
    await manager.save(wallet);
    await manager.save(new Deposit({ wallet, amount, signature, txTimestamp: tx.blockTime }));
  });
}

출금 요청 API
  └── 잔액 차감 + Withdrawal(status=Pending) 저장
 
출금 데몬 (@Cron 30분마다)
  └── status=Pending인 Withdrawal 조회
        └── Alchemy (SOL) / CryptoAPIs (BTC·ETH)로 전송 요청
              ├── 성공: signature(txId) 저장, status=Complete
              └── 실패: status=Failed, 잔액 환불