Sha256: 9d8c1f20c1600ecc42efec9088a35646437ca8fbc0e6df2e3f166113cd258b5b
Contents?: true
Size: 851 Bytes
Versions: 32
Compression:
Stored size: 851 Bytes
Contents
module Katello
module Resources
module Candlepin
class UpstreamJob < UpstreamCandlepinResource
class << self
NOT_FINISHED_STATES = %w(CREATED WAITING PENDING RUNNING).freeze unless defined? NOT_FINISHED_STATES
API_URL = 'https://subscription.rhsm.redhat.com/subscription'.freeze
def not_finished?(job)
NOT_FINISHED_STATES.include?(job[:state])
end
def get(id, upstream)
url = API_URL
response = Resources::Candlepin::UpstreamConsumer.get_export("#{url}#{path(id)}", upstream['idCert']['cert'],
upstream['idCert']['key'], nil)
job = JSON.parse(response)
job.with_indifferent_access
end
def path(id = nil)
"/jobs/#{id}"
end
end
end
end
end
end
Version data entries
32 entries across 32 versions & 1 rubygems