Replace with a trimmed mainnet.json

Plus a couple of other fixes

Author: akegaviar

src/RaydiumSwap.ts

@@ -13,6 +13,8 @@ import {
 } from '@raydium-io/raydium-sdk'
 import { Wallet } from '@coral-xyz/anchor'
 import bs58 from 'bs58'
+import fs from 'fs';
+import path from 'path';
 
 /**
  * Class representing a Raydium Swap operation.
@@ -39,9 +41,14 @@ class RaydiumSwap {
    * @returns {Promise<void>}
    */
   async loadPoolKeys(liquidityFile: string) {
-    const liquidityJsonResp = await fetch(liquidityFile);
-    if (!liquidityJsonResp.ok) return
-    const liquidityJson = (await liquidityJsonResp.json()) as { official: any; unOfficial: any }
+    let liquidityJson;
+    if (liquidityFile.startsWith('http')) {
+      const liquidityJsonResp = await fetch(liquidityFile);
+      if (!liquidityJsonResp.ok) return;
+      liquidityJson = await liquidityJsonResp.json();
+    } else {
+      liquidityJson = JSON.parse(fs.readFileSync(path.join(__dirname, liquidityFile), 'utf-8'));
+    }
     const allPoolKeysJson = [...(liquidityJson?.official ?? []), ...(liquidityJson?.unOfficial ?? [])]
 
     this.allPoolKeysJson = allPoolKeysJson
@@ -271,4 +278,4 @@ class RaydiumSwap {
   }
 }
 
-export default RaydiumSwap
+export default RaydiumSwap

src/swapConfig.ts

@@ -1,11 +1,11 @@
 export const swapConfig = {
   executeSwap: false, // Send tx when true, simulate tx when false
   useVersionedTransaction: true,
-  tokenAAmount: 0.01, // Swap 0.01 SOL for USDT in this example
+  tokenAAmount: 0.001, // Swap 0.01 SOL for USDC in this example
   tokenAAddress: "So11111111111111111111111111111111111111112", // Token to swap for the other, SOL in this case
   tokenBAddress: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v", // USDC address
   maxLamports: 1500000, // Micro lamports for priority fee
   direction: "in" as "in" | "out", // Swap direction: 'in' or 'out'
-  liquidityFile: "https://api.raydium.io/v2/sdk/liquidity/mainnet.json",
+  liquidityFile: "trimmed_mainnet.json",
   maxRetries: 20,
 };

src/trimMainnet.ts

@@ -0,0 +1,58 @@
+import fs from 'fs';
+import { swapConfig } from './swapConfig';
+
+interface PoolInfo {
+    id: string;
+    baseMint: string;
+    quoteMint: string;
+    lpMint: string;
+    version: number;
+    programId: string;
+    authority: string;
+    openOrders: string;
+    targetOrders: string;
+    baseVault: string;
+    quoteVault: string;
+    withdrawQueue: string;
+    lpVault: string;
+    marketVersion: number;
+    marketProgramId: string;
+    marketId: string;
+    marketAuthority: string;
+    marketBaseVault: string;
+    marketQuoteVault: string;
+    marketBids: string;
+    marketAsks: string;
+    marketEventQueue: string;
+}
+
+function trimMainnetJson() {
+    // Read the local mainnet.json file
+    const mainnetData = JSON.parse(fs.readFileSync('../mainnet.json', 'utf-8'));
+
+    // Get the token addresses from swapConfig
+    const { tokenAAddress, tokenBAddress } = swapConfig;
+
+    // Find the pool that matches the token pair
+    const relevantPool = mainnetData.official.find((pool: PoolInfo) => 
+        (pool.baseMint === tokenAAddress && pool.quoteMint === tokenBAddress) ||
+        (pool.baseMint === tokenBAddress && pool.quoteMint === tokenAAddress)
+    );
+
+    if (!relevantPool) {
+        console.error('No matching pool found for the given token pair');
+        return;
+    }
+
+    // Create a new object with only the necessary information
+    const trimmedData = {
+        official: [relevantPool]
+    };
+
+    // Write the trimmed data to a new file
+    fs.writeFileSync('trimmed_mainnet.json', JSON.stringify(trimmedData, null, 2));
+
+    console.log('Trimmed mainnet.json file has been created as trimmed_mainnet.json');
+}
+
+trimMainnetJson();

src/trimmed_mainnet.json

@@ -0,0 +1,32 @@
+{
+    "official": [
+      {
+        "id": "58oQChx4yWmvKdwLLZzBi4ChoCc2fqCUWBkwMihLYQo2",
+        "baseMint": "So11111111111111111111111111111111111111112",
+        "quoteMint": "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
+        "lpMint": "8HoQnePLqPj4M7PUDzfw8e3Ymdwgc7NLGnaTUapubyvu",
+        "baseDecimals": 9,
+        "quoteDecimals": 6,
+        "lpDecimals": 9,
+        "version": 4,
+        "programId": "675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8",
+        "authority": "5Q544fKrFoe6tsEbD7S8EmxGTJYAKtTVhAW5Q5pge4j1",
+        "openOrders": "HmiHHzq4Fym9e1D4qzLS6LDDM3tNsCTBPDWHTLZ763jY",
+        "targetOrders": "CZza3Ej4Mc58MnxWA385itCC9jCo3L1D7zc3LKy1bZMR",
+        "baseVault": "DQyrAcCrDXQ7NeoqGgDCZwBvWDcYmFCjSb9JtteuvPpz",
+        "quoteVault": "HLmqeL62xR1QoZ1HKKbXRrdN1p3phKpxRMb2VVopvBBz",
+        "withdrawQueue": "11111111111111111111111111111111",
+        "lpVault": "11111111111111111111111111111111",
+        "marketVersion": 4,
+        "marketProgramId": "srmqPvymJeFKQ4zGQed1GFppgkRHL9kaELCbyksJtPX",
+        "marketId": "8BnEgHoWFysVcuFFX7QztDmzuH8r5ZFvyP3sYwn1XTh6",
+        "marketAuthority": "CTz5UMLQm2SRWHzQnU62Pi4yJqbNGjgRBHqqp6oDHfF7",
+        "marketBaseVault": "CKxTHwM9fPMRRvZmFnFoqKNd9pQR21c5Aq9bh5h9oghX",
+        "marketQuoteVault": "6A5NHCj1yF6urc9wZNe6Bcjj4LVszQNj5DwAWG97yzMu",
+        "marketBids": "5jWUncPNBMZJ3sTHKmMLszypVkoRK6bfEQMQUHweeQnh",
+        "marketAsks": "EaXdHx7x3mdGA38j5RSmKYSXMzAFzzUXCLNBEDXDn1d5",
+        "marketEventQueue": "8CvwxZ9Db6XbLD46NZwwmVDZZRDy7eydFcAGkXKh9axa",
+        "lookupTableAccount": "3q8sZGGpPESLxurJjNmr7s7wcKS5RPCCHMagbuHP9U2W"
+      }
+    ]
+  }