+ Message string `xorm:"TEXT"` // if task failed, saved the error reason, it could be a JSON string of TranslatableMessage or a plain message

+const TaskTypeMigrateRepo TaskType = iota // migrate repository from external or local disk

+ TaskStatusQueued TaskStatus = iota // 0 task is queued

+ TaskStatusStopped // 2 task is stopped (never used)

+migrate.migrating_failed.error = Failed to migrate: %s

+migrate.cancel_migrating_title = Cancel Migration

+migrate.cancel_migrating_confirm = Do you want to cancel this migration?

+ admin_model "code.gitea.io/gitea/models/admin"

+

+func MigrateCancelPost(ctx *context.Context) {

+ migratingTask, err := admin_model.GetMigratingTask(ctx.Repo.Repository.ID)

+ if err != nil {

+ log.Error("GetMigratingTask: %v", err)

+ ctx.Redirect(ctx.Repo.Repository.Link())

+ return

+ }

+ if migratingTask.Status == structs.TaskStatusRunning {

+ taskUpdate := &admin_model.Task{ID: migratingTask.ID, Status: structs.TaskStatusFailed, Message: "canceled"}

+ if err = taskUpdate.UpdateCols("status", "message"); err != nil {

+ ctx.ServerError("task.UpdateCols", err)

+ return

+ }

+ }

+ ctx.Redirect(ctx.Repo.Repository.Link())

+}

+ m.Post("/migrate/cancel", repo.MigrateCancelPost) // this handler must be under "settings", otherwise this incomplete repo can't be accessed

+

+ // do not delete the repository, otherwise the end users won't be able to see the last error message

+ "time"

+ return fmt.Errorf("you have already reached your limit of %d repositories", owner.MaxCreationLimit())

+ return errors.New("the repository name is already used")

+ return fmt.Errorf("the repository name '%s' is reserved", err.(db.ErrNameReserved).Name)

+ return fmt.Errorf("the pattern '%s' is not allowed in a repository name", err.(db.ErrNamePatternNotAllowed).Pattern)

+ log.Error("runMigrateTask[%d] by DoerID[%d] to RepoID[%d] for OwnerID[%d] failed: %v", t.ID, t.DoerID, t.RepoID, t.OwnerID, err)

+

+ if err := t.UpdateCols("status", "message", "end_time"); err != nil {

+ // then, do not delete the repository, otherwise the users won't be able to see the last error

+ ctx, cancel, finished := pm.AddContext(graceful.GetManager().ShutdownContext(), fmt.Sprintf("MigrateTask: %s/%s", t.Owner.Name, opts.RepoName))

+ // check whether the task should be canceled, this goroutine is also managed by process manager

+ go func() {

+ for {

+ select {

+ case <-time.After(2 * time.Second):

+ case <-ctx.Done():

+ return

+ }

+ task, _ := admin_model.GetMigratingTask(t.RepoID)

+ if task != nil && task.Status != structs.TaskStatusRunning {

+ log.Debug("MigrateTask[%d] by DoerID[%d] to RepoID[%d] for OwnerID[%d] is canceled due to status is not 'running'", t.ID, t.DoerID, t.RepoID, t.OwnerID)

+ cancel()

+ return

+ }

+ }

+ }()

+

+

+ err = errors.New("the repository name is already used")

+ return fmt.Errorf("authentication failed: %w", err)

+ return fmt.Errorf("migration failed: %w", err)

+ Status: structs.TaskStatusQueued,

+ <div id="repo_migrating" class="sixteen wide center aligned centered column" data-migrating-task-id="{{.MigrateTask.ID}}">

+ {{if .Permission.IsAdmin}}

+ {{if .Failed}}

+ {{else}}

+ <button class="ui basic red show-modal button" data-modal="#cancel-repo-modal">{{.locale.Tr "cancel"}}</button>

+ {{end}}

+

+

+<div class="ui g-modal-confirm modal" id="cancel-repo-modal">

+ <div class="header">

+ {{.locale.Tr "repo.migrate.cancel_migrating_title"}}

+ </div>

+ <form action="{{.Link}}/settings/migrate/cancel" method="post">

+ {{.CsrfTokenHtml}}

+ <div class="content">

+ {{.locale.Tr "repo.migrate.cancel_migrating_confirm"}}

+ </div>

+ {{template "base/modal_actions_confirm" .}}

+ </form>

+</div>

+

+const {appSubUrl} = window.config;

+ const $repoMigrating = $('#repo_migrating');

+ if (!$repoMigrating.length) return;

+

+ const task = $repoMigrating.attr('data-migrating-task-id');

+

+ // returns true if the refresh still need to be called after a while

+ const refresh = async () => {

+ const res = await fetch(`${appSubUrl}/user/task/${task}`);

+ if (res.status !== 200) return true; // continue to refresh if network error occurs

+

+ const data = await res.json();

+

+ // for all status

+ if (data.message) {

+ $('#repo_migrating_progress_message').text(data.message);

+ }

+

+ // TaskStatusFinished

+ if (data.status === 4) {

+ window.location.reload();

+ return false;

+

+ // TaskStatusFailed

+ if (data.status === 3) {

+ hideElem('#repo_migrating_progress');

+ hideElem('#repo_migrating');

+ showElem('#repo_migrating_failed');

+ showElem('#repo_migrating_failed_image');

+ $('#repo_migrating_failed_error').text(data.message);

+ return false;

+ }

+

+ return true; // continue to refresh

+ };

+

+ const syncTaskStatus = async () => {

+ let doNextRefresh = true;

+ try {

+ doNextRefresh = await refresh();

+ } finally {

+ if (doNextRefresh) {

+ setTimeout(syncTaskStatus, 2000);

+ }

+ };

+

+ syncTaskStatus(); // no await