Add config / start loop in service.

dydxprotocol · Oct 23, 2023 · 51cea70 · 51cea70
1 parent 2352bd2
commit 51cea70
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/indexer/services/roundtable/src/config.ts b/indexer/services/roundtable/src/config.ts
@@ -41,6 +41,7 @@ export const configSchema = {
   LOOPS_CANCEL_STALE_ORDERS: parseBoolean({ default: true }),
   LOOPS_ENABLED_UPDATE_RESEARCH_ENVIRONMENT: parseBoolean({ default: true }),
   LOOPS_ENABLED_TRACK_LAG: parseBoolean({ default: false }),
+  LOOPS_ENABLED_REMOVE_OLD_ORDER_UPDATES: parseBoolean({ default: true }),
 
   // Loop Timing
   LOOPS_INTERVAL_MS_MARKET_UPDATER: parseInteger({
@@ -70,6 +71,9 @@ export const configSchema = {
   LOOPS_INTERVAL_MS_TRACK_LAG: parseInteger({
     default: TEN_SECONDS_IN_MILLISECONDS,
   }),
+  LOOPS_INTERVAL_MS_REMOVE_OLD_ORDER_UPDATES: parseInteger({
+    default: THIRTY_SECONDS_IN_MILLISECONDS,
+  }),
 
   // Start delay
   START_DELAY_ENABLED: parseBoolean({ default: true }),

diff --git a/indexer/services/roundtable/src/index.ts b/indexer/services/roundtable/src/index.ts
@@ -14,6 +14,7 @@ import deleteZeroPriceLevelsTask from './tasks/delete-zero-price-levels';
 import marketUpdaterTask from './tasks/market-updater';
 import orderbookInstrumentationTask from './tasks/orderbook-instrumentation';
 import removeExpiredOrdersTask from './tasks/remove-expired-orders';
+import removeOldOrderUpdatesTask from './tasks/remove-old-order-updates';
 import trackLag from './tasks/track-lag';
 import updateComplianceDataTask from './tasks/update-compliance-data';
 import updateResearchEnvironmentTask from './tasks/update-research-environment';
@@ -112,6 +113,14 @@ async function start(): Promise<void> {
     );
   }
 
+  if (config.LOOPS_ENABLED_REMOVE_OLD_ORDER_UPDATES) {
+    startLoop(
+      removeOldOrderUpdatesTask,
+      'remove_old_order_updates',
+      config.LOOPS_INTERVAL_MS_REMOVE_OLD_ORDER_UPDATES,
+    );
+  }
+
   logger.info({
     at: 'index',
     message: 'Successfully started',