Class: Service::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/opennebula/oneflow_client.rb

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ Client

Returns a new instance of Client.



300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
 
# File 'lib/opennebula/oneflow_client.rb', line 300

def initialize(opts={})
    @username = opts[:username] || ENV['ONEFLOW_USER']
    @password = opts[:password] || ENV['ONEFLOW_PASSWORD']

    url = opts[:url] || ENV['ONEFLOW_URL'] || 'http://localhost:2474'

    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) ⇒ Object 



368
369
370
371
372
 
# File 'lib/opennebula/oneflow_client.rb', line 368

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

    do_request(req)
end

#get(path) ⇒ Object 



362
363
364
365
366
 
# File 'lib/opennebula/oneflow_client.rb', line 362

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

    do_request(req)
end

#login ⇒ Object 



393
394
395
396
397
 
# File 'lib/opennebula/oneflow_client.rb', line 393

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

    do_request(req)
end

#logout ⇒ Object 



399
400
401
402
403
 
# File 'lib/opennebula/oneflow_client.rb', line 399

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

    do_request(req)
end

#post(path, body) ⇒ Object 



374
375
376
377
378
379
380
381
382
383
384
 
# File 'lib/opennebula/oneflow_client.rb', line 374

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 



386
387
388
389
390
391
 
# File 'lib/opennebula/oneflow_client.rb', line 386

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 



358
359
360
 
# File 'lib/opennebula/oneflow_client.rb', line 358

def set_content_type(content_type)
    @content_type = content_type
end