fix: add test

pkg/storer/internal/pinning/export_test.go

@@ -23,6 +23,7 @@ var (
 	ErrInvalidPinCollectionItemSize = errInvalidPinCollectionSize
 	ErrPutterAlreadyClosed          = errPutterAlreadyClosed
 	ErrCollectionRootAddressIsZero  = errCollectionRootAddressIsZero
+	ErrDuplicatePinCollection       = errDuplicatePinCollection
 )
 
 var NewUUID = newUUID

pkg/storer/internal/pinning/pinning.go

@@ -40,6 +40,8 @@ var (
 	// errCollectionRootAddressIsZero is returned if the putter is closed with a zero
 	// swarm.Address. Root reference has to be set.
 	errCollectionRootAddressIsZero = errors.New("pin store: collection root address is zero")
+	// errDuplicatePinCollection is returned when attempted to pin the same file repeatedly
+	errDuplicatePinCollection = errors.New("pin store: duplicate pin collection")
 )
 
 // creates a new UUID and returns it as a byte slice
@@ -273,7 +275,7 @@ func (c *collectionPutter) Close(st internal.Storage, writer storage.Writer, roo
 
 	if has {
 		// trigger the Cleanup
-		return fmt.Errorf("pin store: duplicate collection")
+		return errDuplicatePinCollection
 	}
 
 	// Save the root pin reference.

pkg/storer/internal/pinning/pinning_test.go

@@ -276,6 +276,29 @@ func TestPinStore(t *testing.T) {
 		}
 	})
 
+	t.Run("duplicate collection", func(t *testing.T) {
+		root := chunktest.GenerateTestRandomChunk()
+		putter, err := pinstore.NewCollection(st)
+		if err != nil {
+			t.Fatal(err)
+		}
+
+		err = putter.Put(context.Background(), st, st.IndexStore(), root)
+		if err != nil {
+			t.Fatal(err)
+		}
+
+		err = putter.Close(st, st.IndexStore(), root.Address())
+		if err != nil {
+			t.Fatal(err)
+		}
+
+		err = putter.Close(st, st.IndexStore(), root.Address())
+		if err == nil || !errors.Is(err, pinstore.ErrDuplicatePinCollection) {
+			t.Fatalf("unexpected error during CLose, want: %v, got: %v", pinstore.ErrDuplicatePinCollection, err)
+		}
+	})
+
 	t.Run("zero address close", func(t *testing.T) {
 		root := chunktest.GenerateTestRandomChunk()
 		putter, err := pinstore.NewCollection(st)
@@ -292,7 +315,6 @@ func TestPinStore(t *testing.T) {
 		if !errors.Is(err, pinstore.ErrCollectionRootAddressIsZero) {
 			t.Fatalf("unexpected error on close, want: %v, got: %v", pinstore.ErrCollectionRootAddressIsZero, err)
 		}
-
 	})
 }