refactor(core): validate wf config (#117)

* refactor(core): validate wf config
Co-authored-by: Njjwygjj <wangyaoguang@cel.la>

example/receiver/workflow.yaml

+name: Service
+host: localhost
+port: 9998
+sinks:
+  - name: db
+    host: localhost
+    port: 4242
\ No newline at end of file

example/sender/workflow.yaml

+name: Service
+host: localhost
+port: 9999
+sinks:
+  - name: receiver
+    host: localhost
+    port: 9998
\ No newline at end of file

go.sum

@@ -275,6 +275,7 @@ github.com/stretchr/testify v1.4.0 h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJy
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/subosito/gotenv v1.2.0/go.mod h1:N0PQaV/YGNqwC0u51sEeR/aUtSLEXKX9iv69rRypqCw=
 github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07/go.mod h1:kDXzergiv9cbyO7IOYJZWg1U88JhDg3PB6klq9Hg2pA=

internal/cmd/wf/utils.go

@@ -46,35 +46,10 @@ func validateConfig(wfConf *conf.WorkflowConfig) error {
 		return errors.New("conf is nil")
 	}
 
-	m := map[string][]conf.App{
-		"Flows": wfConf.Flows,
-		"Sinks": wfConf.Sinks,
-	}
-
-	missingApps := []string{}
-	missingParams := []string{}
-	for k, apps := range m {
-		if len(apps) == 0 {
-			missingApps = append(missingApps, k)
-		} else {
-			for _, app := range apps {
-				if app.Name == "" || app.Host == "" || app.Port <= 0 {
-					missingParams = append(missingParams, k)
-				}
-			}
-		}
-	}
-
 	errMsg := ""
 	if wfConf.Name == "" || wfConf.Host == "" || wfConf.Port <= 0 {
 		errMsg = "Missing name, host or port in workflow config. "
 	}
-	if len(missingApps) > 0 {
-		errMsg += "Missing apps in " + strings.Join(missingApps, ", "+". ")
-	}
-	if len(missingApps) > 0 {
-		errMsg += "Missing name, host or port in " + strings.Join(missingApps, ", "+". ")
-	}
 
 	if errMsg != "" {
 		return errors.New(errMsg)