Remove messages in beforeAll

dydxprotocol · May 7, 2024 · 1f1edaf · 1f1edaf
1 parent 614577c
commit 1f1edaf
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/indexer/services/socks/__tests__/lib/message-forwarder.test.ts b/indexer/services/socks/__tests__/lib/message-forwarder.test.ts
@@ -192,6 +192,20 @@ describe('message-forwarder', () => {
     subscriptions = new Subscriptions();
     index = new Index(wss, subscriptions);
     (axiosRequest as jest.Mock).mockImplementation(() => (JSON.stringify(mockAxiosResponse)));
+    await admin.deleteTopicRecords({
+      topic: WebsocketTopics.TO_WEBSOCKETS_TRADES,
+      partitions: [{
+        partition: 0,
+        offset: '-1',
+      }],
+    });
+    await admin.deleteTopicRecords({
+      topic: WebsocketTopics.TO_WEBSOCKETS_SUBACCOUNTS,
+      partitions: [{
+        partition: 0,
+        offset: '-1',
+      }],
+    });
   });
 
   afterEach(() => {
@@ -422,7 +436,7 @@ describe('message-forwarder', () => {
     });
   });
 
-  /*it('forwards messages', (done: jest.DoneCallback) => {
+  it('forwards messages', (done: jest.DoneCallback) => {
     const channel: Channel = Channel.V4_TRADES;
     const id: string = ethTicker;
 
@@ -494,7 +508,7 @@ describe('message-forwarder', () => {
         batched: false,
       }));
     });
-  });*/
+  });
 });
 
 function checkInitialMessage(