Contents

# frozen_string_literal: true

module ChronoTrigger
  class Schedule
    include Singleton
    attr_reader :events

    def initialize
      @events = Concurrent::Array.new
      @pool = Concurrent::Actor::Utils::Pool.spawn! "pool", 5 do |index|
        Rails.logger.info "ChronoTrigger: Spawning worker schedule-#{index}"
        ChronoTrigger::Worker.spawn name: "schedule-#{index}", supervise: true, args: []
      end
    end

    def add(event)
      @events << event if event&.is_a?(ChronoTrigger::Event)
      self
    end

    def remove(uuid)
      uuid_regex = /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/
      @events.each { |event| event.purge! if event.id == uuid } if uuid && uuid_regex.match?(uuid.to_s.downcase)
      self
    end

    def clear
      @events.each { |event| event.purge! }
      self
    end

    def clear_scope(value)
      return self unless value
      scope = value if value.is_a?(String)
      scope = value.to_gid.to_s if value.is_a?(ActiveRecord::Base)
      @events.each { |event| event.purge! if event.scope == scope }
      self
    end

    def process_events
      now = right_now
      events.each do |event|
        if event.purge || (event.before && now >= event.before) || event.repeats == 0
          @events.delete(event)
          next
        end
        next if event.after && now < event.after
        if event.at.nil? || event.at == now
          @pool << event
          event.at = now + event.every
          event.repeats -= 1 unless event.repeats == :forever
        end
      end
    end

    def refresh
      now = right_now
      events.each do |event|
        next if event.at.nil?
        event.at = nil if event.at < now
      end
    end

    private

    include ChronoTrigger::Helpers::Now
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
chrono_trigger-1.0.4	lib/chrono_trigger/schedule.rb
chrono_trigger-1.0.3	lib/chrono_trigger/schedule.rb