chore(contract_managager) Add Scripts to update all pricefeeds.

contract_manager/package.json

@@ -31,6 +31,7 @@
     "@pythnetwork/contract-manager": "workspace:*",
     "@pythnetwork/cosmwasm-deploy-tools": "workspace:*",
     "@pythnetwork/entropy-sdk-solidity": "workspace:*",
+    "@pythnetwork/hermes-client": "workspace:*",
     "@pythnetwork/price-service-client": "workspace:*",
     "@pythnetwork/pyth-fuel-js": "workspace:*",
     "@pythnetwork/pyth-sdk-solidity": "workspace:^",
@@ -55,6 +56,7 @@
     "yaml": "^2.1.1"
   },
   "devDependencies": {
+    "@types/node": "^22.7.4",
     "@types/web3": "^1.2.2",
     "eslint": "^8.0.0",
     "prettier": "^2.6.2",

contract_manager/scripts/update_all_pricefeed.ts

@@ -0,0 +1,79 @@
+import yargs from "yargs";
+import { hideBin } from "yargs/helpers";
+import {
+  HermesClient,
+  AssetType,
+  PriceFeedMetadata,
+} from "@pythnetwork/hermes-client";
+import { DefaultStore, toPrivateKey } from "../src";
+import { schemas } from "@pythnetwork/hermes-client/lib/zodSchemas";
+
+const parser = yargs(hideBin(process.argv))
+  .usage("Update the set of price feeds in a network. Usage: $0")
+  .options({
+    "private-key": {
+      type: "string",
+      demandOption: true,
+      desc: "Private key to sign the transactions with",
+    },
+    contract: {
+      type: "string",
+      demandOption: true,
+      desc: "Contract to update price feeds for (e.g mumbai_0xff1a0f4744e8582DF1aE09D5611b887B6a12925C)",
+    },
+    // assetType: {
+    //   type: "string",
+    //   demandOption: false,
+    //   desc: "Asset type to initiate the price feed on",
+    // },
+    endpoint: {
+        type: "string",
+        desc: "Hermes endpoint to use, defaults to https://hermes.pyth.network",
+      },
+  });
+
+
+async function main() {
+  const argv = await parser.argv;
+  let priceFeedsMetadata: PriceFeedMetadata[] = [];
+  const client = new HermesClient(argv.endpoint || "https://hermes.pyth.network");
+  const contract = DefaultStore.contracts[argv.contract];
+  const privateKey = toPrivateKey(argv["private-key"]);
+
+
+  // // Filter via asset type
+  // if (argv.assetType === null) {
+  //   priceFeedsMetadata = await getPriceFeeds();
+  // } else {
+  //   const parsed = schemas.AssetType.safeParse(argv.assetType);
+  //   if (parsed.success) {
+  //     priceFeedsMetadata = await getPriceFeeds(argv.assetType as AssetType);
+  //   } else {
+  //     console.error("Invalid asset type");
+  //     return;
+  //   }
+  // }
+
+  priceFeedsMetadata = await client.getPriceFeeds();
+
+  const priceFeedIds = priceFeedsMetadata.map((feed) => feed.id);
+  console.log(`Fetched ${priceFeedIds.length} price feed IDs`);
+
+  // We can adjust the chunk size based on the chain. Don't exceed 150 for now.
+  const chunkSize = 150;
+  for (let i = 0; i < priceFeedIds.length; i += chunkSize) {
+    const chunk = priceFeedIds.slice(i, i + chunkSize);
+    console.log(`length: ${chunk.length}`)
+    const updates = await client.getLatestPriceUpdates(chunk, {
+      parsed: false,
+    });
+    console.log(
+      await contract.executeUpdatePriceFeed(
+        privateKey,
+        updates.binary.data.map(update => Buffer.from(update, 'hex'))
+      )
+    );
+  }
+}
+
+main();