mirror of
https://github.com/hanzo-fi/stack.git
synced 2026-10-30 20:34:43 +00:00
42 lines
1.1 KiB
Go
42 lines
1.1 KiB
Go
package workflow
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/formancehq/go-libs/bun/bundebug"
|
|
"github.com/uptrace/bun"
|
|
|
|
"github.com/formancehq/go-libs/bun/bunconnect"
|
|
"github.com/formancehq/go-libs/logging"
|
|
"github.com/formancehq/go-libs/publish"
|
|
"github.com/stretchr/testify/require"
|
|
"go.temporal.io/sdk/testsuite"
|
|
)
|
|
|
|
func TestActivities(t *testing.T) {
|
|
|
|
hooks := make([]bun.QueryHook, 0)
|
|
if testing.Verbose() {
|
|
hooks = append(hooks, bundebug.NewQueryHook())
|
|
}
|
|
|
|
database := srv.NewDatabase(t)
|
|
db, err := bunconnect.OpenSQLDB(logging.TestingContext(), bunconnect.ConnectionOptions{
|
|
DatabaseSourceName: database.ConnString(),
|
|
}, hooks...)
|
|
require.NoError(t, err)
|
|
t.Cleanup(func() {
|
|
_ = db.Close()
|
|
})
|
|
|
|
publisher := publish.InMemory()
|
|
activities := NewActivities(publisher, db)
|
|
|
|
testSuite := &testsuite.WorkflowTestSuite{}
|
|
env := testSuite.NewTestActivityEnvironment()
|
|
env.RegisterActivity(activities.SendWorkflowTerminationEvent)
|
|
_, err = env.ExecuteActivity(SendWorkflowTerminationEventActivity, NewInstance("vvv", "xxx"))
|
|
require.NoError(t, err)
|
|
require.NotEmpty(t, publisher.AllMessages())
|
|
}
|