require 'multi_json'
require_relative 'collection'

module TicketingHub
  module Request

    def delete(path, options={})
      request(:delete, path, options).body
    end

    def get(path, options={})
      TicketingHub::Collection.new self, path, options
    end

    def patch(path, options={})
      request(:patch, path, options).body
    end

    def post(path, options={})
      request(:post, path, options).body
    end

    def put(path, options={})
      request(:put, path, options).body
    end

    def request(method, path, options={})
      force_urlencoded = options.delete(:force_urlencoded) || false
      url = options.delete(:endpoint) || api_endpoint
      conn_options = { force_urlencoded: force_urlencoded, url: url }

      connection(conn_options).send(method) do |request|
        case method
          when :get, :delete, :head
            request.url(path, options)
          when :patch, :post, :put
            request.path = path
            request.body = force_urlencoded ? options : MultiJson.dump(options) unless options.empty?
        end
        request.headers['Host'] = TicketingHub.request_host if TicketingHub.request_host
      end
    rescue TicketingHub::Unauthorized => e
      if refresh_token.present? && e.response_body == ' '
        body = post '/oauth/token', { grant_type: 'refresh_token',
          refresh_token: refresh_token, client_id: client_id, client_secret: client_secret }
        self.refresh_token = body.refresh_token
        self.access_token = body.access_token
        self.expires_at = Time.now + body.expires_in.to_i
        request(method, path, options)
      else throw TicketingHub::Unauthorized.new end
    end
  end
end