diff --git a/pkg/file/joiner/joiner_test.go b/pkg/file/joiner/joiner_test.go index 996229b1bcd..56fe48c7a72 100644 --- a/pkg/file/joiner/joiner_test.go +++ b/pkg/file/joiner/joiner_test.go @@ -88,7 +88,7 @@ func TestJoinerSingleChunk(t *testing.T) { } } -// TestJoinerDecryptingStore_NormalChunk verifies the the mock store that uses +// TestJoinerDecryptingStore_NormalChunk verifies the mock store that uses // the decrypting store manages to retrieve a normal chunk which is not encrypted func TestJoinerDecryptingStore_NormalChunk(t *testing.T) { t.Parallel() @@ -1287,7 +1287,7 @@ func TestJoinerRedundancyMultilevel(t *testing.T) { } } - // first sanity check and and recover a range + // first sanity check and recover a range t.Run("NONE w/o fallback CAN retrieve", func(t *testing.T) { store.Record() defer store.Unrecord() diff --git a/pkg/node/node.go b/pkg/node/node.go index 8f1d6b3aa11..f4149ba8097 100644 --- a/pkg/node/node.go +++ b/pkg/node/node.go @@ -253,7 +253,7 @@ func NewBee( } b.stateStoreCloser = stateStore - // Check if the the batchstore exists. If not, we can assume it's missing + // Check if the batchstore exists. If not, we can assume it's missing // due to a migration or it's a fresh install. batchStoreExists, err := batchStoreExists(stateStore) if err != nil { diff --git a/pkg/p2p/libp2p/internal/handshake/handshake.go b/pkg/p2p/libp2p/internal/handshake/handshake.go index 102fd00b68a..badfcd31568 100644 --- a/pkg/p2p/libp2p/internal/handshake/handshake.go +++ b/pkg/p2p/libp2p/internal/handshake/handshake.go @@ -326,7 +326,7 @@ func (s *Service) SetWelcomeMessage(msg string) (err error) { return nil } -// GetWelcomeMessage returns the the current handshake welcome message. +// GetWelcomeMessage returns the current handshake welcome message. func (s *Service) GetWelcomeMessage() string { return s.welcomeMessage.Load().(string) } diff --git a/pkg/postage/batchstore/store_test.go b/pkg/postage/batchstore/store_test.go index 43e24014d33..836bb1fb855 100644 --- a/pkg/postage/batchstore/store_test.go +++ b/pkg/postage/batchstore/store_test.go @@ -328,7 +328,7 @@ func TestBatchUpdate(t *testing.T) { // state after the batch is saved/updated. Unlike depth updates, value updates // that are above cumulative amount should NOT result in any radius changes. // Value updates that are less than or equal to the cumulative amount trigger - // the eviction for the the batch, as such, radius may be altered. + // the eviction for the batch, as such, radius may be altered. tcs := []testCase{ { diff --git a/pkg/storer/sample.go b/pkg/storer/sample.go index 7fd5cc2ad4a..45ba3da129c 100644 --- a/pkg/storer/sample.go +++ b/pkg/storer/sample.go @@ -337,7 +337,7 @@ func transformedAddress(hasher *bmt.Hasher, chunk swarm.Chunk, chType swarm.Chun case swarm.ChunkTypeSingleOwner: return transformedAddressSOC(hasher, chunk) default: - return swarm.ZeroAddress, fmt.Errorf("chunk type [%v] is is not valid", chType) + return swarm.ZeroAddress, fmt.Errorf("chunk type [%v] is not valid", chType) } } diff --git a/pkg/topology/kademlia/kademlia.go b/pkg/topology/kademlia/kademlia.go index 277eeba331a..70339c55d7c 100644 --- a/pkg/topology/kademlia/kademlia.go +++ b/pkg/topology/kademlia/kademlia.go @@ -913,7 +913,7 @@ func (k *Kad) recalcDepth() { } // connect connects to a peer and gossips its address to our connected peers, -// as well as sends the peers we are connected to to the newly connected peer +// as well as sends the peers we are connected to the newly connected peer func (k *Kad) connect(ctx context.Context, peer swarm.Address, ma ma.Multiaddr) error { k.logger.Debug("attempting connect to peer", "peer_address", peer)