less errors (#387)

pkg/kademlia/kademlia.go

@@ -153,7 +153,7 @@ func (k *Kad) manage() {
 				bzzAddr, err := k.addressBook.Get(peer)
 				if err != nil {
 					if err == addressbook.ErrNotFound {
-						k.logger.Errorf("failed to get address book entry for peer: %s", peer.String())
+						k.logger.Debugf("failed to get address book entry for peer: %s", peer.String())
 						peerToRemove = peer
 						return false, false, errMissingAddressBookEntry
 					}

pkg/pusher/pusher.go

@@ -127,7 +127,7 @@ LOOP:
 				_, err = s.pushSyncer.PushChunkToClosest(ctx, ch)
 				if err != nil {
 					if !errors.Is(err, topology.ErrNotFound) {
-						s.logger.Errorf("pusher: error while sending chunk or receiving receipt: %v", err)
+						s.logger.Debugf("pusher: error while sending chunk or receiving receipt: %v", err)
 					}
 					return
 				}
@@ -169,7 +169,7 @@ LOOP:
 	select {
 	case <-closeC:
 	case <-time.After(2 * time.Second):
-		s.logger.Error("pusher shutting down with pending operations")
+		s.logger.Warning("pusher shutting down with pending operations")
 	}
 }
 

pkg/retrieval/retrieval.go

@@ -118,7 +118,7 @@ func (s *Service) retrieveChunk(ctx context.Context, addr swarm.Address, skipPee
 	if err != nil {
 		return nil, peer, fmt.Errorf("get closest: %w", err)
 	}
-	s.logger.Tracef("retrieval: get chunk %s from peer %s", addr, peer)
+	s.logger.Tracef("retrieval: requesting chunk %s from peer %s", addr, peer)
 	stream, err := s.streamer.NewStream(ctx, peer, nil, protocolName, protocolVersion, streamName)
 	if err != nil {
 		return nil, peer, fmt.Errorf("new stream: %w", err)