Skip to content

Commit dd3347c

Browse files
committed
INFOPLAT-2963 Wires up Signer for Loop Server
1 parent c433c59 commit dd3347c

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

pkg/loop/internal/relayer/relayer.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import (
1313
"google.golang.org/protobuf/types/known/emptypb"
1414
"google.golang.org/protobuf/types/known/structpb"
1515

16+
"github.com/smartcontractkit/chainlink-common/pkg/beholder"
1617
evmpb "github.com/smartcontractkit/chainlink-common/pkg/chains/evm"
1718
tonpb "github.com/smartcontractkit/chainlink-common/pkg/chains/ton"
1819
"github.com/smartcontractkit/chainlink-common/pkg/logger"
@@ -134,7 +135,12 @@ func (p *pluginRelayerServer) NewRelayer(ctx context.Context, request *pb.NewRel
134135
crRes := net.Resource{Closer: capRegistryConn, Name: "CapabilityRegistry"}
135136
capRegistry := capability.NewCapabilitiesRegistryClient(capRegistryConn, p.BrokerExt)
136137

137-
r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), ks.NewClient(ksCSAConn), capRegistry)
138+
csaKeystore := ks.NewClient(ksCSAConn)
139+
140+
// Sets the auth header signing mechanism
141+
beholder.GetClient().SetSigner(csaKeystore)
142+
143+
r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), csaKeystore, capRegistry)
138144
if err != nil {
139145
p.CloseAll(ksRes, ksCSARes, crRes)
140146
return nil, err

0 commit comments

Comments
 (0)