feat(pyth-lazer-sui-js): Init Lazer Sui SDK

lazer/contracts/sui/sdk/js/.gitignore

@@ -0,0 +1,3 @@
+dist/
+node_modules/
+*.tsbuildinfo

lazer/contracts/sui/sdk/js/.prettierignore

@@ -0,0 +1,3 @@
+.turbo/
+node_modules/
+dist/

lazer/contracts/sui/sdk/js/README.md

@@ -0,0 +1,77 @@
+# Pyth Lazer Sui JS SDK
+
+This package provides utilities to create a Sui Programmable Transaction to parse & verify a Pyth Lazer price update on-chain.
+
+## Build
+
+From the repository root:
+
+```sh
+pnpm turbo build -F @pythnetwork/pyth-lazer-sui-js
+```
+
+## Quickstart
+
+A runnable example is provided at `examples/FetchAndVerifyUpdate.ts`. It:
+
+- connects to Lazer via `@pythnetwork/pyth-lazer-sdk`,
+- fetches a single `leEcdsa` payload,
+- composes a Sui transaction calling `parse_and_verify_le_ecdsa_update`.
+
+### Run the example
+
+Install `tsx` to run TypeScript scripts:
+
+```sh
+npm install -g tsx
+```
+
+Execute the example script:
+
+```sh
+SUI_KEY=<YOUR_SUI_PRIVATE_KEY> pnpm -F @pythnetwork/pyth-lazer-sui-js example:fetch-and-verify --fullnodeUrl <SUI_FULLNODE_URL> --packageId <PYTH_LAZER_PACKAGE_ID> --stateObjectId <PYTH_LAZER_STATE_OBJECT_ID> --token <LAZER_TOKEN>
+```
+
+The script's core logic is summarized below:
+
+```ts
+import { SuiClient } from "@mysten/sui/client";
+import { Transaction } from "@mysten/sui/transactions";
+import { SuiLazerClient } from "@pythnetwork/pyth-lazer-sui-js";
+
+// Prepare Mysten Sui client
+const provider = new SuiClient({ url: "<sui-fullnode-url>" });
+
+// Create SDK client
+const client = new SuiLazerClient(provider);
+
+// Obtain a Lazer leEcdsa payload using @pythnetwork/pyth-lazer-sdk.
+// See examples/FetchAndVerifyUpdate.ts for a runnable end-to-end example.
+const leEcdsa: Buffer = /* fetch via @pythnetwork/pyth-lazer-sdk */ Buffer.from(
+  [],
+);
+
+// Build transaction calling parse_and_verify_le_ecdsa_update
+const tx = new Transaction();
+const packageId = "<pyth_lazer_package_id>";
+const stateObjectId = "<pyth_lazer_state_object_id>";
+
+const updateVal = client.addParseAndVerifyLeEcdsaUpdateCall({
+  tx,
+  packageId,
+  stateObjectId,
+  updateBytes: leEcdsa,
+});
+
+// Sign and execute the transaction using your signer.
+```
+
+## Notes
+
+- FIXME: Automatic `packageId` management is coming soon. The Lazer contract doesn't support upgradeability yet.
+
+## References
+
+- Pyth Lazer Sui contract: `lazer/contracts/sui/`
+- Lazer JS SDK (data source): `lazer/sdk/js/`
+- Mysten Sui TS SDK docs: https://sdk.mystenlabs.com/typescript/transaction-building/basics

lazer/contracts/sui/sdk/js/eslint.config.js

@@ -0,0 +1 @@
+export { base as default } from "@cprussin/eslint-config";

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

@@ -0,0 +1,125 @@
+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) {
+  const lazer = await PythLazerClient.create({
+    urls,
+    token,
+    numConnections: 1,
+  });
+
+  const subscription: SubscriptionRequest = {
+    subscriptionId: 1,
+    type: "subscribe",
+    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);
+      }
+    });
+  });
+}
+
+async function main() {
+  const args = await yargs(hideBin(process.argv))
+    .option("fullnodeUrl", {
+      type: "string",
+      description:
+        "URL of the full Sui node RPC endpoint. e.g: https://fullnode.testnet.sui.io:443",
+      demandOption: true,
+    })
+    .option("packageId", {
+      type: "string",
+      description: "Lazer contract package ID",
+      demandOption: true,
+    })
+    .option("stateObjectId", {
+      type: "string",
+      description: "Lazer contract shared State object ID",
+      demandOption: true,
+    })
+    .option("lazerUrls", {
+      type: "array",
+      string: true,
+      description: "Lazer WebSocket URLs",
+      default: [
+        "wss://pyth-lazer-0.dourolabs.app/v1/stream",
+        "wss://pyth-lazer-1.dourolabs.app/v1/stream",
+      ],
+    })
+    .option("lazerToken", {
+      type: "string",
+      description: "Lazer authentication token",
+      demandOption: true,
+    })
+    .help()
+    .parseAsync();
+
+  // Defined as a dependency in turbo.json
+  // eslint-disable-next-line n/no-process-env
+  if (process.env.SUI_KEY === undefined) {
+    throw new Error(
+      `SUI_KEY environment variable should be set to your Sui private key in hex format.`,
+    );
+  }
+
+  const provider = new SuiClient({ url: args.fullnodeUrl });
+
+  // Fetch the price update
+  const updateBytes = await getOneLeEcdsaUpdate(
+    args.lazerUrls,
+    args.lazerToken,
+  );
+
+  // Build the Sui transaction
+  const tx = new Transaction();
+
+  // Add the parse and verify call
+  addParseAndVerifyLeEcdsaUpdateCall({
+    tx,
+    packageId: args.packageId,
+    stateObjectId: args.stateObjectId,
+    updateBytes,
+  });
+
+  // --- You can add more calls to the transaction that consume the parsed update here ---
+
+  const wallet = Ed25519Keypair.fromSecretKey(
+    // eslint-disable-next-line n/no-process-env
+    Buffer.from(process.env.SUI_KEY, "hex"),
+  );
+  const res = await provider.signAndExecuteTransaction({
+    signer: wallet,
+    transaction: tx,
+    options: { showEffects: true, showEvents: true },
+  });
+
+  // eslint-disable-next-line no-console
+  console.log("Execution result:", JSON.stringify(res, undefined, 2));
+}
+
+// eslint-disable-next-line unicorn/prefer-top-level-await
+main().catch((error: unknown) => {
+  throw error;
+});

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

