use omitempty for start workflow input (#370)

service/api/service.go

@@ -109,8 +109,8 @@ func (s *serviceImpl) ApiV1WorkflowStartPost(
 		IwfWorkflowType:                    req.GetIwfWorkflowType(),
 		IwfWorkerUrl:                       req.GetIwfWorkerUrl(),
 		StartStateId:                       req.StartStateId,
-		StateInput:                         req.GetStateInput(),
-		StateOptions:                       req.GetStateOptions(),
+		StateInput:                         req.StateInput,
+		StateOptions:                       req.StateOptions,
 		InitSearchAttributes:               initCustomSAs,
 		Config:                             workflowConfig,
 		UseMemoForDataAttributes:           useMemo,

service/interfaces.go

@@ -1,8 +1,6 @@
 package service
 
 import (
-	"time"
-
 	"github.com/indeedeng/iwf/gen/iwfidl"
 )
 
@@ -16,23 +14,21 @@ type (
 
 		WaitForCompletionStateExecutionIds []string `json:"waitForCompletionStateExecutionIds,omitempty"`
 
-		StateInput iwfidl.EncodedObject `json:"stateInput,omitempty"`
+		StateInput *iwfidl.EncodedObject `json:"stateInput,omitempty"`
 
-		StateOptions iwfidl.WorkflowStateOptions `json:"stateOptions,omitempty"`
+		StateOptions *iwfidl.WorkflowStateOptions `json:"stateOptions,omitempty"`
 
 		InitSearchAttributes []iwfidl.SearchAttribute `json:"initSearchAttributes,omitempty"`
 
-		UseMemoForDataAttributes bool `json:"useMemoForDataAttributes"`
+		UseMemoForDataAttributes bool `json:"useMemoForDataAttributes,omitempty"`
 
 		Config iwfidl.WorkflowConfig `json:"config,omitempty"`
 
 		// IsResumeFromContinueAsNew indicate this is input for continueAsNew
 		// when true, will ignore StartStateId, StateInput, StateOptions, InitSearchAttributes
-		IsResumeFromContinueAsNew bool `json:"isResumeFromContinueAsNew"`
-
-		ContinueAsNewInput ContinueAsNewInput `json:"continueAsNewInput"`
+		IsResumeFromContinueAsNew bool `json:"isResumeFromContinueAsNew,omitempty"`
 
-		WorkflowExecutionTimeout time.Duration
+		ContinueAsNewInput *ContinueAsNewInput `json:"continueAsNewInput,omitempty"`
 	}
 
 	ContinueAsNewInput struct {
@@ -178,7 +174,9 @@ const (
 // ValidateTimerSkipRequest validates if the skip timer request is valid
 // return true if it's valid, along with the timer pointer
 // use timerIdx if timerId is not empty
-func ValidateTimerSkipRequest(stateExeTimerInfos map[string][]*TimerInfo, stateExeId, timerId string, timerIdx int) (*TimerInfo, bool) {
+func ValidateTimerSkipRequest(
+	stateExeTimerInfos map[string][]*TimerInfo, stateExeId, timerId string, timerIdx int,
+) (*TimerInfo, bool) {
 	timerInfos := stateExeTimerInfos[stateExeId]
 	if len(timerInfos) == 0 {
 		return nil, false

service/interpreter/workflowImpl.go

@@ -110,8 +110,8 @@ func InterpreterImpl(
 		if input.StartStateId != nil {
 			startingState := iwfidl.StateMovement{
 				StateId:      *input.StartStateId,
-				StateOptions: &input.StateOptions,
-				StateInput:   &input.StateInput,
+				StateOptions: input.StateOptions,
+				StateInput:   input.StateInput,
 			}
 			stateRequestQueue.AddStateStartRequests([]iwfidl.StateMovement{startingState})
 		}
@@ -302,9 +302,13 @@ func InterpreterImpl(
 			// last update config, do it here because we use input to carry over config, not continueAsNewer query
 			input.Config = workflowConfiger.Get() // update config to the lastest before continueAsNew to carry over
 			input.IsResumeFromContinueAsNew = true
-			input.ContinueAsNewInput = service.ContinueAsNewInput{
+			input.ContinueAsNewInput = &service.ContinueAsNewInput{
 				PreviousInternalRunId: provider.GetWorkflowInfo(ctx).WorkflowExecution.RunID,
 			}
+			// nix the unused data
+			input.StateInput = nil
+			input.StateOptions = nil
+			input.StartStateId = nil
 			return nil, provider.NewInterpreterContinueAsNewError(ctx, input)
 		}
 	} // end main loop