test(go): add skipped test for Test suite run

- we have a deserialization bug on this entity #154

Author: AcevedoR

go/go-sdk/test_go_sdk/api_executions_test.go

@@ -58,17 +58,17 @@ namespace: %s
 description: simple_flow_description
 
 inputs:
-  - id: key
+  - id: inputA
     type: STRING
     defaults: 'default_value'
 
 tasks:
   - id: hello
     type: io.kestra.plugin.core.log.Log
-    message: "Hello World! {{ inputs.key }}🚀"
+    message: "Hello World! {{ inputs.inputA }}🚀"
   - id: return
     type: io.kestra.plugin.core.debug.Return
-    format: "{{ inputs.key }}"
+    format: "{{ inputs.inputA }}"
 outputs:
   - id: flow_output
     type: STRING
@@ -236,7 +236,7 @@ func TestExecutionsAPI_All(t *testing.T) {
 
 		labels := []string{"label1:created"}
 		inputs := map[string]any{
-			"key": "value1",
+			"inputA": "value1",
 		}
 
 		res, _, err := KestraTestApiClient().ExecutionsAPI.
@@ -251,7 +251,7 @@ func TestExecutionsAPI_All(t *testing.T) {
 		require.Equal(t, flowId, res.FlowId)
 		require.Equal(t, openapiclient.Label{Key: "label1", Value: "created", AdditionalProperties: map[string]interface{}{}}, res.Labels[0])
 		require.Equal(t, map[string]any{
-			"key": "value1",
+			"inputA": "value1",
 		}, res.Inputs)
 	})
 
@@ -263,7 +263,7 @@ func TestExecutionsAPI_All(t *testing.T) {
 
 		labels := []string{"label1:created"}
 		inputs := map[string]any{
-			"key": "value1",
+			"inputA": "value1",
 		}
 
 		created, _, err := KestraTestApiClient().ExecutionsAPI.
@@ -276,7 +276,7 @@ func TestExecutionsAPI_All(t *testing.T) {
 		exec, _, err := KestraTestApiClient().ExecutionsAPI.Execution(ctx, created.Id, MAIN_TENANT).Execute()
 		require.NoError(t, err)
 		require.Equal(t, map[string]any{
-			"key": "value1",
+			"inputA": "value1",
 		}, exec.Inputs)
 
 		require.Equal(t, map[string]any{
@@ -664,7 +664,7 @@ func TestExecutionsAPI_All(t *testing.T) {
 
 		// then replay with other inputs
 		inputs := map[string]any{
-			"key": "value1FromReplay",
+			"inputA": "value1FromReplay",
 		}
 		replayingExec, _, err := KestraTestApiClient().ExecutionsAPI.ReplayExecutionWithinputs(ctx, exec.Id, MAIN_TENANT).FormData(inputs).Execute()
 		require.NoError(t, err)

go/go-sdk/test_go_sdk/api_testsuites_test.go

@@ -3,10 +3,11 @@ package main
 import (
 	"context"
 	"fmt"
-	kestra_api_client "github.com/kestra-io/client-sdk/go-sdk"
-	"github.com/stretchr/testify/require"
 	"strings"
 	"testing"
+
+	kestra_api_client "github.com/kestra-io/client-sdk/go-sdk"
+	"github.com/stretchr/testify/require"
 )
 
 func SIMPLE_TEST_SUITE(id string, ns string, flowId string) string {
@@ -313,6 +314,62 @@ func TestTestSuitesAPI_All(t *testing.T) {
 		}
 		require.ElementsMatch(t, []string{testSuiteId4}, foundIds)
 	})
+	t.Run("runTestSuiteTest", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+		testSuiteId := randomId()
+		namespace := randomId()
+		flowId := randomId()
+		ctx := GetAuthContext()
+		testSuiteYaml := SIMPLE_TEST_SUITE(testSuiteId, namespace, flowId)
+		createSimpleFlow(ctx, flowId, namespace)
+		_, _, err := KestraTestApiClient().TestSuitesAPI.CreateTestSuite(ctx, MAIN_TENANT).Body(testSuiteYaml).Execute()
+		require.NoError(t, err)
+
+		res, _, err := KestraTestApiClient().TestSuitesAPI.RunTestSuite(ctx, namespace, testSuiteId, MAIN_TENANT).Execute()
+		require.NoError(t, err)
+
+		require.EqualValues(t, testSuiteId, res.GetTestSuiteId())
+		require.EqualValues(t, kestra_api_client.TESTSTATE_SUCCESS, res.GetState())
+		require.NotEmpty(t, res.GetEndDate())
+	})
+	t.Run("runTestSuiteTest_failed", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+		testSuiteId := randomId()
+		namespace := randomId()
+		flowId := randomId()
+		ctx := GetAuthContext()
+		testSuiteYaml := FAILING_SIMPLE_TEST_SUITE(testSuiteId, namespace, flowId)
+		createSimpleFlow(ctx, flowId, namespace)
+		_, _, err := KestraTestApiClient().TestSuitesAPI.CreateTestSuite(ctx, MAIN_TENANT).Body(testSuiteYaml).Execute()
+		require.NoError(t, err)
+
+		res, _, err := KestraTestApiClient().TestSuitesAPI.RunTestSuite(ctx, namespace, testSuiteId, MAIN_TENANT).Execute()
+		require.NoError(t, err)
+
+		require.EqualValues(t, testSuiteId, res.GetTestSuiteId())
+		require.EqualValues(t, kestra_api_client.TESTSTATE_FAILED, res.GetState())
+		require.Len(t, res.GetResults(), 1)
+		result := res.GetResults()[0]
+		require.EqualValues(t, "test_case_1", result.GetTestId())
+		require.Len(t, result.GetAssertionResults(), 1)
+		assertionResult := result.GetAssertionResults()[0]
+		require.EqualValues(t, "Hi there", assertionResult.GetExpected())
+		require.EqualValues(t, "another value", assertionResult.GetActual())
+		require.EqualValues(t, "equalTo", assertionResult.GetOperator())
+		require.False(t, assertionResult.GetIsSuccess())
+	})
+	t.Run("runTestSuiteByQueryTest", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+	})
+	t.Run("searchTestSuitesResultsTest", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+	})
+	t.Run("getTestResult", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+	})
+	t.Run("getTestsLastResultTest", func(t *testing.T) {
+		t.Skip("need to fix AssertionResult expected and actual deserialization first")
+	})
 }
 func assertTestSuiteExists(t *testing.T, ctx context.Context, namespace string, id string) {
 	_, _, err := KestraTestApiClient().TestSuitesAPI.TestSuite(ctx, namespace, id, MAIN_TENANT).Execute()