mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
## What changed? - Add chasm.Context.ExecutionKey() method - Refactor `context.go` to use better struct names and unexport concepts that should not be exported - Add some docstrings
27 lines
698 B
Go
27 lines
698 B
Go
package chasm
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
persistencespb "go.temporal.io/server/api/persistence/v1"
|
|
)
|
|
|
|
func TestTaskValidator(t *testing.T) {
|
|
ctx := &MockMutableContext{}
|
|
visibility := NewVisibility(ctx)
|
|
task := &persistencespb.ChasmVisibilityTaskData{
|
|
TransitionCount: 3,
|
|
}
|
|
|
|
visibility.Data.TransitionCount = 1
|
|
valid, err := defaultVisibilityTaskHandler.Validate(ctx, visibility, TaskAttributes{}, task)
|
|
require.NoError(t, err)
|
|
require.False(t, valid)
|
|
|
|
visibility.Data.TransitionCount = task.TransitionCount
|
|
valid, err = defaultVisibilityTaskHandler.Validate(ctx, visibility, TaskAttributes{}, task)
|
|
require.NoError(t, err)
|
|
require.True(t, valid)
|
|
}
|