svm: revert

Signed-off-by: bingyuyap <[email protected]>
wormhole-foundation · Nov 22, 2024 · 563aa11 · 563aa11
1 parent b71e632
commit 563aa11
Showing 1 changed file with 7 additions and 39 deletions.
diff --git a/watcher/scripts/watchFt.ts b/watcher/scripts/watchFt.ts
@@ -11,44 +11,12 @@ import { PublicKey } from '@solana/web3.js';
 const network = getNetwork();
 async function watchFtSolana(network: Network, fromSlot: number, toSlot: number) {
   const watcher = new FTSolanaWatcher(network);
+  const batchSize = 1000;
 
-  // for (let currentSlot = fromSlot; currentSlot <= toSlot; currentSlot += batchSize) {
-  //   const batchEndSlot = Math.min(currentSlot + batchSize - 1, toSlot);
-  //   await watcher.getFtMessagesForBlocks(currentSlot, batchEndSlot);
-  //   console.log(`Processed slots ${currentSlot} to ${batchEndSlot}`);
-  // }
-
-  const sigs = [
-    "3gC3F2wvr5p77JXvb7szwihPUNYR79ob68vtspkbaNboULPJV1q55qvAiZSsKiXnNXEeQv3tg492dEa35wbmEPQy",
-    "26Mw7dUekSQUQbPoRF8jiwTURUuvrgRvysASJ8Am7SS2MXjkSYgFMLyQPo5UwHc9fNb8jooa3G2naLyPrS3a5Qcp",
-    "4kXB42Ujb67Hm28XQPuggcTu8qox8RsHANS6UBEnb74WEngSDyhHWfLqq5ftJxnA5fNBaASmhwBrnhQGMhtp7oDM",
-    "5HoSzuRrXEpAyTobdcW9Nvv8qUVUM5rrQqmFrtNdaoZhQs63G8PTryiwU9BYASqvEyyGKLDc1gH9ECPjKggQX61T",
-    "9NYj698U9AzBDdQAC4NxgSoCWEMF3n8X6KzfK2TSq6AKRcfzvu51aQnBas8PP6yobqJA9ip7E3mEgMuunh3ysuW",
-    "3cFvuacoBULB5xFbymQvLnGsVBdnTuf8kLt6DjYL8sb7gZdk3ToPr9ZPmvtMaQGXpHW8oENvHXYDzVunB2gUHcZE",
-    "4YYxJEpcpUokCStcPnbR5GNAYRwnQuHKuLvXuVwDwdct2P3v72VnfbyviQ2TTnLfhGEXDyJF3chVY6bfq3zx7yji",
-    "3LJ2HJtUj7AjajvxFSkKr6skZwt9cB1JtLftBpj619PUG8Yeccow5zFYJcqTYTv6t5aHHxbcrU6mNMA5k2Yoo6zz",
-    "2NqQcdZqGAmjco6Lk5npPegMEa3AZKdx11TDyix352n3GgtPHgFWvMS9p3TkpcgYbC3NWAQvxmf2cgzomsySa1bX",
-    "z9VYybpvDUVJaSvpiKvPh7VfaHCuFYmugoNKSfB6ygXDbLZMnJv5Ccjjv7yY4zxXCLGtKyjD3JVPXGoxuxV9KMW",
-    "21Ecs6yZARuoT4JfgAxaVCkmeNoy39f3a1db6dKfYxX8LJuPivPCFnR5i5yYssaQsDzg43f1NFXc2A8m32ghiGFr",
-    "38HYorUdMRS2ocbHerM5VhxjtF83JYXT5617KMxToZhb8HzCCQ3pWUvp79oVBF5AxQUdMEDRBqSFsCuncgedY36j",
-    "43wWsi2BseU4oMfj6uthnLx9FfQN9EjAy1UbYgz8QsdN3vYy9vCs6t6Gyw5a71Y2Xcaz2PaWVcJvyYTTgG27XPJi",
-    "3gCkjjVw5arxWrKW8RfzM9aaWzy7Dz4RXNhe7uSZAVLeAuCCoyVFoBkw6nxyFQhxKKQkvvDLYVaPbjnMah5bt3WF",
-    "4LCCZkE4oFU1hGfdGdT7SSxquFH6cv5SdWEQgF7MLNnnHjJchv9dRvQtkS6A2gybpfR9N5Vx6PV8k6tzndsdcitw",
-    "2V7g7NNPJqHDy2LKXSh3rkrvFMoSJU5Z3MUEMZ8AEjV7BTv8KALT78p42AoxufdhAkct5xQQY5zH9fKB8dBiqiBj"
-  ];
-
-  const txs = await watcher.connection?.getTransactions(sigs, {
-    maxSupportedTransactionVersion: 0
-  });
-
-  const slots = txs?.map(tx => tx?.slot)
-
-  if (slots) {
-    for (const slot of slots) {
-      if (!slot) continue;
-      await watcher.getFtMessagesForBlocks(slot, slot);
-      console.log(`Processed slot ${slot}`);
-    }
+  for (let currentSlot = fromSlot; currentSlot <= toSlot; currentSlot += batchSize) {
+    const batchEndSlot = Math.min(currentSlot + batchSize - 1, toSlot);
+    await watcher.getFtMessagesForBlocks(currentSlot, batchEndSlot);
+    console.log(`Processed slots ${currentSlot} to ${batchEndSlot}`);
   }
 }
 
@@ -68,8 +36,8 @@ async function watchFt(
   }
 }
 
-const fromSlot = 301569871;
-const toSlot = 301569872;
+const fromSlot = 301566320;
+const toSlot = 302610552;
 
 const arbitrumFromBlock = 247028328;
 const arbitrumToBlock = 247037682;