Sha256: c67d635c1b010add4979ae90a65526f178504d169c3cd4025d0d1adc8a9a061b
Contents?: true
Size: 1.57 KB
Versions: 16
Compression:
Stored size: 1.57 KB
Contents
require 'tempfile'
module ForemanInventoryUpload
module Async
class UploadReportJob < ShellProcess
def self.output_label(label)
"upload_for_#{label}"
end
def perform(filename, organization_id)
@filename = filename
@organization = Organization.find(organization_id)
Tempfile.create([@organization.name, '.pem']) do |cer_file|
cer_file.write(rh_credentials[:cert])
cer_file.write(rh_credentials[:key])
cer_file.flush
@cer_path = cer_file.path
super(UploadReportJob.output_label(organization_id))
end
end
def command
File.join(File.dirname(@filename), ForemanInventoryUpload.upload_script_file)
end
def env
env_vars = super.merge(
'FILES' => @filename,
'CER_PATH' => @cer_path
)
if http_proxy_string
env_vars['http_proxy'] = http_proxy_string
env_vars['https_proxy'] = http_proxy_string
end
env_vars
end
def http_proxy_string
@http_proxy_string ||= begin
if Setting[:content_default_http_proxy]
HttpProxy.unscoped.find_by(name: Setting[:content_default_http_proxy])&.full_url
end
end
end
def rh_credentials
@rh_credentials ||= begin
candlepin_id_certificate = @organization.owner_details['upstreamConsumer']['idCert']
{
cert: candlepin_id_certificate['cert'],
key: candlepin_id_certificate['key'],
}
end
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems