Skip to content

Commit

Permalink
Merge pull request #62 from aliraza556/fix-latest-trade-detail-interface
Browse files Browse the repository at this point in the history
Fix: Update Latest Trade Detail WebSocket Event Interface
  • Loading branch information
singlesly committed Jan 22, 2024
2 parents 3f3e134 + e6098c2 commit 8ac118d
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 9 deletions.
6 changes: 3 additions & 3 deletions src/bingx-socket/bingx-market-socket-stream.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,9 +16,9 @@ import { HeartbeatInterface } from 'bingx-api/bingx-socket/interfaces/heartbeat.
import {
LatestTradeEvent,
MarkerSubscription,
MarkerWebsocketEvents,
MarketWebsocketEvents,
SubscriptionType,
} from 'bingx-api/bingx-socket/events/marker-websocket-events';
} from 'bingx-api/bingx-socket/events/market-websocket-events';

export class BingxMarketSocketStream {
private forceClose$ = new BehaviorSubject<boolean>(false);
Expand All @@ -36,7 +36,7 @@ export class BingxMarketSocketStream {
}

private async connect(url: URL): Promise<void> {
const socket$ = webSocket<MarkerWebsocketEvents | MarkerSubscription>({
const socket$ = webSocket<MarketWebsocketEvents | MarkerSubscription>({
deserializer: (e) => new BingxWebsocketDeserializer().deserializer(e),
serializer: (e) => new BingxWebsocketSerializer().serializer(e),
url: url.toString(),
Expand Down
4 changes: 2 additions & 2 deletions src/bingx-socket/events/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,11 @@ export {
SubscriptionType,
LatestTradeEvent,
TradeDataType,
MarkerWebsocketEvents,
MarketWebsocketEvents,
Price,
Volume,
MarkerWebsocketEventCode,
IsMarketMaker,
TransactionTimeInMillis,
MarkerSubscription,
} from './marker-websocket-events';
} from './market-websocket-events';
Original file line number Diff line number Diff line change
Expand Up @@ -19,16 +19,21 @@ export type TradeDataType = `${TradingPair}@trade`;

export type SubscriptionType = TradeDataType;

export interface MarkerWebsocketEvents {
export interface MarketWebsocketEvents {
code: MarkerWebsocketEventCode;
dataType: SubscriptionType;
}

export interface LatestTradeEvent extends MarkerWebsocketEvents {
dataType: TradeDataType;
export interface TradeDetail {
T: TransactionTimeInMillis;
s: TradingPair;
m: IsMarketMaker;
p: Price;
v: Volume;
v: Volume; // Assuming 'q' represents volume
}

export interface LatestTradeEvent extends MarketWebsocketEvents {
code: MarkerWebsocketEventCode;
dataType: TradeDataType;
data: TradeDetail[];
}

0 comments on commit 8ac118d

Please sign in to comment.