Reconstruction

common/src/consts.ts

@@ -64,7 +64,7 @@ export const INITIAL_DEPLOYMENT_BLOCK_BY_NETWORK_AND_CHAIN: {
     aptos: '0', // block is 1094390 but AptosWatcher uses sequence number instead
     near: '72767136',
     xpla: '777549',
-    solana: '94401321', // https://explorer.solana.com/tx/KhLy688yDxbP7xbXVXK7TGpZU5DAFHbYiaoX16zZArxvVySz8i8g7N7Ss2noQYoq9XRbg6HDzrQBjUfmNcSWwhe
+    solana: '94396403', // https://explorer.solana.com/tx/2L8rQY94W2d44sycRkhHA1PyXdh5z6ND541ftDDk1dgBcv6RLR9a3zUgTJispPmXjkmqdqd5EDytXcnP5PC2AmEJ
     sui: '1485552', // https://explorer.sui.io/txblock/671SoTvVUvBZQWKXeameDvAwzHQvnr8Nj7dR9MUwm3CV?network=https%3A%2F%2Frpc.mainnet.sui.io
     base: '1422314',
     sei: '238594',

watcher/package.json

@@ -15,11 +15,13 @@
     "backfill-near": "ts-node scripts/backfillNear.ts",
     "backfill-signed-vaas": "ts-node scripts/backfillSignedVAAs",
     "backfill-vaas-by-tx-hash": "ts-node scripts/backfillVAAsByTxHash.ts",
+    "delete-messages-by-chain": "ts-node scripts/deleteMessagesByChain.ts",
     "locate-message-gaps": "ts-node scripts/locateMessageGaps.ts",
     "fetch-missing-vaas": "ts-node scripts/fetchMissingVAAs.ts",
     "update-found-vaas": "ts-node scripts/updateFoundVAAs.ts",
     "read-bigtable": "ts-node scripts/readBigtable.ts",
-    "read-firestore": "ts-node scripts/readFirestore.ts"
+    "read-firestore": "ts-node scripts/readFirestore.ts",
+    "reconstruct-vaa": "ts-node scripts/reconstructVAA.ts"
   },
   "dependencies": {
     "@celo-tools/celo-ethers-wrapper": "^0.3.0",

watcher/scripts/locateMessageGaps.ts

@@ -1,7 +1,12 @@
 import * as dotenv from 'dotenv';
 dotenv.config();
-import { ChainId, coalesceChainName } from '@certusone/wormhole-sdk';
-import { Environment, getEnvironment, sleep } from '@wormhole-foundation/wormhole-monitor-common';
+import { ChainId, CHAIN_ID_SOLANA, coalesceChainName } from '@certusone/wormhole-sdk';
+import {
+  Environment,
+  INITIAL_DEPLOYMENT_BLOCK_BY_NETWORK_AND_CHAIN,
+  getEnvironment,
+  sleep,
+} from '@wormhole-foundation/wormhole-monitor-common';
 import { TIMEOUT } from '../src/consts';
 import { BigtableDatabase } from '../src/databases/BigtableDatabase';
 import { parseMessageId } from '../src/databases/utils';
@@ -21,10 +26,20 @@ import { Watcher } from '../src/watchers/Watcher';
   const messageTable = instance.table(bt.msgTableId);
   try {
     // Find gaps in sequence numbers with the same chain and emitter
+    // Filter known bad emitters
     // Sort by ascending sequence number
-    const observedMessages = (await messageTable.getRows())[0].sort((a, b) =>
-      Number(parseMessageId(a.id).sequence - parseMessageId(b.id).sequence)
-    );
+    const observedMessages = (await messageTable.getRows())[0]
+      .filter((m) => {
+        const { chain, emitter } = parseMessageId(m.id);
+        if (
+          chain === CHAIN_ID_SOLANA &&
+          emitter === '6bb14509a612f01fbbc4cffeebd4bbfb492a86df717ebe92eb6df432a3f00a25'
+        ) {
+          return false;
+        }
+        return true;
+      })
+      .sort((a, b) => Number(parseMessageId(a.id).sequence - parseMessageId(b.id).sequence));
     const total = observedMessages.length;
     console.log(`processing ${total} messages`);
     const gaps = [];
@@ -36,9 +51,13 @@ import { Watcher } from '../src/watchers/Watcher';
         emitter: emitterAddress,
         sequence,
       } = parseMessageId(observedMessage.id);
+      const chainName = coalesceChainName(emitterChain as ChainId);
       const emitter = `${emitterChain}/${emitterAddress}`;
       if (!latestEmission[emitter]) {
-        latestEmission[emitter] = { sequence: 0n, block: 0 };
+        latestEmission[emitter] = {
+          sequence: chainName === 'algorand' || chainName === 'near' ? 0n : -1n,
+          block: Number(INITIAL_DEPLOYMENT_BLOCK_BY_NETWORK_AND_CHAIN[network][chainName] || 0),
+        };
       }
       while (sequence > latestEmission[emitter].sequence + 1n) {
         latestEmission[emitter].sequence += 1n;
@@ -71,6 +90,10 @@ import { Watcher } from '../src/watchers/Watcher';
     for (const gap of gaps) {
       const [chain, blockRange, emitter, sequence] = gap.split('/');
       const chainName = coalesceChainName(Number(chain) as ChainId);
+      if (chainName === 'algorand') {
+        console.warn('skipping algorand gaps until backfilled');
+        continue;
+      }
       let watcher: Watcher;
       try {
         watcher = makeFinalizedWatcher(network, chainName);