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

fix: ensure order IDs are consistently treated as strings and configure ed25519 to use custom sha512 implementation

Browse Source
This commit is contained in:
discountry
2025-10-23 19:45:19 +08:00
parent f1ebfacaa2
commit 6196912cf4
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/exchanges/backpack/gateway.ts
+9 -8
View File
@@ -31,8 +31,9 @@ const WebSocketCtor: typeof globalThis.WebSocket =
? globalThis.WebSocket ? globalThis.WebSocket
: ((NodeWebSocket as unknown) as typeof globalThis.WebSocket); : ((NodeWebSocket as unknown) as typeof globalThis.WebSocket);
edUtils.sha512 = sha512 as unknown as typeof edUtils.sha512; // Configure ed25519 to use our sha512 implementation
edHashes.sha512 = sha512; (edUtils as any).sha512 = sha512;
(edHashes as any).sha512 = sha512;
const ORDER_STATUS_MAP: Record<string, string> = { const ORDER_STATUS_MAP: Record<string, string> = {
NEW: "NEW", NEW: "NEW",
@@ -253,7 +254,7 @@ export class BackpackGateway {
const status = this.normalizeStatus(entry.status ?? (entry.info?.status as string)); const status = this.normalizeStatus(entry.status ?? (entry.info?.status as string));
if (this.isTerminalStatus(status)) continue; if (this.isTerminalStatus(status)) continue;
const mapped = this.mapRestOrder(entry); const mapped = this.mapRestOrder(entry);
active.set(mapped.orderId, mapped); active.set(String(mapped.orderId), mapped);
} }
this.localOrders.clear(); this.localOrders.clear();
for (const [id, order] of active.entries()) { for (const [id, order] of active.entries()) {
@@ -361,7 +362,7 @@ export class BackpackGateway {
const order = await this.exchange.createOrder(symbol, ccxtType, side, amount, price, extraParams); const order = await this.exchange.createOrder(symbol, ccxtType, side, amount, price, extraParams);
const mapped = this.mapRestOrder(order as CcxtOrder); const mapped = this.mapRestOrder(order as CcxtOrder);
this.localOrders.set(mapped.orderId, mapped); this.localOrders.set(String(mapped.orderId), mapped);
this.emitOrders(); this.emitOrders();
return mapped; return mapped;
} }
@@ -541,7 +542,7 @@ export class BackpackGateway {
private mapRestOrder(order: CcxtOrder): AsterOrder { private mapRestOrder(order: CcxtOrder): AsterOrder {
const info = (order.info ?? {}) as Record<string, unknown>; const info = (order.info ?? {}) as Record<string, unknown>;
const side = (order.side ?? "buy").toUpperCase() as "BUY" | "SELL"; const side = (order.side ?? "buy").toUpperCase() as "BUY" | "SELL";
let type = this.normalizeOrderType(order.type ?? (info.o as string)); let type = this.normalizeOrderType(order.type ?? (info.o as string)) as OrderType;
if ( if (
order.triggerPrice != null || order.triggerPrice != null ||
info.triggerPrice != null || info.triggerPrice != null ||
@@ -585,7 +586,7 @@ export class BackpackGateway {
const sideRaw = String(data.S ?? "").toUpperCase(); const sideRaw = String(data.S ?? "").toUpperCase();
const side: "BUY" | "SELL" = sideRaw === "BID" ? "BUY" : "SELL"; const side: "BUY" | "SELL" = sideRaw === "BID" ? "BUY" : "SELL";
const triggerPresent = data.P != null || data.B != null; const triggerPresent = data.P != null || data.B != null;
const type = triggerPresent ? "STOP_MARKET" : String(data.o ?? "LIMIT").toUpperCase(); const type = (triggerPresent ? "STOP_MARKET" : String(data.o ?? "LIMIT").toUpperCase()) as OrderType;
const status = this.normalizeStatus(data.X as string); const status = this.normalizeStatus(data.X as string);
const price = this.pickString([data.p, data.P, "0"]); const price = this.pickString([data.p, data.P, "0"]);
const quantity = this.pickString([data.q, data.Y]); const quantity = this.pickString([data.q, data.Y]);
@@ -834,12 +835,12 @@ export class BackpackGateway {
const status = mapped.status; const status = mapped.status;
const id = mapped.orderId; const id = mapped.orderId;
if (this.isTerminalStatus(status)) { if (this.isTerminalStatus(status)) {
if (this.localOrders.delete(id)) { if (this.localOrders.delete(String(id))) {
this.emitOrders(); this.emitOrders();
} }
return; return;
} }
this.localOrders.set(id, mapped); this.localOrders.set(String(id), mapped);
this.emitOrders(); this.emitOrders();
} }