lib/runcible/extensions/repository.rb in runcible-0.1.3 vs lib/runcible/extensions/repository.rb in runcible-0.1.4

- old
+ new

@@ -88,13 +88,11 @@ end def self.rpm_remove(repo_id, package_ids) criteria = {:type_ids => ['rpm'], :filters => {}} criteria[:filters]['association'] = {'unit_id' => {'$in' => package_ids}} - payload = {} - payload[:criteria] = criteria - self.unassociate_units(repo_id, payload) + self.unassociate_units(repo_id, criteria) end #optional # errata_ids def self.errata_copy(source_repo_id, destination_repo_id, optional={}) @@ -105,12 +103,11 @@ end def self.errata_remove(repo_id, errata_ids) criteria = {:type_ids => ['erratum'], :filters => {}} criteria[:filters][:unit] = { :id=>{ '$in' => errata_ids } } - payload = {:criteria => criteria} - self.unassociate_units(repo_id, payload) + self.unassociate_units(repo_id, criteria) end #optoinal # distribution_ids def self.distribution_copy(source_repo_id, destination_repo_id, optional={}) @@ -121,27 +118,20 @@ end def self.distribution_remove(repo_id, distribution_id) criteria = {:type_ids => ['distribution'], :filters => {}} criteria[:filters][:unit] = { :id=>{ '$in' => [distribution_id] } } - payload = {:criteria => criteria} - self.unassociate_units(repo_id, payload) + self.unassociate_units(repo_id, criteria) end def self.rpm_ids(id) - criteria = {:type_ids=>['rpm'], - :sort => { - :unit => [ ['name', 'ascending'], ['version', 'descending'] ] - }} + criteria = {:type_ids=>['rpm']} self.unit_search(id, criteria).collect{|i| i['unit_id']} end def self.rpms(id) - criteria = {:type_ids=>['rpm'], - :sort => { - :unit => [ ['name', 'ascending'], ['version', 'descending'] ] - }} + criteria = {:type_ids=>['rpm']} self.unit_search(id, criteria).collect{|i| i['metadata'].with_indifferent_access} end def self.packages_by_nvre(id, name, version=nil, release=nil, epoch=nil) and_condition = [] @@ -161,48 +151,28 @@ }} self.unit_search(id, criteria).collect{|p| p['metadata'].with_indifferent_access} end def self.errata_ids(id, filter = {}) - criteria = { - :type_ids=>['erratum'], - :sort => { - :unit => [ ['title', 'ascending'] ] - } - } + criteria = {:type_ids=>['erratum']} self.unit_search(id, criteria).collect{|i| i['unit_id']} end def self.distributions(id) - criteria = { - :type_ids=>['distribution'], - :sort => { - :unit => [ ['id', 'ascending'] ] - } - } + criteria = {:type_ids=>['distribution']} self.unit_search(id, criteria).collect{|i| i['metadata'].with_indifferent_access} end def self.package_groups(id) - criteria = { - :type_ids=>[Runcible::Extensions::PackageGroup::TYPE], - :sort => { - :unit => [ ['id', 'ascending'] ] - } - } + criteria = {:type_ids=>[Runcible::Extensions::PackageGroup::TYPE]} self.unit_search(id, criteria).collect{|i| i['metadata'].with_indifferent_access} end def self.package_categories(id) - criteria = { - :type_ids=>[Runcible::Extensions::PackageCategory::TYPE], - :sort => { - :unit => [ ['id', 'ascending'] ] - } - } + criteria = {:type_ids=>[Runcible::Extensions::PackageCategory::TYPE]} self.unit_search(id, criteria).collect{|i| i['metadata'].with_indifferent_access} end def self.create_or_update_schedule(repo_id, type, schedule) schedules = Runcible::Resources::RepositorySchedule.list(repo_id, type)