Skip to content

Commit 6781ddd

Browse files
committed
Removes deferred beholder signer wire up
Removes wire up Removes code refactor
1 parent e0b201d commit 6781ddd

File tree

2 files changed

+1
-15
lines changed

2 files changed

+1
-15
lines changed

pkg/loop/internal/relayer/relayer.go

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@ 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"
1716
evmpb "github.com/smartcontractkit/chainlink-common/pkg/chains/evm"
1817
tonpb "github.com/smartcontractkit/chainlink-common/pkg/chains/ton"
1918
"github.com/smartcontractkit/chainlink-common/pkg/logger"
@@ -72,9 +71,6 @@ func (p *PluginRelayerClient) NewRelayer(ctx context.Context, config string, key
7271
}
7372
deps.Add(ksCSARes)
7473

75-
beholder.GetClient().SetSigner(csaKeystore)
76-
p.Logger.Debug("Set beholder signer from CSA keystore")
77-
7874
capabilityRegistryID, capabilityRegistryResource, err := p.ServeNew("CapabilitiesRegistry", func(s *grpc.Server) {
7975
pb.RegisterCapabilitiesRegistryServer(s, capability.NewCapabilitiesRegistryServer(p.BrokerExt, capabilityRegistry))
8076
})
@@ -138,12 +134,7 @@ func (p *pluginRelayerServer) NewRelayer(ctx context.Context, request *pb.NewRel
138134
crRes := net.Resource{Closer: capRegistryConn, Name: "CapabilityRegistry"}
139135
capRegistry := capability.NewCapabilitiesRegistryClient(capRegistryConn, p.BrokerExt)
140136

141-
csaKeystore := ks.NewClient(ksCSAConn)
142-
143-
beholder.GetClient().SetSigner(csaKeystore)
144-
p.Logger.Debug("Set beholder signer from CSA keystore")
145-
146-
r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), csaKeystore, capRegistry)
137+
r, err := p.impl.NewRelayer(ctx, request.Config, ks.NewClient(ksConn), ks.NewClient(ksCSAConn), capRegistry)
147138
if err != nil {
148139
p.CloseAll(ksRes, ksCSARes, crRes)
149140
return nil, err

pkg/loop/relayer_service.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
"math/big"
77
"os/exec"
88

9-
"github.com/smartcontractkit/chainlink-common/pkg/beholder"
109
"github.com/smartcontractkit/chainlink-common/pkg/logger"
1110
"github.com/smartcontractkit/chainlink-common/pkg/loop/internal/goplugin"
1211
"github.com/smartcontractkit/chainlink-common/pkg/services"
@@ -33,10 +32,6 @@ func NewRelayerService(lggr logger.Logger, grpcOpts GRPCOpts, cmd func() *exec.C
3332
if err != nil {
3433
return nil, nil, fmt.Errorf("failed to create Relayer: %w", err)
3534
}
36-
if bc := beholder.GetClient(); bc != nil && !bc.IsSignerSet() {
37-
bc.SetSigner(csaKeystore)
38-
lggr.Debug("Set beholder signer from CSA keystore")
39-
}
4035
return r, plug, nil
4136
}
4237
stopCh := make(chan struct{})

0 commit comments

Comments
 (0)