MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Register IssuedReceiptMigrationCommand

This commit is contained in:
Ravi Khadiwala 2024-12-06 15:41:47 -06:00 committed by ravi-signal
parent 14427523ae
commit f16428ce2a
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
View File

@ -267,6 +267,7 @@ import org.whispersystems.textsecuregcm.workers.CertificateCommand;
import org.whispersystems.textsecuregcm.workers.CheckDynamicConfigurationCommand; import org.whispersystems.textsecuregcm.workers.CheckDynamicConfigurationCommand;
import org.whispersystems.textsecuregcm.workers.DeleteUserCommand; import org.whispersystems.textsecuregcm.workers.DeleteUserCommand;
import org.whispersystems.textsecuregcm.workers.IdleDeviceNotificationSchedulerFactory; import org.whispersystems.textsecuregcm.workers.IdleDeviceNotificationSchedulerFactory;
import org.whispersystems.textsecuregcm.workers.IssuedReceiptMigrationCommand;
import org.whispersystems.textsecuregcm.workers.MessagePersisterServiceCommand; import org.whispersystems.textsecuregcm.workers.MessagePersisterServiceCommand;
import org.whispersystems.textsecuregcm.workers.NotifyIdleDevicesCommand; import org.whispersystems.textsecuregcm.workers.NotifyIdleDevicesCommand;
import org.whispersystems.textsecuregcm.workers.ProcessScheduledJobsServiceCommand; import org.whispersystems.textsecuregcm.workers.ProcessScheduledJobsServiceCommand;
@ -332,6 +333,7 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
bootstrap.addCommand(new BackupMetricsCommand(Clock.systemUTC())); bootstrap.addCommand(new BackupMetricsCommand(Clock.systemUTC()));
bootstrap.addCommand(new RemoveExpiredLinkedDevicesCommand()); bootstrap.addCommand(new RemoveExpiredLinkedDevicesCommand());
bootstrap.addCommand(new NotifyIdleDevicesCommand()); bootstrap.addCommand(new NotifyIdleDevicesCommand());
bootstrap.addCommand(new IssuedReceiptMigrationCommand());
bootstrap.addCommand(new ProcessScheduledJobsServiceCommand("process-idle-device-notification-jobs", bootstrap.addCommand(new ProcessScheduledJobsServiceCommand("process-idle-device-notification-jobs",
"Processes scheduled jobs to send notifications to idle devices", "Processes scheduled jobs to send notifications to idle devices",
new IdleDeviceNotificationSchedulerFactory())); new IdleDeviceNotificationSchedulerFactory()));

5
service/src/main/java/org/whispersystems/textsecuregcm/workers/IssuedReceiptMigrationCommand.java
View File

@ -41,15 +41,12 @@ public class IssuedReceiptMigrationCommand extends AbstractCommandWithDependenci
private static final String MIGRATED_ISSUED_RECEIPTS = MetricsUtil.name(IssuedReceiptMigrationCommand.class, private static final String MIGRATED_ISSUED_RECEIPTS = MetricsUtil.name(IssuedReceiptMigrationCommand.class,
"migratedIssuedReceipts"); "migratedIssuedReceipts");
private final Clock clock; public IssuedReceiptMigrationCommand() {
public IssuedReceiptMigrationCommand(final Clock clock) {
super(new Application<>() { super(new Application<>() {
@Override @Override
public void run(final WhisperServerConfiguration configuration, final Environment environment) { public void run(final WhisperServerConfiguration configuration, final Environment environment) {
} }
}, "migrate-issued-receipts", "Migrates columns in the issued receipts table"); }, "migrate-issued-receipts", "Migrates columns in the issued receipts table");
this.clock = clock;
} }
@Override @Override