mzoe/ritmex-bot
1
0
Fork 0
mirror of https://github.com/discountry/ritmex-bot.git synced 2026-09-11 09:18:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: streamline order handling logic in LighterGateway by consolidating market ID checks and improving snapshot order clearing

Browse Source
This commit is contained in:
discountry
2025-11-08 12:09:27 +08:00
parent d0d1afa0ea
commit a91e87534b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/exchanges/lighter/gateway.ts
+3 -3
View File
@@ -687,8 +687,6 @@ export class LighterGateway {
const channelMarketId = this.extractMarketIdFromChannel(message.channel); const channelMarketId = this.extractMarketIdFromChannel(message.channel);
if (position && Number.isFinite(Number(position.market_id))) { if (position && Number.isFinite(Number(position.market_id))) {
this.mergePositions([position]); this.mergePositions([position]);
} else if (type === "subscribed/account_market" && channelMarketId != null) {
this.removePositionsForMarkets([channelMarketId]);
} }
if (Array.isArray(message.orders) && message.orders.length) { if (Array.isArray(message.orders) && message.orders.length) {
const marketId = Number(position?.market_id ?? channelMarketId ?? this.marketId ?? NaN); const marketId = Number(position?.market_id ?? channelMarketId ?? this.marketId ?? NaN);
@@ -823,11 +821,13 @@ export class LighterGateway {
private applyOrderList(rawOrders: unknown, marketId: number | null, snapshot: boolean): void { private applyOrderList(rawOrders: unknown, marketId: number | null, snapshot: boolean): void {
const orders = this.normalizeOrders(rawOrders); const orders = this.normalizeOrders(rawOrders);
if (snapshot) {
if (marketId != null) { if (marketId != null) {
this.clearOrdersForMarket(marketId); this.clearOrdersForMarket(marketId);
} else if (snapshot) { } else {
this.orderMap.clear(); this.orderMap.clear();
} }
}
for (const order of orders) { for (const order of orders) {
this.applyOrderUpdate(order); this.applyOrderUpdate(order);
} }