Class: Oxidized::HTTP

Inherits:

Source

• Object
• Source
• Oxidized::HTTP

Defined in:

lib/oxidized/source/http.rb

Instance Method Summary

• #initialize ⇒ HTTP constructor

  A new instance of HTTP.

• #load ⇒ Object
• #setup ⇒ Object

Methods inherited from Source

#map_model

Constructor Details

#initialize ⇒ HTTP

Returns a new instance of HTTP.

# File 'lib/oxidized/source/http.rb', line 3

def initialize
  @cfg = Oxidized.config.source.http
  super
end

Instance Method Details

#load ⇒ Object

# File 'lib/oxidized/source/http.rb', line 18

def load
  nodes = []
  uri = URI.parse(@cfg.url)
  http = Net::HTTP.new(uri.host, uri.port)
  http.use_ssl = true if uri.scheme == 'https'

  # map headers
  headers = {}
  @cfg.headers.each do |header, value|
    headers[header] = value
  end

  request = Net::HTTP::Get.new(uri.request_uri, headers)
  if (@cfg.user && @cfg.pass)
      request.basic_auth(@cfg.user,@cfg.pass)
  end

  response = http.request(request)
  data = JSON.parse(response.body)
  data.each do |line|
    next if line.empty?
    # map node parameters
    keys = {}
    @cfg.map.each do |key, position|
      keys[key.to_sym] = line[position]
    end
    keys[:model] = map_model keys[:model] if keys.key? :model

    # map node specific vars, empty value is considered as nil
    vars = {}
    @cfg.vars_map.each { |key, position| vars[key.to_sym] = line[position].to_s.empty? ? nil : line[position] }
    keys[:vars] = vars unless vars.empty?

    nodes << keys
  end
  nodes
end

#setup ⇒ Object

# File 'lib/oxidized/source/http.rb', line 8

def setup
  if @cfg.url.empty?
    raise NoConfig, 'no source http url config, edit ~/.config/oxidized/config'
  end
end