require 'peddler/client'

module MWS
  # The Amazon MWS Subscriptions API section enables you to subscribe to
  # receive notifications that are relevant to your business with Amazon. With
  # the operations in the Subscriptions API section, you can register to
  # receive important information from Amazon without having to poll the
  # Amazon MWS service. Instead, the information is sent directly to you when
  # an event occurs to which you are subscribed.
  class Subscriptions < ::Peddler::Client
    path 'Subscriptions/2013-07-01'

    # Registers a new destination to receive notifications
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_RegisterDestination.html
    # @method register_destination
    # @overload register_destination(sqs_queue_url, marketplace_id = marketplace_id)
    #   @param sqs_queue_url [String]
    #   @param marketplace_id [String]
    # @return [Peddler::Parser]
    def register_destination(sqs_queue_url, marketplace_id = marketplace_id)
      operation('RegisterDestination')
        .add('MarketplaceId' => marketplace_id)
        .add(build_destination(sqs_queue_url))

      run
    end

    # Removes an existing destination from the list of registered destinations
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_DeregisterDestination.html
    # @method deregister_destination
    # @overload deregister_destination(sqs_queue_url, marketplace_id = marketplace_id)
    #   @param sqs_queue_url [String]
    #   @param marketplace_id [String]
    # @return [Peddler::Parser]
    def deregister_destination(sqs_queue_url, marketplace_id = marketplace_id)
      operation('DeregisterDestination')
        .add('MarketplaceId' => marketplace_id)
        .add(build_destination(sqs_queue_url))

      run
    end

    # Lists all registered destinations
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_ListRegisteredDestinations.html
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def list_registered_destinations( marketplace_id = marketplace_id)
      operation('ListRegisteredDestinations')
        .add('MarketplaceId' => marketplace_id)

      run
    end

    # Sends a test notification to an existing destination
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_SendTestNotificationToDestination.html
    # @method send_test_notification_to_destination
    # @overload send_test_notification_to_destination(sqs_queue_url, marketplace_id = marketplace_id)
    #   @param sqs_queue_url [String]
    #   @param marketplace_id [String]
    # @return [Peddler::Parser]
    def send_test_notification_to_destination(sqs_queue_url, marketplace_id = marketplace_id)
      operation('SendTestNotificationToDestination')
        .add('MarketplaceId' => marketplace_id)
        .add(build_destination(sqs_queue_url))

      run
    end

    # Creates a new subscription
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_CreateSubscription.html
    # @param notification_type [String]
    # @param sqs_queue_url [String]
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def create_subscription(notification_type, sqs_queue_url, marketplace_id = marketplace_id)
      operation('CreateSubscription')
        .add('MarketplaceId' => marketplace_id)
        .add(build_subscription(notification_type, sqs_queue_url))

      run
    end

    # Gets a subscription
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_GetSubscription.html
    # @param notification_type [String]
    # @param sqs_queue_url [String]
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def get_subscription(notification_type, sqs_queue_url, marketplace_id = marketplace_id)
      operation('GetSubscription')
        .add('MarketplaceId' => marketplace_id, 'NotificationType' => notification_type)
        .add(build_destination(sqs_queue_url))

      run
    end

    # Deletes a subscription
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_DeleteSubscription.html
    # @param notification_type [String]
    # @param sqs_queue_url [String]
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def delete_subscription(notification_type, sqs_queue_url, marketplace_id = marketplace_id)
      operation('DeleteSubscription')
        .add('MarketplaceId' => marketplace_id, 'NotificationType' => notification_type)
        .add(build_destination(sqs_queue_url))

      run
    end

    # Lists current subscriptions
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_ListSubscriptions.html
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def list_subscriptions(marketplace_id = marketplace_id)
      operation('ListSubscriptions')
        .add('MarketplaceId' => marketplace_id)

      run
    end

    # Updates a subscription
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_UpdateSubscription.html
    # @param notification_type [String]
    # @param sqs_queue_url [String]
    # @param enabled [Boolean]
    # @param marketplace_id [String]
    # @return [Peddler::Parser]
    def update_subscription(notification_type, sqs_queue_url, enabled, marketplace_id = marketplace_id)
      operation('CreateSubscription')
        .add('MarketplaceId' => marketplace_id)
        .add(build_subscription(notification_type, sqs_queue_url, enabled))

      run
    end

    # Gets the service status of the API
    #
    # @see http://docs.developer.amazonservices.com/en_US/subscriptions/Subscriptions_GetServiceStatus.html
    # @return [Peddler::Parser]
    def get_service_status
      operation('GetServiceStatus')
      run
    end

    private

    def build_destination(sqs_queue_url)
      {
        'Destination.DeliveryChannel' => 'SQS',
        'Destination.AttributeList.member.1.Key' => 'sqsQueueUrl',
        'Destination.AttributeList.member.1.Value' => sqs_queue_url
      }
    end

    def build_subscription(notification_type, sqs_queue_url, enabled = true)
      {
        'Subscription.IsEnabled' => enabled,
        'Subscription.NotificationType' => notification_type,
        'Subscription.Destination.DeliveryChannel' => 'SQS',
        'Subscription.Destination.AttributeList.member.1.Key' => 'sqsQueueUrl',
        'Subscription.Destination.AttributeList.member.1.Value' => sqs_queue_url
      }
    end
  end
end