add solana ix example

Author: keyvankhademi

lazer/js/package.json

@@ -16,8 +16,7 @@
   "author": "",
   "license": "Apache-2.0",
   "dependencies": {
-    "@pythnetwork/pyth-lazer-sdk": "^0.1.1",
-    "@solana/buffer-layout": "^4.0.1",
+    "@pythnetwork/pyth-lazer-sdk": "^0.3.1",
     "@solana/web3.js": "^1.98.0"
   },
   "devDependencies": {

lazer/js/pnpm-lock.yaml

@@ -1,10 +1,11 @@
 import { PythLazerClient } from "@pythnetwork/pyth-lazer-sdk";
 
 /* eslint-disable no-console */
-const client = new PythLazerClient(
-  "wss://pyth-lazer-staging.dourolabs.app/v1/stream",
-  "my_token",
+const client = await PythLazerClient.create(
+  ["wss://pyth-lazer-staging.dourolabs.app/v1/stream"],
+  "my_token"
 );
+
 client.addMessageListener((message) => {
   console.log("got message:", message);
   switch (message.type) {
@@ -14,7 +15,7 @@ client.addMessageListener((message) => {
           "stream updated for subscription",
           message.value.subscriptionId,
           ":",
-          message.value.parsed?.priceFeeds,
+          message.value.parsed?.priceFeeds
         );
       }
       break;
@@ -30,15 +31,21 @@ client.addMessageListener((message) => {
     }
   }
 });
-client.ws.addEventListener("open", () => {
-  client.send({
-    type: "subscribe",
-    subscriptionId: 1,
-    priceFeedIds: [1, 2],
-    properties: ["price"],
-    chains: ["solana"],
-    deliveryFormat: "json",
-    channel: "fixed_rate@200ms",
-    jsonBinaryEncoding: "hex",
-  });
+
+client.addAllConnectionsDownListener(() => {
+  console.log("All connections are down");
 });
+
+client.subscribe({
+  type: "subscribe",
+  subscriptionId: 1,
+  priceFeedIds: [1, 2],
+  properties: ["price"],
+  chains: ["solana"],
+  deliveryFormat: "json",
+  channel: "fixed_rate@200ms",
+  jsonBinaryEncoding: "hex",
+});
+
+// shutdown client after 10 seconds
+setTimeout(() => client.shutdown(), 10000);

lazer/js/src/ed25519.ts

@@ -1,5 +1,7 @@
-import { PythLazerClient } from "@pythnetwork/pyth-lazer-sdk";
-import { createEd25519Instruction } from "./ed25519.js";
+import {
+  PythLazerClient,
+  createEd25519Instruction,
+} from "@pythnetwork/pyth-lazer-sdk";
 import fs from "fs";
 
 import {
@@ -15,7 +17,7 @@ import { SYSVAR_INSTRUCTIONS_PUBKEY } from "@solana/web3.js";
 
 const SOLANA_RPC_URL = "https://api.devnet.solana.com";
 const PAYER_SECRET_KEY = Uint8Array.from(
-  JSON.parse(fs.readFileSync("/path/to/secret/key.json", "utf8")) as number[]
+  JSON.parse(fs.readFileSync("/path/to/private-key.json", "utf8")) as number[]
 );
 // Program ID of the example contract on devnet
 const PROGRAM_ID = "HU64YGK66e1wdxD83D3snGuZEvfhM4YDdYShTfQvf6nm";
@@ -35,16 +37,17 @@ const connection = new Connection(SOLANA_RPC_URL, "confirmed");
 const payer = Keypair.fromSecretKey(PAYER_SECRET_KEY);
 
 /* eslint-disable no-console */
-const client = new PythLazerClient(
-  "wss://pyth-lazer-staging.dourolabs.app/v1/stream",
-  "{access_token}"
+const client = await PythLazerClient.create(
+  ["wss://pyth-lazer-staging.dourolabs.app/v1/stream"],
+  "my_token"
 );
 
-let received = false;
+// data received from pyth lazer
+let rawData: string | undefined = undefined;
 
 client.addMessageListener(async (message) => {
   // avoid processing multiple messages
-  if (received) {
+  if (rawData) {
     return;
   }
 
@@ -64,18 +67,16 @@ client.addMessageListener(async (message) => {
 
   // close the ws connection
   // we only need 1 message
-  client.ws.close();
+  client.shutdown();
 
   // We are expecting a streamUpdated message
   if (message.value.type !== "streamUpdated") {
     console.log("unexpected message value type:", message.value.type);
     return;
   }
 
-  received = true;
-
   // Extract the base64 encoded data
-  const rawData = message.value.solana?.data;
+  rawData = message.value.solana?.data;
   console.log("rawData:", rawData);
 
   // Decode the base64 encoded data
@@ -160,16 +161,14 @@ client.addMessageListener(async (message) => {
   console.log("Transaction confirmed with signature:", signature);
 });
 
-client.ws.addEventListener("open", () => {
-  client.send({
-    type: "subscribe",
-    subscriptionId: 1,
-    // Example contract receives ETH/USD price
-    priceFeedIds: [2],
-    properties: ["price"],
-    chains: ["solana"],
-    deliveryFormat: "json",
-    channel: "real_time",
-    jsonBinaryEncoding: "hex",
-  });
+client.subscribe({
+  type: "subscribe",
+  subscriptionId: 1,
+  // Example contract receives ETH/USD price
+  priceFeedIds: [2],
+  properties: ["price"],
+  chains: ["solana"],
+  deliveryFormat: "json",
+  channel: "real_time",
+  jsonBinaryEncoding: "hex",
 });