Merge remote-tracking branch 'upstream/main' into migrate-to-pnpm

apps/hermes/client/js/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/hermes-client",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "Pyth Hermes Client",
   "author": {
     "name": "Pyth Data Association"

apps/hermes/client/js/src/HermesClient.ts

@@ -1,6 +1,7 @@
 import EventSource from "eventsource";
 import { schemas } from "./zodSchemas";
 import { z } from "zod";
+import { camelToSnakeCaseObject } from "./utils";
 
 // Accessing schema objects
 export type AssetType = z.infer<typeof schemas.AssetType>;
@@ -193,8 +194,8 @@ export class HermesClient {
     options?: {
       encoding?: EncodingType;
       parsed?: boolean;
-      allow_unordered?: boolean;
-      benchmarks_only?: boolean;
+      allowUnordered?: boolean;
+      benchmarksOnly?: boolean;
     }
   ): Promise<EventSource> {
     const url = new URL("/v2/updates/price/stream", this.baseURL);
@@ -203,7 +204,8 @@ export class HermesClient {
     });
 
     if (options) {
-      this.appendUrlSearchParams(url, options);
+      const transformedOptions = camelToSnakeCaseObject(options);
+      this.appendUrlSearchParams(url, transformedOptions);
     }
 
     return new EventSource(url.toString());

apps/hermes/client/js/src/examples/HermesClient.ts

@@ -45,7 +45,12 @@ async function run() {
   console.log(priceUpdates);
 
   // Streaming price updates
-  const eventSource = await connection.getPriceUpdatesStream(priceIds);
+  const eventSource = await connection.getPriceUpdatesStream(priceIds, {
+    encoding: "hex",
+    parsed: true,
+    allowUnordered: true,
+    benchmarksOnly: true,
+  });
 
   eventSource.onmessage = (event) => {
     console.log("Received price update:", event.data);

apps/hermes/client/js/src/utils.ts

@@ -0,0 +1,13 @@
+function camelToSnakeCase(str: string): string {
+  return str.replace(/[A-Z]/g, (letter) => `_${letter.toLowerCase()}`);
+}
+
+export function camelToSnakeCaseObject(
+  obj: Record<string, string | boolean>
+): Record<string, string | boolean> {
+  const result: Record<string, string | boolean> = {};
+  Object.keys(obj).forEach((key) => {
+    result[camelToSnakeCase(key)] = obj[key];
+  });
+  return result;
+}