[review] delayed_cron_job を入れ替える rake タスク

lib/sg_fargate_rails/delayed_cron_job_utility.rb

@@ -0,0 +1,59 @@
+module SgFargateRails
+  class DelayedCronJobUtility
+    class << self
+      def refresh_cron_jobs!
+        DelayedCronJobUtility.new.refresh_cron_jobs!
+      end
+
+      def cron_jobs
+        Delayed::Job.where.not(cron: nil)
+      end
+    end
+
+    def initialize
+      unless defined?(::DelayedCronJob)
+        raise 'DelayedCronJob not defined.'
+      end
+    end
+
+    def refresh_cron_jobs!
+      ActiveRecord::Base.transaction do
+        destroy_cron_jobs!
+        create_cron_jobs!
+      end
+    end
+
+    private
+
+      def destroy_cron_jobs!
+        DelayedCronJobUtility.cron_jobs.find_each do |delayed_job|
+          # NOTE: 念のため cron が設定されていることを再チェック
+          if delayed_job.cron.present?
+            delayed_job.destroy!
+          end
+        end
+      end
+
+      def create_cron_jobs!
+        cron_settings.each do |_name, options|
+          job_class = options[:class]
+          job_class = options[:class].constantize unless job_class.is_a?(Class)
+
+          args = options[:args]
+          if args.blank?
+            job_class.set(cron: options[:cron]).perform_later
+          elsif args.is_a?(Array)
+            job_class.set(cron: options[:cron]).perform_later(*args)
+          elsif args.is_a?(Hash)
+            job_class.set(cron: options[:cron]).perform_later(**args)
+          else
+            raise 'invalid args option.'
+          end
+        end
+      end
+
+      def cron_settings
+        @cron_settings ||= Rails.application.config_for('delayed_cron_jobs')
+      end
+  end
+end

lib/sg_fargate_rails/railtie.rb

@@ -1,4 +1,5 @@
 require 'sg_fargate_rails/adjust_cloudfront_headers'
+require 'sg_fargate_rails/delayed_cron_job_utility'
 require 'sg_fargate_rails/healthcheck'
 require 'sg_fargate_rails/maintenance'
 require 'sg_fargate_rails/remote_ip'

lib/tasks/sg_fargate_rails.rake

@@ -29,4 +29,11 @@ namespace :sg_fargate_rails do
       )
     end
   end
+
+  desc 'Refresh Delayed Cron Jobs'
+  task refresh_delayed_cron_jobs: :environment do
+    Rails.logger.info('[refresh_delayed_cron_jobs] refresh begin...')
+    SgFargateRails::DelayedCronJobUtility.refresh_cron_jobs!
+    Rails.logger.info('[refresh_delayed_cron_jobs] refresh end.')
+  end
 end