diff --git a/drift-common b/drift-common index fc0fb4d..bac3177 160000 --- a/drift-common +++ b/drift-common @@ -1 +1 @@ -Subproject commit fc0fb4d2bd37ede822008c6f57a6e7dbb2b9cb39 +Subproject commit bac317766c42bfeab31c093bd3f5cbbbc7e0da8c diff --git a/src/dlob-subscriber/DLOBSubscriberIO.ts b/src/dlob-subscriber/DLOBSubscriberIO.ts index ad5ac28..5acbc7a 100644 --- a/src/dlob-subscriber/DLOBSubscriberIO.ts +++ b/src/dlob-subscriber/DLOBSubscriberIO.ts @@ -134,6 +134,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { override async updateDLOB(): Promise { await super.updateDLOB(); + let indicativeOrderId = 0; for (const marketArgs of this.marketArgs) { try { if (this.indicativeQuotesRedisClient) { @@ -185,13 +186,14 @@ export class DLOBSubscriberIO extends DLOBSubscriber { postedSlotTail: 0, }; - if (quote['bid_size'] && quote['bid_price']) { + if (quote['bid_size'] && quote['bid_price'] != null) { // Sanity check bid price and size const indicativeBid: Order = Object.assign( {}, indicativeBaseOrder, { + orderId: indicativeOrderId, oraclePriceOffset: quote['is_oracle_offset'] ? quote['bid_price'] : 0, @@ -208,13 +210,15 @@ export class DLOBSubscriberIO extends DLOBSubscriber { this.slotSource.getSlot(), false ); + indicativeOrderId += 1; } - if (quote['ask_size'] && quote['ask_price']) { + if (quote['ask_size'] && quote['ask_price'] != null) { const indicativeAsk: Order = Object.assign( {}, indicativeBaseOrder, { + orderId: indicativeOrderId, oraclePriceOffset: quote['is_oracle_offset'] ? quote['ask_price'] : 0, @@ -231,6 +235,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { this.slotSource.getSlot(), false ); + indicativeOrderId += 1; } } }