Move FileDownloadDispatchWorker under the Geo namespace

app/workers/geo/file_download_dispatch_worker.rb

+module Geo
+  class FileDownloadDispatchWorker < Geo::BaseSchedulerWorker
+    private
+
+    def schedule_job(object_db_id, object_type)
+      job_id = GeoFileDownloadWorker.perform_async(object_type, object_db_id)
+
+      { id: object_db_id, type: object_type, job_id: job_id } if job_id
+    end
+
+    def load_pending_resources
+      lfs_object_ids = find_lfs_object_ids(db_retrieve_batch_size)
+      objects_ids    = find_object_ids(db_retrieve_batch_size)
+
+      interleave(lfs_object_ids, objects_ids)
+    end
+
+    def find_object_ids(limit)
+      downloaded_ids = find_downloaded_ids([:attachment, :avatar, :file])
+
+      Upload.where.not(id: downloaded_ids)
+            .order(created_at: :desc)
+            .limit(limit)
+            .pluck(:id, :uploader)
+            .map { |id, uploader| [id, uploader.sub(/Uploader\z/, '').downcase] }
+    end
+
+    def find_lfs_object_ids(limit)
+      downloaded_ids = find_downloaded_ids([:lfs])
+
+      LfsObject.where.not(id: downloaded_ids)
+               .order(created_at: :desc)
+               .limit(limit)
+               .pluck(:id)
+               .map { |id| [id, :lfs] }
+    end
+
+    def find_downloaded_ids(file_types)
+      downloaded_ids = Geo::FileRegistry.where(file_type: file_types).pluck(:file_id)
+      (downloaded_ids + scheduled_file_ids(file_types)).uniq
+    end
+
+    def scheduled_file_ids(types)
+      scheduled_jobs.select { |data| types.include?(data[:type]) }.map { |data| data[:id] }
+    end
+  end
+end

app/workers/geo_file_download_dispatch_worker.rb

-class GeoFileDownloadDispatchWorker < Geo::BaseSchedulerWorker
-  private
-
-  def schedule_job(object_db_id, object_type)
-    job_id = GeoFileDownloadWorker.perform_async(object_type, object_db_id)
-
-    { id: object_db_id, type: object_type, job_id: job_id } if job_id
-  end
-
-  def load_pending_resources
-    lfs_object_ids = find_lfs_object_ids(db_retrieve_batch_size)
-    objects_ids    = find_object_ids(db_retrieve_batch_size)
-
-    interleave(lfs_object_ids, objects_ids)
-  end
-
-  def find_object_ids(limit)
-    downloaded_ids = find_downloaded_ids([:attachment, :avatar, :file])
-
-    Upload.where.not(id: downloaded_ids)
-          .order(created_at: :desc)
-          .limit(limit)
-          .pluck(:id, :uploader)
-          .map { |id, uploader| [id, uploader.sub(/Uploader\z/, '').downcase] }
-  end
-
-  def find_lfs_object_ids(limit)
-    downloaded_ids = find_downloaded_ids([:lfs])
-
-    LfsObject.where.not(id: downloaded_ids)
-             .order(created_at: :desc)
-             .limit(limit)
-             .pluck(:id)
-             .map { |id| [id, :lfs] }
-  end
-
-  def find_downloaded_ids(file_types)
-    downloaded_ids = Geo::FileRegistry.where(file_type: file_types).pluck(:file_id)
-    (downloaded_ids + scheduled_file_ids(file_types)).uniq
-  end
-
-  def scheduled_file_ids(types)
-    scheduled_jobs.select { |data| types.include?(data[:type]) }.map { |data| data[:id] }
-  end
-end

config/initializers/1_settings.rb

@@ -412,7 +412,7 @@ Settings.cron_jobs['geo_repository_sync_worker']['cron'] ||= '*/5 * * * *'
 Settings.cron_jobs['geo_repository_sync_worker']['job_class'] ||= 'GeoRepositorySyncWorker'
 Settings.cron_jobs['geo_file_download_dispatch_worker'] ||= Settingslogic.new({})
 Settings.cron_jobs['geo_file_download_dispatch_worker']['cron'] ||= '5 * * * *'
-Settings.cron_jobs['geo_file_download_dispatch_worker']['job_class'] ||= 'GeoFileDownloadDispatchWorker'
+Settings.cron_jobs['geo_file_download_dispatch_worker']['job_class'] ||= 'Geo::FileDownloadDispatchWorker'
 Settings.cron_jobs['import_export_project_cleanup_worker'] ||= Settingslogic.new({})
 Settings.cron_jobs['import_export_project_cleanup_worker']['cron'] ||= '0 * * * *'
 Settings.cron_jobs['import_export_project_cleanup_worker']['job_class'] = 'ImportExportProjectCleanupWorker'

spec/workers/geo_file_download_dispatch_worker_spec.rb → spec/workers/geo/file_download_dispatch_worker_spec.rb

 require 'spec_helper'
 
-describe GeoFileDownloadDispatchWorker do
+describe Geo::FileDownloadDispatchWorker do
   before do
     @primary = create(:geo_node, :primary, host: 'primary-geo-node')
     @secondary = create(:geo_node, :current)