WIP

Signed-off-by: prxt <prxt@6529.io>
6529-Collections · Jul 1, 2024 · 537b410 · 537b410
1 parent bb6d8d5
commit 537b410
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 13 deletions.
diff --git a/src/prenode.ts b/src/prenode.ts
@@ -40,9 +40,9 @@ cron.schedule(
   }
 );
 
-// transactions every 5 minutes
+// transactions every 2 minutes
 cron.schedule(
-  '*/5 * * * *',
+  '*/2 * * * *',
   async () => {
     if (RUNNING_TDH || RUNNING_UPDATE || RUNNING_TRX) {
       logger.info(

diff --git a/src/transactions/transaction_values.ts b/src/transactions/transaction_values.ts
@@ -92,12 +92,11 @@ export const findTransactionValues = async (
 
   const transactionsWithValues: Transaction[] = [];
 
-  await Promise.all(
-    transactions.map(async (t) => {
-      const parsedTransaction = await resolveValue(t);
-      transactionsWithValues.push(parsedTransaction);
-    })
-  );
+  for (const t of transactions) {
+    await sleep(100);
+    const parsedTransaction = await resolveValue(t);
+    transactionsWithValues.push(parsedTransaction);
+  }
 
   logger.info(
     `[PROCESSED ${transactionsWithValues.length} TRANSACTION VALUES]`
@@ -107,7 +106,6 @@ export const findTransactionValues = async (
 };
 
 async function resolveValue(t: Transaction) {
-  await sleep(500); // Alchemy rate limit
   const transaction = await alchemy.core.getTransaction(t.transaction);
   t.value = transaction ? parseFloat(Utils.formatEther(transaction.value)) : 0;
   t.royalties = 0;
@@ -120,7 +118,6 @@ async function resolveValue(t: Transaction) {
   }
 
   if (transaction) {
-    await sleep(500); // Alchemy rate limit
     const receipt = await alchemy.core.getTransactionReceipt(transaction?.hash);
     const logCount =
       receipt?.logs.filter(
@@ -212,7 +209,6 @@ async function resolveValue(t: Transaction) {
       toBlock: block
     };
 
-    await sleep(500); // Alchemy rate limit
     const internlTrfs = await alchemy.core.getAssetTransfers(settings);
     const filteredInternalTrfs = internlTrfs.transfers.filter(
       (it) =>

diff --git a/src/transactions/transactions-discovery.service.ts b/src/transactions/transactions-discovery.service.ts
@@ -84,7 +84,7 @@ export class TransactionsDiscoveryService {
         pageKey
       );
 
-      await sleep(500); // Alchemy rate limit
+      await sleep(1000); // Alchemy rate limit
       const { transfers, pageKey: nextPageKey } =
         await this.alchemy.core.getAssetTransfers(alchemyParams);
 
@@ -134,7 +134,7 @@ export class TransactionsDiscoveryService {
       category: [AssetTransfersCategory.ERC1155, AssetTransfersCategory.ERC721],
       contractAddresses: [contract],
       withMetadata: true,
-      maxCount: 150,
+      maxCount: 50,
       fromBlock: startingBlockHex,
       toBlock: toBlockHex,
       pageKey: pageKey