Change Quote interface to MarketQuote, to match other RTC payload names like MarketTrade and MarketDepth.

Author: hunter547

src/index.ts

@@ -1,9 +1,14 @@
 // Main client
-export { TopstepXClient } from './client';
+export { TopstepXClient } from "./client";
 
 // Auth
-export { AuthService } from './auth';
-export type { AuthConfig, LoginRequest, LoginResponse, ValidateResponse } from './auth';
+export { AuthService } from "./auth";
+export type {
+  AuthConfig,
+  LoginRequest,
+  LoginResponse,
+  ValidateResponse,
+} from "./auth";
 
 // REST APIs
 export {
@@ -14,7 +19,7 @@ export {
   TradeApi,
   ContractApi,
   HistoryApi,
-} from './rest';
+} from "./rest";
 
 export type {
   HttpClientConfig,
@@ -55,15 +60,15 @@ export type {
   Bar,
   RetrieveBarsRequest,
   RetrieveBarsResponse,
-} from './rest';
+} from "./rest";
 
 // Realtime
-export { ConnectionManager, MarketHub, UserHub } from './realtime';
+export { ConnectionManager, MarketHub, UserHub } from "./realtime";
 
 export type {
   ConnectionManagerConfig,
   // Market hub types
-  Quote,
+  MarketQuote,
   MarketTrade,
   MarketDepth,
   MarketEvent,
@@ -74,7 +79,7 @@ export type {
   TradeUpdate,
   AccountUpdate,
   UserHubEvents,
-} from './realtime';
+} from "./realtime";
 
 // Types & Enums
 export {
@@ -84,17 +89,21 @@ export {
   BarUnit,
   PositionType,
   TradeType,
-} from './types';
+} from "./types";
 
-export type { ApiResponse, TopstepXClientConfig, TopstepXClientEvents } from './types';
+export type {
+  ApiResponse,
+  TopstepXClientConfig,
+  TopstepXClientEvents,
+} from "./types";
 
 // Errors
 export {
   TopstepXError,
   AuthenticationError,
   ApiError,
   ConnectionError,
-} from './errors';
+} from "./errors";
 
 // Utilities
-export { TypedEventEmitter } from './utils';
+export { TypedEventEmitter } from "./utils";

src/realtime/index.ts

@@ -1,20 +1,20 @@
-export { ConnectionManager } from './connection-manager';
-export type { ConnectionManagerConfig } from './connection-manager';
+export { ConnectionManager } from "./connection-manager";
+export type { ConnectionManagerConfig } from "./connection-manager";
 
-export { MarketHub } from './market';
+export { MarketHub } from "./market";
 export type {
-  Quote,
+  MarketQuote,
   MarketTrade,
   MarketDepth,
   MarketEvent,
   MarketHubEvents,
-} from './market';
+} from "./market";
 
-export { UserHub } from './user';
+export { UserHub } from "./user";
 export type {
   OrderUpdate,
   PositionUpdate,
   TradeUpdate,
   AccountUpdate,
   UserHubEvents,
-} from './user';
+} from "./user";

src/realtime/market/index.ts

@@ -1,8 +1,8 @@
-export { MarketHub } from './market-hub';
+export { MarketHub } from "./market-hub";
 export type {
-  Quote,
+  MarketQuote,
   MarketTrade,
   MarketDepth,
   MarketEvent,
   MarketHubEvents,
-} from './types';
+} from "./types";

src/realtime/market/market-hub.ts

@@ -1,6 +1,11 @@
-import type { ConnectionManager } from '../connection-manager';
-import { TypedEventEmitter } from '../../utils/event-emitter';
-import type { Quote, MarketTrade, MarketDepth, MarketHubEvents } from './types';
+import type { ConnectionManager } from "../connection-manager";
+import { TypedEventEmitter } from "../../utils/event-emitter";
+import type {
+  MarketQuote,
+  MarketTrade,
+  MarketDepth,
+  MarketHubEvents,
+} from "./types";
 
 export class MarketHub extends TypedEventEmitter<MarketHubEvents> {
   private subscribedQuotes = new Set<string>();
@@ -14,22 +19,25 @@ export class MarketHub extends TypedEventEmitter<MarketHubEvents> {
 
   private setupEventHandlers(): void {
     this.connectionManager.onMarketConnection((connection) => {
-      connection.on('GatewayQuote', (contractId: string, data: Quote[]) => {
-        this.emit('quote', { contractId, data });
-      });
+      connection.on(
+        "GatewayQuote",
+        (contractId: string, data: MarketQuote[]) => {
+          this.emit("quote", { contractId, data });
+        },
+      );
 
       connection.on(
-        'GatewayTrade',
+        "GatewayTrade",
         (contractId: string, data: MarketTrade[]) => {
-          this.emit('trade', { contractId, data });
-        }
+          this.emit("trade", { contractId, data });
+        },
       );
 
       connection.on(
-        'GatewayDepth',
+        "GatewayDepth",
         (contractId: string, data: MarketDepth[]) => {
-          this.emit('depth', { contractId, data });
-        }
+          this.emit("depth", { contractId, data });
+        },
       );
     });
   }
@@ -53,42 +61,42 @@ export class MarketHub extends TypedEventEmitter<MarketHubEvents> {
   async subscribeQuotes(contractId: string): Promise<void> {
     if (this.subscribedQuotes.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('SubscribeContractQuotes', contractId);
+    await connection.invoke("SubscribeContractQuotes", contractId);
     this.subscribedQuotes.add(contractId);
   }
 
   async unsubscribeQuotes(contractId: string): Promise<void> {
     if (!this.subscribedQuotes.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('UnsubscribeContractQuotes', contractId);
+    await connection.invoke("UnsubscribeContractQuotes", contractId);
     this.subscribedQuotes.delete(contractId);
   }
 
   async subscribeTrades(contractId: string): Promise<void> {
     if (this.subscribedTrades.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('SubscribeContractTrades', contractId);
+    await connection.invoke("SubscribeContractTrades", contractId);
     this.subscribedTrades.add(contractId);
   }
 
   async unsubscribeTrades(contractId: string): Promise<void> {
     if (!this.subscribedTrades.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('UnsubscribeContractTrades', contractId);
+    await connection.invoke("UnsubscribeContractTrades", contractId);
     this.subscribedTrades.delete(contractId);
   }
 
   async subscribeDepth(contractId: string): Promise<void> {
     if (this.subscribedDepth.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('SubscribeContractMarketDepth', contractId);
+    await connection.invoke("SubscribeContractMarketDepth", contractId);
     this.subscribedDepth.add(contractId);
   }
 
   async unsubscribeDepth(contractId: string): Promise<void> {
     if (!this.subscribedDepth.has(contractId)) return;
     const connection = this.connectionManager.marketConnection;
-    await connection.invoke('UnsubscribeContractMarketDepth', contractId);
+    await connection.invoke("UnsubscribeContractMarketDepth", contractId);
     this.subscribedDepth.delete(contractId);
   }
 }

src/realtime/market/types.ts

@@ -1,4 +1,4 @@
-export interface Quote {
+export interface MarketQuote {
   symbol: string;
   lastPrice: number;
   bestBid: number;
@@ -33,7 +33,7 @@ export interface MarketEvent<T> {
 
 export interface MarketHubEvents {
   [key: string]: unknown;
-  quote: MarketEvent<Quote>;
+  quote: MarketEvent<MarketQuote>;
   trade: MarketEvent<MarketTrade>;
   depth: MarketEvent<MarketDepth>;
 }