# frozen_string_literal: true

begin
  require 'bunny'
rescue LoadError # rubocop:disable Lint/SuppressedException
end

module PubSubModelSync
  class ServiceRabbit < ServiceBase
    attr_accessor :config, :service, :channel, :queue, :topic

    def initialize
      @config = PubSubModelSync::Config
      @service = Bunny.new(*config.bunny_connection)
    end

    def listen_messages
      log('Listener starting...')
      subscribe_to_queue
      log('Listener started')
      queue.subscribe(subscribe_settings, &method(:process_message))
      loop { sleep 5 }
    rescue PubSubModelSync::Runner::ShutDown
      log('Listener stopped')
    rescue => e
      log("Error listening message: #{[e.message, e.backtrace]}", :error)
    end

    def publish(payload)
      qty_retry ||= 0
      deliver_data(payload)
    rescue => e
      if e.is_a?(Timeout::Error) && (qty_retry += 1) <= 2
        log("Error publishing (retrying....): #{e.message}", :error)
        initialize
        retry
      end
      raise
    end

    def stop
      log('Listener stopping...')
      service.close
    end

    private

    def message_settings
      {
        routing_key: queue.name,
        type: SERVICE_KEY
      }
    end

    def subscribe_settings
      { manual_ack: false }
    end

    def process_message(_delivery_info, meta_info, payload)
      return unless meta_info[:type] == SERVICE_KEY

      super(payload)
    end

    def subscribe_to_queue
      service.start
      @channel = service.create_channel
      queue_settings = { durable: true, auto_delete: false }
      @queue = channel.queue(config.queue_name, queue_settings)
      subscribe_to_exchange
    end

    def subscribe_to_exchange
      @topic = channel.fanout(config.topic_name)
      queue.bind(topic, routing_key: queue.name)
    end

    def deliver_data(payload)
      subscribe_to_queue
      topic.publish(payload.to_json, message_settings)

      # Ugly fix: "IO timeout when reading 7 bytes"
      # https://stackoverflow.com/questions/39039129/rabbitmq-timeouterror-io-timeout-when-reading-7-bytes
      channel.close
      service.close
    end
  end
end