fix: Fixed the List method repeatedly placing objects into the channe…

…l to be migrated (#336)

migrate/copy.go

@@ -72,6 +72,7 @@ func copyTask(ctx context.Context) (err error) {
 		}
 
 		if !isFinished(ctx) {
+			//t.Status = constants.TaskStatusRerun
 			return constants.ErrTaskNotFinished
 		}
 

migrate/list.go

@@ -27,26 +27,14 @@ func List(ctx context.Context) (err error) {
 		if err != nil {
 			logrus.Panic(err)
 		}
-	}
-
-	// Traverse already running but not finished directory object.
-	p := ""
-	for {
-		do, err := model.NextDirectoryObject(ctx, p)
-		if err != nil {
-			logrus.Panic(err)
-		}
-		if do == nil {
-			break
-		}
 
 		jwg.Add(1)
-		jc <- do
-		p = do.Key
+		jc <- o
+		return nil
 	}
 
 	// Traverse already running but not finished single object.
-	p = ""
+	p := ""
 	for {
 		so, err := model.NextSingleObject(ctx, p)
 		if err != nil {
@@ -77,6 +65,22 @@ func List(ctx context.Context) (err error) {
 		pn = po.PartNumber
 	}
 
+	// Traverse already running but not finished directory object.
+	p = ""
+	for {
+		do, err := model.NextDirectoryObject(ctx, p)
+		if err != nil {
+			logrus.Panic(err)
+		}
+		if do == nil {
+			break
+		}
+
+		jwg.Add(1)
+		jc <- do
+		p = do.Key
+	}
+
 	return
 }