check storage ID first

Author: LexLuthr

cmd/curio/storacha-migration.go

@@ -126,14 +126,19 @@ var importPiecesCmd = &cli.Command{
 			return xerrors.Errorf("resolving target path: %w", err)
 		}
 
+		storageID, err := pieceStorageID(targetPath)
+		if err != nil {
+			return xerrors.Errorf("getting storage ID: %w", err)
+		}
+
 		db, err := deps.MakeDB(cctx)
 		if err != nil {
 			return err
 		}
 
 		si := paths.NewDBIndex(curioalerting.NewAlertingSystem(), db)
 
-		out, err := runImportPieces(ctx, db, si, sourcePath, targetPath, cctx.Int("batch-size"))
+		out, err := runImportPieces(ctx, db, si, storageID, sourcePath, targetPath, cctx.Int("batch-size"))
 		if err != nil {
 			return err
 		}
@@ -147,14 +152,9 @@ var importPiecesCmd = &cli.Command{
 	},
 }
 
-func runImportPieces(ctx context.Context, db *harmonydb.DB, si paths.SectorIndex, sourcePath, targetPath string, batchSize int) (importPiecesOutput, error) {
+func runImportPieces(ctx context.Context, db *harmonydb.DB, si paths.SectorIndex, storageID storiface.ID, sourcePath, targetPath string, batchSize int) (importPiecesOutput, error) {
 	var out importPiecesOutput
 
-	storageID, err := pieceStorageID(targetPath)
-	if err != nil {
-		return out, err
-	}
-
 	staging := filepath.Join(targetPath, "storacha-staging")
 	existing, err := os.ReadDir(staging)
 	if err != nil {