Skip to content

Commit

Permalink
Merge pull request #2438 from nazihkalo/nazih/fix_phantom_fees
Browse files Browse the repository at this point in the history
 fix phantom fees
  • Loading branch information
0xngmi authored Feb 19, 2025
2 parents 448f91c + 8031ab0 commit a64e2d3
Show file tree
Hide file tree
Showing 2 changed files with 24 additions and 11 deletions.
24 changes: 14 additions & 10 deletions fees/phantom.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,17 +2,21 @@ import { FetchOptions, SimpleAdapter } from "../adapters/types";
import { CHAIN } from "../helpers/chains";
import { getSolanaReceived } from "../helpers/token";


const fee_wallet_addresses = [
'25mYnjJ2MXHZH6NvTTdA63JvjgRVcuiaj6MRiEQNs1Dq',
'9yj3zvLS3fDMqi1F8zhkaWfq8TZpZWHe6cz1Sgt7djXf',
'8psNvWTrdNTiVRNzAgsou9kETXNJm2SXZyaKuJraVRtf',
'CnmA6Zb8hLrG33AT4RTzKdGv1vKwRBKQQr8iNckvv8Yg',
'2rQZb9xqQGwoCMDkpabbzDB9wyPTjSPj9WNhJodTaRHm',
'9gnLg6NtVxaASvxtADLFKZ9s8yHft1jXb1Vu6gVKvh1J',
'wtpXRqKLdGc7vpReogsRugv6EFCw4HBHcxm8pFcR84a',
'D1NJy3Qq3RKBG29EDRj28ozbGwnhmM5yBUp8PonSYUnm',
];

const fetch: any = async (options: FetchOptions) => {
const dailyFees = await getSolanaReceived({ options, targets: [
'25mYnjJ2MXHZH6NvTTdA63JvjgRVcuiaj6MRiEQNs1Dq'
,'9yj3zvLS3fDMqi1F8zhkaWfq8TZpZWHe6cz1Sgt7djXf',
'8psNvWTrdNTiVRNzAgsou9kETXNJm2SXZyaKuJraVRtf',
'CnmA6Zb8hLrG33AT4RTzKdGv1vKwRBKQQr8iNckvv8Yg',
'2rQZb9xqQGwoCMDkpabbzDB9wyPTjSPj9WNhJodTaRHm',
'9gnLg6NtVxaASvxtADLFKZ9s8yHft1jXb1Vu6gVKvh1J',
'wtpXRqKLdGc7vpReogsRugv6EFCw4HBHcxm8pFcR84a',
'D1NJy3Qq3RKBG29EDRj28ozbGwnhmM5yBUp8PonSYUnm',
]})
const dailyFees = await getSolanaReceived({ options, targets: fee_wallet_addresses, blacklist_signers: fee_wallet_addresses
})
return { dailyFees, dailyRevenue: dailyFees }
}

Expand Down
11 changes: 10 additions & 1 deletion helpers/token.ts
Original file line number Diff line number Diff line change
Expand Up @@ -317,12 +317,13 @@ export const evmReceivedGasAndTokens = (receiverWallet: string, tokens: string[]
}
}

export async function getSolanaReceived({ options, balances, target, targets, blacklists }: {
export async function getSolanaReceived({ options, balances, target, targets, blacklists, blacklist_signers }: {
options: FetchOptions;
balances?: sdk.Balances;
target?: string;
targets?: string[];
blacklists?: string[];
blacklist_signers?: string[];
}) {
if (!balances) balances = options.createBalances();

Expand All @@ -338,13 +339,21 @@ export const evmReceivedGasAndTokens = (receiverWallet: string, tokens: string[]
const formattedBlacklist = blacklists.map(addr => `'${addr}'`).join(', ');
blacklistCondition = `AND from_address NOT IN (${formattedBlacklist})`;
}

let blacklist_signersCondition = '';

if (blacklist_signers && blacklist_signers.length > 0) {
const formattedBlacklist = blacklist_signers.map(addr => `'${addr}'`).join(', ');
blacklist_signersCondition = `AND signer NOT IN (${formattedBlacklist})`;
}

const query = `
SELECT SUM(usd_amount) as usd_value, SUM(amount) as amount
FROM solana.assets.transfers
WHERE to_address = '${target}'
AND block_timestamp BETWEEN TO_TIMESTAMP_NTZ(${options.startTimestamp}) AND TO_TIMESTAMP_NTZ(${options.endTimestamp})
${blacklistCondition}
${blacklist_signersCondition}
`;

const res = await queryAllium(query);
Expand Down

0 comments on commit a64e2d3

Please sign in to comment.