Wait for candle updates to run before checking for updates

dydxprotocol · Jul 25, 2024 · 3903935 · 3903935
1 parent 5037908
commit 3903935
Showing 1 changed file with 26 additions and 25 deletions.
diff --git a/indexer/services/ender/__tests__/lib/candles-generator.test.ts b/indexer/services/ender/__tests__/lib/candles-generator.test.ts
@@ -505,31 +505,32 @@ describe('candleHelper', () => {
     ]);
 
     // Create new candles, with trades
-    await runUpdateCandles(publisher);
-
-    // Verify previous candles have orderbookMidPriceClose updated
-    const previousExpectedCandles: CandleFromDatabase[] = _.map(
-      Object.values(CandleResolution),
-      (resolution: CandleResolution) => {
-        return {
-          id: CandleTable.uuid(previousStartedAt, defaultCandle.ticker, resolution),
-          startedAt: previousStartedAt,
-          ticker: defaultCandle.ticker,
-          resolution,
-          low: existingPrice,
-          high: existingPrice,
-          open: existingPrice,
-          close: existingPrice,
-          baseTokenVolume,
-          usdVolume,
-          trades: existingTrades,
-          startingOpenInterest,
-          orderbookMidPriceClose: '10005',
-          orderbookMidPriceOpen,
-        };
-      },
-    );
-    await verifyCandlesInPostgres(previousExpectedCandles);
+    await runUpdateCandles(publisher).then(async () => {
+
+      // Verify previous candles have orderbookMidPriceClose updated
+      const previousExpectedCandles: CandleFromDatabase[] = _.map(
+        Object.values(CandleResolution),
+        (resolution: CandleResolution) => {
+          return {
+            id: CandleTable.uuid(previousStartedAt, defaultCandle.ticker, resolution),
+            startedAt: previousStartedAt,
+            ticker: defaultCandle.ticker,
+            resolution,
+            low: existingPrice,
+            high: existingPrice,
+            open: existingPrice,
+            close: existingPrice,
+            baseTokenVolume,
+            usdVolume,
+            trades: existingTrades,
+            startingOpenInterest,
+            orderbookMidPriceClose: '10005',
+            orderbookMidPriceOpen,
+          };
+        },
+      );
+      await verifyCandlesInPostgres(previousExpectedCandles);
+    });
 
     // Verify new candles were created
     const expectedCandles: CandleFromDatabase[] = _.map(