39 lines
1.0 KiB
Ruby
39 lines
1.0 KiB
Ruby
class PublishTaskManagerJob < BaseActiveRecordJob
|
|
include Sidekiq::Worker
|
|
sidekiq_options :queue => :middle
|
|
|
|
def perform_with_ar_connection
|
|
regenerate_metadata_for_software_center
|
|
resign_repositories
|
|
regenerate_metadata
|
|
AbfWorkerService::Rpm.publish!
|
|
end
|
|
|
|
protected
|
|
|
|
def regenerate_metadata_for_software_center
|
|
Platform.main.waiting_for_regeneration.each do |platform|
|
|
AbfWorkerService::PlatformMetadata.new(platform).regenerate!
|
|
end
|
|
end
|
|
|
|
def resign_repositories
|
|
statuses = RepositoryStatus.platform_ready.
|
|
for_resign.includes(repository: :platform).readonly(false)
|
|
|
|
statuses.each do |repository_status|
|
|
AbfWorkerService::Repository.new(repository_status.repository).resign!(repository_status)
|
|
end
|
|
end
|
|
|
|
def regenerate_metadata
|
|
statuses = RepositoryStatus.platform_ready.
|
|
for_regeneration.includes(repository: :platform).readonly(false)
|
|
|
|
statuses.each do |repository_status|
|
|
AbfWorkerService::RepositoryMetadata.new(repository_status).regenerate!
|
|
end
|
|
end
|
|
|
|
|
|
end |