diff --git a/app/jobs/migrate_remote_repository_job.rb b/app/jobs/migrate_remote_repository_job.rb index 28c547648..75cf0613f 100644 --- a/app/jobs/migrate_remote_repository_job.rb +++ b/app/jobs/migrate_remote_repository_job.rb @@ -2,20 +2,14 @@ class MigrateRemoteRepositoryJob < ApplicationJob queue_as :default def perform(repo_id, token, params) + puts "############ perform: repo_id: #{repo_id}, token: #{token}, params: #{params}}" repo = Repository.find_by(id: repo_id) return if repo.blank? gitea_repository = Gitea::Repository::MigrateService.new(token, params).call - sync_project(repo, gitea_repository) - sync_repository(repo, gitea_repository) - end - - private - def sync_project(repo, gitea_repository) - repo&.project.update_columns(gpid: gitea_repository["id"], identifier: gitea_repository["name"]) if gitea_repository - end - - def sync_repository(repository, gitea_repository) - repository.mirror.update_columns(statuses: Mirror.statuses[:succeeded]) if gitea_repository + if gitea_repository + repo&.project&.update_columns(gpid: gitea_repository["id"], identifier: gitea_repository["name"]) + repo&.mirror&.update_columns(status: Mirror.statuses[:succeeded]) + end end end