diff options
author | Lunny Xiao <xiaolunwen@gmail.com> | 2021-11-16 21:30:11 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-11-16 21:30:11 +0800 |
commit | 48ccd325a1b81a58ac6d1d5d94fc4e90974599ea (patch) | |
tree | e7bb31d69343dd9845a1b0df013b093c8720f14b /modules/cron/tasks_basic.go | |
parent | 447428f44659cee0e94e1c444f6291defac2bda2 (diff) | |
download | gitea-48ccd325a1b81a58ac6d1d5d94fc4e90974599ea.tar.gz gitea-48ccd325a1b81a58ac6d1d5d94fc4e90974599ea.zip |
Move some functions into services/repository (#17660)
Diffstat (limited to 'modules/cron/tasks_basic.go')
-rw-r--r-- | modules/cron/tasks_basic.go | 141 |
1 files changed, 0 insertions, 141 deletions
diff --git a/modules/cron/tasks_basic.go b/modules/cron/tasks_basic.go deleted file mode 100644 index a42c031b36..0000000000 --- a/modules/cron/tasks_basic.go +++ /dev/null @@ -1,141 +0,0 @@ -// Copyright 2020 The Gitea Authors. All rights reserved. -// Use of this source code is governed by a MIT-style -// license that can be found in the LICENSE file. - -package cron - -import ( - "context" - "time" - - "code.gitea.io/gitea/models" - "code.gitea.io/gitea/models/webhook" - "code.gitea.io/gitea/modules/migrations" - repository_service "code.gitea.io/gitea/modules/repository" - "code.gitea.io/gitea/modules/setting" - "code.gitea.io/gitea/services/auth" - mirror_service "code.gitea.io/gitea/services/mirror" -) - -func registerUpdateMirrorTask() { - RegisterTaskFatal("update_mirrors", &BaseConfig{ - Enabled: true, - RunAtStart: false, - Schedule: "@every 10m", - NoSuccessNotice: true, - }, func(ctx context.Context, _ *models.User, _ Config) error { - return mirror_service.Update(ctx) - }) -} - -func registerRepoHealthCheck() { - type RepoHealthCheckConfig struct { - BaseConfig - Timeout time.Duration - Args []string `delim:" "` - } - RegisterTaskFatal("repo_health_check", &RepoHealthCheckConfig{ - BaseConfig: BaseConfig{ - Enabled: true, - RunAtStart: false, - Schedule: "@midnight", - }, - Timeout: 60 * time.Second, - Args: []string{}, - }, func(ctx context.Context, _ *models.User, config Config) error { - rhcConfig := config.(*RepoHealthCheckConfig) - return repository_service.GitFsck(ctx, rhcConfig.Timeout, rhcConfig.Args) - }) -} - -func registerCheckRepoStats() { - RegisterTaskFatal("check_repo_stats", &BaseConfig{ - Enabled: true, - RunAtStart: true, - Schedule: "@midnight", - }, func(ctx context.Context, _ *models.User, _ Config) error { - return models.CheckRepoStats(ctx) - }) -} - -func registerArchiveCleanup() { - RegisterTaskFatal("archive_cleanup", &OlderThanConfig{ - BaseConfig: BaseConfig{ - Enabled: true, - RunAtStart: true, - Schedule: "@midnight", - }, - OlderThan: 24 * time.Hour, - }, func(ctx context.Context, _ *models.User, config Config) error { - acConfig := config.(*OlderThanConfig) - return models.DeleteOldRepositoryArchives(ctx, acConfig.OlderThan) - }) -} - -func registerSyncExternalUsers() { - RegisterTaskFatal("sync_external_users", &UpdateExistingConfig{ - BaseConfig: BaseConfig{ - Enabled: true, - RunAtStart: false, - Schedule: "@midnight", - }, - UpdateExisting: true, - }, func(ctx context.Context, _ *models.User, config Config) error { - realConfig := config.(*UpdateExistingConfig) - return auth.SyncExternalUsers(ctx, realConfig.UpdateExisting) - }) -} - -func registerDeletedBranchesCleanup() { - RegisterTaskFatal("deleted_branches_cleanup", &OlderThanConfig{ - BaseConfig: BaseConfig{ - Enabled: true, - RunAtStart: true, - Schedule: "@midnight", - }, - OlderThan: 24 * time.Hour, - }, func(ctx context.Context, _ *models.User, config Config) error { - realConfig := config.(*OlderThanConfig) - models.RemoveOldDeletedBranches(ctx, realConfig.OlderThan) - return nil - }) -} - -func registerUpdateMigrationPosterID() { - RegisterTaskFatal("update_migration_poster_id", &BaseConfig{ - Enabled: true, - RunAtStart: true, - Schedule: "@midnight", - }, func(ctx context.Context, _ *models.User, _ Config) error { - return migrations.UpdateMigrationPosterID(ctx) - }) -} - -func registerCleanupHookTaskTable() { - RegisterTaskFatal("cleanup_hook_task_table", &CleanupHookTaskConfig{ - BaseConfig: BaseConfig{ - Enabled: true, - RunAtStart: false, - Schedule: "@midnight", - }, - CleanupType: "OlderThan", - OlderThan: 168 * time.Hour, - NumberToKeep: 10, - }, func(ctx context.Context, _ *models.User, config Config) error { - realConfig := config.(*CleanupHookTaskConfig) - return webhook.CleanupHookTaskTable(ctx, webhook.ToHookTaskCleanupType(realConfig.CleanupType), realConfig.OlderThan, realConfig.NumberToKeep) - }) -} - -func initBasicTasks() { - registerUpdateMirrorTask() - registerRepoHealthCheck() - registerCheckRepoStats() - registerArchiveCleanup() - registerSyncExternalUsers() - registerDeletedBranchesCleanup() - if !setting.Repository.DisableMigrations { - registerUpdateMigrationPosterID() - } - registerCleanupHookTaskTable() -} |