Remove invalid disconnected call (#553)

* disconnected calls fixe

* remove unused disconnect

pkg/p2p/libp2p/libp2p.go

@@ -429,7 +429,6 @@ func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (address *bzz.
 func (s *Service) Disconnect(overlay swarm.Address) error {
 	peerID, found := s.peers.peerID(overlay)
 	if !found {
-		s.peers.disconnect(overlay)
 		return p2p.ErrPeerNotFound
 	}
 
@@ -456,7 +455,6 @@ func (s *Service) AddNotifier(n topology.Notifier) {
 func (s *Service) NewStream(ctx context.Context, overlay swarm.Address, headers p2p.Headers, protocolName, protocolVersion, streamName string) (p2p.Stream, error) {
 	peerID, found := s.peers.peerID(overlay)
 	if !found {
-		s.peers.disconnect(overlay)
 		return nil, p2p.ErrPeerNotFound
 	}
 

pkg/p2p/libp2p/peer.go

@@ -183,9 +183,3 @@ func (r *peerRegistry) remove(peerID libp2ppeer.ID) {
 func (r *peerRegistry) addDisconnecter(d topology.Disconnecter) {
 	r.disconnecters = append(r.disconnecters, d)
 }
-
-func (r *peerRegistry) disconnect(address swarm.Address) {
-	for _, d := range r.disconnecters {
-		d.Disconnected(address)
-	}
-}