Skip to content

Commit

Permalink
test: unskip TestWithBlocklistStreams test
Browse files Browse the repository at this point in the history
  • Loading branch information
gacevicljubisa committed Nov 25, 2024
1 parent 4dc554e commit 9736bc0
Showing 1 changed file with 10 additions and 8 deletions.
18 changes: 10 additions & 8 deletions pkg/p2p/libp2p/connections_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -433,7 +433,8 @@ func TestDoubleConnectOnAllAddresses(t *testing.T) {
notifier: mockNotifier(noopCf, noopDf, true),
libp2pOpts: libp2p.Options{
FullNode: true,
}})
},
})
addrs, err := s1.Addresses()
if err != nil {
t.Fatal(err)
Expand Down Expand Up @@ -1019,7 +1020,6 @@ func TestWithDisconnectStreams(t *testing.T) {

func TestWithBlocklistStreams(t *testing.T) {
t.Parallel()
t.Skip("this test always fails")

ctx, cancel := context.WithCancel(context.Background())
defer cancel()
Expand Down Expand Up @@ -1369,9 +1369,11 @@ type (
reachableFunc func(swarm.Address, p2p.ReachabilityStatus)
)

var noopCf = func(context.Context, p2p.Peer, bool) error { return nil }
var noopDf = func(p2p.Peer) {}
var noopAnnounce = func(context.Context, swarm.Address, bool) error { return nil }
var noopAnnounceTo = func(context.Context, swarm.Address, swarm.Address, bool) error { return nil }
var noopReachability = func(p2p.ReachabilityStatus) {}
var noopReachable = func(swarm.Address, p2p.ReachabilityStatus) {}
var (
noopCf = func(context.Context, p2p.Peer, bool) error { return nil }
noopDf = func(p2p.Peer) {}
noopAnnounce = func(context.Context, swarm.Address, bool) error { return nil }
noopAnnounceTo = func(context.Context, swarm.Address, swarm.Address, bool) error { return nil }
noopReachability = func(p2p.ReachabilityStatus) {}
noopReachable = func(swarm.Address, p2p.ReachabilityStatus) {}
)

0 comments on commit 9736bc0

Please sign in to comment.