diff --git a/src/dlob-subscriber/DLOBSubscriberIO.ts b/src/dlob-subscriber/DLOBSubscriberIO.ts index b67b1b4..41491e7 100644 --- a/src/dlob-subscriber/DLOBSubscriberIO.ts +++ b/src/dlob-subscriber/DLOBSubscriberIO.ts @@ -124,6 +124,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { l2Formatted['marketName'] = marketName?.toUpperCase(); l2Formatted['marketType'] = marketType?.toLowerCase(); l2Formatted['marketIndex'] = l2Args.marketIndex; + l2Formatted['ts'] = Date.now(); l2Formatted['slot'] = slot; addOracletoResponse( l2Formatted, @@ -137,7 +138,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { l2Args.marketType, l2Args.marketIndex ); - + const l2Formatted_depth100 = Object.assign({}, l2Formatted, { bids: l2Formatted.bids.slice(0, 100), asks: l2Formatted.asks.slice(0, 100), diff --git a/src/utils/utils.ts b/src/utils/utils.ts index 831a7fb..2c958a6 100644 --- a/src/utils/utils.ts +++ b/src/utils/utils.ts @@ -140,9 +140,13 @@ export const addMarketSlotToResponse = ( ): void => { let marketSlot: number; if (isVariant(marketType, 'perp')) { - marketSlot = driftClient.accountSubscriber.getMarketAccountAndSlot(marketIndex).slot; + marketSlot = + driftClient.accountSubscriber.getMarketAccountAndSlot(marketIndex).slot; } else { - marketSlot = driftClient.accountSubscriber.getSpotMarketAccountAndSlot(marketIndex).slot; + marketSlot = + driftClient.accountSubscriber.getSpotMarketAccountAndSlot( + marketIndex + ).slot; } response['marketSlot'] = marketSlot; }; diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts index a189a82..cf99b7d 100644 --- a/src/wsConnectionManager.ts +++ b/src/wsConnectionManager.ts @@ -164,12 +164,16 @@ async function main() { .subscribe(redisChannel) .then(() => { subscribedChannels.add(redisChannel); + ws.send( + JSON.stringify({ + message: `Subscribe received for channel: ${parsedMessage.channel}, market: ${parsedMessage.market}, marketType: ${parsedMessage.marketType}`, + }) + ); }) .catch(() => { ws.send( JSON.stringify({ - redisChannel, - error: `Error subscribing to channel: ${redisChannel}`, + error: `Error subscribing to channel: ${parsedMessage}`, }) ); return; @@ -198,6 +202,7 @@ async function main() { ); } } + break; } case 'unsubscribe': {