@@ -0,0 +1,53 @@
+{
+  "name": "@pythnetwork/pyth-lazer-sui-js",
+  "version": "0.1.0",
+  "description": "TypeScript SDK for the Pyth Lazer Sui contract",
+  "license": "Apache-2.0",
+  "type": "module",
+  "engines": {
+    "node": "22"
+  },
+  "files": [
+    "dist"
+  ],
+  "exports": {
+    ".": {
+      "import": {
+        "types": "./dist/esm/client.d.ts",
+        "default": "./dist/esm/client.js"
+      },
+      "require": {
+        "types": "./dist/cjs/client.d.ts",
+        "default": "./dist/cjs/client.js"
+      }
+    }
+  },
+  "sideEffects": false,
+  "scripts": {
+    "build:cjs": "tsc --project tsconfig.build.json --verbatimModuleSyntax false --module commonjs --outDir ./dist/cjs && echo '{\"type\":\"commonjs\"}' > dist/cjs/package.json",
+    "build:esm": "tsc --project tsconfig.build.json --outDir ./dist/esm && echo '{\"type\":\"module\"}' > dist/esm/package.json",
+    "fix:format": "prettier --write .",
+    "fix:lint": "eslint --fix .",
+    "test:format": "prettier --check .",
+    "test:lint": "eslint . --max-warnings 0",
+    "test:types": "tsc",
+    "example:fetch-and-verify": "tsx examples/fetch-and-verify-update.ts"
+  },
+  "dependencies": {
+    "@mysten/sui": "catalog:",
+    "@pythnetwork/pyth-lazer-sdk": "workspace:*",
+    "@types/yargs": "catalog:",
+    "yargs": "catalog:"
+  },
+  "devDependencies": {
+    "@cprussin/eslint-config": "catalog:",
+    "@cprussin/tsconfig": "catalog:",
+    "@types/node": "catalog:",
+    "eslint": "catalog:",
+    "prettier": "catalog:",
+    "typescript": "catalog:"
+  },
+  "publishConfig": {
+    "access": "public"
+  }
+}

lazer/contracts/sui/sdk/js/src/client.ts

@@ -0,0 +1,25 @@
+import { bcs } from "@mysten/sui/bcs";
+import { Transaction } from "@mysten/sui/transactions";
+import { SUI_CLOCK_OBJECT_ID } from "@mysten/sui/utils";
+
+export function addParseAndVerifyLeEcdsaUpdateCall({
+  tx,
+  packageId,
+  stateObjectId,
+  updateBytes,
+}: {
+  tx: Transaction;
+  packageId: string;
+  stateObjectId: string;
+  updateBytes: Uint8Array;
+}) {
+  const [updateObj] = tx.moveCall({
+    target: `${packageId}::pyth_lazer::parse_and_verify_le_ecdsa_update`,
+    arguments: [
+      tx.object(stateObjectId),
+      tx.object(SUI_CLOCK_OBJECT_ID),
+      tx.pure(bcs.vector(bcs.U8).serialize(updateBytes).toBytes()),
+    ],
+  });
+  return updateObj;
+}

lazer/contracts/sui/sdk/js/tsconfig.build.json

@@ -0,0 +1,9 @@
+{
+  "extends": "./tsconfig.json",
+  "compilerOptions": {
+    "noEmit": false,
+    "incremental": false,
+    "declaration": true
+  },
+  "exclude": ["node_modules", "dist"]
+}

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

@@ -0,0 +1,3 @@
+{
+  "extends": "@cprussin/tsconfig/base.json"
+}

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

@@ -0,0 +1,9 @@
+{
+  "$schema": "https://turbo.build/schema.json",
+  "extends": ["//"],
+  "tasks": {
+    "example:fetch-and-verify": {
+      "env": ["SUI_KEY"]
+    }
+  }
+}