Skip to content

Commit

Permalink
lint
Browse files Browse the repository at this point in the history
  • Loading branch information
felipemadero committed Dec 23, 2022
1 parent 783f741 commit 6f892f7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 8 deletions.
6 changes: 3 additions & 3 deletions local/network_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ func (lt *localTestFlagCheckProcessCreator) NewNodeProcess(config node.Config, f
// TODO have this method return an API Client that has all
// APIs and methods implemented
func newMockAPISuccessful(string, uint16) api.Client {
healthReply := &health.APIHealthReply{Healthy: true}
healthReply := &health.APIReply{Healthy: true}
healthClient := &healthmocks.Client{}
healthClient.On("Health", mock.Anything).Return(healthReply, nil)
// ethClient used when removing nodes, to close websocket connection
Expand All @@ -93,7 +93,7 @@ func newMockAPISuccessful(string, uint16) api.Client {

// Returns an API client where the Health API's Health method always returns unhealthy
func newMockAPIUnhealthy(string, uint16) api.Client {
healthReply := &health.APIHealthReply{Healthy: false}
healthReply := &health.APIReply{Healthy: false}
healthClient := &healthmocks.Client{}
healthClient.On("Health", mock.Anything).Return(healthReply, nil)
client := &apimocks.Client{}
Expand Down Expand Up @@ -1279,7 +1279,7 @@ func newMockAPIHealthyBlocks(string, uint16) api.Client {
healthClient.On("Health", mock.MatchedBy(func(_ context.Context) bool {
return true
}), mock.Anything).Return(
func(ctx context.Context, _ ...rpc.Option) *health.APIHealthReply {
func(ctx context.Context, _ ...rpc.Option) *health.APIReply {
<-ctx.Done()
return nil
},
Expand Down
5 changes: 0 additions & 5 deletions local/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,10 +122,6 @@ func (node *localNode) AttachPeer(ctx context.Context, router router.InboundHand
}
signerIP := ips.NewDynamicIPPort(net.IPv6zero, 0)
tls := tlsCert.PrivateKey.(crypto.Signer)
gossipTracker, err := peer.NewGossipTracker(prometheus.NewRegistry(), "anr")
if err != nil {
return nil, err
}
config := &peer.Config{
Metrics: metrics,
MessageCreator: mc,
Expand All @@ -141,7 +137,6 @@ func (node *localNode) AttachPeer(ctx context.Context, router router.InboundHand
PongTimeout: constants.DefaultPingPongTimeout,
MaxClockDifference: time.Minute,
ResourceTracker: resourceTracker,
GossipTracker: gossipTracker,
IPSigner: peer.NewIPSigner(signerIP, tls),
}
_, conn, cert, err := clientUpgrader.Upgrade(conn)
Expand Down

0 comments on commit 6f892f7

Please sign in to comment.