Add receive time to the price service (#360)

* Add receive time to the price service

* Bump version to 2.1.0

Author: ali-behjati

third_party/pyth/p2w-sdk/js/package-lock.json

@@ -42,7 +42,7 @@
     "dependencies": {
         "@certusone/wormhole-sdk": "0.2.1",
         "@improbable-eng/grpc-web-node-http-transport": "^0.14.1",
-        "@pythnetwork/pyth-sdk-js": "^1.0.0"
+        "@pythnetwork/pyth-sdk-js": "^1.1.0"
     },
     "bugs": {
         "url": "https://github.com/pyth-network/pyth-crosschain/issues"

third_party/pyth/p2w-sdk/js/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/pyth-price-service",
-  "version": "2.0.0",
+  "version": "2.1.0",
   "description": "Pyth Price Service",
   "main": "index.js",
   "scripts": {
@@ -28,10 +28,10 @@
     "typescript": "^4.3.5"
   },
   "dependencies": {
-    "@pythnetwork/p2w-sdk-js": "file:../p2w-sdk/js",
     "@certusone/wormhole-sdk": "^0.1.4",
     "@certusone/wormhole-spydk": "^0.0.1",
-    "@pythnetwork/pyth-sdk-js": "^1.0.0",
+    "@pythnetwork/p2w-sdk-js": "file:../p2w-sdk/js",
+    "@pythnetwork/pyth-sdk-js": "^1.1.0",
     "@types/cors": "^2.8.12",
     "@types/express": "^4.17.13",
     "@types/morgan": "^1.9.3",

third_party/pyth/price-service/package-lock.json

@@ -43,6 +43,7 @@ function dummyPriceInfoPair(
       seqNum,
       vaaBytes: Buffer.from(vaa, "hex").toString("binary"),
       emitterChainId: 0,
+      priceServiceReceiveTime: 0,
     },
   ];
 }

third_party/pyth/price-service/package.json

@@ -1,5 +1,6 @@
 import { HexString, PriceFeed } from "@pythnetwork/pyth-sdk-js";
 import { Server } from "http";
+import { number } from "joi";
 import { WebSocket, WebSocketServer } from "ws";
 import { sleep } from "../helpers";
 import { PriceInfo, PriceStore } from "../listen";
@@ -21,12 +22,14 @@ function expandTo64Len(id: string): string {
 function dummyPriceMetadata(
   attestationTime: number,
   emitterChainId: number,
-  seqNum: number
+  seqNum: number,
+  priceServiceReceiveTime: number
 ): any {
   return {
     attestation_time: attestationTime,
     emitter_chain: emitterChainId,
     sequence_number: seqNum,
+    price_service_receive_time: priceServiceReceiveTime,
   };
 }
 
@@ -41,6 +44,7 @@ function dummyPriceInfo(
     emitterChainId: dummyPriceMetadataValue.emitter_chain,
     priceFeed: dummyPriceFeed(id),
     vaaBytes: Buffer.from(vaa, "hex").toString("binary"),
+    priceServiceReceiveTime: dummyPriceMetadataValue.price_service_receive_time,
   };
 }
 
@@ -92,7 +96,7 @@ async function createSocketClient(): Promise<[WebSocket, any[]]> {
 }
 
 beforeAll(async () => {
-  priceMetadata = dummyPriceMetadata(0, 0, 0);
+  priceMetadata = dummyPriceMetadata(0, 0, 0, 0);
   priceInfos = [
     dummyPriceInfo(expandTo64Len("abcd"), "a1b2c3d4", priceMetadata),
     dummyPriceInfo(expandTo64Len("ef01"), "a1b2c3d4", priceMetadata),

third_party/pyth/price-service/src/__tests__/rest.test.ts

@@ -32,6 +32,7 @@ export type PriceInfo = {
   attestationTime: TimestampInSec;
   priceFeed: PriceFeed;
   emitterChainId: number;
+  priceServiceReceiveTime: number;
 };
 
 export interface PriceStore {
@@ -198,6 +199,7 @@ export class Listener implements PriceStore {
           attestationTime: priceAttestation.attestationTime,
           priceFeed,
           emitterChainId: parsedVAA.emitter_chain,
+          priceServiceReceiveTime: Math.floor(new Date().getTime() / 1000),
         };
         this.priceFeedVaaMap.set(key, priceInfo);
 

third_party/pyth/price-service/src/__tests__/ws.test.ts

@@ -179,6 +179,8 @@ export class RestAPI {
                 emitter_chain: latestPriceInfo.emitterChainId,
                 attestation_time: latestPriceInfo.attestationTime,
                 sequence_number: latestPriceInfo.seqNum,
+                price_service_receive_time:
+                  latestPriceInfo.priceServiceReceiveTime,
               },
             });
           } else {

third_party/pyth/price-service/src/listen.ts

@@ -109,6 +109,7 @@ export class WebSocketAPI {
                 emitter_chain: priceInfo.emitterChainId,
                 attestation_time: priceInfo.attestationTime,
                 sequence_number: priceInfo.seqNum,
+                price_service_receive_time: priceInfo.priceServiceReceiveTime,
               },
             },
           }