Class: Service::Client

Inherits:

Object

• Object
• Service::Client

Defined in:

lib/opennebula/oneflow_client.rb

Instance Method Summary

• #delete(path, body = nil) ⇒ Object
• #get(path) ⇒ Object
• #initialize(opts = {}) ⇒ Client constructor

  A new instance of Client.

• #login ⇒ Object
• #logout ⇒ Object
• #post(path, body) ⇒ Object
• #put(path, body) ⇒ Object
• #set_content_type(content_type) ⇒ Object

Constructor Details

#initialize(opts = {}) ⇒ Client

Returns a new instance of Client.

# File 'lib/opennebula/oneflow_client.rb', line 321

def initialize(opts={})
    endpoint  = '/.one/oneflow_endpoint'
    @username = opts[:username] || ENV['ONEFLOW_USER']
    @password = opts[:password] || ENV['ONEFLOW_PASSWORD']

    if opts[:url]
        url = opts[:url]
    elsif ENV['ONEFLOW_URL']
        url = ENV['ONEFLOW_URL']
    elsif ENV['HOME'] && File.exists?(ENV['HOME'] + endpoint)
        url = File.read(ENV['HOME'] + endpoint).strip
    elsif File.exists?('/var/lib/one/.one/oneflow_endpoint')
        url = File.read('/var/lib/one/.one/oneflow_endpoint').strip
    else
        url = 'http://localhost:2474'
    end

    if @username.nil? && @password.nil?
        if ENV["ONE_AUTH"] and !ENV["ONE_AUTH"].empty? and File.file?(ENV["ONE_AUTH"])
            one_auth = File.read(ENV["ONE_AUTH"])
        elsif ENV["HOME"] and File.file?(ENV["HOME"]+"/.one/one_auth")
            one_auth = File.read(ENV["HOME"]+"/.one/one_auth")
        elsif File.file?("/var/lib/one/.one/one_auth")
            one_auth = File.read("/var/lib/one/.one/one_auth")
        else
            raise "ONE_AUTH file not present"
        end

        one_auth = one_auth.rstrip

        @username, @password = one_auth.split(':')
    end

    @uri = URI.parse(url)

    @user_agent = "OpenNebula #{CloudClient::VERSION} " <<
        "(#{opts[:user_agent]||"Ruby"})"

    @host = nil
    @port = nil

    if ENV['http_proxy']
        uri_proxy  = URI.parse(ENV['http_proxy'])
        flag = false

        # Check if we need to bypass the proxy
        if ENV['no_proxy']
            ENV['no_proxy'].split(',').each do |item|
                item = item.rstrip.lstrip

                unless (IPAddress @uri.host rescue nil).nil?
                    unless (IPAddress item rescue nil).nil?
                        flag |= IPAddress(item).include? IPAddress(@uri.host)
                    end
                else
                    if (IPAddress(item) rescue nil).nil?
                        flag |= (item == @uri.host)
                    end
                end
            end
        end

        unless flag
            @host = uri_proxy.host
            @port = uri_proxy.port
        end
    end
end

Instance Method Details

#delete(path, body = nil) ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 400

def delete(path, body = nil)
    req = Net::HTTP::Proxy(@host, @port)::Delete.new(path)
    req.body = body if body

    do_request(req)
end

#get(path) ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 394

def get(path)
    req = Net::HTTP::Proxy(@host, @port)::Get.new(path)

    do_request(req)
end

#login ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 426

def login
    req = Net::HTTP::Proxy(@host, @port)::Post.new('/login')

    do_request(req)
end

#logout ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 432

def logout
    req = Net::HTTP::Proxy(@host, @port)::Post.new('/logout')

    do_request(req)
end

#post(path, body) ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 407

def post(path, body)
    req = Net::HTTP::Proxy(@host, @port)::Post.new(path)
    req.body = body

    if path.start_with?('/service_template')
        unless @content_type.nil?
            req.content_type = @content_type
        end
    end
    do_request(req)
end

#put(path, body) ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 419

def put(path, body)
    req = Net::HTTP::Proxy(@host, @port)::Put.new(path)
    req.body = body

    do_request(req)
end

#set_content_type(content_type) ⇒ Object

# File 'lib/opennebula/oneflow_client.rb', line 390

def set_content_type(content_type)
    @content_type = content_type
end