don't start up ad handler without sub

go.mod

@@ -14,7 +14,7 @@ require (
 	github.com/ipfs/go-datastore v0.6.0
 	github.com/ipfs/go-ds-badger v0.3.0
 	github.com/kardianos/osext v0.0.0-20190222173326-2bc1f35cddc0
-	github.com/libp2p/go-libp2p v0.27.5
+	github.com/libp2p/go-libp2p v0.26.3
 	github.com/libp2p/go-libp2p-kad-dht v0.23.0
 	github.com/libp2p/go-libp2p-pubsub v0.9.3
 	github.com/libp2p/go-libp2p-record v0.2.0

go.sum

@@ -856,8 +856,8 @@ github.com/libp2p/go-cidranger v1.1.0 h1:ewPN8EZ0dd1LSnrtuwd4709PXVcITVeuwbag38y
 github.com/libp2p/go-cidranger v1.1.0/go.mod h1:KWZTfSr+r9qEo9OkI9/SIEeAtw+NNoU0dXIXt15Okic=
 github.com/libp2p/go-flow-metrics v0.1.0 h1:0iPhMI8PskQwzh57jB9WxIuIOQ0r+15PChFGkx3Q3WM=
 github.com/libp2p/go-flow-metrics v0.1.0/go.mod h1:4Xi8MX8wj5aWNDAZttg6UPmc0ZrnFNsMtpsYUClFtro=
-github.com/libp2p/go-libp2p v0.27.5 h1:KwA7pXKXpz8hG6Cr1fMA7UkgleogcwQj0sxl5qquWRg=
-github.com/libp2p/go-libp2p v0.27.5/go.mod h1:oMfQGTb9CHnrOuSM6yMmyK2lXz3qIhnkn2+oK3B1Y2g=
+github.com/libp2p/go-libp2p v0.26.3 h1:6g/psubqwdaBqNNoidbRKSTBEYgaOuKBhHl8Q5tO+PM=
+github.com/libp2p/go-libp2p v0.26.3/go.mod h1:x75BN32YbwuY0Awm2Uix4d4KOz+/4piInkp4Wr3yOo8=
 github.com/libp2p/go-libp2p-asn-util v0.3.0 h1:gMDcMyYiZKkocGXDQ5nsUQyquC9+H+iLEQHwOCZ7s8s=
 github.com/libp2p/go-libp2p-asn-util v0.3.0/go.mod h1:B1mcOrKUE35Xq/ASTmQ4tN3LNzVVaMNmq2NACuqyB9w=
 github.com/libp2p/go-libp2p-kad-dht v0.23.0 h1:sxE6LxLopp79eLeV695n7+c77V/Vn4AMF28AdM/XFqM=

pkg/engine/dispatcher/dispatcher.go

@@ -642,7 +642,7 @@ func NewDispatcher(l *transport.Conn, ctx context.Context,
 	d.rekeying.Store(false)
 	d.ip = blue(d.Conn.RemoteMultiaddr())
 	var e error
-	prk := d.Conn.RemotePublicKey()
+	prk := d.Conn.LocalPrivateKey()
 	var rprk slice.Bytes
 	if rprk, e = prk.Raw(); fails(e) {
 		return

pkg/engine/engine.go

@@ -172,7 +172,10 @@ func (ng *Engine) Shutdown() {
 // Start a single thread of the Engine.
 func (ng *Engine) Start() {
 	log.T.Ln("starting engine")
-	ng.RunAdHandler(ng.HandleAd)
+	if ng.sub != nil {
+		log.I.Ln("starting gossip handling")
+		ng.RunAdHandler(ng.HandleAd)
+	}
 	for {
 		if ng.Handler() {
 			break

pkg/engine/sess/send.go

@@ -40,7 +40,6 @@ func (sm *Manager) SendWithOneHook(ap *netip.AddrPort,
 			return errors.New("nil response hook")
 		}
 	}
-	log.I.S("res", res.ID)
 	p.Add(responses.ResponseParams{
 		ID:       res.ID,
 		SentSize: res.B.Len(),