Skip to content
This repository has been archived by the owner on May 26, 2022. It is now read-only.

warn when we encounter a useless transport #90

Merged
merged 1 commit into from
Nov 16, 2018
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions swarm_transport.go
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,10 @@ func (s *Swarm) TransportForListening(a ma.Multiaddr) transport.Transport {
func (s *Swarm) AddTransport(t transport.Transport) error {
protocols := t.Protocols()

if len(protocols) == 0 {
return fmt.Errorf("useless transport handles no protocols: %T", t)
}

s.transports.Lock()
defer s.transports.Unlock()
var registered []string
Expand Down
47 changes: 47 additions & 0 deletions transport_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,47 @@
package swarm_test

import (
"context"
"testing"

swarmt "github.com/libp2p/go-libp2p-swarm/testing"

peer "github.com/libp2p/go-libp2p-peer"
transport "github.com/libp2p/go-libp2p-transport"
ma "github.com/multiformats/go-multiaddr"
)

type dummyTransport struct {
protocols []int
proxy bool
}

func (dt *dummyTransport) Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (transport.Conn, error) {
panic("unimplemented")
}

func (dt *dummyTransport) CanDial(addr ma.Multiaddr) bool {
panic("unimplemented")
}

func (dt *dummyTransport) Listen(laddr ma.Multiaddr) (transport.Listener, error) {
panic("unimplemented")
}

func (dt *dummyTransport) Proxy() bool {
return dt.proxy
}

func (dt *dummyTransport) Protocols() []int {
return dt.protocols
}

func TestUselessTransport(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
swarm := swarmt.GenSwarm(t, ctx)
err := swarm.AddTransport(new(dummyTransport))
if err == nil {
t.Fatal("adding a transport that supports no protocols should have failed")
}
}