class RxgClient

# File lib/rxg_client.rb, line 33
def initialize(hostname, api_key, request_format: :json, default_timeout: 5,
  raise_exceptions: false, verify_ssl: false, fleet: false, debug_output: nil,
  base_uri: 'admin/scaffolds', auth_method: :headers)

  self.api_key = api_key

  self.hostname = hostname

  self.set_base_uri(base_uri)

  self.fleet = fleet

  self.default_timeout = default_timeout

  self.raise_exceptions = raise_exceptions

  self.verify_ssl = verify_ssl

  self.debug_output = debug_output

  self.request_format = request_format.to_sym

  self.auth_method = auth_method

end

# File lib/rxg_client.rb, line 198
def self.rescue_from exception, *meths, &handler
  meths.each do |meth|
    # store the previous implementation
    old = instance_method(meth)
    # wrap it
    define_method(meth) do |*args|
      begin
        old.bind(self).call(*args)
      rescue exception => e
        handler.call(e, self)
      end
    end
  end
end

# File lib/rxg_client.rb, line 155
def create(table, new_record)
  self.post("/#{table}/create", body: {record: new_record})
end

# File lib/rxg_client.rb, line 87
def default_header
  @headers ||= begin
    h = { 'Accept' => "application/#{self.request_format}" }
    if self.fleet
      h['fleetkey'] = self.api_key
    elsif self.auth_method == :headers # compatible with rXg version 11.442 or later
      h['apikey'] = self.api_key
    end
    h
  end
end

# File lib/rxg_client.rb, line 99
def default_query
  case self.auth_method
  when :query
    { api_key: self.api_key }
  when :headers
    { }
  end
end

# File lib/rxg_client.rb, line 179
def destroy(table, id)
  self.post("/#{table}/destroy/#{id}")
end

# File lib/rxg_client.rb, line 183
def execute(table, request)
  # executes an arbitrary method on given scaffold
  # The "request" hash parameters:
  #   record_name - The "name" attribute of the desired record, if any. Not required if calling a class method or if record_id is present.
  #   record_id - The id of the desired record, if any. Not required if calling a class method or if record_name is present.
  #   method_name - The name of the desired class or instance method to be run against the model.
  #   method_args - A serialized Array or Hash of the argument(s) expected by the method.
  # example method call:
  #   node.execute("shared_credential_groups", {record_id: 7, method_name: "make_login_session", method_args:["192.168.20.111", "00:00:00:00:00:05", "test", 1]})
  self.post("/#{table}/execute", body: {request: request})
end

# File lib/rxg_client.rb, line 160
def list(table)
  self.get("/#{table}")
end

# File lib/rxg_client.rb, line 126
def parse(body)
  return {success: true} if body == ""
  begin
    case self.request_format
    when :json
      result = JSON.parse(body)
    when :xml
      result = Hash.from_xml(body)
    else
      raise "Request format should be one of: :json, :xml"
    end

    if result.is_a?(Array)
      result = result.map do |hash|
        # symbolize keys
        hash.inject({}){|memo,(k,v)| memo[k.to_sym] = v; memo}
      end
    elsif result.is_a?(Hash)
      # symbolize keys
      result = result.inject({}){|memo,(k,v)| memo[k.to_sym] = v; memo}
    end

  rescue JSON::ParserError => e
    return body
  end

end

# File lib/rxg_client.rb, line 9
def request_format= (requested_format)
  raise HTTParty::UnsupportedFormat unless [ :json, :xml ].include?(requested_format.to_sym)
  @request_format = requested_format
end

# File lib/rxg_client.rb, line 164
def search(table, search_params)
  self.post("/#{table}/index", body: search_params)
end

# File lib/rxg_client.rb, line 61
def set_base_uri(base_uri)
  if base_uri =~ /^https?:\/\//
    self.base_uri = base_uri
  else
    self.base_uri = "https://#{self.hostname}/#{base_uri.delete_prefix('/')}"
  end
end

# File lib/rxg_client.rb, line 169
def show(table, id)
  self.get("/#{table}/show/#{id}")
end

# File lib/rxg_client.rb, line 174
def update(table, id, updated_record_hash)
  self.post("/#{table}/update/#{id}", body: {record: updated_record_hash})
end

# File lib/rxg_client.rb, line 71
def with_base_uri(new_base_uri, &blk)
  if block_given?
    begin
      old_uri = self.base_uri

      set_base_uri(new_base_uri)

      blk.call
    ensure
      set_base_uri(old_uri)
    end
  end
end