Remove CommandStopListener

service/config/sample.yml

@@ -452,8 +452,5 @@ registrationService:
 turn:
   secret: secret://turn.secret
 
-commandStopListener:
-  path: /example/path
-
 linkDevice:
   secret: secret://linkDevice.secret

service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java

@@ -26,7 +26,6 @@ import org.whispersystems.textsecuregcm.configuration.Cdn3StorageManagerConfigur
 import org.whispersystems.textsecuregcm.configuration.CdnConfiguration;
 import org.whispersystems.textsecuregcm.configuration.ClientCdnConfiguration;
 import org.whispersystems.textsecuregcm.configuration.ClientReleaseConfiguration;
-import org.whispersystems.textsecuregcm.configuration.CommandStopListenerConfiguration;
 import org.whispersystems.textsecuregcm.configuration.DirectoryV2Configuration;
 import org.whispersystems.textsecuregcm.configuration.DogstatsdConfiguration;
 import org.whispersystems.textsecuregcm.configuration.DynamoDbClientConfiguration;
@@ -312,11 +311,6 @@ public class WhisperServerConfiguration extends Configuration {
   @JsonProperty
   private MessageByteLimitCardinalityEstimatorConfiguration messageByteLimitCardinalityEstimator = new MessageByteLimitCardinalityEstimatorConfiguration(Duration.ofDays(1));
 
-  @Valid
-  @NotNull
-  @JsonProperty
-  private CommandStopListenerConfiguration commandStopListener;
-
   @Valid
   @NotNull
   @JsonProperty
@@ -530,10 +524,6 @@ public class WhisperServerConfiguration extends Configuration {
     return messageByteLimitCardinalityEstimator;
   }
 
-  public CommandStopListenerConfiguration getCommandStopListener() {
-    return commandStopListener;
-  }
-
   public LinkDeviceSecretConfiguration getLinkDeviceSecretConfiguration() {
     return linkDevice;
   }

service/src/main/java/org/whispersystems/textsecuregcm/configuration/CommandStopListenerConfiguration.java

@@ -1,12 +0,0 @@
-/*
- * Copyright 2023 Signal Messenger, LLC
- * SPDX-License-Identifier: AGPL-3.0-only
- */
-
-package org.whispersystems.textsecuregcm.configuration;
-
-import javax.validation.constraints.NotNull;
-
-public record CommandStopListenerConfiguration(@NotNull String path) {
-
-}

service/src/main/java/org/whispersystems/textsecuregcm/workers/AbstractSinglePassCrawlAccountsCommand.java

@@ -70,8 +70,6 @@ public abstract class AbstractSinglePassCrawlAccountsCommand extends Environment
 
     final int segments = Objects.requireNonNull(namespace.getInt(SEGMENT_COUNT));
 
-    environment.lifecycle().manage(new CommandStopListener(configuration.getCommandStopListener()));
-
     logger.info("Crawling accounts with {} segments and {} processors",
         segments,
         Runtime.getRuntime().availableProcessors());

service/src/main/java/org/whispersystems/textsecuregcm/workers/CommandStopListener.java

@@ -1,45 +0,0 @@
-/*
- * Copyright 2023 Signal Messenger, LLC
- * SPDX-License-Identifier: AGPL-3.0-only
- */
-
-package org.whispersystems.textsecuregcm.workers;
-
-import io.dropwizard.lifecycle.Managed;
-import java.io.FileWriter;
-import java.io.IOException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.whispersystems.textsecuregcm.configuration.CommandStopListenerConfiguration;
-
-/**
- * When {@link Managed#stop()} is called, writes to a configured file path
- * <p>
- * Useful for coordinating process termination via a shared file-system, such as a Kubernetes volume mount.
- */
-public class CommandStopListener implements Managed {
-
-  private static final Logger logger = LoggerFactory.getLogger(CommandStopListener.class);
-
-  private final String path;
-
-  CommandStopListener(CommandStopListenerConfiguration config) {
-    this.path = config.path();
-  }
-
-  @Override
-  public void start() {
-
-  }
-
-  @Override
-  public void stop() {
-    try {
-      try (FileWriter writer = new FileWriter(path)) {
-        writer.write("stopped");
-      }
-    } catch (final IOException e) {
-      logger.error("Failed to open file {}", path, e);
-    }
-  }
-}

service/src/main/java/org/whispersystems/textsecuregcm/workers/UnlinkDeviceCommand.java

@@ -52,10 +52,6 @@ public class UnlinkDeviceCommand extends EnvironmentCommand<WhisperServerConfigu
       final WhisperServerConfiguration configuration) throws Exception {
     environment.getObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
 
-    final CommandStopListener commandStopListener = new CommandStopListener(configuration.getCommandStopListener());
-    try {
-      commandStopListener.start();
-
       final UUID aci = UUID.fromString(namespace.getString("uuid").trim());
       final List<Byte> deviceIds = namespace.getList("deviceIds");
 
@@ -73,8 +69,5 @@ public class UnlinkDeviceCommand extends EnvironmentCommand<WhisperServerConfigu
         System.out.format("Removing device %s::%d\n", aci, deviceId);
         deps.accountsManager().removeDevice(account, deviceId).join();
       }
-    } finally {
-      commandStopListener.stop();
-    }
   }
 }