feat: add new listings logos

scripts/build-products.js

@@ -6,7 +6,7 @@ const { CoverProducts, Cover, addresses } = require('@nexusmutual/deployments');
 const ethers = require('ethers');
 const fetch = require('node-fetch');
 
-const { parseProductCoverAssets, parseFilePath, getCoverAssetsSymbols } = require('./utils');
+const { parseProductCoverAssets, parseFilePath, getCoverAssetsSymbols, fetchEventsInBatches } = require('./utils');
 const { allPrivateProductsIds } = require(path.join(__dirname, '../src/constants/privateProducts.js'));
 const productMetadata = require('../data/legacy-product-metadata.json');
 
@@ -60,9 +60,12 @@ const createLogoDict = async logosDir => {
   return map;
 };
 
+const EVENTS_START_BLOCK = 7700000;
+
 const fetchProducts = async (coverContract, coverProducts, provider) => {
   const eventFilter = coverProducts.filters.ProductSet();
-  const events = await coverProducts.queryFilter(eventFilter);
+
+  const events = await fetchEventsInBatches(coverProducts, eventFilter, EVENTS_START_BLOCK, provider);
 
   const logos = await createLogoDict(path.join(__dirname, '../src/logos'));
 

scripts/utils.js

@@ -79,9 +79,39 @@ const parseFilePath = filePath => {
   return { id, filename, extension };
 };
 
+/**
+ * Fetches events in batches to avoid RPC limitations.
+ * All batches are fetched in parallel for better performance.
+ *
+ * @param {ethers.Contract} contract - The contract to query events from.
+ * @param {ethers.EventFilter} eventFilter - The event filter to apply.
+ * @param {number} startBlock - The starting block number.
+ * @param {ethers.providers.Provider} provider - The Ethereum provider to interact with the blockchain.
+ * @param {number} [batchSize=10000] - The number of blocks to query per batch.
+ * @returns {Promise<ethers.Event[]>} A promise that resolves to an array of events.
+ */
+const fetchEventsInBatches = async (contract, eventFilter, startBlock, provider, batchSize = 10_000) => {
+  const endBlock = await provider.getBlockNumber();
+  const batches = [];
+
+  for (let fromBlock = startBlock; fromBlock <= endBlock; fromBlock += batchSize) {
+    const toBlock = Math.min(fromBlock + batchSize - 1, endBlock);
+    batches.push({ fromBlock, toBlock });
+  }
+
+  const batchResults = await Promise.all(
+    batches.map(({ fromBlock, toBlock }) => {
+      return contract.queryFilter(eventFilter, fromBlock, toBlock);
+    }),
+  );
+
+  return batchResults.flat();
+};
+
 module.exports = {
   parseProductCoverAssets,
   parseCoverAssetToProductAsset,
   parseFilePath,
   getCoverAssetsSymbols,
+  fetchEventsInBatches,
 };

src/constants/privateProducts.js

@@ -94,6 +94,8 @@ const allPrivateProductsIds = [
   400, // OpenCover Steakhouse H Yield I USDC
   401, // PT-stcUSD-23JUL2026 (Morpho)
   402, // PT-cUSD-23JUL2026 (Morpho)
+  403, // TermMax
+  405, // OpenCover YoUSD
 ];
 
 module.exports = {

src/constants/products.ts

@@ -396,4 +396,5 @@ export const productCategoryMap: { [productId: number]: ProductCategoryEnum } =
   387: ProductCategoryEnum.Depeg, // Neutrl USD Depeg
   388: ProductCategoryEnum.Dex, // Hybra Finance
   391: ProductCategoryEnum.YieldOptimizer, // IPOR
+  404: ProductCategoryEnum.Custody, // BingX Custody
 };