Use services to schedule workers in geo log daemon

Instead of scheduling the workers from the code, use service with
`async_execute` instead.

app/services/geo/move_repository_service.rb

@@ -11,6 +11,10 @@ module Geo
       @new_path_with_namespace = new_path_with_namespace
     end
 
+    def async_execute
+      GeoRepositoryMoveWorker.perform_async(id, name, old_path_with_namespace, new_path_with_namespace)
+    end
+
     def execute
       project = Project.find(id)
       project.expire_caches_before_rename(old_path_with_namespace)

app/services/geo/repository_destroy_service.rb

+module Geo
+  class RepositoryDestroyService
+    attr_reader :id, :name, :path_with_namespace
+
+    def initialize(id, name, path)
+      @id = id
+      @name = name
+      @path_with_namespace = path
+    end
+
+    def async_execute
+      GeoRepositoryDestroyWorker.perform_async(id, name, path_with_namespace)
+    end
+  end
+end

lib/gitlab/geo/log_cursor/daemon.rb

@@ -132,10 +132,11 @@ module Gitlab
           # GeoRepositoryDestroyWorker to avoid doing this
           full_path = File.join(deleted_event.repository_storage_path,
                                 deleted_event.deleted_path)
-          job_id = ::GeoRepositoryDestroyWorker.perform_async(
-            deleted_event.project_id,
-            deleted_event.deleted_project_name,
-            full_path)
+          job_id = ::Geo::RepositoryDestroyService
+                     .new(deleted_event.project_id,
+                          deleted_event.deleted_project_name,
+                          full_path)
+                     .async_execute
           log_event_info(event.created_at,
                          message: "Deleted project",
                          project_id: deleted_event.project_id,
@@ -164,8 +165,9 @@ module Gitlab
           old_path = renamed_event.old_path_with_namespace
           new_path = renamed_event.new_path_with_namespace
 
-          job_id = ::GeoRepositoryMoveWorker.perform_async(
-            renamed_event.project_id, "", old_path, new_path)
+          job_id = ::Geo::MoveRepositoryService
+                     .new(renamed_event.project_id, "", old_path, new_path)
+                     .async_execute
 
           log_event_info(event.created_at,
                          message: "Renaming project",

spec/services/geo/move_repository_service_spec.rb

@@ -17,4 +17,18 @@ describe Geo::MoveRepositoryService do
       expect(File.directory?("#{full_new_path}.git")).to be_truthy
     end
   end
+
+  describe '#async_execute' do
+    it 'starts the worker' do
+      expect(GeoRepositoryMoveWorker).to receive(:perform_async)
+
+      subject.async_execute
+    end
+
+    it 'returns job id' do
+      allow(GeoRepositoryMoveWorker).to receive(:perform_async).and_return('foo')
+
+      expect(subject.async_execute).to eq('foo')
+    end
+  end
 end