Replace firingUnixTimestamp with durationSeconds in TimerCommand (#229)

indeedeng · Jul 22, 2024 · 5fdc22e · 5fdc22e
1 parent 1f9f8be
commit 5fdc22e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/iwf-idl b/iwf-idl
diff --git a/src/main/java/io/iworkflow/core/command/TimerCommand.java b/src/main/java/io/iworkflow/core/command/TimerCommand.java
@@ -7,18 +7,18 @@
 @Value.Immutable
 public abstract class TimerCommand implements BaseCommand {
 
-    public abstract int getFiringUnixTimestampSeconds();
+    public abstract long getDurationSeconds();
 
     public static TimerCommand createByDuration(String commandId, Duration duration) {
         return ImmutableTimerCommand.builder()
                 .commandId(commandId)
-                .firingUnixTimestampSeconds((int) (System.currentTimeMillis() / 1000 + duration.getSeconds()))
+                .durationSeconds(duration.getSeconds())
                 .build();
     }
 
     public static TimerCommand createByDuration(Duration duration) {
         return ImmutableTimerCommand.builder()
-                .firingUnixTimestampSeconds((int) (System.currentTimeMillis() / 1000 + duration.getSeconds()))
+                .durationSeconds(duration.getSeconds())
                 .build();
     }
 }
diff --git a/src/main/java/io/iworkflow/core/mapper/TimerCommandMapper.java b/src/main/java/io/iworkflow/core/mapper/TimerCommandMapper.java
@@ -5,7 +5,7 @@
 public class TimerCommandMapper {
     public static TimerCommand toGenerated(io.iworkflow.core.command.TimerCommand timerCommand) {
         final TimerCommand command = new TimerCommand()
-                .firingUnixTimestampSeconds((long) timerCommand.getFiringUnixTimestampSeconds());
+                .durationSeconds(timerCommand.getDurationSeconds());
         if (timerCommand.getCommandId().isPresent()) {
             command.commandId(timerCommand.getCommandId().get());
         }