diff --git a/src/index.ts b/src/index.ts index 54c3935..31c7586 100644 --- a/src/index.ts +++ b/src/index.ts @@ -774,11 +774,18 @@ const main = async (): Promise => { } } + let validateIncludeVamm = false; + if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') { + const perpMarket = driftClient.getPerpMarketAccount(normedMarketIndex); + validateIncludeVamm = + !isVariant(perpMarket.status, 'ammPaused') && + !isVariant(perpMarket.status, 'initialized'); + } const l2 = dlobSubscriber.getL2({ marketIndex: normedMarketIndex, marketType: normedMarketType, depth: parseInt(adjustedDepth as string), - includeVamm: isSpot ? false : `${includeVamm}`.toLowerCase() === 'true', + includeVamm: validateIncludeVamm, numVammOrders: parseInt((numVammOrders ?? '100') as string), fallbackL2Generators: isSpot ? [ @@ -938,13 +945,19 @@ const main = async (): Promise => { } } + let validateIncludeVamm = false; + if (!isSpot && `${includeVamm}`.toLowerCase() === 'true') { + const perpMarket = + driftClient.getPerpMarketAccount(normedMarketIndex); + validateIncludeVamm = + !isVariant(perpMarket.status, 'ammPaused') && + !isVariant(perpMarket.status, 'initialized'); + } const l2 = dlobSubscriber.getL2({ marketIndex: normedMarketIndex, marketType: normedMarketType, depth: parseInt(adjustedDepth as string), - includeVamm: isSpot - ? false - : `${normedParam['includeVamm']}`.toLowerCase() === 'true', + includeVamm: validateIncludeVamm, fallbackL2Generators: isSpot ? [ `${normedParam['includePhoenix']}`.toLowerCase() === 'true' &&