fix(sdk): add SuiBetsOptions interface and wire walletAddress through TS client

- Add SuiBetsOptions interface extending ExchangeOptions with optional walletAddress
- SuiBets class now accepts SuiBetsOptions and stores _walletAddress
- Override getCredentials() to include walletAddress in sidecar payload
- Base client.ts is current upstream main (all WS refactor changes included)

Author: elpou88

sdks/typescript/pmxt/client.ts

@@ -36,12 +36,14 @@ import {
     PaginatedMarketsResult,
     PaginatedEventsResult,
     Position,
+    SeriesFetchParams,
     PriceCandle,
     SubscribedAddressSnapshot,
     SubscriptionOption,
     Trade,
     UnifiedEvent,
     UnifiedMarket,
+    UnifiedSeries,
     UserTrade,
     FirehoseEvent,
 } from "./models.js";
@@ -61,6 +63,7 @@ interface SidecarWsClientInternals {
     ws: RawWebSocketLike | null;
     activeSubs: Map<string, string>;
     subscriptions: Map<string, { reject: ((error: Error) => void) | null }>;
+    dataQueues: Map<string, any[]>;
     dataStore: Map<string, any>;
 }
 
@@ -171,6 +174,10 @@ function convertEvent(raw: any): UnifiedEvent {
     return { ...raw, markets };
 }
 
+function convertSeries(raw: any): UnifiedSeries {
+    const events = Array.isArray(raw.events) ? raw.events.map(convertEvent) : undefined;
+    return { ...raw, ...(events !== undefined ? { events } : {}) };
+}
 
 function convertSubscriptionSnapshot(raw: any): SubscribedAddressSnapshot {
     return {
@@ -238,6 +245,13 @@ export interface ExchangeOptions {
  * prediction market platforms (Polymarket, Kalshi, etc.).
  */
 export abstract class Exchange {
+    private static readonly OBDATA_WATCH_ALL_SOURCES = new Set([
+        "polymarket",
+        "limitless",
+        "kalshi",
+        "opinion",
+    ]);
+
     protected exchangeName: string;
     protected apiKey?: string;
     protected privateKey?: string;
@@ -508,6 +522,13 @@ export abstract class Exchange {
             && /connection failed|no websocket|websocket.*not connected/i.test(error.message);
     }
 
+    private defaultWatchAllOrderBookVenues(): string[] | undefined {
+        if (Exchange.OBDATA_WATCH_ALL_SOURCES.has(this.exchangeName)) {
+            return [this.exchangeName];
+        }
+        return undefined;
+    }
+
     private getWsInternals(ws: SidecarWsClient): SidecarWsClientInternals {
         return ws as unknown as SidecarWsClientInternals;
     }
@@ -538,6 +559,7 @@ export abstract class Exchange {
 
         internals.activeSubs.delete(subKey);
         internals.subscriptions.delete(requestId);
+        internals.dataQueues.delete(requestId);
         internals.dataStore.delete(requestId);
 
         const firstArg = args[0] ?? "";
@@ -847,6 +869,32 @@ export abstract class Exchange {
         }
     }
 
+    async fetchSeries(params?: SeriesFetchParams): Promise<UnifiedSeries[]> {
+        await this.initPromise;
+        try {
+            const args: any[] = [];
+            if (params !== undefined) args.push(params);
+            const response = await this.fetchWithRetry(`${this.resolveBaseUrl()}/api/${this.exchangeName}/fetchSeries`, {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json', ...this.getAuthHeaders() },
+                body: JSON.stringify({ args, credentials: this.getCredentials() }),
+            });
+            if (!response.ok) {
+                const body = await response.json().catch(() => ({}));
+                if (body.error && typeof body.error === "object") {
+                    throw fromServerError(body.error);
+                }
+                throw new PmxtError(body.error?.message || response.statusText);
+            }
+            const json = await response.json();
+            const data = this.handleResponse(json);
+            return data.map(convertSeries);
+        } catch (error) {
+            if (error instanceof PmxtError) throw error;
+            throw new PmxtError(`Failed to fetchSeries: ${error}`);
+        }
+    }
+
     async fetchMarket(params?: MarketFetchParams): Promise<UnifiedMarket> {
         await this.initPromise;
         try {
@@ -1199,32 +1247,24 @@ export abstract class Exchange {
 
     async unwatchOrderBook(outcomeId: string | MarketOutcome): Promise<void> {
         await this.initPromise;
-        const resolvedOutcomeId = resolveOutcomeId(outcomeId);
-        const args: any[] = [resolvedOutcomeId];
         try {
-            const ws = await this.getOrCreateWs();
-            if (!ws) {
-                throw this.wsTransportUnavailableError("unwatchOrderBook");
+            const args: any[] = [];
+            args.push(resolveOutcomeId(outcomeId));
+            const response = await this.fetchWithRetry(`${this.resolveBaseUrl()}/api/${this.exchangeName}/unwatchOrderBook`, {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json', ...this.getAuthHeaders() },
+                body: JSON.stringify({ args, credentials: this.getCredentials() }),
+            });
+            if (!response.ok) {
+                const body = await response.json().catch(() => ({}));
+                if (body.error && typeof body.error === "object") {
+                    throw fromServerError(body.error);
+                }
+                throw new PmxtError(body.error?.message || response.statusText);
             }
-
-            const requestId = this.getWsSubscriptionId(ws, "watchOrderBook", args)
-                ?? `req-${Math.random().toString(36).slice(2, 14)}`;
-
-            await this.sendWsMessage(
-                ws,
-                {
-                    id: requestId,
-                    action: "unsubscribe",
-                    exchange: this.exchangeName,
-                    method: "unwatchOrderBook",
-                    args,
-                },
-            );
-            this.clearWsSubscription(ws, "watchOrderBook", args);
+            const json = await response.json();
+            this.handleResponse(json);
         } catch (error) {
-            if (this.isWsTransportUnavailableError(error)) {
-                throw this.wsTransportUnavailableError("unwatchOrderBook");
-            }
             if (error instanceof PmxtError) throw error;
             throw new PmxtError(`Failed to unwatchOrderBook: ${error}`);
         }
@@ -1718,7 +1758,8 @@ export abstract class Exchange {
      * Call repeatedly in a loop to stream updates (CCXT Pro pattern).
      * Requires hosted mode (`pmxtApiKey` set).
      *
-     * @param venues - Optional venue filter (e.g. ["polymarket", "limitless"])
+     * @param venues - Optional venue filter. Defaults to this exchange's venue
+     *   for venue clients (e.g. Kalshi -> ["kalshi"]); Router defaults to all venues.
      * @returns Next event with source, symbol, and orderbook
      *
      * @example
@@ -1737,7 +1778,8 @@ export abstract class Exchange {
             throw new PmxtError("watchAllOrderBooks() requires hosted mode (set pmxtApiKey)");
         }
 
-        const args: any[] = venues ? [venues] : [];
+        const effectiveVenues = venues ?? this.defaultWatchAllOrderBookVenues();
+        const args: any[] = effectiveVenues?.length ? [effectiveVenues] : [];
         const wsData = await this.watchViaWs("watchAllOrderBooks", args);
         if (wsData !== null) {
             return {