# frozen_string_literal: true

module SidekiqUniqueJobs
  # Calculates timeout and expiration
  #
  # @author Mikael Henriksson <mikael@zoolutions.se>
  class TimeCalculator
    # includes "SidekiqUniqueJobs::SidekiqWorkerMethods"
    # @!parse include SidekiqUniqueJobs::SidekiqWorkerMethods
    include SidekiqUniqueJobs::SidekiqWorkerMethods

    # @!attribute [r] item
    #   @return [Hash] the Sidekiq job hash
    attr_reader :item

    # @param [Hash] item the Sidekiq job hash
    # @option item [Integer, nil] :lock_ttl the configured lock expiration
    # @option item [Integer, nil] :lock_timeout the configured lock timeout
    # @option item [String] :class the class of the sidekiq worker
    # @option item [Float] :at the unix time the job is scheduled at
    def initialize(item)
      @item         = item
      @worker_class = item[CLASS]
    end

    #
    # Calculates the time until the job is scheduled starting from now
    #
    #
    # @return [Integer] the number of seconds until job is scheduled
    #
    def time_until_scheduled
      return 0 unless scheduled_at

      scheduled_at.to_i - Time.now.utc.to_i
    end

    # The time a job is scheduled
    # @return [Float] the exact unix time the job is scheduled at
    def scheduled_at
      @scheduled_at ||= item[AT]
    end

    #
    # Computes lock ttl from job arguments, sidekiq_options.
    #   Falls back to {default_lock_ttl}
    #
    # @note this method takes into consideration the time
    #   until a job is scheduled
    #
    #
    # @return [Integer] the number of seconds to live
    #
    def lock_ttl
      @lock_ttl ||= begin
        ttl = item[LOCK_TTL]
        ttl ||= worker_options[LOCK_TTL]
        ttl ||= item[LOCK_EXPIRATION] # TODO: Deprecate at some point
        ttl ||= worker_options[LOCK_EXPIRATION] # TODO: Deprecate at some point
        ttl ||= default_lock_ttl
        ttl && ttl.to_i + time_until_scheduled
      end
    end

    #
    # Finds a lock timeout in either of
    #  default worker options, {default_lock_timeout} or provided worker_options
    #
    #
    # @return [Integer, nil]
    #
    def lock_timeout
      @lock_timeout = begin
        timeout = default_worker_options[LOCK_TIMEOUT]
        timeout = default_lock_timeout if default_lock_timeout
        timeout = worker_options[LOCK_TIMEOUT] if worker_options.key?(LOCK_TIMEOUT)
        timeout
      end
    end

    #
    # The configured default_lock_timeout
    # @see SidekiqUniqueJobs::Config#default_lock_timeout
    #
    #
    # @return [Integer, nil]
    #
    def default_lock_timeout
      SidekiqUniqueJobs.config.default_lock_timeout
    end

    #
    # The configured default_lock_ttl
    # @see SidekiqUniqueJobs::Config#default_lock_ttl
    #
    #
    # @return [Integer, nil]
    #
    def default_lock_ttl
      SidekiqUniqueJobs.config.default_lock_ttl
    end
  end
end