Added delete actions task and steps

Signed-off-by: cassiozareck <[email protected]>

Author: cassiozareck

models/actions/run.go

@@ -305,8 +305,21 @@ func InsertRun(ctx context.Context, run *ActionRun, jobs []*jobparser.SingleWork
 	return commiter.Commit()
 }
 
-func DeleteRunJobs(ctx context.Context, jobs []*ActionRunJob) error {
-	return db.DeleteBeans(ctx, jobs)
+func DeleteTaskSteps(ctx context.Context, steps []*ActionTaskStep) error {
+	for _, step := range steps {
+		if err := db.DeleteBeans(ctx, step); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func DeleteTask(ctx context.Context, actionTask *ActionTask) error {
+	return db.DeleteBeans(ctx, actionTask)
+}
+
+func DeleteRunJob(ctx context.Context, job *ActionRunJob) error {
+	return db.DeleteBeans(ctx, job)
 }
 
 func DeleteRun(ctx context.Context, run *ActionRun) error {
@@ -322,11 +335,7 @@ func DeleteRun(ctx context.Context, run *ActionRun) error {
 		return err
 	}
 
-	if err := updateRepoRunsNumbers(ctx, run.Repo); err != nil {
-		return err
-	}
-
-	return nil
+	return updateRepoRunsNumbers(ctx, run.Repo)
 }
 
 func GetRunByID(ctx context.Context, id int64) (*ActionRun, error) {

routers/web/repo/actions/view.go

@@ -405,28 +405,58 @@ func Cancel(ctx *context_module.Context) {
 	ctx.JSON(http.StatusOK, struct{}{})
 }
 
+// Delete deletes a run and all its jobs.
 func Delete(ctx *context_module.Context) {
-
 	runIndex := ctx.ParamsInt64("run")
 
-	_, jobs := getRunJobs(ctx, runIndex, -1)
-	if ctx.Written() {
-		return
-	}
-
 	run, err := actions_model.GetRunByID(ctx, runIndex)
 	if err != nil {
 		ctx.Error(http.StatusNotFound, err.Error())
 		return
 	}
 
+	_, jobs := getRunJobs(ctx, runIndex, -1)
+	if ctx.Written() {
+		return
+	}
+
+	// Initializes a transaction where it will:
+	// 1. Get all the tasks associate with each job as well as the task steps
+	// 2. Delete all the task steps, tasks, jobs and run itself.
 	if err := db.WithTx(ctx, func(ctx context.Context) error {
+		for _, job := range jobs {
 
-		if err := actions_model.DeleteRunJobs(ctx, jobs); err != nil {
-			return err
+			if job.TaskID == 0 {
+				return fmt.Errorf("job not associate with any task")
+			}
+			if job.Status == actions_model.StatusRunning {
+				return fmt.Errorf("job is running, can't delete")
+			}
+
+			task, err := actions_model.GetTaskByID(ctx, job.TaskID)
+			if err != nil {
+				return fmt.Errorf("error while getting task: %v", err)
+			}
+
+			taskSteps, err := actions_model.GetTaskStepsByTaskID(ctx, task.ID)
+			if err != nil {
+				return fmt.Errorf("error while getting task steps: %v", err)
+			}
+
+			if err := actions_model.DeleteTaskSteps(ctx, taskSteps); err != nil {
+				return fmt.Errorf("error while deleting task steps: %v", err)
+			}
+
+			if err := actions_model.DeleteTask(ctx, task); err != nil {
+				return fmt.Errorf("error while deleting task: %v", err)
+			}
+
+			if err := actions_model.DeleteRunJob(ctx, job); err != nil {
+				return fmt.Errorf("error while deleting run job: %v", err)
+			}
 		}
 		if err := actions_model.DeleteRun(ctx, run); err != nil {
-			return err
+			return fmt.Errorf("error while deleting run: %v", err)
 		}
 		return nil
 	}); err != nil {