From 51cea70e0a38bdd28565091716e7ca0e383e188f Mon Sep 17 00:00:00 2001
From: Vincent Chau <99756290+vincentwschau@users.noreply.github.com>
Date: Mon, 23 Oct 2023 12:18:48 -0400
Subject: [PATCH] Add config / start loop in service.

---
 indexer/services/roundtable/src/config.ts | 4 ++++
 indexer/services/roundtable/src/index.ts  | 9 +++++++++
 2 files changed, 13 insertions(+)

diff --git a/indexer/services/roundtable/src/config.ts b/indexer/services/roundtable/src/config.ts
index 62e1eaa495..b444ffd097 100644
--- 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
index 3486c862f1..fb40d616d8 100644
--- 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',