chore(price-puhser) Use Hermes Client (#2312)

* initial commit

* update-2

* update-3

* removed test

* wip

* update

* update

* update

* ton-config-update

* 1.0.0

* version bump

* update

Author: aditya520

apps/price_pusher/README.md

@@ -203,8 +203,7 @@ human-readable logs, you can pipe the output of the program to `pino-pretty`. Se
 
 You can configure the log level of some of the modules of the price pusher as well. The available modules are PriceServiceConnection, which
 is responsible for connecting to the Hermes price service, and Controller, which is responsible for checking the prices from the Hermes
-and the on-chain Pyth contract and deciding whether to push a new price. You can configure the log level of these modules by passing the
-`--price-service-connection-log-level` and `--controller-log-level` arguments, respectively.
+and the on-chain Pyth contract and deciding whether to push a new price. You can configure the log level of these modules by passing the `--controller-log-level` arguments, respectively.
 
 ### Example
 

apps/price_pusher/config.aptos.testnet.sample.json

@@ -1,5 +1,5 @@
 {
-  "endpoint": "https://fullnode.testnet.aptoslabs.com/v1",
+  "endpoint": "https://api.testnet.aptoslabs.com/v1",
   "pyth-contract-address": "0x7e783b349d3e89cf5931af376ebeadbfab855b3fa239b7ada8f5a92fbea6b387",
   "price-service-endpoint": "https://hermes-beta.pyth.network",
   "mnemonic-file": "./mnemonic",

apps/price_pusher/config.evm.stable.sample.json renamed to apps/price_pusher/config.evm.mainnet.sample.json

@@ -1,6 +1,6 @@
 {
   "grpc-endpoint": "https://k8s.testnet.chain.grpc-web.injective.network",
-  "pyth-contract-address": "inj1z60tg0tekdzcasenhuuwq3htjcd5slmgf7gpez",
+  "pyth-contract-address": "inj18rlflp3735h25jmjx97d22c72sxk260amdjxlu",
   "price-service-endpoint": "https://hermes-beta.pyth.network",
   "mnemonic-file": "./mnemonic",
   "price-config-file": "./price-config.beta.sample.yaml",

apps/price_pusher/config.injective.testnet.sample.json

@@ -1,7 +1,7 @@
 {
-  "endpoint": "https://sui-testnet-rpc.allthatnode.com",
-  "pyth-package-id": "0x00b53b0f4174108627fbee72e2498b58d6a2714cded53fac537034c220d26302",
-  "pyth-state-id": "0xf9ff3ef935ef6cdfb659a203bf2754cebeb63346e29114a535ea6f41315e5a3f",
+  "endpoint": "https://sui-mainnet-endpoint.blockvision.org",
+  "pyth-package-id": "0x04e20ddf36af412a4096f9014f4a565af9e812db9a05cc40254846cf6ed0ad91",
+  "pyth-state-id": "0x1f9310238ee9298fb703c3419030b35b22bb1cc37113e3bb5007c99aec79e5b8",
   "wormhole-package-id": "0x5306f64e312b581766351c07af79c72fcb1cd25147157fdc2f8ad76de9a3fb6a",
   "wormhole-state-id": "0xaeab97f96cf9877fee2883315d459552b2b921edc16d7ceac6eab944dd88919c",
   "price-feed-to-price-info-object-table-id": "0x14b4697477d24c30c8eecc31dd1bd49a3115a9fe0db6bd4fd570cf14640b79a0",

apps/price_pusher/config.sui.mainnet.sample.json

@@ -1,6 +1,6 @@
 {
   "endpoint": "https://toncenter.com/api/v2/jsonRPC",
-  "pyth-contract-address": "EQBU6k8HH6yX4Jf3d18swWbnYr31D3PJI7PgjXT",
+  "pyth-contract-address": "EQBU6k8HH6yX4Jf3d18swWbnYr31D3PJI7PgjXT-flsKHqql",
   "price-service-endpoint": "https://hermes.pyth.network",
   "private-key-file": "./mnemonic",
   "price-config-file": "./price-config.stable.sample.yaml"

apps/price_pusher/config.ton.mainnet.sample.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/price-pusher",
-  "version": "8.3.3",
+  "version": "9.0.0",
   "description": "Pyth Price Pusher",
   "homepage": "https://pyth.network",
   "main": "lib/index.js",
@@ -24,7 +24,6 @@
     "format": "prettier --write \"src/**/*.ts\"",
     "test:lint": "eslint src/",
     "start": "node lib/index.js",
-    "test": "jest",
     "dev": "ts-node src/index.ts",
     "prepublishOnly": "pnpm run build && pnpm run test:lint",
     "preversion": "pnpm run test:lint",
@@ -61,7 +60,7 @@
     "@injectivelabs/networks": "^1.14.6",
     "@injectivelabs/sdk-ts": "1.10.72",
     "@mysten/sui": "^1.3.0",
-    "@pythnetwork/price-service-client": "workspace:*",
+    "@pythnetwork/hermes-client": "^1.3.1",
     "@pythnetwork/price-service-sdk": "workspace:^",
     "@pythnetwork/pyth-fuel-js": "workspace:*",
     "@pythnetwork/pyth-sdk-solidity": "workspace:*",

apps/price_pusher/package.json

@@ -12,3 +12,8 @@
     time_difference: 30
     price_deviation: 0.5
     confidence_ratio: 0.1
+- alias: PYTH/USD
+  id: 2f95862b045670cd22bee3114c39763a4a08beeb663b145d283c31d7d1101c23
+  time_difference: 60
+  price_deviation: 0.5
+  confidence_ratio: 1

apps/price_pusher/price-config.stable.sample.yaml

@@ -6,7 +6,7 @@ import {
 } from "../interface";
 import { AptosAccount, AptosClient } from "aptos";
 import { DurationInSeconds } from "../utils";
-import { PriceServiceConnection } from "@pythnetwork/price-service-client";
+import { HermesClient } from "@pythnetwork/hermes-client";
 import { Logger } from "pino";
 
 export class AptosPriceListener extends ChainPriceListener {
@@ -89,7 +89,7 @@ export class AptosPricePusher implements IPricePusher {
   private sequenceNumberLocked: boolean;
 
   constructor(
-    private priceServiceConnection: PriceServiceConnection,
+    private hermesClient: HermesClient,
     private logger: Logger,
     private pythContractAddress: string,
     private endpoint: string,
@@ -107,11 +107,12 @@ export class AptosPricePusher implements IPricePusher {
    * @returns Array of price update data.
    */
   async getPriceFeedsUpdateData(priceIds: string[]): Promise<number[][]> {
-    // Fetch the latest price feed update VAAs from the price service
-    const latestVaas = await this.priceServiceConnection.getLatestVaas(
-      priceIds
+    const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
+      encoding: "base64",
+    });
+    return response.binary.data.map((data) =>
+      Array.from(Buffer.from(data, "base64"))
     );
-    return latestVaas.map((vaa) => Array.from(Buffer.from(vaa, "base64")));
   }
 
   async updatePriceFeed(
@@ -226,7 +227,7 @@ export class AptosPricePusher implements IPricePusher {
           );
           return this.lastSequenceNumber;
         } catch (e: any) {
-          throw new Error("Failed to retrieve sequence number");
+          throw new Error("Failed to retrieve sequence number" + e);
         } finally {
           this.sequenceNumberLocked = false;
         }