# frozen_string_literal: true

require 'singleton'
require 'yaml'
require 'json'
require 'securerandom'
require 'bunny'
require 'logger'
require 'key_path'
require 'active_support'
require 'erb'

# :reek:TooManyStatements

# Primary module for this gem
module RubyRabbitmqJanus
  # @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>

  # # RubyRabbitmqJanus - RRJ
  #
  # Initialize RRJ gem and create automatically a session with janus and
  # sending a keepalive message. The Time To Live is configured in yaml
  # configuration file `config/default.yml` or if you a customize config in
  # `config/ruby-rabbitmq-janus.yml`.
  #
  # @!attribute [r] session
  #   @return [Fixnum] Return an session number created when this gem is
  #     instanciate. It's janus who creates the number of the session.
  #
  # @see file:/config/requests.md For more information to type requests used.
  # @see file:/config/default.md For more information to config file used.
  class RRJ
    attr_reader :session

    # Return a new instance of RubyRabbitmqJanus.
    #
    # @example Create a instance to this gem
    #   @rrj = RubyRabbitmqJanus::RRJ.new
    #   => #<RubyRabbitmqJanus::RRJ:0x007 @session=123>
    def initialize
      @option = Tools::Option.new
      ObjectSpace.define_finalizer(self, RRJ.method(:delete).to_proc) \
        unless File.basename($PROGRAM_NAME).eql?('rspec')
    rescue => error
      raise Errors::RRJ::InstanciateGem, error
    end

    # Start a transaction with Janus. Request use session_id information.
    #
    # @param [Boolean] exclusive Choose if message is storage in exclusive queue
    # @param [Hash] options
    #   Give a session number for use another session in Janus
    #
    # @example Get Janus information
    #   @rrj.start_transaction do |transaction|
    #     response = transaction.publish_message('base::info').to_hash
    #   end
    #
    # @since 2.0.0
    def start_transaction(exclusive = true, options = {})
      session = @option.use_current_session?(options)
      transaction = Janus::Transactions::Session.new(exclusive, session)
      transaction.connect { yield(transaction) }
    rescue
      raise Errors::RRJ::StartTransaction.new(exclusive, options)
    end

    # Start a transaction with Janus. Request used session_id/handle_id
    # information.
    #
    # @param [Boolean] exclusive Choose if message is storage in exclusive queue
    # @param [Hash] options
    #   Give a session number for use another session in Janus
    #
    # @note Use transaction.detach for closing handle in Janus
    #
    # @example Send request trickles for exclusive queue
    #   @cde = { 'sdpMid' => '...', sdpMLineIndex => 0, 'candidate' => '...' }
    #   @rrj.start_transaction_handle do |transaction|
    #     transaction.publish_message('base::trickle', @cde)
    #   end
    #
    # @example Send request trickles for non exclusive queue
    #   @cde = { 'sdpMid' => '...', sdpMLineIndex => 0, 'candidate' => '...' }
    #   @rrj.start_transaction_handle(false) do |transaction|
    #     transaction.publish_message('base::trickle', @cde)
    #   end
    #
    # @return [Fixnum] Handle used for transaction
    #
    # @since 2.0.0
    def start_transaction_handle(exclusive = true, options = {})
      session = @option.use_current_session?(options)
      handle = @option.use_current_handle?(options)
      instance = options['instance'] || 1
      transaction = Janus::Transactions::Handle.new(exclusive,
                                                    session,
                                                    handle,
                                                    instance)
      transaction.connect { yield(transaction) }
    rescue
      raise Errors::RRJ::StartTransactionHandle, exclusive, options
    end

    # Delete all resources to JanusInstance reference.
    # Warning: All data in database and Janus Instance is delete
    #
    # @since 2.1.0
    def cleanup_connection
      Models::JanusInstance.destroys
    rescue
      raise Errors::RRJ::CleanupConnection
    end

    private

    attr_reader :option

    def self.delete(_id)
      Tools::Cluster.instance.sessions.each do |janus_instance|
        array_ji = "#{janus_instance.instance},#{janus_instance.session}"
        `rake rrj:delete:one_instance[#{array_ji}]`
      end
    end

    private_class_method :delete
  end
end