/refresh_wikis endpoint and workers to handle sync on secondaries

app/models/project_wiki.rb

@@ -54,6 +54,10 @@ class ProjectWiki
     end
   end
 
+  def repository_exists?
+    !!repository.exists?
+  end
+
   def empty?
     pages.empty?
   end

app/services/geo/schedule_wiki_repo_update_service.rb

+module Geo
+  class ScheduleWikiRepoUpdateService
+    attr_reader :projects
+
+    def initialize(projects)
+      @projects = projects
+    end
+
+    def execute
+      @projects.each do |project|
+        GeoWikiRepositoryUpdateWorker.perform_async(project['id'], project['clone_url'])
+      end
+    end
+  end
+end

app/workers/geo_repository_update_worker.rb

@@ -9,13 +9,13 @@ class GeoRepositoryUpdateWorker
   def perform(project_id, clone_url)
     @project = Project.find(project_id)
 
-    fetch_repository(@project, clone_url)
+    fetch_repository(clone_url)
   end
 
   private
 
-  def fetch_repository(project, remote_url)
-    project.create_repository unless project.repository_exists?
-    project.repository.fetch_geo_mirror(remote_url)
+  def fetch_repository(remote_url)
+    @project.create_repository unless @project.repository_exists?
+    @project.repository.fetch_geo_mirror(remote_url)
   end
 end

app/workers/geo_wiki_repository_update_worker.rb

+class GeoWikiRepositoryUpdateWorker
+  include Sidekiq::Worker
+  include Gitlab::ShellAdapter
+
+  sidekiq_options queue: :default
+
+  attr_accessor :project
+
+  def perform(project_id, clone_url)
+    @project = Project.find(project_id)
+
+    fetch_repository(clone_url)
+  end
+
+  private
+
+  def fetch_repository(remote_url)
+    # Second .wiki call returns a Gollum::Wiki, and it will always create the physical repository when not found
+    if @project.wiki.wiki.exist?
+      @project.wiki.repository.fetch_geo_mirror(remote_url)
+    end
+  end
+end

lib/api/geo.rb

@@ -13,6 +13,16 @@ module API
         required_attributes! [:projects]
         ::Geo::ScheduleRepoUpdateService.new(params[:projects]).execute
       end
+
+      # Enqueue a batch of IDs of wiki's projects to have their
+      # wiki repositories updated
+      #
+      # Example request:
+      #   POST /refresh_wikis
+      post 'refresh_wikis' do
+        required_attributes! [:projects]
+        ::Geo::ScheduleWikiRepoUpdateService.new(params[:projects]).execute
+      end
     end
   end
 end