Improved Performance

.changeset/improvedperformance.md

@@ -0,0 +1,5 @@
+---
+'@degenfrends/solana-rugchecker': patch
+---
+
+## @degenfrends/solana-rugchecker: Initial version

index.js

@@ -2,11 +2,11 @@ const SPLRugchecker = require('./dist/index.js').default;
 const WebsiteChecker = require('./dist/index.js').WebsiteChecker;
 async function main() {
     const rugCheckConfig = {
-        solanaRpcEndpoint: 'https://solana-mainnet.rpc.extrnode.com/036e028d-7094-4f3d-876e-956d6e56f0ff',
-        poolFilePath: './all_pools.json'
+        solanaRpcEndpoint: 'https://solana-mainnet.rpc.extrnode.com/036e028d-7094-4f3d-876e-956d6e56f0ff'
+        //poolFilePath: './all_pools.json'
     };
     const rugChecker = new SPLRugchecker(rugCheckConfig);
-    const result = await rugChecker.check('97oWtQfbZMdDbn1jdNciDHm2vnPBR8VT3Ns7vSS7i9cm');
+    const result = await rugChecker.check('7Hk81bdBwjgfNDvJc6WBzjEw95Rnt5Tts6qJg2Mnt38L');
     const score = rugChecker.rugScore(result);
     const isRug = rugChecker.isRug(result);
     console.log(result);

package.json

@@ -29,17 +29,17 @@
     "license": "MIT",
     "devDependencies": {
         "@changesets/cli": "^2.27.5",
-        "@swc/core": "^1.5.7",
+        "@swc/core": "^1.5.28",
         "@types/jest": "^29.5.12",
         "jest": "^29.7.0",
         "ts-jest": "^29.1.4",
         "ts-node": "^10.9.2",
-        "tsup": "^8.0.2",
+        "tsup": "^8.1.0",
         "typescript": "^5.4.5"
     },
     "dependencies": {
         "@metaplex-foundation/js": "^0.20.1",
-        "@raydium-io/raydium-sdk": "^1.3.1-beta.52",
+        "@raydium-io/raydium-sdk": "1.3.1-beta.54",
         "@solana/web3.js": "^1.92.3",
         "axios": "^1.7.2",
         "dotenv": "^16.4.5",

src/checker/holders-checker.ts

@@ -32,7 +32,6 @@ export default class HoldersChecker {
         for (const holder of largestHoldersResponse.value) {
             const tokenAccountsResponse = await this.connection.getParsedAccountInfo(holder.address);
             const walletAddress = (tokenAccountsResponse.value?.data as ParsedAccountData)?.parsed?.info?.owner;
-            await sleep(300);
             if (holder.uiAmount !== null && walletAddress !== null && walletAddress !== '5Q544fKrFoe6tsEbD7S8EmxGTJYAKtTVhAW5Q5pge4j1') {
                 whaleSupply += holder.uiAmount;
                 let topHolder = new HolderCheckResult();
@@ -53,6 +52,7 @@ export default class HoldersChecker {
         holdersCheckResult.topHolders = topHolders;
         holdersCheckResult.topHoldersPercentage = topHoldersPercentage;
         holdersCheckResult.raydiumPercentage = raydiumPercentage;
+
         return holdersCheckResult;
     }
 }

src/checker/liquidity-checker.ts

@@ -9,15 +9,19 @@ export default class LiquidityChecker {
     private connection: Connection;
 
     private poolFilePath: string;
-
-    constructor({ solanaRpcEndpoint, poolFilePath }: LiquidityCheckConfig, connection?: Connection) {
+    private poolAddress: string;
+    constructor({ solanaRpcEndpoint, poolFilePath, poolAddress }: LiquidityCheckConfig, connection?: Connection) {
         if (!solanaRpcEndpoint) {
             solanaRpcEndpoint = String(process.env.SOLANA_RPC_ENDPOINT);
         }
         if (!poolFilePath) {
             poolFilePath = String(process.env.POOL_FILE_PATH);
+        } else {
+            this.poolFilePath = poolFilePath;
+        }
+        if (poolAddress) {
+            this.poolAddress = poolAddress;
         }
-        this.poolFilePath = poolFilePath;
         if (!connection) {
             connection = new Connection(solanaRpcEndpoint);
         }
@@ -26,10 +30,14 @@ export default class LiquidityChecker {
 
     async check(tokenAddress: string): Promise<LiquidityCheckResult> {
         let poolAddress;
-        if (!this.poolFilePath) {
-            poolAddress = await this.getRaydiumPoolAddress(tokenAddress);
+        if (this.poolAddress) {
+            poolAddress = this.poolAddress;
         } else {
-            poolAddress = await this.getLiquidityPool(tokenAddress);
+            if (!this.poolFilePath) {
+                poolAddress = await this.getRaydiumPoolAddress(tokenAddress);
+            } else {
+                poolAddress = await this.getLiquidityPool(tokenAddress);
+            }
         }
         const liquidityCheckResult = new LiquidityCheckResult();
         if (!poolAddress) {
@@ -51,6 +59,7 @@ export default class LiquidityChecker {
         liquidityCheckResult.isLiquidityLocked = burnPct > 95;
         liquidityCheckResult.burnt = burnPct;
         liquidityCheckResult.liquidityPoolAddress = poolAddress;
+
         return liquidityCheckResult;
     }
 
@@ -73,9 +82,7 @@ export default class LiquidityChecker {
     async getRaydiumPoolAddress(mintAddress: string) {
         try {
             const url = 'https://api.geckoterminal.com/api/v2/networks/solana/tokens/' + mintAddress;
-
             const response = await axios.get(url);
-            console.log(response);
             return response.data.data.relationships.top_pools.data[0].id.replace('solana_', '');
         } catch (error) {
             console.error('Error fetching pool address:', error);

src/index.ts

@@ -19,9 +19,11 @@ export default class SPLRugchecker {
     }
 
     async check(tokenAddress: string): Promise<RugCheckResult> {
-        const metadataCheckResult = await this.metadataChecker.check(tokenAddress);
-        const holdersCheckResult = await this.holdersChecker.check(tokenAddress);
-        const liquidityCheckResult = await this.liquidityChecker.check(tokenAddress);
+        const [metadataCheckResult, holdersCheckResult, liquidityCheckResult] = await Promise.all([
+            this.metadataChecker.check(tokenAddress),
+            this.holdersChecker.check(tokenAddress),
+            this.liquidityChecker.check(tokenAddress)
+        ]);
 
         const rugCheckResult = new RugCheckResult();
         rugCheckResult.metadata = metadataCheckResult;