100ms Raydium Sniper MCP

import { PublicKey } from '@solana/web3.js'; import dotenv from 'dotenv'; dotenv.config(); export class MarketManager { constructor() { this.SERUM_PROGRAM_ID = 'srmqPvymJeFKQ4zGQed1GFppgkRHL9kaELCbyksJtPX'; this.MIN_MARKET_SIZE = 300; } async findMarkets(connection, tokenMint) { try { console.error('Fetching Serum market accounts...'); // Get all program accounts const accounts = await connection.getProgramAccounts(new PublicKey(this.SERUM_PROGRAM_ID), { commitment: 'processed', filters: [ { dataSize: this.MIN_MARKET_SIZE } ] }); // Filter accounts that contain the token mint const markets = accounts.filter(account => { try { const data = account.account.data; const baseMint = new PublicKey(data.slice(5, 37)); const quoteMint = new PublicKey(data.slice(37, 69)); return baseMint.equals(tokenMint) || quoteMint.equals(tokenMint); } catch (error) { return false; } }); console.error(`Found ${markets.length} Serum markets for token ${tokenMint.toBase58()}`); return markets; } catch (error) { // Check if error is due to disabled RPC method if (error.message?.includes('410') || error.message?.includes('disabled')) { console.error('RPC endpoint does not support getProgramAccounts, trying alternative method...'); try { // Try alternative method using getTokenAccountsByOwner const tokenAccounts = await connection.getTokenAccountsByOwner(new PublicKey(this.SERUM_PROGRAM_ID), { programId: new PublicKey('TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA') }); const markets = tokenAccounts.value.filter(account => { try { const data = account.account.data; return data.length >= this.MIN_MARKET_SIZE; } catch (error) { return false; } }); console.error(`Found ${markets.length} Serum markets using alternative method`); return markets; } catch (altError) { throw new Error(`Failed to find Serum markets (alternative method): ${altError.message}`); } } // If error is not due to disabled method, continue with empty markets console.error(`Failed to find Serum markets: ${error.message}`); return []; } } }