summaryrefslogtreecommitdiff
path: root/tests/plugins/temporal/hp_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/plugins/temporal/hp_test.go')
-rw-r--r--tests/plugins/temporal/hp_test.go408
1 files changed, 0 insertions, 408 deletions
diff --git a/tests/plugins/temporal/hp_test.go b/tests/plugins/temporal/hp_test.go
deleted file mode 100644
index bceac025..00000000
--- a/tests/plugins/temporal/hp_test.go
+++ /dev/null
@@ -1,408 +0,0 @@
-package tests
-
-import (
- "context"
- "crypto/rand"
- "crypto/sha512"
- "fmt"
- "testing"
- "time"
-
- "go.temporal.io/api/common/v1"
-
- "github.com/fatih/color"
- "github.com/stretchr/testify/assert"
- "go.temporal.io/api/enums/v1"
- "go.temporal.io/api/history/v1"
- "go.temporal.io/sdk/client"
-)
-
-func init() {
- color.NoColor = false
-}
-
-func Test_VerifyRegistration(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- assert.Contains(t, s.workflows.WorkflowNames(), "SimpleWorkflow")
-
- assert.Contains(t, s.activities.ActivityNames(), "SimpleActivity.echo")
- assert.Contains(t, s.activities.ActivityNames(), "HeartBeatActivity.doSomething")
-
- assert.Contains(t, s.activities.ActivityNames(), "SimpleActivity.lower")
-}
-
-func Test_ExecuteSimpleWorkflow_1(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SimpleWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "HELLO WORLD", result)
-}
-
-type User struct {
- Name string
- Email string
-}
-
-func Test_ExecuteSimpleDTOWorkflow(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SimpleDTOWorkflow",
- User{
- Name: "Antony",
- Email: "[email protected]",
- },
- )
- assert.NoError(t, err)
-
- var result struct{ Message string }
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "Hello Antony <[email protected]>", result.Message)
-}
-
-func Test_ExecuteSimpleWorkflowWithSequenceInBatch(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "WorkflowWithSequence",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "OK", result)
-}
-
-func Test_MultipleWorkflowsInSingleWorker(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SimpleWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- w2, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "TimerWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "HELLO WORLD", result)
-
- assert.NoError(t, w2.Get(context.Background(), &result))
- assert.Equal(t, "hello world", result)
-}
-
-func Test_ExecuteWorkflowWithParallelScopes(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "ParallelScopesWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "HELLO WORLD|Hello World|hello world", result)
-}
-
-func Test_Timer(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- start := time.Now()
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "TimerWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "hello world", result)
- assert.True(t, time.Since(start).Seconds() > 1)
-
- s.AssertContainsEvent(t, w, func(event *history.HistoryEvent) bool {
- return event.EventType == enums.EVENT_TYPE_TIMER_STARTED
- })
-}
-
-func Test_SideEffect(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SideEffectWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Contains(t, result, "hello world-")
-
- s.AssertContainsEvent(t, w, func(event *history.HistoryEvent) bool {
- return event.EventType == enums.EVENT_TYPE_MARKER_RECORDED
- })
-}
-
-func Test_EmptyWorkflow(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "EmptyWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result int
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, 42, result)
-}
-
-func Test_PromiseChaining(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "ChainedWorkflow",
- "Hello World",
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "result:hello world", result)
-}
-
-func Test_ActivityHeartbeat(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SimpleHeartbeatWorkflow",
- 2,
- )
- assert.NoError(t, err)
-
- time.Sleep(time.Second)
-
- we, err := s.Client().DescribeWorkflowExecution(context.Background(), w.GetID(), w.GetRunID())
- assert.NoError(t, err)
- assert.Len(t, we.PendingActivities, 1)
-
- act := we.PendingActivities[0]
-
- assert.Equal(t, `{"value":2}`, string(act.HeartbeatDetails.Payloads[0].Data))
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "OK", result)
-}
-
-func Test_FailedActivityHeartbeat(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "FailedHeartbeatWorkflow",
- 8,
- )
- assert.NoError(t, err)
-
- time.Sleep(time.Second)
-
- we, err := s.Client().DescribeWorkflowExecution(context.Background(), w.GetID(), w.GetRunID())
- assert.NoError(t, err)
- assert.Len(t, we.PendingActivities, 1)
-
- act := we.PendingActivities[0]
-
- assert.Equal(t, `{"value":8}`, string(act.HeartbeatDetails.Payloads[0].Data))
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "OK!", result)
-}
-
-func Test_BinaryPayload(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- rnd := make([]byte, 2500)
-
- _, err := rand.Read(rnd)
- assert.NoError(t, err)
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "BinaryWorkflow",
- rnd,
- )
- assert.NoError(t, err)
-
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
-
- assert.Equal(t, fmt.Sprintf("%x", sha512.Sum512(rnd)), result)
-}
-
-func Test_ContinueAsNew(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "ContinuableWorkflow",
- 1,
- )
- assert.NoError(t, err)
-
- time.Sleep(time.Second)
-
- we, err := s.Client().DescribeWorkflowExecution(context.Background(), w.GetID(), w.GetRunID())
- assert.NoError(t, err)
-
- assert.Equal(t, "ContinuedAsNew", we.WorkflowExecutionInfo.Status.String())
-
- time.Sleep(time.Second)
-
- // the result of the final workflow
- var result string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "OK6", result)
-}
-
-func Test_ActivityStubWorkflow(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "ActivityStubWorkflow",
- "hello world",
- )
- assert.NoError(t, err)
-
- // the result of the final workflow
- var result []string
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, []string{
- "HELLO WORLD",
- "invalid method call",
- "UNTYPED",
- }, result)
-}
-
-func Test_ExecuteProtoWorkflow(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "ProtoPayloadWorkflow",
- )
- assert.NoError(t, err)
-
- var result common.WorkflowExecution
- assert.NoError(t, w.Get(context.Background(), &result))
- assert.Equal(t, "updated", result.RunId)
- assert.Equal(t, "workflow id", result.WorkflowId)
-}
-
-func Test_SagaWorkflow(t *testing.T) {
- s := NewTestServer()
- defer s.MustClose()
-
- w, err := s.Client().ExecuteWorkflow(
- context.Background(),
- client.StartWorkflowOptions{
- TaskQueue: "default",
- },
- "SagaWorkflow",
- )
- assert.NoError(t, err)
-
- var result string
- assert.Error(t, w.Get(context.Background(), &result))
-}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-24 18:40:08 +0000