scripts: get solana missed message accounts

watcher/scripts/solanaMissedMessageAccounts.ts

@@ -0,0 +1,73 @@
+import * as dotenv from 'dotenv';
+dotenv.config();
+
+import { CONTRACTS } from '@certusone/wormhole-sdk/lib/cjs/utils/consts';
+import { Connection } from '@solana/web3.js';
+import axios from 'axios';
+import ora from 'ora';
+import { RPCS_BY_CHAIN } from '../src/consts';
+import { isLegacyMessage, normalizeCompileInstruction } from '../src/utils/solana';
+
+// This script finds the message accounts which correspond to solana misses
+
+(async () => {
+  const now = new Date();
+  now.setHours(now.getHours() - 2);
+  const twoHoursAgo = now.toISOString();
+  let log = ora('Fetching Solana misses').start();
+  try {
+    const response = await axios.get(
+      'https://europe-west3-wormhole-message-db-mainnet.cloudfunctions.net/missing-vaas'
+    );
+    const solanaTxHashes = response.data[1].messages
+      .filter((m: any) => m.timestamp < twoHoursAgo)
+      .map((m: any) => m.txHash);
+    log.succeed();
+    log = ora('Fetching message accounts').start();
+    const connection = new Connection(RPCS_BY_CHAIN.mainnet.solana!, 'finalized');
+    const txs = await connection.getTransactions(solanaTxHashes, {
+      maxSupportedTransactionVersion: 0,
+    });
+    // TODO: share with Solana watcher?
+    const accounts = [];
+    let errorCount = 0;
+    for (const tx of txs) {
+      if (!tx) {
+        errorCount++;
+      } else {
+        const message = tx.transaction.message;
+        const accountKeys = isLegacyMessage(message)
+          ? message.accountKeys
+          : message.staticAccountKeys;
+        const programIdIndex = accountKeys.findIndex(
+          (i) => i.toBase58() === CONTRACTS.MAINNET.solana.core
+        );
+        const instructions = message.compiledInstructions;
+        const innerInstructions =
+          tx.meta?.innerInstructions?.flatMap((i) =>
+            i.instructions.map(normalizeCompileInstruction)
+          ) || [];
+        const whInstructions = innerInstructions
+          .concat(instructions)
+          .filter((i) => i.programIdIndex === programIdIndex);
+        for (const instruction of whInstructions) {
+          // skip if not postMessage instruction
+          const instructionId = instruction.data;
+          if (instructionId[0] !== 0x01) continue;
+
+          accounts.push(accountKeys[instruction.accountKeyIndexes[1]]);
+        }
+      }
+    }
+    log.succeed();
+    for (const a of accounts) {
+      console.log(`send-observation-request 1 ${a}`);
+    }
+    console.log(
+      `Fetch ${accounts.length} accounts from ${solanaTxHashes.length} transactions with ${errorCount} errors`
+    );
+  } catch (e) {
+    log.fail();
+    console.error(e);
+  }
+})();