handle addresses limit

beethovenxfi · Dec 20, 2023 · 6825b46 · 6825b46
1 parent a8c838b
commit 6825b46
Showing 1 changed file with 22 additions and 1 deletion.
diff --git a/modules/web3/events.ts b/modules/web3/events.ts
@@ -10,6 +10,7 @@ export const getEvents = async (
     rpcUrl: string,
     rpcMaxBlockRange: number,
     abi?: any,
+    maxAddresses = 500,
 ): Promise<Event[]> => {
     let iEvents: Interface;
     if (abi && abi.length > 0) {
@@ -28,7 +29,7 @@ export const getEvents = async (
         const from = fromBlock + (i > 0 ? 1 : 0) + i * rpcMaxBlockRange;
         const to = Math.min(fromBlock + (i + 1) * rpcMaxBlockRange, toBlock);
 
-        const addressChunks = chunk(addresses, 500);
+        const addressChunks = chunk(addresses, maxAddresses);
 
         for (const addressChunk of addressChunks) {
             const promise = fetchLogs(from, to, addressChunk, topics, rpcUrl).catch((e: any) => {
@@ -62,6 +63,26 @@ export const getEvents = async (
                     });
                 }
 
+                // Allnodes addresses size limit
+                if (e.includes && e.includes('specify less number of addresses')) {
+                    return new Promise<Event[]>((resolve) => {
+                        setTimeout(() => {
+                            resolve(
+                                getEvents(
+                                    from,
+                                    to,
+                                    addressChunk,
+                                    topics,
+                                    rpcUrl,
+                                    rpcMaxBlockRange,
+                                    undefined,
+                                    maxAddresses / 2,
+                                ),
+                            );
+                        }, 1000);
+                    });
+                }
+
                 console.error('Error fetching logs:', e);
                 return Promise.reject(e);
             });