update lazer sui js sdk to use updated js sdk

Author: tejasbadadare

lazer/contracts/sui/sdk/js/examples/fetch-and-verify-update.ts

@@ -1,44 +1,26 @@
 import { SuiClient } from "@mysten/sui/client";
 import { Ed25519Keypair } from "@mysten/sui/keypairs/ed25519";
 import { Transaction } from "@mysten/sui/transactions";
-import type { Request as SubscriptionRequest } from "@pythnetwork/pyth-lazer-sdk";
 import { PythLazerClient } from "@pythnetwork/pyth-lazer-sdk";
 import yargs from "yargs";
 import { hideBin } from "yargs/helpers";
 
 import { addParseAndVerifyLeEcdsaUpdateCall } from "../src/client.js";
 
-async function getOneLeEcdsaUpdate(urls: string[], token: string) {
+async function getOneLeEcdsaUpdate(token: string) {
   const lazer = await PythLazerClient.create({
-    urls,
     token,
-    numConnections: 1,
   });
 
-  const subscription: SubscriptionRequest = {
-    subscriptionId: 1,
-    type: "subscribe",
+  const latestPrice = await lazer.get_latest_price({
     priceFeedIds: [1],
     properties: ["price", "bestBidPrice", "bestAskPrice", "exponent"],
     formats: ["leEcdsa"],
     channel: "fixed_rate@200ms",
-    deliveryFormat: "binary",
     jsonBinaryEncoding: "hex",
-  };
-
-  lazer.subscribe(subscription);
-
-  return new Promise<Uint8Array>((resolve) => {
-    lazer.addMessageListener((event) => {
-      if (event.type === "binary" && event.value.leEcdsa) {
-        const buf = event.value.leEcdsa;
-
-        // For the purposes of this example, we only need one update.
-        lazer.shutdown();
-        resolve(buf);
-      }
-    });
   });
+
+  return latestPrice
 }
 
 async function main() {
@@ -87,8 +69,7 @@ async function main() {
   const provider = new SuiClient({ url: args.fullnodeUrl });
 
   // Fetch the price update
-  const updateBytes = await getOneLeEcdsaUpdate(
-    args.lazerUrls,
+  const update = await getOneLeEcdsaUpdate(
     args.lazerToken,
   );
 
@@ -100,7 +81,7 @@ async function main() {
     tx,
     packageId: args.packageId,
     stateObjectId: args.stateObjectId,
-    updateBytes,
+    updateBytes: Buffer.from(update.leEcdsa?.data ?? "", "hex"),
   });
 
   // --- You can add more calls to the transaction that consume the parsed update here ---

lazer/contracts/sui/sdk/js/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/pyth-lazer-sui-js",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "TypeScript SDK for the Pyth Lazer Sui contract",
   "license": "Apache-2.0",
   "type": "module",

lazer/sdk/js/examples/streaming.ts

@@ -6,7 +6,7 @@ import type { JsonUpdate } from "../src/index.js";
 import { PythLazerClient } from "../src/index.js";
 
 // Ignore debug messages
-console.debug = () => {};
+console.debug = () => { };
 
 // Store feed data for in-place updates
 const feedData = new Map<
@@ -21,7 +21,7 @@ const feedData = new Map<
 >();
 
 const client = await PythLazerClient.create({
-  token: "your-token-here", // Replace with your actual access token
+  token: "ZpIVWYXIXXIPAARXLt50VTRMNjW91UUAnDu-test", // Replace with your actual access token
   logger: console, // Optionally log operations (to the console in this case.)
   webSocketPoolConfig: {
     numConnections: 4, // Optionally specify number of parallel redundant connections to reduce the chance of dropped messages. The connections will round-robin across the provided URLs. Default is 4.
@@ -86,7 +86,7 @@ client.subscribe({
   properties: ["price", "exponent", "publisherCount", "confidence"],
   formats: ["evm"],
   deliveryFormat: "json",
-  channel: "fixed_rate@200ms",
+  channel: "fixed_rate@50ms",
   parsed: true,
   jsonBinaryEncoding: "hex",
 });
@@ -97,7 +97,7 @@ client.subscribe({
   properties: ["price", "confidence"],
   formats: ["solana"],
   deliveryFormat: "json",
-  channel: "fixed_rate@200ms",
+  channel: "real_time",
   parsed: true,
   jsonBinaryEncoding: "hex",
 });