const { Connection, Keypair, Transaction, SystemProgram, PublicKey, sendAndConfirmTransaction, ComputeBudgetProgram } = require('@solana/web3.js'); const bs58 = require('bs58'); const axios = require('axios'); // Load your wallet keypair from environment variable that you use to send the transactions from const SECRET_KEY = process.env.SECRET_KEY; if (!SECRET_KEY) { throw new Error('SECRET_KEY environment variable is required'); } const sender = Keypair.fromSecretKey(bs58.decode(SECRET_KEY)); // Set up clients const rpcClient = new Connection("https://api.mainnet-beta.solana.com", 'confirmed'); // For RPC calls, you can use any RPC endpoint // TXENGINE_HOST and TXENGINE_TOKEN are from the Telegram bot // if you're specifying jito=1 the TxEngine will also duplicate the transaction to Jito, // but it's required to tip Jito to make it work. // if you don't need Jito you can specify jito=0 or just leave it empty const txEngineEndpoint = `https://${process.env.TXENGINE_HOST}?token=${process.env.TXENGINE_TOKEN}&jito=1`; // Create a custom connection for the transaction engine const txEngineConnection = new Connection(txEngineEndpoint, 'confirmed'); async function sendTransaction() { try { // Get latest blockhash using RPC client const { blockhash } = await rpcClient.getLatestBlockhash(); console.log(`Got blockhash: ${blockhash}`); // Create transfer instruction for sending 0.000001 SOL const receiverPubkey = new PublicKey("SOME_RECIPIENT_PUBLIC_KEY"); // Replace with actual recipient const transaction = new Transaction(); transaction.recentBlockhash = blockhash; transaction.feePayer = sender.publicKey; // Add priority fee transaction.add( ComputeBudgetProgram.setComputeUnitPrice({ microLamports: 1000, }) ); // Add transfer instruction transaction.add( SystemProgram.transfer({ fromPubkey: sender.publicKey, toPubkey: receiverPubkey, lamports: 1000, // 0.000001 SOL }) ); // Sign the transaction transaction.sign(sender); // Send transaction via transaction engine console.log(`Sending transaction at ${new Date().toISOString()}`); console.log(`Using transaction engine: ${txEngineEndpoint}`); const signature = await txEngineConnection.sendRawTransaction(transaction.serialize()); console.log(`Transaction sent at ${new Date().toISOString()}`); console.log(`🎉 SUCCESS! Transaction signature: ${signature}`); return signature; } catch (error) { console.error(`Error: ${error.message}`); throw error; } } // Run the script sendTransaction() .then(signature => { console.log('Transaction completed successfully'); process.exit(0); }) .catch(error => { console.error('Transaction failed:', error); process.exit(1); });