From dd3347ce472910f8c974b122eb0df66e6d2fcb0b Mon Sep 17 00:00:00 2001 From: hendoxc Date: Mon, 20 Oct 2025 17:14:44 -0600 Subject: [PATCH] INFOPLAT-2963 Wires up Signer for Loop Server --- pkg/loop/internal/relayer/relayer.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/pkg/loop/internal/relayer/relayer.go b/pkg/loop/internal/relayer/relayer.go index 79b505f189..64b732d3cf 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" tonpb "github.com/smartcontractkit/chainlink-common/pkg/chains/ton" "github.com/smartcontractkit/chainlink-common/pkg/logger" @@ -134,7 +135,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