Sha256: d0833756b17181e6175957427bcc0b8b9d2b1a6d3db2e138252f241f805a38f7
Contents?: true
Size: 1.22 KB
Versions: 67
Compression:
Stored size: 1.22 KB
Contents
module Actions
module Pulp
module Repository
class UpdateSchedule < Pulp::Abstract
input_format do
param :repo_id
param :schedule
param :enabled
end
def run
repo = ::Katello::Repository.find(input[:repo_id])
schedules = pulp_resources.repository_schedule.list(repo.pulp_id, repo.importer_type)
params = {}
params[:schedule] = input[:schedule] if input.key?(:schedule)
params[:enabled] = input[:enabled] if input.key?(:enabled)
if schedules.empty?
output[:response] = create(repo, params)
else
schedule = schedules.first
output[:response] = update(repo, schedule['_id'], params)
end
end
def create(repo, params)
pulp_resources.repository_schedule.create(
repo.pulp_id,
repo.importer_type,
params[:schedule],
params
)
end
def update(repo, schedule_id, params)
pulp_resources.repository_schedule.update(
repo.pulp_id,
repo.importer_type,
schedule_id,
params
)
end
end
end
end
end
Version data entries
67 entries across 67 versions & 1 rubygems