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

refactor: streamline position handling in LighterGateway by removing unnecessary HTTP empty position logic and improving logging for empty position scenarios

Browse Source
This commit is contained in:
discountry
2025-11-13 02:13:52 +08:00
parent 4ce2b07e21
commit 1bfe4d58c0
1 changed files with 14 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/exchanges/lighter/gateway.ts
+14 -46
View File
@@ -123,7 +123,6 @@ const WS_STALE_TIMEOUT_MS = 20_000;
const FEED_STALE_TIMEOUT_MS = 8_000; const FEED_STALE_TIMEOUT_MS = 8_000;
const STALE_CHECK_INTERVAL_MS = 2_000; const STALE_CHECK_INTERVAL_MS = 2_000;
const ACCOUNT_POLL_INTERVAL_MS = 5_000; const ACCOUNT_POLL_INTERVAL_MS = 5_000;
const ACCOUNT_HTTP_EMPTY_CONFIRM_MS = 15_000;
const POSITION_EPSILON = 1e-12; const POSITION_EPSILON = 1e-12;
const RESOLUTION_MS: Record<string, number> = { const RESOLUTION_MS: Record<string, number> = {
@@ -184,8 +183,8 @@ export class LighterGateway {
private readonly l1Address: string | null; private readonly l1Address: string | null;
private loggedCreateOrderPayload = false; private loggedCreateOrderPayload = false;
private readonly logTxInfo: boolean; private readonly logTxInfo: boolean;
private httpEmptySince: number | null = null;
private lastWsPositionUpdateAt = 0; private lastWsPositionUpdateAt = 0;
private httpPositionsEmptyLogged = false;
private marketId: number | null = null; private marketId: number | null = null;
private priceDecimals: number | null = null; private priceDecimals: number | null = null;
@@ -472,42 +471,20 @@ export class LighterGateway {
const normalized = this.normalizePositions(details.positions); const normalized = this.normalizePositions(details.positions);
if (normalized.length) { if (normalized.length) {
this.replacePositions(normalized); this.replacePositions(normalized);
this.recordHttpPositionUpdate(); this.httpPositionsEmptyLogged = false;
this.httpEmptySince = null;
return; return;
} }
if (!this.isEmptyPositionsPayload(details.positions)) { if (this.isEmptyPositionsPayload(details.positions)) {
return; if (this.positions.length && !this.httpPositionsEmptyLogged) {
} this.logger("accountPoll", "HTTP positions payload empty, retaining existing positions until WS confirms");
this.handleHttpEmptyPositions(); this.httpPositionsEmptyLogged = true;
} }
private handleHttpEmptyPositions(): void {
if (this.positions.length === 0) {
this.httpEmptySince = null;
return;
}
if (this.httpEmptySince == null) {
this.httpEmptySince = Date.now();
return;
}
const now = Date.now();
const sinceEmpty = now - this.httpEmptySince;
const sinceWs = now - this.lastWsPositionUpdateAt;
if (sinceEmpty >= ACCOUNT_HTTP_EMPTY_CONFIRM_MS && sinceWs >= ACCOUNT_HTTP_EMPTY_CONFIRM_MS) {
this.positions = [];
this.recordHttpPositionUpdate();
this.httpEmptySince = null;
} }
} }
private recordWsPositionUpdate(): void { private recordWsPositionUpdate(): void {
this.lastWsPositionUpdateAt = Date.now(); this.lastWsPositionUpdateAt = Date.now();
this.httpEmptySince = null; this.httpPositionsEmptyLogged = false;
}
private recordHttpPositionUpdate(): void {
this.httpEmptySince = null;
} }
private async openWebSocket(): Promise<void> { private async openWebSocket(): Promise<void> {
@@ -760,11 +737,6 @@ export class LighterGateway {
if (incoming.length) { if (incoming.length) {
this.mergePositions(incoming); this.mergePositions(incoming);
this.recordWsPositionUpdate(); this.recordWsPositionUpdate();
} else if (this.isEmptyPositionsPayload(positionsObject)) {
if (this.positions.length) {
this.positions = [];
}
this.recordWsPositionUpdate();
} }
} }
this.emitAccount(); this.emitAccount();
@@ -786,16 +758,12 @@ export class LighterGateway {
this.clearOrdersForMarket(channelMarketId); this.clearOrdersForMarket(channelMarketId);
this.emitOrders(); this.emitOrders();
} }
if ( if (position && this.shouldRemovePosition(position)) {
Object.prototype.hasOwnProperty.call(message, "position") && const target = Number(position.market_id ?? channelMarketId);
!position && if (Number.isFinite(target)) {
this.isEmptyPositionsPayload(message.position) && this.positions = this.positions.filter((entry) => Number(entry.market_id) !== target);
channelMarketId != null && this.recordWsPositionUpdate();
this.positions.length }
) {
const target = Number(channelMarketId);
this.positions = this.positions.filter((entry) => Number(entry.market_id) !== target);
this.recordWsPositionUpdate();
} }
this.emitAccount(); this.emitAccount();
} }