# frozen_string_literal: true

require 'bunny'
module PubSubModelSync
  class ServiceRabbit
    attr_accessor :service, :channel, :queue, :topic
    attr_accessor :config
    SERVICE_KEY = 'service_model_sync'

    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(block: true, manual_ack: false, &method(:process_message))
    rescue PubSubModelSync::Runner::ShutDown
      raise
    rescue => e
      log("Error listening message: #{[e.message, e.backtrace]}")
    end

    def publish(data, attributes)
      log("Publishing: #{[data, attributes]}")
      subscribe_to_queue
      payload = { data: data, attributes: attributes }
      topic.publish(payload.to_json, routing_key: queue.name, type: SERVICE_KEY)
    rescue => e
      log("Error publishing: #{[data, attributes, e.message, e.backtrace]}")
    end

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

    private

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

      data, attrs = parse_message_payload(payload)
      args = [data, attrs[:klass], attrs[:action], attrs]
      PubSubModelSync::MessageProcessor.new(*args).process
    rescue => e
      error = [payload, e.message, e.backtrace]
      log("Error processing message: #{error}")
    end

    def parse_message_payload(payload)
      message_payload = JSON.parse(payload).symbolize_keys
      data = message_payload[:data].symbolize_keys
      attrs = message_payload[:attributes].symbolize_keys
      [data, attrs]
    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_topic
    end

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

    def log(msg)
      config.log("Rabbit Service ==> #{msg}")
    end
  end
end