tymur999/profit-script
1
0
Fork 0
mirror of https://github.com/tymur999/profit-script.git synced 2025-08-05 08:10:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed

Browse Source
This commit is contained in:
tymur999
2024-05-26 15:24:56 -05:00
parent 5df2f3baed
commit d0aa2c0c52
1 changed files with 34 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/index.ts
View File

@@ -1,35 +1,50 @@
import {Connection, PublicKey} from "@solana/web3.js"; import {ConfirmedSignatureInfo, Connection, PublicKey} from "@solana/web3.js";
const connection = new Connection(process.env.RPC!); const connection = new Connection(process.env.RPC!);
//note: only supports last 1000 txns //note: only supports last 1000 txns
async function calculatePumpFunProfit(walletAddress: PublicKey, myToken: PublicKey) { async function calculatePumpFunProfit(walletAddress: PublicKey, myToken: PublicKey) {
let solNetProfit = 0; let solNetProfit = 0;
const sigs = await connection.getSignaturesForAddress(myToken, {limit: 1000}); const sigs: ConfirmedSignatureInfo[] = [];
let lastTxn: string | undefined = undefined;
do {
const newSigs = await connection.getSignaturesForAddress(myToken, {limit: 1000, before: lastTxn});
if(!newSigs.length) break;
sigs.push(
...newSigs
);
lastTxn = newSigs[newSigs.length - 1]?.signature;
} while(true);
const parseTasks: Promise<any>[] = [];
for(const sig of sigs) { for(const sig of sigs) {
if(sig.err) continue; if(sig.err) continue;
const txn = await connection.getParsedTransaction(sig.signature, {maxSupportedTransactionVersion: 0}); parseTasks.push(connection.getParsedTransaction(sig.signature, {maxSupportedTransactionVersion: 0})
if(!txn || !txn.meta) continue; .then(txn => {
if(!txn || !txn.meta) return;
//check if there was a change in myToken //check if there was a change in myToken
const postTokenBalances = txn.meta.postTokenBalances; const postTokenBalances = txn.meta.postTokenBalances;
const preTokenBalances = txn.meta.preTokenBalances; const preTokenBalances = txn.meta.preTokenBalances;
if(!postTokenBalances?.length && !preTokenBalances?.length) continue; if(!postTokenBalances?.length && !preTokenBalances?.length) return;
const postMyToken = postTokenBalances?.find(tb => tb.mint == myToken.toString() && const postMyToken = postTokenBalances?.find(tb => tb.mint == myToken.toString() &&
tb.owner == walletAddress.toString()); tb.owner == walletAddress.toString());
const preMyToken = preTokenBalances?.find(tb => tb.mint == myToken.toString() && const preMyToken = preTokenBalances?.find(tb => tb.mint == myToken.toString() &&
tb.owner == walletAddress.toString()); tb.owner == walletAddress.toString());
if(!postMyToken && !preMyToken) continue; if(!postMyToken && !preMyToken) return;
//calculate sol change //calculate sol change
if(!txn.meta.preBalances.length || !txn.meta.postBalances.length) continue; if(!txn.meta.preBalances.length || !txn.meta.postBalances.length) return;
let solChange = txn.meta.postBalances[0] - txn.meta.preBalances[0]; //in lamports let solChange = txn.meta.postBalances[0] - txn.meta.preBalances[0]; //in lamports
console.log("new transaction with sol change:", solChange); console.log("new transaction with sol change:", solChange);
solNetProfit += solChange; solNetProfit += solChange;
}));
} }
await Promise.all(parseTasks);
console.log(solNetProfit); console.log(solNetProfit);
} }
calculatePumpFunProfit(new PublicKey("BUmWvaEF46YHAGmn3ePQLPEvt19sm6k6JRnKHHTiE4Ag"), new PublicKey("3sSrCimwDE246Lb2HXoogLmAd9jPx6K2ArA4joQZgFL1")); calculatePumpFunProfit(new PublicKey("8NqLtG4BnGyQJrfu91bWK215SJ1qadfhSdygeyX6VjsM"), new PublicKey("BXAtPnRuZjPKe9Gsv9Wsgh54yqWTVT6gR7w7tSYYThnW"));