Enable DON2DON flow for Vault service's GetSecrets() method

.changeset/olive-keys-lose.md

@@ -0,0 +1,5 @@
+---
+"chainlink": patch
+---
+
+#internal Implement fetching encryption keys for all Workflow Nodes in the SecretsFetcher

.mockery.yaml

@@ -404,6 +404,7 @@ packages:
   github.com/smartcontractkit/chainlink/v2/core/services/registrysyncer:
     interfaces:
       ORM:
+      RegistrySyncer:
   github.com/smartcontractkit/chainlink/v2/core/services/workflows/syncer:
     interfaces:
       ORM:

core/capabilities/ccip/delegate.go

@@ -266,7 +266,7 @@ func (d *Delegate) ServicesForSpec(ctx context.Context, spec job.Job) (services
 	)
 
 	// register the capability launcher with the registry syncer
-	registrySyncer.AddLauncher(capLauncher)
+	registrySyncer.AddListener(capLauncher)
 
 	return []job.ServiceCtx{
 		homeChainContractReader,

core/capabilities/ccip/launcher/integration_test.go

@@ -9,6 +9,7 @@ import (
 	cciptypes "github.com/smartcontractkit/chainlink-ccip/pkg/types/ccipocr3"
 
 	"github.com/smartcontractkit/chainlink-ccip/chains/evm/gobindings/generated/v1_6_0/ccip_home"
+
 	it "github.com/smartcontractkit/chainlink/v2/core/capabilities/ccip/ccip_integration_tests/integrationhelpers"
 	cctypes "github.com/smartcontractkit/chainlink/v2/core/capabilities/ccip/types"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils/pgtest"
@@ -56,7 +57,7 @@ func TestIntegration_Launcher(t *testing.T) {
 		1*time.Second,
 		oracleCreator,
 	)
-	regSyncer.AddLauncher(launcher)
+	regSyncer.AddListener(launcher)
 
 	require.NoError(t, launcher.Start(ctx))
 	require.NoError(t, regSyncer.Start(ctx))

core/capabilities/ccip/launcher/launcher.go

@@ -24,7 +24,7 @@ import (
 
 var (
 	_ job.ServiceCtx          = (*launcher)(nil)
-	_ registrysyncer.Launcher = (*launcher)(nil)
+	_ registrysyncer.Listener = (*launcher)(nil)
 )
 
 // New creates a new instance of the CCIP launcher.
@@ -80,8 +80,8 @@ type launcher struct {
 	instances map[registrysyncer.DonID]pluginRegistry
 }
 
-// Launch implements registrysyncer.Launcher.
-func (l *launcher) Launch(ctx context.Context, state *registrysyncer.LocalRegistry) error {
+// OnNewRegistry implements registrysyncer.Listener.
+func (l *launcher) OnNewRegistry(ctx context.Context, state *registrysyncer.LocalRegistry) error {
 	l.lock.Lock()
 	defer l.lock.Unlock()
 	l.lggr.Debugw("Received new state from syncer", "dons", state.IDsToDONs)

core/capabilities/fakes/consensus_nodag.go

@@ -23,6 +23,7 @@ import (
 
 	valuespb "github.com/smartcontractkit/chainlink-common/pkg/values/pb"
 	sdkpb "github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
+
 	"github.com/smartcontractkit/chainlink/v2/core/services/keystore/keys/ocr2key"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm"
 )

core/capabilities/fakes/consensus_nodag_test.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/smartcontractkit/chainlink-common/pkg/capabilities"
 	sdkpb "github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
+
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/keystore/chaintype"
 	"github.com/smartcontractkit/chainlink/v2/core/services/keystore/keys/ocr2key"

core/capabilities/launcher.go

@@ -238,7 +238,7 @@ func (w *launcher) Name() string {
 	return w.lggr.Name()
 }
 
-func (w *launcher) Launch(ctx context.Context, localRegistry *registrysyncer.LocalRegistry) error {
+func (w *launcher) OnNewRegistry(ctx context.Context, localRegistry *registrysyncer.LocalRegistry) error {
 	w.lggr.Debug("CapabilitiesLauncher triggered...")
 	w.registry.SetLocalRegistry(localRegistry)