Skip to content

Commit

Permalink
update skip method
Browse files Browse the repository at this point in the history
  • Loading branch information
@ettec
ettec committed Dec 12, 2024
1 parent aed83ac commit 68a2962
Showing 1 changed file with 89 additions and 90 deletions.
179 changes: 89 additions & 90 deletions core/capabilities/remote/executable/client_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,120 +28,119 @@ const (
workflowOwnerID = "0xAA"
)

/*
TODO investigate occasional flake - JIRA to track -> https://smartcontract-it.atlassian.net/browse/CAPPL-363
func Test_Client_DonTopologies(t *testing.T) {
testutils.SkipFlakey(t, "https://smartcontract-it.atlassian.net/browse/CAPPL-363")
ctx := testutils.Context(t)

func Test_Client_DonTopologies(t *testing.T) {
ctx := testutils.Context(t)
transmissionSchedule, err := values.NewMap(map[string]any{
"schedule": transmission.Schedule_OneAtATime,
"deltaStage": "10ms",
})
require.NoError(t, err)

transmissionSchedule, err := values.NewMap(map[string]any{
"schedule": transmission.Schedule_OneAtATime,
"deltaStage": "10ms",
})
responseTest := func(t *testing.T, response commoncap.CapabilityResponse, responseError error) {
require.NoError(t, responseError)
mp, err := response.Value.Unwrap()
require.NoError(t, err)
assert.Equal(t, "aValue1", mp.(map[string]any)["response"].(string))
}

responseTest := func(t *testing.T, response commoncap.CapabilityResponse, responseError error) {
require.NoError(t, responseError)
mp, err := response.Value.Unwrap()
require.NoError(t, err)
assert.Equal(t, "aValue1", mp.(map[string]any)["response"].(string))
}
capability := &TestCapability{}
capability := &TestCapability{}

responseTimeOut := 10 * time.Minute
responseTimeOut := 10 * time.Minute

var methods []func(caller commoncap.ExecutableCapability)
var methods []func(caller commoncap.ExecutableCapability)

methods = append(methods, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
methods = append(methods, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})

methods = append(methods, func(caller commoncap.ExecutableCapability) {
registerToWorkflowMethod(ctx, caller, transmissionSchedule, func(t *testing.T, responseError error) {
require.NoError(t, responseError)
}, t)
})
methods = append(methods, func(caller commoncap.ExecutableCapability) {
registerToWorkflowMethod(ctx, caller, transmissionSchedule, func(t *testing.T, responseError error) {
require.NoError(t, responseError)
}, t)
})

methods = append(methods, func(caller commoncap.ExecutableCapability) {
unregisterFromWorkflowMethod(ctx, caller, transmissionSchedule, func(t *testing.T, responseError error) {
require.NoError(t, responseError)
}, t)
})
methods = append(methods, func(caller commoncap.ExecutableCapability) {
unregisterFromWorkflowMethod(ctx, caller, transmissionSchedule, func(t *testing.T, responseError error) {
require.NoError(t, responseError)
}, t)
})

for _, method := range methods {
testClient(t, 1, responseTimeOut, 1, 0,
capability, method)
for _, method := range methods {
testClient(t, 1, responseTimeOut, 1, 0,
capability, method)

testClient(t, 10, responseTimeOut, 1, 0,
capability, method)
testClient(t, 10, responseTimeOut, 1, 0,
capability, method)

testClient(t, 1, responseTimeOut, 10, 3,
capability, method)
testClient(t, 1, responseTimeOut, 10, 3,
capability, method)

testClient(t, 10, responseTimeOut, 10, 3,
capability, method)
testClient(t, 10, responseTimeOut, 10, 3,
capability, method)

testClient(t, 10, responseTimeOut, 10, 9,
capability, method)
}
testClient(t, 10, responseTimeOut, 10, 9,
capability, method)
}
}

func Test_Client_TransmissionSchedules(t *testing.T) {
ctx := testutils.Context(t)
func Test_Client_TransmissionSchedules(t *testing.T) {
testutils.SkipFlakey(t, "https://smartcontract-it.atlassian.net/browse/CAPPL-363")
ctx := testutils.Context(t)

responseTest := func(t *testing.T, response commoncap.CapabilityResponse, responseError error) {
require.NoError(t, responseError)
mp, err := response.Value.Unwrap()
require.NoError(t, err)
assert.Equal(t, "aValue1", mp.(map[string]any)["response"].(string))
}
responseTest := func(t *testing.T, response commoncap.CapabilityResponse, responseError error) {
require.NoError(t, responseError)
mp, err := response.Value.Unwrap()
require.NoError(t, err)
assert.Equal(t, "aValue1", mp.(map[string]any)["response"].(string))
}

capability := &TestCapability{}

capability := &TestCapability{}
responseTimeOut := 10 * time.Minute

responseTimeOut := 10 * time.Minute
transmissionSchedule, err := values.NewMap(map[string]any{
"schedule": transmission.Schedule_OneAtATime,
"deltaStage": "10ms",
})
require.NoError(t, err)

transmissionSchedule, err := values.NewMap(map[string]any{
"schedule": transmission.Schedule_OneAtATime,
"deltaStage": "10ms",
testClient(t, 1, responseTimeOut, 1, 0,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err2 := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err2)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
testClient(t, 10, responseTimeOut, 10, 3,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err2 := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err2)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
require.NoError(t, err)

testClient(t, 1, responseTimeOut, 1, 0,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err2 := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err2)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
testClient(t, 10, responseTimeOut, 10, 3,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err2 := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err2)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
transmissionSchedule, err = values.NewMap(map[string]any{
"schedule": transmission.Schedule_AllAtOnce,
"deltaStage": "10ms",
transmissionSchedule, err = values.NewMap(map[string]any{
"schedule": transmission.Schedule_AllAtOnce,
"deltaStage": "10ms",
})
require.NoError(t, err)

testClient(t, 1, responseTimeOut, 1, 0,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
require.NoError(t, err)
testClient(t, 10, responseTimeOut, 10, 3,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
}

testClient(t, 1, responseTimeOut, 1, 0,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
testClient(t, 10, responseTimeOut, 10, 3,
capability, func(caller commoncap.ExecutableCapability) {
executeInputs, err := values.NewMap(map[string]any{"executeValue1": "aValue1"})
require.NoError(t, err)
executeMethod(ctx, caller, transmissionSchedule, executeInputs, responseTest, t)
})
}
*/
func Test_Client_TimesOutIfInsufficientCapabilityPeerResponses(t *testing.T) {
ctx := testutils.Context(t)

Expand Down

0 comments on commit 68a2962

Please sign in to comment.