diff --git a/adapters/vfat/hourly_blocks.csv b/adapters/vfat/hourly_blocks.csv index afdfb69f..bb659a24 100644 --- a/adapters/vfat/hourly_blocks.csv +++ b/adapters/vfat/hourly_blocks.csv @@ -1,2 +1,2 @@ number,timestamp -5703320,1718801232 \ No newline at end of file +9397663,1726210798 \ No newline at end of file diff --git a/adapters/vfat/src/sdk/nile/lensDetails.ts b/adapters/vfat/src/sdk/nile/lensDetails.ts index b5d9934e..f2e4263f 100644 --- a/adapters/vfat/src/sdk/nile/lensDetails.ts +++ b/adapters/vfat/src/sdk/nile/lensDetails.ts @@ -13,6 +13,7 @@ export interface VoteResponse { result: VoteRequest; } +// Function to fetch user votes with batching export const fetchUserVotes = async ( blockNumber: bigint, userAddress: string, @@ -45,11 +46,13 @@ export const fetchUserVotes = async ( }); } - const userTokensCalls = await multicall( + const userTokensCalls = await batchMulticall( publicClient, veNILEAbi as Abi, calls, blockNumber, + 500, + 200 ); const detailsCall = userTokensCalls.map((call) => { @@ -60,11 +63,13 @@ export const fetchUserVotes = async ( }; }); - const res = (await multicall( + const res = (await batchMulticall( publicClient, veNILEAbi as Abi, detailsCall, blockNumber, + 500, + 200 )) as any; return res.map((r: any) => { @@ -72,6 +77,44 @@ export const fetchUserVotes = async ( }) as VoteResponse[]; }; +// Batch multicall function with a delay +async function batchMulticall( + publicClient: PublicClient, + abi: Abi, + calls: any[], + blockNumber: bigint, + batchSize: number, + delay: number, +) { + const results = []; + + for (let i = 0; i < calls.length; i += batchSize) { + const batch = calls.slice(i, i + batchSize); + + const call: MulticallParameters = { + contracts: batch.map((call) => ({ + address: call.address as Address, + abi, + functionName: call.name, + args: call.params, + })), + blockNumber, + }; + + // Send the batch of requests + const res = await publicClient.multicall(call); + results.push(...res); + + // Introduce delay before sending the next batch + if (i + batchSize < calls.length) { + await new Promise((resolve) => setTimeout(resolve, delay)); + } + } + + return results; +} + +// Regular multicall function function multicall( publicClient: PublicClient, abi: Abi,