chore: avoid duplicate write + cleanup

src/config.ts

@@ -1489,7 +1489,7 @@ const CHAINS: Chain[] = [
       .default("https://evm-rpc.sei-apis.com")
       .parse(process.env.SEI_MAINNET_RPC_URL),
     pricesFromTimestamp: Date.UTC(2024, 0, 1, 0, 0, 0),
-    maxGetLogsRange: 1000,
+    maxGetLogsRange: 10000,
     tokens: [
       {
         code: "SEI",

src/index.ts

@@ -526,13 +526,13 @@ async function catchupAndWatchChain(
       // Iterate through each gateway and attempt to fetch data
       for (const gateway of config.ipfsGateways) {
         const url = `${gateway}/ipfs/${cid}`;
-        chainLogger.info(`Trying IPFS gateway: ${gateway} for CID: ${cid}`);
+        // chainLogger.info(`Trying IPFS gateway: ${gateway} for CID: ${cid}`);
 
         const result = await fetchFromGateway(url);
         if (result !== undefined) {
-          chainLogger.info(
-            `Fetch successful from gateway: ${gateway} for CID: ${cid}`
-          );
+          // chainLogger.info(
+          //   `Fetch successful from gateway: ${gateway} for CID: ${cid}`
+          // );
 
           // Save to IpfsData table
           try {

src/prices/provider.ts

@@ -211,10 +211,19 @@ export function createPriceProvider(
         });
       }
 
-      await db.applyChange({
-        type: "InsertManyPrices",
-        prices: [newPrice],
-      });
+      // Check if the price is already in the database
+      const existingPrice = await db.getTokenPriceByBlockNumber(
+        chainId,
+        newPrice.tokenAddress,
+        blockNumber
+      );
+
+      if (!existingPrice) {
+        await db.applyChange({
+          type: "InsertManyPrices",
+          prices: [newPrice],
+        });
+      }
 
       return { ...newPrice, tokenDecimals: token.decimals };
     }