Enable e2e tests for all 3 backens

Author: cschleiden

backend/mysql/mysql_test.go

@@ -55,3 +55,42 @@ func Test_MysqlBackend(t *testing.T) {
 		}
 	})
 }
+
+func TestMySqlBackendE2E(t *testing.T) {
+	if testing.Short() {
+		t.Skip()
+	}
+
+	var dbName string
+
+	test.EndToEndBackendTest(t, func() backend.Backend {
+		db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@/?parseTime=true&interpolateParams=true", testUser, testPassword))
+		if err != nil {
+			panic(err)
+		}
+
+		dbName = "test_" + strings.Replace(uuid.NewString(), "-", "", -1)
+		if _, err := db.Exec("CREATE DATABASE " + dbName); err != nil {
+			panic(fmt.Errorf("creating database: %w", err))
+		}
+
+		if err := db.Close(); err != nil {
+			panic(err)
+		}
+
+		return NewMysqlBackend("localhost", 3306, testUser, testPassword, dbName, backend.WithStickyTimeout(0))
+	}, func(b backend.Backend) {
+		db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@/?parseTime=true&interpolateParams=true", testUser, testPassword))
+		if err != nil {
+			panic(err)
+		}
+
+		if _, err := db.Exec("DROP DATABASE IF EXISTS " + dbName); err != nil {
+			panic(fmt.Errorf("dropping database: %w", err))
+		}
+
+		if err := db.Close(); err != nil {
+			panic(err)
+		}
+	})
+}

backend/redis/redis_test.go

@@ -8,35 +8,46 @@ import (
 	"github.com/cschleiden/go-workflows/backend"
 	"github.com/cschleiden/go-workflows/backend/test"
 	"github.com/go-redis/redis/v8"
-	"github.com/stretchr/testify/require"
 )
 
 func Test_RedisBackend(t *testing.T) {
 	if testing.Short() {
 		t.Skip()
 	}
 
-	test.BackendTest(t, func() backend.Backend {
-		address := "localhost:6379"
-		user := ""
-		password := "RedisPassw0rd"
-
-		// Flush database
-		client := redis.NewUniversalClient(&redis.UniversalOptions{
-			Addrs:    []string{address},
-			Username: user,
-			Password: password,
-			DB:       0,
-		})
-
-		if err := client.FlushDB(context.Background()).Err(); err != nil {
-			panic(err)
-		}
-
-		// Disable sticky workflow behavior for the test execution
-		b, err := NewRedisBackend(address, user, password, 0, WithBlockTimeout(time.Millisecond*2))
-		require.NoError(t, err)
-
-		return b
-	}, nil)
+	test.BackendTest(t, createBackend, nil)
+}
+
+func Test_EndToEndRedisBackend(t *testing.T) {
+	if testing.Short() {
+		t.Skip()
+	}
+
+	test.EndToEndBackendTest(t, createBackend, nil)
+}
+
+func createBackend() backend.Backend {
+	address := "localhost:6379"
+	user := ""
+	password := "RedisPassw0rd"
+
+	// Flush database
+	client := redis.NewUniversalClient(&redis.UniversalOptions{
+		Addrs:    []string{address},
+		Username: user,
+		Password: password,
+		DB:       0,
+	})
+
+	if err := client.FlushDB(context.Background()).Err(); err != nil {
+		panic(err)
+	}
+
+	// Disable sticky workflow behavior for the test execution
+	b, err := NewRedisBackend(address, user, password, 0, WithBlockTimeout(time.Millisecond*2))
+	if err != nil {
+		panic(err)
+	}
+
+	return b
 }

backend/test/e2e.go

@@ -44,8 +44,8 @@ func EndToEndBackendTest(t *testing.T, setup func() backend.Backend, teardown fu
 
 				output, err := runWorkflowWithResult[string](t, ctx, c, wf, "hello")
 
-				require.Nil(t, output)
-				require.Error(t, err)
+				require.Zero(t, output)
+				require.ErrorContains(t, err, "workflow 1 not found")
 			},
 		},
 		{
@@ -55,7 +55,7 @@ func EndToEndBackendTest(t *testing.T, setup func() backend.Backend, teardown fu
 				wf := func(ctx workflow.Context) (int, error) {
 					return workflow.ExecuteActivity[int](ctx, workflow.DefaultActivityOptions, a).Get(ctx)
 				}
-				register(t, ctx, w, nil, []interface{}{wf})
+				register(t, ctx, w, []interface{}{wf}, nil)
 
 				output, err := runWorkflowWithResult[int](t, ctx, c, wf)