Refactoring Geo::ScheduleWikiRepoUpdateService

app/services/geo/schedule_wiki_repo_update_service.rb

@@ -8,18 +8,10 @@ module Geo
 
     def execute
       @projects.each do |project|
-        next unless can_update?(project['id'])
+        next unless Gitlab::Geo.current_node&.projects_include?(project['id'].to_i)
 
         GeoWikiRepositoryUpdateWorker.perform_async(project['id'], project['clone_url'])
       end
     end
-
-    private
-
-    def can_update?(project_id)
-      return true if Gitlab::Geo.current_node&.restricted_project_ids.nil?
-
-      Gitlab::Geo.current_node.restricted_project_ids.include?(project_id)
-    end
   end
 end

spec/services/geo/schedule_wiki_repo_update_service_spec.rb

@@ -16,6 +16,8 @@ describe Geo::ScheduleWikiRepoUpdateService do
     subject { described_class.new(projects) }
 
     it "enqueues a batch of IDs of wiki's projects to have their wiki repositories updated" do
+      create(:geo_node, :current)
+
       expect(GeoWikiRepositoryUpdateWorker).to receive(:perform_async)
         .once.with(project_1.id, 'git@example.com:mike/diaspora.git').and_return(spy)
       expect(GeoWikiRepositoryUpdateWorker).to receive(:perform_async)