feat: reintroduce the mock streams trigger on develop

core/capabilities/registry.go

@@ -83,25 +83,34 @@ func NewRegistry(lggr logger.Logger) *Registry {
 // interface. It is used when ExternalCapabilitiesRegistry is not available.
 type TestMetadataRegistry struct {
 	core.UnimplementedCapabilitiesRegistryMetadata
+	WorkflowDONF uint8
 }
 
+const (
+	testWorkflowDONID            = 1
+	testWorkflowDONConfigVersion = 1
+)
+
 func (t *TestMetadataRegistry) LocalNode(ctx context.Context) (capabilities.Node, error) {
 	peerID := p2ptypes.PeerID{}
-	workflowDON := capabilities.DON{
-		ID:            1,
-		ConfigVersion: 1,
+	return capabilities.Node{
+		PeerID:         &peerID,
+		WorkflowDON:    newTestWorkflowDON(peerID, t.WorkflowDONF),
+		CapabilityDONs: []capabilities.DON{},
+	}, nil
+}
+
+func newTestWorkflowDON(peerID p2ptypes.PeerID, faultTolerance uint8) capabilities.DON {
+	return capabilities.DON{
+		ID:            testWorkflowDONID,
+		ConfigVersion: testWorkflowDONConfigVersion,
 		Members: []p2ptypes.PeerID{
 			peerID,
 		},
-		F:                0,
+		F:                faultTolerance,
 		IsPublic:         false,
 		AcceptsWorkflows: true,
 	}
-	return capabilities.Node{
-		PeerID:         &peerID,
-		WorkflowDON:    workflowDON,
-		CapabilityDONs: []capabilities.DON{},
-	}, nil
 }
 
 func (t *TestMetadataRegistry) NodeByPeerID(ctx context.Context, _ p2ptypes.PeerID) (capabilities.Node, error) {

core/capabilities/registry_test.go

@@ -0,0 +1,39 @@
+package capabilities
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestTestMetadataRegistry_LocalNode_UsesConfiguredWorkflowDONF(t *testing.T) {
+	t.Parallel()
+
+	tests := []struct {
+		name         string
+		registry     TestMetadataRegistry
+		expectedDonF uint8
+	}{
+		{
+			name:         "default workflow DON fault tolerance",
+			registry:     TestMetadataRegistry{},
+			expectedDonF: 0,
+		},
+		{
+			name:         "mock trigger workflow DON fault tolerance",
+			registry:     TestMetadataRegistry{WorkflowDONF: 1},
+			expectedDonF: 1,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
+
+			node, err := tt.registry.LocalNode(context.Background())
+			require.NoError(t, err)
+			require.Equal(t, tt.expectedDonF, node.WorkflowDON.F)
+		})
+	}
+}