Add support to enqueue wiki updates

app/services/geo/enqueue_wiki_update_service.rb

+module Geo
+  class EnqueueWikiUpdateService
+    attr_reader :project
+
+    def initialize(project)
+      @queue = Gitlab::Geo::UpdateQueue.new('updated_wikis')
+      @project = project
+    end
+
+    def execute
+      @queue.store({ id: @project.id, clone_url: @project.wiki.url_to_repo })
+    end
+  end
+end

lib/gitlab/geo.rb

@@ -38,6 +38,10 @@ module Gitlab
       ::Geo::EnqueueProjectUpdateService.new(project).execute
     end
 
+    def self.notify_wiki_update(project)
+      ::Geo::EnqueueWikiUpdateService.new(project).execute
+    end
+
     def self.bulk_notify_job
       Sidekiq::Cron::Job.find('geo_bulk_notify_worker')
     end

spec/services/geo/enqueue_wiki_update_service_spec.rb

+describe Geo::EnqueueWikiUpdateService, service: true do
+  subject { Geo::EnqueueWikiUpdateService.new(project) }
+  let(:project) { double(:project) }
+  let(:fake_url) { 'git@localhost:repo/path.git' }
+  let(:fake_id) { 999 }
+  let(:queue) { subject.instance_variable_get(:@queue) }
+
+  before(:each) do
+    queue.empty!
+    expect(project).to receive_message_chain(:wiki, :url_to_repo) { fake_url }
+    expect(project).to receive(:id) { fake_id }
+  end
+
+  describe '#execute' do
+    let(:stored_data) { queue.first }
+    before(:each) { subject.execute }
+
+    it 'persists id and clone_url to redis queue' do
+      expect(stored_data).to have_key('id')
+      expect(stored_data).to have_key('clone_url')
+    end
+
+    it 'persisted id is equal to original' do
+      expect(stored_data['id']).to eq(fake_id)
+    end
+
+    it 'persisted clone_url is equal to original' do
+      expect(stored_data['clone_url']).to eq(fake_url)
+    end
+  end
+end