fix: stop and cleanup on dup collection

pkg/storer/internal/pinning/pinning.go

@@ -243,16 +243,6 @@ func (c *collectionPutter) Put(ctx context.Context, st internal.Storage, writer
 		return nil
 	}
 
-	rootCollection := &pinCollectionItem{Addr: ch.Address()}
-	has, err := st.IndexStore().Has(rootCollection)
-	if err != nil {
-		return fmt.Errorf("pin store: check previous root: %w", err)
-	}
-	if has {
-		// duplicate PUT of the same root address
-		return nil
-	}
-
 	err = writer.Put(collectionChunk)
 	if err != nil {
 		return fmt.Errorf("pin store: failed putting collection chunk: %w", err)
@@ -276,17 +266,20 @@ func (c *collectionPutter) Close(st internal.Storage, writer storage.Writer, roo
 
 	collection := &pinCollectionItem{Addr: root}
 	has, err := st.IndexStore().Has(collection)
+
 	if err != nil {
 		return fmt.Errorf("pin store: check previous root: %w", err)
 	}
 
-	if !has {
-		// Save the root pin reference.
-		c.collection.Addr = root
-		err := writer.Put(c.collection)
-		if err != nil {
-			return fmt.Errorf("pin store: failed updating collection: %w", err)
-		}
+	if has {
+		return fmt.Errorf("pin store: duplicate collection: %w", err) // will trigger the Cleanup
+	}
+
+	// Save the root pin reference.
+	c.collection.Addr = root
+	err = writer.Put(c.collection)
+	if err != nil {
+		return fmt.Errorf("pin store: failed updating collection: %w", err)
 	}
 
 	err = writer.Delete(&dirtyCollection{UUID: c.collection.UUID})