feat: plan for migrate command

client/cmd/internal/plan/operation.go

@@ -6,6 +6,7 @@ const (
 	OperationDelete Operation = iota + 1
 	OperationCreate
 	OperationUpdate
+	OperationMigrate
 )
 
 func (o Operation) String() string {
@@ -16,6 +17,8 @@ func (o Operation) String() string {
 		return "create"
 	case OperationUpdate:
 		return "update"
+	case OperationMigrate:
+		return "migrate"
 	default:
 		return ""
 	}
@@ -29,6 +32,8 @@ func NewOperationByString(operation string) Operation {
 		return OperationCreate
 	case "update":
 		return OperationUpdate
+	case "migrate":
+		return OperationMigrate
 	default:
 		return 0
 	}

client/cmd/job/plan.go

@@ -116,16 +116,24 @@ func (p *planCommand) RunE(_ *cobra.Command, _ []string) error {
 	plans := make(plan.Plans, 0, len(directories))
 	p.logger.Info("job plan found changed in directories: %+v", directories)
 
+	plansByName := map[string]*plan.Plan{}
 	for _, directory := range directories {
 		var jobPlan *plan.Plan
 		jobPlan, err = p.describePlanFromDirectory(ctx, directory)
 		if err != nil {
 			return err
 		}
+		if jobMigrated := p.getPlanMigrated(plansByName, jobPlan); jobMigrated != nil {
+			jobPlan = jobMigrated
+		}
+		plansByName[jobPlan.KindName] = jobPlan
+	}
+
+	for _, jobPlan := range plansByName {
+		plans = append(plans, jobPlan)
 		if p.verbose {
 			p.logger.Info("[%s] plan operation %s for job %s", jobPlan.NamespaceName, jobPlan.Operation, jobPlan.KindName)
 		}
-		plans = append(plans, jobPlan)
 	}
 
 	sort.SliceStable(plans, plans.SortByOperationPriority)
@@ -181,6 +189,20 @@ func (p *planCommand) describePlanFromDirectory(ctx context.Context, directory s
 	return jobPlan, nil
 }
 
+func (*planCommand) getPlanMigrated(plansByName map[string]*plan.Plan, targetPlan *plan.Plan) *plan.Plan {
+	existedPlan, ok := plansByName[targetPlan.KindName]
+	isMigrated := ok && existedPlan.NamespaceName != targetPlan.NamespaceName
+	jobPlan := targetPlan
+	if isMigrated {
+		if existedPlan.Operation == plan.OperationCreate {
+			jobPlan = existedPlan
+		}
+		jobPlan.Operation = plan.OperationMigrate
+		return jobPlan
+	}
+	return nil
+}
+
 func (*planCommand) appendDirectory(directory string, directoryExists map[string]bool, fileDirectories []string) []string {
 	index := strings.Index(directory, "/assets")
 	if !strings.HasSuffix(directory, "/"+jobFileName) && index < 1 {