change
This commit is contained in:
parent
cdbe5396e2
commit
98e60ee9d3
|
@ -4,16 +4,22 @@ class CheckMirrorRake
|
||||||
def call
|
def call
|
||||||
SyncLog.sync_log("=====begin to check mirror======")
|
SyncLog.sync_log("=====begin to check mirror======")
|
||||||
empty_repo = []
|
empty_repo = []
|
||||||
|
empty_user = []
|
||||||
all_projects = Project.select(:id,:identifier,:user_id, :gpid, :forked_count,:is_public).includes(:owner, :repository)
|
all_projects = Project.select(:id,:identifier,:user_id, :gpid, :forked_count,:is_public).includes(:owner, :repository)
|
||||||
all_projects.each do |project|
|
all_projects.each do |project|
|
||||||
SyncLog.sync_log("=====check_project_id:#{project.id}======")
|
SyncLog.sync_log("=====check_project_id:#{project.id}======")
|
||||||
# CheckMirrorJob.perform_later(project)
|
# CheckMirrorJob.perform_later(project)
|
||||||
|
if project.owner.present?
|
||||||
response = Gitea::Repository::Branches::ListService.new(project.owner, project.identifier).call
|
response = Gitea::Repository::Branches::ListService.new(project.owner, project.identifier).call
|
||||||
|
else
|
||||||
|
response = "22"
|
||||||
|
empty_user.push(project.id)
|
||||||
|
end
|
||||||
unless response.present?
|
unless response.present?
|
||||||
empty_repo.push(project.id)
|
empty_repo.push(project.id)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
SyncLog.sync_log("=====completed_response:#{empty_repo}======")
|
SyncLog.sync_log("=====empty_repo_project_ids:#{empty_repo}======")
|
||||||
|
SyncLog.sync_log("=====empty_user_project_ids:#{empty_user}======")
|
||||||
end
|
end
|
||||||
end
|
end
|
|
@ -1,14 +0,0 @@
|
||||||
class CreateMirrorRake
|
|
||||||
# 运行示例: 检查哪些项目的repo不存在,bundle exec rails runner "CreateMirrorRake.new.call()"
|
|
||||||
|
|
||||||
def call
|
|
||||||
SyncLog.sync_log("=====begin to create mirror======")
|
|
||||||
empty_repo = []
|
|
||||||
all_projects = Project.select(:id,:identifier,:user_id, :gpid, :forked_count,:is_public).includes(:owner, :repository)
|
|
||||||
all_projects.each do |project|
|
|
||||||
SyncLog.sync_log("=====check_project_id:#{project.id}======")
|
|
||||||
CheckMirrorJob.perform_later(project)
|
|
||||||
end
|
|
||||||
SyncLog.sync_log("=====completed_response======")
|
|
||||||
end
|
|
||||||
end
|
|
Loading…
Reference in New Issue