require('pkginfo')(module)
version = @version

_ = require('underscore')

ironCore = require('iron_core');

class APIClient extends ironCore.Client
  AWS_US_EAST_HOST: 'mq-aws-us-east-1-1.iron.io'
  # APIClient.prototype.RACKSPACE_HOST = 'mq-rackspace-ord.iron.io';
  # RACKSPACE_HOST: 'mq-rackspace-dfw.iron.io'

  constructor: (options) ->
    defaultOptions =
      scheme: 'https',
      host: @AWS_US_EAST_HOST,
      port: 443,
      api_version: 3,
      user_agent: version,
      queue_name: 'default'

    super('iron', 'mq', options, defaultOptions, ['project_id', 'token', 'api_version', 'queue_name'])

  version: ->
    "iron_mq_node-#{version} (#{super()})"

  url: ->
    super() + @options.api_version.toString() + "/projects/#{@options.project_id}/queues"

  headers: ->
    _.extend({}, super(), {'Authorization': "OAuth #{@options.token}"})

  queuesList: (options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @get("", options, (error, response, body) ->
      try
        body = JSON.parse(body)
        parseResponseBind(error, response, body['queues'], cb)
      catch e
        parseResponseBind(e, response, null, cb)
    )

  queuesGet: (queue_name, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @get("/#{queue_name}", {}, (error, response, body) ->
      try
        body = JSON.parse(body)
        parseResponseBind(error, response, body['queue'], cb)
      catch e
        parseResponseBind(e, response, null, cb)
    )

  queuesClear: (queue_name, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @delete("/#{queue_name}/messages", {}, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesCreate: (queue_name, options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @put("/#{queue_name}", options, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesUpdate: (queue_name, options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @patch("/#{queue_name}", options, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesAddSubscribers: (queue_name, subscribers, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @post("/#{queue_name}/subscribers", subscribers, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesRemoveSubscribers: (queue_name, subscribers, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @delete("/#{queue_name}/subscribers", subscribers, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesReplaceSubscribers: (queue_name, subscribers, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @put("/#{queue_name}/subscribers", subscribers, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  queuesDelete: (queue_name, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @delete("/#{queue_name}", {}, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesPost: (queue_name, messages, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @post("/#{queue_name}/messages", {messages: messages}, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesGet: (queue_name, options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @post("/#{queue_name}/reservations", options, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesGetById: (queue_name, message_id, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @get("/#{queue_name}/messages/#{message_id}", {}, (error, response, body) ->
      try
        body = JSON.parse(body)
        parseResponseBind(error, response, body['message'], cb)
      catch e
        parseResponseBind(e, response, null, cb)
    )

  messagesDelete: (queue_name, message_id, options, cb) ->
    body = _.pick(options, 'reservation_id', 'subscriber_name')
    parseResponseBind = _.bind(@parseResponse, @)

    @delete("/#{queue_name}/messages/#{message_id}", body, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesMultipleDelete: (queue_name, options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @delete("/#{queue_name}/messages", options, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesPeek: (queue_name, options, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @get("/#{queue_name}/messages", options, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messageTouch: (queue_name, message_id, reservation_id, options, cb) ->
    body = _.pick(options, 'timeout')
    body['reservation_id'] = reservation_id;
    parseResponseBind = _.bind(@parseResponse, @)

    @post("/#{queue_name}/messages/#{message_id}/touch", body, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messageRelease: (queue_name, message_id, reservation_id, options, cb) ->
    body = _.pick(options, 'delay');
    body['reservation_id'] = reservation_id;
    parseResponseBind = _.bind(@parseResponse, @)

    @post("/#{queue_name}/messages/#{message_id}/release", body, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

  messagesPushStatuses: (queue_name, message_id, cb) ->
    parseResponseBind = _.bind(@parseResponse, @)

    @get("/#{queue_name}/messages/#{message_id}/subscribers", {}, (error, response, body) ->
      parseResponseBind(error, response, body, cb)
    )

module.exports.APIClient = APIClient