From c2317e84931ed4d6e4863d2ba22640ae20c9fb8d Mon Sep 17 00:00:00 2001
From: Chris Eager <chris@signal.org>
Date: Tue, 23 May 2023 17:10:25 -0500
Subject: [PATCH] Start the dynamic configuration manager in dependent commands

---
 .../textsecuregcm/workers/CrawlAccountsCommand.java           | 2 ++
 .../textsecuregcm/workers/MessagePersisterServiceCommand.java | 4 +++-
 .../ScheduledApnPushNotificationSenderServiceCommand.java     | 2 ++
 3 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/CrawlAccountsCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/CrawlAccountsCommand.java
index 3a9a1590d..beaa5e5f7 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/CrawlAccountsCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/CrawlAccountsCommand.java
@@ -90,6 +90,8 @@ public class CrawlAccountsCommand extends EnvironmentCommand<WhisperServerConfig
             configuration.getAppConfig().getConfigurationName(),
             DynamicConfiguration.class);
 
+    dynamicConfigurationManager.start();
+
     final AccountDatabaseCrawler crawler =
 
         switch ((CrawlType) namespace.get(CRAWL_TYPE)) {
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/MessagePersisterServiceCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/MessagePersisterServiceCommand.java
index ebbbd7045..f93d8bc0d 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/MessagePersisterServiceCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/MessagePersisterServiceCommand.java
@@ -53,7 +53,9 @@ public class MessagePersisterServiceCommand extends EnvironmentCommand<WhisperSe
         configuration.getAppConfig().getConfigurationName(),
         DynamicConfiguration.class);
 
-    MessagePersister messagePersister = new MessagePersister(deps.messagesCache(), deps.messagesManager(),
+    dynamicConfigurationManager.start();
+
+    final MessagePersister messagePersister = new MessagePersister(deps.messagesCache(), deps.messagesManager(),
         deps.accountsManager(),
         dynamicConfigurationManager,
         Duration.ofMinutes(configuration.getMessageCacheConfiguration().getPersistDelayMinutes()),
diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScheduledApnPushNotificationSenderServiceCommand.java b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScheduledApnPushNotificationSenderServiceCommand.java
index 0ee699e60..2c95f0f6a 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScheduledApnPushNotificationSenderServiceCommand.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/workers/ScheduledApnPushNotificationSenderServiceCommand.java
@@ -63,6 +63,8 @@ public class ScheduledApnPushNotificationSenderServiceCommand extends Environmen
         configuration.getAppConfig().getConfigurationName(),
         DynamicConfiguration.class);
 
+    dynamicConfigurationManager.start();
+
     final APNSender apnSender = new APNSender(apnSenderExecutor, configuration.getApnConfiguration());
     final ApnPushNotificationScheduler apnPushNotificationScheduler = new ApnPushNotificationScheduler(
         pushSchedulerCluster, apnSender, deps.accountsManager(), Optional.of(namespace.getInt(WORKER_COUNT)),