move changes from pyth-js (#624)

Author: Dev Kalra

price_pusher/README.md

@@ -122,4 +122,4 @@ docker-compose -f docker-compose.testnet.sample.yaml up
 
 It will take a few minutes until all the services are up and running.
 
-[pyth price service]: https://github.com/pyth-network/pyth-crosschain/tree/main/third_party/pyth/price-service
+[pyth price service]: https://github.com/pyth-network/pyth-crosschain/tree/main/price_service/server

price_pusher/docker-compose.mainnet.sample.yaml

@@ -1,7 +1,7 @@
 services:
   spy:
     # Find latest Guardian images in https://github.com/wormhole-foundation/wormhole/pkgs/container/guardiand
-    image: ghcr.io/wormhole-foundation/guardiand:v.2.14.5
+    image: ghcr.io/wormhole-foundation/guardiand:v.2.14.8.1
     command:
       - "spy"
       - "--nodeKey"
@@ -16,7 +16,7 @@ services:
       - "warn"
   price-service:
     # Find latest price service images https://gallery.ecr.aws/pyth-network/xc-server
-    image: public.ecr.aws/pyth-network/xc-server:v2.2.3
+    image: public.ecr.aws/pyth-network/xc-server:v3.0.0
     environment:
       SPY_SERVICE_HOST: "spy:7072"
       SPY_SERVICE_FILTERS: |

price_pusher/docker-compose.testnet.sample.yaml

@@ -1,7 +1,7 @@
 services:
   spy:
     # Find latest Guardian images in https://github.com/wormhole-foundation/wormhole/pkgs/container/guardiand
-    image: ghcr.io/wormhole-foundation/guardiand:v.2.14.5
+    image: ghcr.io/wormhole-foundation/guardiand:v.2.14.8.1
     command:
       - "spy"
       - "--nodeKey"
@@ -16,7 +16,7 @@ services:
       - "warn"
   price-service:
     # Find latest price service images https://gallery.ecr.aws/pyth-network/xc-server
-    image: public.ecr.aws/pyth-network/xc-server:v2.2.3
+    image: public.ecr.aws/pyth-network/xc-server:v3.0.0
     environment:
       SPY_SERVICE_HOST: "spy:7072"
       SPY_SERVICE_FILTERS: |

price_pusher/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/pyth-evm-price-pusher",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "description": "Pyth EVM Price Pusher",
   "homepage": "https://pyth.network",
   "main": "lib/index.js",
@@ -43,6 +43,7 @@
     "typescript": "^4.6.3"
   },
   "dependencies": {
+    "@pythnetwork/pyth-common-js": "^1.2.0",
     "@pythnetwork/pyth-evm-js": "^1.1.0",
     "@pythnetwork/pyth-sdk-solidity": "^2.2.0",
     "@truffle/hdwallet-provider": "^2.1.3",

price_pusher/package.json

@@ -0,0 +1,44 @@
+import { UnixTimestamp } from "@pythnetwork/pyth-evm-js";
+import { DurationInSeconds, sleep } from "./utils";
+import { ChainPricePusher, PriceListener } from "./interface";
+import { PriceConfig, shouldUpdate } from "./price-config";
+
+export class Controller {
+  private cooldownDuration: DurationInSeconds;
+  constructor(
+    private priceConfigs: PriceConfig[],
+    private sourcePriceListener: PriceListener,
+    private targetPriceListener: PriceListener,
+    private targetChainPricePusher: ChainPricePusher,
+    config: {
+      cooldownDuration: DurationInSeconds;
+    }
+  ) {
+    this.cooldownDuration = config.cooldownDuration;
+  }
+
+  async start() {
+    for (;;) {
+      const pricesToPush: PriceConfig[] = [];
+      const pubTimesToPush: UnixTimestamp[] = [];
+
+      for (const priceConfig of this.priceConfigs) {
+        const priceId = priceConfig.id;
+
+        const targetLatestPrice =
+          this.targetPriceListener.getLatestPriceInfo(priceId);
+        const sourceLatestPrice =
+          this.sourcePriceListener.getLatestPriceInfo(priceId);
+
+        if (shouldUpdate(priceConfig, sourceLatestPrice, targetLatestPrice)) {
+          pricesToPush.push(priceConfig);
+          pubTimesToPush.push((targetLatestPrice?.publishTime || 0) + 1);
+        }
+      }
+      // note that the priceIds are without leading "0x"
+      const priceIds = pricesToPush.map((priceConfig) => priceConfig.id);
+      this.targetChainPricePusher.updatePriceFeed(priceIds, pubTimesToPush);
+      await sleep(this.cooldownDuration * 1000);
+    }
+  }
+}