# frozen_string_literal: true

module AMQP
  class Client
    # High level representation of an exchange
    class Exchange
      # Should only be initialized from the Client
      # @api private
      def initialize(client, name)
        @client = client
        @name = name
      end

      # Publish to the exchange
      # @param body [String] The message body
      # @param routing_key [String] The routing key of the message,
      #   the exchange may use this when routing the message to bound queues
      # @param properties [Properties]
      # @option properties [String] content_type Content type of the message body
      # @option properties [String] content_encoding Content encoding of the body
      # @option properties [Hash<String, Object>] headers Custom headers
      # @option properties [Integer] delivery_mode 2 for persisted message, transient messages for all other values
      # @option properties [Integer] priority A priority of the message (between 0 and 255)
      # @option properties [Integer] correlation_id A correlation id, most often used used for RPC communication
      # @option properties [String] reply_to Queue to reply RPC responses to
      # @option properties [Integer, String] expiration Number of seconds the message will stay in the queue
      # @option properties [String] message_id Can be used to uniquely identify the message, e.g. for deduplication
      # @option properties [Date] timestamp Often used for the time the message was originally generated
      # @option properties [String] type Can indicate what kind of message this is
      # @option properties [String] user_id Can be used to verify that this is the user that published the message
      # @option properties [String] app_id Can be used to indicates which app that generated the message
      # @return [Exchange] self
      def publish(body, routing_key, **properties)
        @client.publish(body, @name, routing_key, **properties)
        self
      end

      # Bind to another exchange
      # @param exchange [String] Name of the exchange to bind to
      # @param binding_key [String] Binding key on which messages that match might be routed (depending on exchange type)
      # @param arguments [Hash] Message headers to match on (only relevant for header exchanges)
      # @return [Exchange] self
      def bind(exchange, binding_key, arguments: {})
        @client.exchange_bind(@name, exchange, binding_key, arguments: arguments)
        self
      end

      # Unbind from another exchange
      # @param exchange [String] Name of the exchange to unbind from
      # @param binding_key [String] Binding key which the queue is bound to the exchange with
      # @param arguments [Hash] Arguments matching the binding that's being removed
      # @return [Exchange] self
      def unbind(exchange, binding_key, arguments: {})
        @client.exchange_unbind(@name, exchange, binding_key, arguments: arguments)
        self
      end

      # Delete the exchange
      # @return [nil]
      def delete
        @client.delete_exchange(@name)
        nil
      end
    end
  end
end