diff --git a/pkg/loop/cmd/loopinstall/config.go b/pkg/loop/cmd/loopinstall/config.go index dbfd7252d..ee0345bd6 100644 --- a/pkg/loop/cmd/loopinstall/config.go +++ b/pkg/loop/cmd/loopinstall/config.go @@ -64,4 +64,3 @@ func pluginKey(pluginType string, plugin PluginDef) string { func isPluginEnabled(plugin PluginDef) bool { return plugin.Enabled == nil || *plugin.Enabled } - diff --git a/pkg/loop/internal/core/services/capability/standard/standard_capabilities.go b/pkg/loop/internal/core/services/capability/standard/standard_capabilities.go index f93a74515..255e90b34 100644 --- a/pkg/loop/internal/core/services/capability/standard/standard_capabilities.go +++ b/pkg/loop/internal/core/services/capability/standard/standard_capabilities.go @@ -7,6 +7,7 @@ import ( "google.golang.org/grpc" "google.golang.org/protobuf/types/known/emptypb" + "github.com/smartcontractkit/chainlink-common/pkg/beholder" "github.com/smartcontractkit/chainlink-common/pkg/capabilities" capabilitiespb "github.com/smartcontractkit/chainlink-common/pkg/capabilities/pb" "github.com/smartcontractkit/chainlink-common/pkg/logger" @@ -304,6 +305,9 @@ func (s *standardCapabilitiesServer) Initialise(ctx context.Context, request *ca resources = append(resources, net.Resource{Closer: keystoreConn, Name: "KeystoreConn"}) keyStore := keystoreservice.NewClient(keystoreConn) + // Sets the auth header signing mechanism + beholder.GetClient().SetSigner(keyStore) + capabilitiesRegistryConn, err := s.Dial(request.CapRegistryId) if err != nil { s.CloseAll(resources...) diff --git a/pkg/loop/internal/relayer/relayer.go b/pkg/loop/internal/relayer/relayer.go index c0309c5db..416cb42a0 100644 --- a/pkg/loop/internal/relayer/relayer.go +++ b/pkg/loop/internal/relayer/relayer.go @@ -13,6 +13,7 @@ import ( "google.golang.org/protobuf/types/known/emptypb" "google.golang.org/protobuf/types/known/structpb" + "github.com/smartcontractkit/chainlink-common/pkg/beholder" evmpb "github.com/smartcontractkit/chainlink-common/pkg/chains/evm" solpb "github.com/smartcontractkit/chainlink-common/pkg/chains/solana" tonpb "github.com/smartcontractkit/chainlink-common/pkg/chains/ton" @@ -135,7 +136,12 @@ func (p *pluginRelayerServer) NewRelayer(ctx context.Context, request *pb.NewRel crRes := net.Resource{Closer: capRegistryConn, Name: "CapabilityRegistry"} capRegistry := capability.NewCapabilitiesRegistryClient(capRegistryConn, p.BrokerExt) - r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), ks.NewClient(ksCSAConn), capRegistry) + csaKeystore := ks.NewClient(ksCSAConn) + + // Sets the auth header signing mechanism + beholder.GetClient().SetSigner(csaKeystore) + + r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), csaKeystore, capRegistry) if err != nil { p.CloseAll(ksRes, ksCSARes, crRes) return nil, err