Fixes #33525 - Add debs packages_restrict_latest

app/controllers/katello/api/v2/debs_controller.rb

@@ -98,6 +98,16 @@ def custom_index_relation(collection)
       collection
     end
 
+    def final_custom_index_relation(collection)
+      # :packages_restrict_latest is intended to filter the result set after all
+      # other constraints have been applied, including the scoped_search
+      # constraints.  If any constraints are applied after this, then a package
+      # will not be returned if its latest version does not match those
+      # constraints, even if an older version does match those constraints.
+      collection = Katello::Deb.latest(collection) if ::Foreman::Cast.to_bool(params[:packages_restrict_latest])
+      collection
+    end
+
     private
 
     def find_hosts

app/models/katello/deb.rb

@@ -95,8 +95,13 @@ def self.applicable_to_hosts(hosts)
         where("#{Katello::Host::ContentFacet.table_name}.host_id" => hosts).distinct
     end
 
-    def self.latest(_relation)
-      fail 'NotImplemented'
+    def self.latest(relation)
+      # This might be very slow
+      return relation.joins(
+        "LEFT OUTER JOIN(#{relation.to_sql}) AS katello_debs2 ON " \
+        'katello_debs.name = katello_debs2.name AND katello_debs.architecture = katello_debs2.architecture AND ' \
+        'deb_version_cmp(katello_debs.version, katello_debs2.version) < 0 ' \
+      ).where('katello_debs2.id IS NULL')
     end
   end
 end

test/controllers/api/v2/debs_controller_test.rb

@@ -7,6 +7,7 @@ def models
       @version = ContentViewVersion.first
       @deb = katello_debs(:one)
       @host = hosts(:one)
+      @org = get_organization
     end
 
     def setup
@@ -70,6 +71,15 @@ def test_index_with_available_for_content_view_version
       assert_includes ids, @deb.id
     end
 
+    def test_index_with_latest
+      response = get :index, params: { :packages_restrict_latest => true, :organization_id => @org.id }
+
+      assert_response :success
+      ids = JSON.parse(response.body)['results'].map { |p| p['id'] }
+      assert_includes ids, katello_debs(:one_new).id
+      refute_includes ids, @deb.id
+    end
+
     def test_index_protected
       assert_protected_action(:index, @auth_permissions, @unauth_permissions) do
         get :index, params: { :repository_id => @repo.id }