IWF-158: Keeping compatibility for NewTimerCommand(firingTime)

integ/signal_workflow_state2.go

@@ -27,7 +27,7 @@ func (b signalWorkflowState2) WaitUntil(ctx iwf.WorkflowContext, input iwf.Objec
 		},
 		iwf.NewSignalCommand(signalCommandId, testChannelName1),
 		iwf.NewSignalCommand(signalCommandId, testChannelName2),
-		iwf.NewTimerCommand(timerCommandId, int64(time.Duration(24)*time.Hour/time.Second)),
+		iwf.NewTimerCommandByDuration(timerCommandId, 24*time.Hour),
 	), nil
 }
 

integ/timer_workflow_state1.go

@@ -2,6 +2,7 @@ package integ
 
 import (
 	"github.com/indeedeng/iwf-golang-sdk/iwf"
+	"time"
 )
 
 type timerWorkflowState1 struct {
@@ -10,10 +11,10 @@ type timerWorkflowState1 struct {
 }
 
 func (b timerWorkflowState1) WaitUntil(ctx iwf.WorkflowContext, input iwf.Object, persistence iwf.Persistence, communication iwf.Communication) (*iwf.CommandRequest, error) {
-	var i int64
+	var i int
 	input.Get(&i)
 	return iwf.AllCommandsCompletedRequest(
-		iwf.NewTimerCommand("", i),
+		iwf.NewTimerCommandByDuration("", time.Duration(i)*time.Second),
 	), nil
 }
 

iwf/command.go

@@ -1,5 +1,7 @@
 package iwf
 
+import "time"
+
 type (
 	CommandType string
 
@@ -50,7 +52,12 @@ func NewInternalChannelCommand(commandId, channelName string) Command {
 	}
 }
 
-func NewTimerCommand(commandId string, durationSeconds int64) Command {
+func NewTimerCommand(commandId string, firingTime time.Time) Command {
+	durationSeconds := int64(firingTime.Sub(time.Now()).Seconds())
+	if durationSeconds < 0 {
+		panic("Firing time is set in the past")
+	}
+
 	return Command{
 		CommandId:   commandId,
 		CommandType: CommandTypeTimer,
@@ -59,3 +66,13 @@ func NewTimerCommand(commandId string, durationSeconds int64) Command {
 		},
 	}
 }
+
+func NewTimerCommandByDuration(commandId string, durationSeconds time.Duration) Command {
+	return Command{
+		CommandId:   commandId,
+		CommandType: CommandTypeTimer,
+		TimerCommand: &TimerCommand{
+			DurationSeconds: int64(durationSeconds.Seconds()),
+		},
+	}
+}