class Seatsio::HttpClient

def delete(endpoint, payload = {})
  execute(:delete, endpoint, payload)
end

def execute(*args)
  begin
    headers = { :Authorization => "Basic #{@secret_key}" }
    headers[:'X-Client-Lib'] = "ruby"
    unless @workspace_key.nil?
      headers[:'X-Workspace-Key'] = @workspace_key
    end
    url = "#{@base_url}/#{args[1]}"
    if args[2].include? :params
      params = args[2][:params]
      if params.is_a? Hash
        headers[:params] = params
      else
        url += "?" + params
      end
    end
    request_options = { method: args[0], url: url, headers: headers }
    if args[0] == :post || args[0] == :delete
      args[2].delete :params
      request_options[:payload] = args[2].to_json
    end
    response = execute_with_retries(request_options)
    # If RAW
    if args[3]
      return response
    end
    JSON.parse(response) unless response.empty?
  rescue RestClient::NotFound => e
    raise Exception::NotFoundException.new(e.response)
  rescue RestClient::ExceptionWithResponse => e
    if e.response.code == 429
      raise Exception::RateLimitExceededException.new(e.response)
    else
      raise Exception::SeatsioException.new(e.response)
    end
  rescue RestClient::Exceptions::Timeout
    raise Exception::SeatsioException.new("Timeout ERROR")
  rescue SocketError
    raise Exception::SeatsioException.new("Failed to connect to backend")
  end
end

def execute_with_retries(request_options)
  retry_count = 0
  while true
    begin
      return RestClient::Request.execute(request_options)
    rescue RestClient::ExceptionWithResponse => e
      if e.response.code != 429 || retry_count >= @max_retries
        raise e
      else
        wait_time = (2 ** (retry_count + 2)) / 10.0
        sleep(wait_time)
        retry_count += 1
      end
    end
  end
end

def get(endpoint, params = {})
  payload = { :params => params }
  execute(:get, endpoint, payload)
end

def get_raw(endpoint, params = {})
  execute(:get, endpoint, params, true)
end

def initialize(secret_key, workspace_key, base_url, max_retries)
  @secret_key = Base64.encode64(secret_key)
  @workspace_key = workspace_key
  @base_url = base_url
  @max_retries = max_retries
end

def post(endpoint, payload = {})
  execute(:post, endpoint, payload)
end