feat: update log

reservoirprotocol · Jan 22, 2025 · e613b54 · e613b54
1 parent 8d9aeab
commit e613b54
Showing 1 changed file with 13 additions and 4 deletions.
diff --git a/src/jobs/seaport-sync/utils.ts b/src/jobs/seaport-sync/utils.ts
@@ -23,7 +23,8 @@ export const fetchOrders = async (
     overrideBaseUrl?: string;
     contract?: string;
     maxOrders?: number;
-  }
+  },
+  userNftTools = false
 ) => {
   logger.debug("fetch_orders_seaport", `Seaport - Start. side=${side}`);
 
@@ -50,12 +51,12 @@ export const fetchOrders = async (
       "X-API-KEY": _.includes(
         [5, 80001, 80002, 84531, 999, 11155111],
         config.chainId
-      ) || (config.openseaApiUrl && config.openseaNftApiKey)
+      ) || (userNftTools && config.openseaApiUrl && config.openseaNftApiKey)
         ? ""
         : details?.apiKey || config.realtimeOpenseaApiKey,
     };
 
-    if (config.openseaApiUrl && config.openseaNftApiKey) {
+    if (userNftTools && config.openseaApiUrl && config.openseaNftApiKey) {
       headers["x-nft-api-key"] = config.openseaNftApiKey;
     }
 
@@ -158,16 +159,24 @@ export const fetchOrders = async (
           "fetch_orders_seaport",
           JSON.stringify(
             {
-              message: `Seaport - Rate Limited. side=${side}, cursor=${cursor}, url=${config.openseaApiUrl || url}, error=${error.message}`,
+              message: `Seaport - Rate Limited. userNftTools=${userNftTools}, side=${side}, cursor=${cursor}, url=${config.openseaApiUrl || url}, error=${error.message}`,
               openseaApiUrl: config.openseaApiUrl,
               openseaNftApiKey: config.openseaNftApiKey,
               options,
               responseData: error.response?.data,
               responseStatus: error.response?.status,
+              userNftTools,
             }
           )
         );
 
+        if (!userNftTools && config.openseaApiUrl && config.openseaNftApiKey) {
+          headers["x-nft-api-key"] = config.openseaNftApiKey;
+
+          await fetchOrders(side, details, true);
+          continue;
+        }
+
         if (cursor) {
           await new Promise((resolve) => setTimeout(resolve, 5000));
           continue;