Use relative time(duration) for timer instead of absolute (firingUnix…

…TimestampSeconds)
indeedeng · May 20, 2024 · e64909d · e64909d
1 parent f11512a
commit e64909d
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 int getDurationSeconds();
 
     public static TimerCommand createByDuration(String commandId, Duration duration) {
         return ImmutableTimerCommand.builder()
                 .commandId(commandId)
-                .firingUnixTimestampSeconds((int) (System.currentTimeMillis() / 1000 + duration.getSeconds()))
+                .durationSeconds((int) duration.getSeconds())
                 .build();
     }
 
     public static TimerCommand createByDuration(Duration duration) {
         return ImmutableTimerCommand.builder()
-                .firingUnixTimestampSeconds((int) (System.currentTimeMillis() / 1000 + duration.getSeconds()))
+                .durationSeconds((int) 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());
         }