Validate the refs exists

hack/deepcopy-gen.sh

@@ -44,5 +44,6 @@ if [ "${GENS}" = "all" ] || grep -qw "deepcopy" <<<"${GENS}"; then
   "${GOPATH}/bin/deepcopy-gen" -v 1 \
       --input-dirs ./model -O zz_generated.deepcopy \
       --go-header-file "${SCRIPT_ROOT}/hack/boilerplate.txt" \
+      --output-base ./
       "$@"
 fi

model/action.go

@@ -14,6 +14,8 @@
 
 package model
 
+import "github.com/serverlessworkflow/sdk-go/v2/util"
+
 // Action specify invocations of services or other workflows during workflow execution.
 type Action struct {
 	// Defines Unique action identifier.
@@ -61,7 +63,7 @@ type actionUnmarshal Action
 // UnmarshalJSON implements json.Unmarshaler
 func (a *Action) UnmarshalJSON(data []byte) error {
 	a.ApplyDefault()
-	return unmarshalObject("action", data, (*actionUnmarshal)(a))
+	return util.UnmarshalObject("action", data, (*actionUnmarshal)(a))
 }
 
 // ApplyDefault set the default values for Action
@@ -93,7 +95,7 @@ type functionRefUnmarshal FunctionRef
 // UnmarshalJSON implements json.Unmarshaler
 func (f *FunctionRef) UnmarshalJSON(data []byte) error {
 	f.ApplyDefault()
-	return unmarshalPrimitiveOrObject("functionRef", data, &f.RefName, (*functionRefUnmarshal)(f))
+	return util.UnmarshalPrimitiveOrObject("functionRef", data, &f.RefName, (*functionRefUnmarshal)(f))
 }
 
 // ApplyDefault set the default values for Function Ref
@@ -117,5 +119,5 @@ type sleepUnmarshal Sleep
 
 // UnmarshalJSON implements json.Unmarshaler
 func (s *Sleep) UnmarshalJSON(data []byte) error {
-	return unmarshalObject("sleep", data, (*sleepUnmarshal)(s))
+	return util.UnmarshalObject("sleep", data, (*sleepUnmarshal)(s))
 }

model/action_data_filter.go

@@ -14,6 +14,8 @@
 
 package model
 
+import "github.com/serverlessworkflow/sdk-go/v2/util"
+
 // ActionDataFilter used to filter action data results.
 // +optional
 // +optional
@@ -40,7 +42,7 @@ type actionDataFilterUnmarshal ActionDataFilter
 // UnmarshalJSON implements json.Unmarshaler
 func (a *ActionDataFilter) UnmarshalJSON(data []byte) error {
 	a.ApplyDefault()
-	return unmarshalObject("actionDataFilter", data, (*actionDataFilterUnmarshal)(a))
+	return util.UnmarshalObject("actionDataFilter", data, (*actionDataFilterUnmarshal)(a))
 }
 
 // ApplyDefault set the default values for Action Data Filter

model/action_data_filter_validator_test.go

@@ -0,0 +1,22 @@
+// Copyright 2022 The Serverless Workflow Specification Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package model
+
+import "testing"
+
+func TestActionDataFilterStructLevelValidation(t *testing.T) {
+	testCases := []ValidationCase{}
+	StructLevelValidationCtx(t, testCases)
+}

model/action_test.go

@@ -19,81 +19,8 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
-
-	val "github.com/serverlessworkflow/sdk-go/v2/validator"
 )
 
-func TestSleepValidate(t *testing.T) {
-	type testCase struct {
-		desp  string
-		sleep Sleep
-		err   string
-	}
-	testCases := []testCase{
-		{
-			desp: "all field empty",
-			sleep: Sleep{
-				Before: "",
-				After:  "",
-			},
-			err: ``,
-		},
-		{
-			desp: "only before field",
-			sleep: Sleep{
-				Before: "PT5M",
-				After:  "",
-			},
-			err: ``,
-		},
-		{
-			desp: "only after field",
-			sleep: Sleep{
-				Before: "",
-				After:  "PT5M",
-			},
-			err: ``,
-		},
-		{
-			desp: "all field",
-			sleep: Sleep{
-				Before: "PT5M",
-				After:  "PT5M",
-			},
-			err: ``,
-		},
-		{
-			desp: "invalid before value",
-			sleep: Sleep{
-				Before: "T5M",
-				After:  "PT5M",
-			},
-			err: `Key: 'Sleep.Before' Error:Field validation for 'Before' failed on the 'iso8601duration' tag`,
-		},
-		{
-			desp: "invalid after value",
-			sleep: Sleep{
-				Before: "PT5M",
-				After:  "T5M",
-			},
-			err: `Key: 'Sleep.After' Error:Field validation for 'After' failed on the 'iso8601duration' tag`,
-		},
-	}
-	for _, tc := range testCases {
-		t.Run(tc.desp, func(t *testing.T) {
-			err := val.GetValidator().Struct(tc.sleep)
-
-			if tc.err != "" {
-				assert.Error(t, err)
-				assert.Regexp(t, tc.err, err)
-				return
-			}
-
-			assert.NoError(t, err)
-		})
-	}
-}
-
 func TestFunctionRefUnmarshalJSON(t *testing.T) {
 	type testCase struct {
 		desp   string

model/action_validator.go

@@ -0,0 +1,58 @@
+// Copyright 2022 The Serverless Workflow Specification Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package model
+
+import (
+	validator "github.com/go-playground/validator/v10"
+
+	val "github.com/serverlessworkflow/sdk-go/v2/validator"
+)
+
+func init() {
+	val.GetValidator().RegisterStructValidationCtx(ValidationWrap(actionStructLevelValidationCtx), Action{})
+	val.GetValidator().RegisterStructValidationCtx(ValidationWrap(functionRefStructLevelValidation), FunctionRef{})
+}
+
+func actionStructLevelValidationCtx(ctx ValidatorContext, structLevel validator.StructLevel) {
+	action := structLevel.Current().Interface().(Action)
+
+	if action.FunctionRef == nil && action.EventRef == nil && action.SubFlowRef == nil {
+		structLevel.ReportError(action.FunctionRef, "FunctionRef", "FunctionRef", "required_without", "")
+		return
+	}
+
+	values := []bool{
+		action.FunctionRef != nil,
+		action.EventRef != nil,
+		action.SubFlowRef != nil,
+	}
+
+	if validationNotExclusiveParamters(values) {
+		structLevel.ReportError(action.FunctionRef, "FunctionRef", "FunctionRef", val.TagExclusive, "")
+		structLevel.ReportError(action.EventRef, "EventRef", "EventRef", val.TagExclusive, "")
+		structLevel.ReportError(action.SubFlowRef, "SubFlowRef", "SubFlowRef", val.TagExclusive, "")
+	}
+
+	if action.RetryRef != "" && !ctx.ExistRetry(action.RetryRef) {
+		structLevel.ReportError(action.RetryRef, "RetryRef", "RetryRef", val.TagExists, "")
+	}
+}
+
+func functionRefStructLevelValidation(ctx ValidatorContext, structLevel validator.StructLevel) {
+	functionRef := structLevel.Current().Interface().(FunctionRef)
+	if !ctx.ExistFunction(functionRef.RefName) {
+		structLevel.ReportError(functionRef.RefName, "RefName", "RefName", val.TagExists, functionRef.RefName)
+	}
+}