Contents

# frozen_string_literal: true

module Motor
  module Alerts
    module Scheduler
      SCHEDULER_INTERVAL = 10.seconds
      CHECK_BEHIND_DURATION = 15.minutes

      SCHEDULER_TASK = Concurrent::TimerTask.new(
        execution_interval: SCHEDULER_INTERVAL
      ) { Motor::Alerts::Scheduler.call }

      ALREADY_PROCESSED_CACHE = ActiveSupport::Cache::MemoryStore.new(size: 5.megabytes)

      module_function

      def call
        ScheduledAlertsCache.all.each do |alert|
          next unless (CHECK_BEHIND_DURATION.ago..Time.current).cover?(alert.cron.previous_time.to_local_time)

          ALREADY_PROCESSED_CACHE.fetch("#{alert.id}-#{alert.cron.previous_time.to_i}") do
            Motor::AlertSendingJob.perform_later(alert).job_id
          end
        rescue StandardError => e
          Rials.logger.error(e)
        end
      end
    end
  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

Version	Path
motor-admin-0.1.37	lib/motor/alerts/scheduler.rb
motor-admin-0.1.36	lib/motor/alerts/scheduler.rb
motor-admin-0.1.35	lib/motor/alerts/scheduler.rb
motor-admin-0.1.34	lib/motor/alerts/scheduler.rb
motor-admin-0.1.33	lib/motor/alerts/scheduler.rb
motor-admin-0.1.32	lib/motor/alerts/scheduler.rb
motor-admin-0.1.31	lib/motor/alerts/scheduler.rb
motor-admin-0.1.29	lib/motor/alerts/scheduler.rb
motor-admin-0.1.28	lib/motor/alerts/scheduler.rb
motor-admin-0.1.27	lib/motor/alerts/scheduler.rb
motor-admin-0.1.25	lib/motor/alerts/scheduler.rb
motor-admin-0.1.23	lib/motor/alerts/scheduler.rb
motor-admin-0.1.22	lib/motor/alerts/scheduler.rb
motor-admin-0.1.21	lib/motor/alerts/scheduler.rb
motor-admin-0.1.20	lib/motor/alerts/scheduler.rb
motor-admin-0.1.18	lib/motor/alerts/scheduler.rb
motor-admin-0.1.17	lib/motor/alerts/scheduler.rb
motor-admin-0.1.15	lib/motor/alerts/scheduler.rb
motor-admin-0.1.16	lib/motor/alerts/scheduler.rb
motor-admin-0.1.14	lib/motor/alerts/scheduler.rb