# frozen_string_literal: true

require 'timeout'
require 'timers'

# :reek:DuplicateMethodCall

module RubyRabbitmqJanus
  module Process
    module Concurrencies
      # @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
      #
      # # Manage time for thread
      #
      # Configure all timer used in keepalive class
      #
      # @!attribute [r] time_to_live
      #   @return [Integer] Time for interval between keepalive message
      # @!attribute [r] time_to_die
      #   @return [Integer] Time before timer stop it
      class KeepaliveTimer
        attr_reader :time_to_live, :time_to_die

        # Initialize timer to keeaplive thread.
        def initialize
          @time_to_live = Tools::Config.instance.ttl
          @time_to_die = test_time_to_die >= 60 ? 59 : test_time_to_die
          @timers = Timers::Group.new
          @timer = nil
        rescue
          raise Errors::Process::KeepaliveTimer::Initializer
        end

        # Execute a loop with timer for sending keepalive message
        # to Janus Instance
        def loop_keepalive(&block)
          @timer = @timers.now_and_every(@time_to_live) { prepare_loop(&block) }
          loop { @timers.wait }
        rescue
          raise Errors::Process::KeepaliveTimer::LoopKeepalive
        end

        # Test if session is present/exist in Janus Instance
        def session(&block)
          Timeout.timeout(@time_to_die) { yield }
        rescue Timeout::Error
          block.binding.receiver.instance_is_down
        rescue
          raise Errors::Process::KeepaliveTimer::Session
        end

        # Stop timer to keepalive thread
        def stop_timer
          @timer.cancel
          @timer = nil
        rescue
          raise Errors::Process::KeepaliveTimer::StopTimer
        end

        private

        # :reek:FeatureEnvy
        def prepare_loop(&block)
          Timeout.timeout(@time_to_die) do
            block.binding.receiver.restart_session if yield
          end
        rescue Timeout::Error
          block.binding.receiver.instance_is_down
        end

        def test_time_to_die
          @time_to_live + 5
        end
      end
    end
  end
end