diff --git a/src/index.ts b/src/index.ts index 50c90ed..e327da4 100644 --- a/src/index.ts +++ b/src/index.ts @@ -650,11 +650,11 @@ const main = async () => { numVammOrders: parseInt((numVammOrders ?? '100') as string), fallbackL2Generators: isSpot ? [ - `${includePhoenix}`.toLowerCase() === 'true' && - MARKET_SUBSCRIBERS[normedMarketIndex].phoenix, - `${includeSerum}`.toLowerCase() === 'true' && - MARKET_SUBSCRIBERS[normedMarketIndex].serum, - ].filter((a) => !!a) + `${includePhoenix}`.toLowerCase() === 'true' && + MARKET_SUBSCRIBERS[normedMarketIndex].phoenix, + `${includeSerum}`.toLowerCase() === 'true' && + MARKET_SUBSCRIBERS[normedMarketIndex].serum, + ].filter((a) => !!a) : [], }); @@ -768,11 +768,11 @@ const main = async () => { : `${normedParam['includeVamm']}`.toLowerCase() === 'true', fallbackL2Generators: isSpot ? [ - `${normedParam['includePhoenix']}`.toLowerCase() === 'true' && - MARKET_SUBSCRIBERS[normedMarketIndex].phoenix, - `${normedParam['includeSerum']}`.toLowerCase() === 'true' && - MARKET_SUBSCRIBERS[normedMarketIndex].serum, - ].filter((a) => !!a) + `${normedParam['includePhoenix']}`.toLowerCase() === 'true' && + MARKET_SUBSCRIBERS[normedMarketIndex].phoenix, + `${normedParam['includeSerum']}`.toLowerCase() === 'true' && + MARKET_SUBSCRIBERS[normedMarketIndex].serum, + ].filter((a) => !!a) : [], }); diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index 4f7399f..a598f30 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -66,7 +66,6 @@ const main = async () => { accountLoader: bulkAccountLoader, }, env: driftEnv, - userStats: true, }); const slotSubscriber = new SlotSubscriber(connection, {}); diff --git a/src/publishers/tradesPublisher.ts b/src/publishers/tradesPublisher.ts index 5feaaf1..d0bd14e 100644 --- a/src/publishers/tradesPublisher.ts +++ b/src/publishers/tradesPublisher.ts @@ -74,7 +74,6 @@ const main = async () => { accountLoader: bulkAccountLoader, }, env: driftEnv, - userStats: true, }); const slotSubscriber = new SlotSubscriber(connection, {});