solana-program-examples/tokens/token-swap/steel/tests/utils.ts

import {
  MINT_SIZE,
  TOKEN_PROGRAM_ID,
  createAssociatedTokenAccountInstruction,
  createInitializeMint2Instruction,
  createMintToInstruction,
  getAssociatedTokenAddressSync,
} from '@solana/spl-token';
import { Keypair, LAMPORTS_PER_SOL, PublicKey, SystemProgram, Transaction } from '@solana/web3.js';
import * as borsh from 'borsh';
import { ProgramTestContext } from 'solana-bankrun';

export const instructionDiscriminators = {
  CreateAmm: Buffer.from([0]),
  CreatePool: Buffer.from([1]),
  DepositLiquidity: Buffer.from([2]),
  WithdrawLiquidity: Buffer.from([3]),
  Swap: Buffer.from([4]),
};
export const getCreatePoolInstructionData = () => {
  return Buffer.concat([instructionDiscriminators.CreatePool]);
};

export const encodeBigint = (value: bigint) => {
  const buffer = Buffer.alloc(8);
  buffer.writeBigUInt64LE(value);
  return Uint8Array.from(buffer);
};

export const getDepositLiquidityInstructionData = (amountA: bigint, amountB: bigint) => {
  return Buffer.concat([instructionDiscriminators.DepositLiquidity, encodeBigint(amountA), encodeBigint(amountB)]);
};

export const getWithdrawLiquidityInstructionData = (amountLp: bigint) => {
  return Buffer.concat([instructionDiscriminators.WithdrawLiquidity, encodeBigint(amountLp)]);
};

export const getSwapInstructionData = (swapA: boolean, inputAmount: bigint, minimunAmountOut: bigint) => {
  return Buffer.concat([instructionDiscriminators.Swap, Buffer.from([swapA ? 1 : 0]), encodeBigint(inputAmount), encodeBigint(minimunAmountOut)]);
};

export const getCreateAmmInstructionData = (id: PublicKey, fee: number) => {
  const buffer = Buffer.alloc(2);
  buffer.writeUint16LE(fee, 0);
  return Buffer.concat([instructionDiscriminators.CreateAmm, id.toBuffer(), Buffer.from(buffer)]);
};

export const createAMint = async (context: ProgramTestContext, payer: Keypair, mint: Keypair) => {
  const tx = new Transaction();
  tx.add(
    SystemProgram.createAccount({
      fromPubkey: payer.publicKey,
      newAccountPubkey: mint.publicKey,
      // the `space` required for a token mint is accessible in the `@solana/spl-token` sdk
      space: MINT_SIZE,
      // store enough lamports needed for our `space` to be rent exempt
      lamports: Number((await context.banksClient.getRent()).minimumBalance(BigInt(MINT_SIZE))),
      // tokens are owned by the "token program"
      programId: TOKEN_PROGRAM_ID,
    }),
    createInitializeMint2Instruction(mint.publicKey, 9, payer.publicKey, payer.publicKey),
  );
  tx.recentBlockhash = context.lastBlockhash;
  tx.sign(payer, mint);

  // process the transaction
  await context.banksClient.processTransaction(tx);
};

export const mintTo = async (context: ProgramTestContext, payer: Keypair, owner: PublicKey, mint: PublicKey) => {
  const tokenAccount = getAssociatedTokenAddressSync(mint, owner, false);
  const tx = new Transaction();
  tx.add(
    createAssociatedTokenAccountInstruction(payer.publicKey, tokenAccount, owner, mint),
    createMintToInstruction(mint, tokenAccount, payer.publicKey, 1_000 * LAMPORTS_PER_SOL),
  );
  tx.recentBlockhash = context.lastBlockhash;
  tx.sign(payer);

  // process the transaction
  await context.banksClient.processTransaction(tx);
  return tokenAccount;
};

// Define AmmAccount type
export type AmmAccount = {
  id: PublicKey;
  admin: PublicKey;
  fee: number;
};

// Define DataAccountRaw type for deserialization
export type AmmAccountRaw = {
  id: Uint8Array;
  admin: Uint8Array;
  fee: number;
};

// Define the schema for the account data
export const ammAccountSchema: borsh.Schema = {
  struct: {
    discriminator: 'u64',
    id: { array: { type: 'u8', len: 32 } },
    admin: { array: { type: 'u8', len: 32 } },
    fee: 'u16',
  },
};

export const deserializeAmmAccount = (data: Uint8Array): AmmAccount => {
  const account = borsh.deserialize(ammAccountSchema, data) as AmmAccountRaw;
  return {
    id: new PublicKey(account.id),
    admin: new PublicKey(account.admin),
    fee: account.fee,
  };
};

// Define AmmAccount type
export type PoolAccount = {
  amm: PublicKey;
  mintA: PublicKey;
  mintB: PublicKey;
};

// Define DataAccountRaw type for deserialization
export type PoolAccountRaw = {
  amm: Uint8Array;
  mint_a: Uint8Array;
  mint_b: Uint8Array;
};

// Define the schema for the account data
export const poolAccountSchema: borsh.Schema = {
  struct: {
    discriminator: 'u64',
    amm: { array: { type: 'u8', len: 32 } },
    mint_a: { array: { type: 'u8', len: 32 } },
    mint_b: { array: { type: 'u8', len: 32 } },
  },
};

export const deserializePoolAccount = (data: Uint8Array): PoolAccount => {
  const account = borsh.deserialize(poolAccountSchema, data) as PoolAccountRaw;
  return {
    amm: new PublicKey(account.amm),
    mintA: new PublicKey(account.mint_a),
    mintB: new PublicKey(account.mint_b),
  };
};