|
|
|
@@ -1,7 +1,7 @@ |
|
|
|
class MigrateRemoteRepositoryJob < ApplicationJob |
|
|
|
queue_as :default |
|
|
|
|
|
|
|
def perform(repo_id, token, params) |
|
|
|
def perform(repo_id, token, user_id, params) |
|
|
|
repo = Repository.find_by(id: repo_id) |
|
|
|
return if repo.blank? |
|
|
|
|
|
|
|
@@ -14,11 +14,6 @@ class MigrateRemoteRepositoryJob < ApplicationJob |
|
|
|
repo&.mirror&.succeeded! |
|
|
|
## open jianmu devops |
|
|
|
project_id = repo&.project&.id |
|
|
|
if repo&.project.present? && repo&.project.owner.is_a?(Organization) |
|
|
|
user_id = repo&.project.members.take&.user_id |
|
|
|
else |
|
|
|
user_id = repo&.project.user_id |
|
|
|
end |
|
|
|
puts "############ mirror project_id,user_id: #{project_id},#{user_id} ############" |
|
|
|
OpenProjectDevOpsJob.perform_later(project_id, user_id) if project_id.present? && user_id.present? |
|
|
|
puts "############ mirror status: #{repo.mirror.status} ############" |
|
|
|
|