Skip to content

Commit

Permalink
check cr service is started
Browse files Browse the repository at this point in the history
  • Loading branch information
@Farber98
Farber98 committed Aug 14, 2024
1 parent f2bf9fa commit 352adfe
Showing 1 changed file with 41 additions and 0 deletions.
41 changes: 41 additions & 0 deletions pkg/types/interfacetests/chain_reader_interface_tests.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@ const (
AnySecondContractName = "Not" + AnyContractName
)

var ErrServiceNotStarted = errors.New("service not started")
var AnySliceToReadWithoutAnArgument = []uint64{3, 4}

const AnyExtraValue = 3
Expand All @@ -70,6 +71,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
tester.SetTestStructLatestValue(t, &secondItem)

cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

actual := &TestStruct{}
Expand All @@ -88,6 +91,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

var prim uint64
Expand All @@ -101,6 +106,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

var returnVal1 uint64
Expand Down Expand Up @@ -140,6 +147,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
bindings := tester.GetBindings(t)
seenAddrs := map[string]bool{}
for _, binding := range bindings {
Expand All @@ -160,6 +169,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

var slice []uint64
Expand All @@ -176,6 +187,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
testStruct.BigField = nil
testStruct.Account = nil
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

actual := &TestStructWithExtraField{}
Expand All @@ -194,6 +207,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
ts := CreateTestStruct[T](0, tester)
tester.TriggerEvent(t, &ts)
Expand All @@ -212,6 +227,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
ts1 := CreateTestStruct[T](2, tester)
tester.TriggerEvent(t, &ts1)
Expand Down Expand Up @@ -242,6 +259,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result := &TestStruct{}
Expand All @@ -254,6 +273,8 @@ func runChainReaderGetLatestValueInterfaceTests[T TestingT[T]](t T, tester Chain
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
ts0 := CreateTestStruct(0, tester)
tester.TriggerEvent(t, &ts0)
Expand Down Expand Up @@ -296,6 +317,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))

require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
Expand All @@ -318,6 +341,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValuesRequest)
Expand All @@ -340,6 +365,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValuesRequest)
Expand All @@ -366,6 +393,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
require.NoError(t, err)
Expand All @@ -390,6 +419,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
require.NoError(t, err)
Expand Down Expand Up @@ -422,6 +453,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
Expand Down Expand Up @@ -454,6 +487,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
Expand Down Expand Up @@ -485,6 +520,8 @@ func runChainReaderBatchGetLatestValuesInterfaceTests[T TestingT[T]](t T, tester

ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

result, err := cr.BatchGetLatestValues(ctx, batchGetLatestValueRequest)
Expand Down Expand Up @@ -515,6 +552,8 @@ func runQueryKeyInterfaceTests[T TestingT[T]](t T, tester ChainReaderInterfaceTe
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))

require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))

Expand All @@ -529,6 +568,8 @@ func runQueryKeyInterfaceTests[T TestingT[T]](t T, tester ChainReaderInterfaceTe
test: func(t T) {
ctx := tests.Context(t)
cr := tester.GetChainReader(t)
require.Error(t, ErrServiceNotStarted)
require.NoError(t, cr.Start(ctx))
require.NoError(t, cr.Bind(ctx, tester.GetBindings(t)))
ts1 := CreateTestStruct[T](0, tester)
tester.TriggerEvent(t, &ts1)
Expand Down

0 comments on commit 352adfe

Please sign in to comment.