Refactor legacy finder to find registries verification failed

These changes use the new finder when FDW is enabled without selective
sync to avoid code duplication.

ee/app/finders/geo/legacy_project_registry_verification_failed_finder.rb

@@ -22,30 +22,16 @@ module Geo
     end
 
     def execute
-      if selective_sync?
-        failed_registries_for_selective_sync
-      else
-        failed_registries
-      end
-    end
-
-    private
-
-    attr_reader :type
-
-    def failed_registries
-      Geo::ProjectRegistry.verification_failed(type)
-    end
-
-    # rubocop: disable CodeReuse/ActiveRecord
-    def failed_registries_for_selective_sync
       legacy_inner_join_registry_ids(
-        failed_registries,
-        current_node.projects.pluck(:id),
+        Geo::ProjectRegistry.verification_failed(type),
+        current_node.projects.pluck_primary_key,
         Geo::ProjectRegistry,
         foreign_key: :project_id
       )
     end
-    # rubocop: enable CodeReuse/ActiveRecord
+
+    private
+
+    attr_reader :type
   end
 end

ee/spec/finders/geo/legacy_project_registry_verification_failed_finder_spec.rb

@@ -3,8 +3,6 @@
 require 'spec_helper'
 
 describe Geo::LegacyProjectRegistryVerificationFailedFinder, :geo do
-  include EE::GeoHelpers
-
   describe '#execute' do
     let(:node) { create(:geo_node) }
     let(:group_1) { create(:group) }
@@ -22,102 +20,82 @@ describe Geo::LegacyProjectRegistryVerificationFailedFinder, :geo do
     let!(:registry_repository_verification_failed_broken_shard) { create(:geo_project_registry, :repository_verification_failed, :wiki_verified, project: project_5) }
     let!(:registry_verified) { create(:geo_project_registry, :repository_verified, :wiki_verified) }
 
-    shared_examples 'finds registries that verification failed' do
-      context 'with repository type' do
-        subject { described_class.new(current_node: node, type: :repository) }
+    context 'with repository type' do
+      subject { described_class.new(current_node: node, type: :repository) }
 
-        context 'without selective sync' do
-          it 'returns all failed registries' do
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_repository_verification_failed_broken_shard)
-          end
-        end
-
-        context 'with selective sync by namespace' do
-          it 'returns failed registries where projects belongs to the namespaces' do
-            node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
-
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed)
-          end
+      context 'without selective sync' do
+        it 'returns all failed registries' do
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_repository_verification_failed_broken_shard)
         end
+      end
 
-        context 'with selective sync by shard' do
-          it 'returns failed registries where projects belongs to the shards' do
-            node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
+      context 'with selective sync by namespace' do
+        it 'returns failed registries where projects belongs to the namespaces' do
+          node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
 
-            expect(subject.execute).to contain_exactly(registry_repository_verification_failed_broken_shard)
-          end
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed)
         end
       end
 
-      context 'with wiki type' do
-        subject { described_class.new(current_node: node, type: :wiki) }
+      context 'with selective sync by shard' do
+        it 'returns failed registries where projects belongs to the shards' do
+          node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
 
-        context 'without selective sync' do
-          it 'returns all failed registries' do
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_wiki_verification_failed, registry_wiki_verification_failed_broken_shard)
-          end
+          expect(subject.execute).to contain_exactly(registry_repository_verification_failed_broken_shard)
         end
+      end
+    end
 
-        context 'with selective sync by namespace' do
-          it 'returns failed registries where projects belongs to the namespaces' do
-            node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
+    context 'with wiki type' do
+      subject { described_class.new(current_node: node, type: :wiki) }
 
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_wiki_verification_failed)
-          end
+      context 'without selective sync' do
+        it 'returns all failed registries' do
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_wiki_verification_failed, registry_wiki_verification_failed_broken_shard)
         end
+      end
 
-        context 'with selective sync by shard' do
-          it 'returns failed registries where projects belongs to the shards' do
-            node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
+      context 'with selective sync by namespace' do
+        it 'returns failed registries where projects belongs to the namespaces' do
+          node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
 
-            expect(subject.execute).to contain_exactly(registry_wiki_verification_failed_broken_shard)
-          end
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_wiki_verification_failed)
         end
       end
 
-      context 'with no type' do
-        subject { described_class.new(current_node: node, type: :invalid) }
+      context 'with selective sync by shard' do
+        it 'returns failed registries where projects belongs to the shards' do
+          node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
 
-        context 'without selective sync' do
-          it 'returns all failed registries' do
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_wiki_verification_failed, registry_repository_verification_failed_broken_shard, registry_wiki_verification_failed_broken_shard)
-          end
+          expect(subject.execute).to contain_exactly(registry_wiki_verification_failed_broken_shard)
         end
+      end
+    end
 
-        context 'with selective sync by namespace' do
-          it 'returns all failed registries where projects belongs to the namespaces' do
-            node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
+    context 'with no type' do
+      subject { described_class.new(current_node: node, type: :invalid) }
 
-            expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_wiki_verification_failed)
-          end
+      context 'without selective sync' do
+        it 'returns all failed registries' do
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_wiki_verification_failed, registry_repository_verification_failed_broken_shard, registry_wiki_verification_failed_broken_shard)
         end
+      end
 
-        context 'with selective sync by shard' do
-          it 'returns all failed registries where projects belongs to the shards' do
-            node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
+      context 'with selective sync by namespace' do
+        it 'returns all failed registries where projects belongs to the namespaces' do
+          node.update!(selective_sync_type: 'namespaces', namespaces: [group_1, nested_group_1])
 
-            expect(subject.execute).to contain_exactly(registry_repository_verification_failed_broken_shard, registry_wiki_verification_failed_broken_shard)
-          end
+          expect(subject.execute).to contain_exactly(registry_verification_failed, registry_repository_verification_failed, registry_wiki_verification_failed)
         end
       end
-    end
-
-    # Disable transactions via :delete method because a foreign table
-    # can't see changes inside a transaction of a different connection.
-    context 'FDW', :delete do
-      before do
-        skip('FDW is not configured') unless Gitlab::Geo::Fdw.enabled?
-      end
 
-      include_examples 'finds registries that verification failed'
-    end
+      context 'with selective sync by shard' do
+        it 'returns all failed registries where projects belongs to the shards' do
+          node.update!(selective_sync_type: 'shards', selective_sync_shards: ['broken'])
 
-    context 'Legacy' do
-      before do
-        stub_fdw_disabled
+          expect(subject.execute).to contain_exactly(registry_repository_verification_failed_broken_shard, registry_wiki_verification_failed_broken_shard)
+        end
       end
-
-      include_examples 'finds registries that verification failed'
     end
   end
 end