Sha256: 77c13248ed34b25696cc401aeed659585fab5ecf0e94433c7dcf02f3fac5fcfe
Contents?: true
Size: 1.65 KB
Versions: 14
Compression:
Stored size: 1.65 KB
Contents
module Katello
class Api::Rhsm::CandlepinDynflowProxyController < Api::V2::ApiController
include Katello::Authentication::ClientAuthentication
include ForemanTasks::Triggers
include AbstractController::Callbacks
skip_before_action :authorize, :only => [:upload_package_profile]
before_action :find_host, :only => [:upload_package_profile]
before_action :authorize_client_or_user, :only => [:upload_package_profile]
#api :PUT, "/consumers/:id/packages", N_("Update installed packages")
#api :PUT, "/consumers/:id/profile", N_("Update installed packages")
#param :id, String, :desc => N_("UUID of the consumer"), :required => true
def upload_package_profile
User.as_anonymous_admin do
async_task(::Actions::Katello::Host::UploadPackageProfile, @host, request.raw_post)
end
render :json => Resources::Candlepin::Consumer.get(@host.subscription_facet.uuid)
end
def find_host(uuid = nil)
params = request.path_parameters
uuid ||= params[:id]
facet = Katello::Host::SubscriptionFacet.where(:uuid => uuid).first
if facet.nil?
# check with candlepin if consumer is Gone, raises RestClient::Gone
User.as_anonymous_admin { Resources::Candlepin::Consumer.get(uuid) }
fail HttpErrors::NotFound, _("Couldn't find consumer '%s'") % uuid
end
@host = facet.host
end
def authorize_client_or_user
client_authorized? || authorize
end
def client_authorized?
authorized = authenticate_client && User.consumer?
authorized = (User.current.uuid == @host.subscription_facet.uuid) if @host && User.consumer?
authorized
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems