MiqVimClientBase.rb

$:.push(File.dirname(__FILE__))
require 'pathname'
require Pathname.new(__dir__).join("../util/extensions/miq-uri")

require 'sync'
require 'VimService'

# require 'profile'

class MiqVimClientBase < VimService
	
	@@receiveTimeout = 120
	
	attr_reader :server, :username, :password, :connId
	
	def initialize(server, username, password)
		@server   = server
	    @username = username
	    @password = password
	    @connId   = "#{@server}_#{@username}"
	
		@receiveTimeout = @@receiveTimeout
		
		on_http_client_init do |http_client, headers|
			http_client.ssl_config.verify_mode		= OpenSSL::SSL::VERIFY_NONE
			http_client.ssl_config.verify_callback	= method(:verify_callback).to_proc
			http_client.receive_timeout				= @receiveTimeout
		end
		
		on_log_header { |msg| $vim_log.info msg }
		on_log_body   { |msg| $vim_log.debug msg if $miq_wiredump }
	
		super(:uri => sdk_uri, :version => 1)
		
		@connected	= false
		@connLock	= Sync.new
	end

	def sdk_uri
		URI::HTTPS.build(:host => server, :path => "/sdk")
	end
	
	def self.receiveTimeout=(val)
		@@receiveTimeout = val
	end
	
	def self.receiveTimeout
		@@receiveTimeout
	end
	
	def receiveTimeout=(val)
		@connLock.synchronize(:EX) do
			@receiveTimeout = val
			http_client.receive_timeout = @receiveTimeout if http_client
		end
	end
	
	def receiveTimeout
		@connLock.synchronize(:SH) do
			@receiveTimeout
		end
	end
	
	def connect
		$vim_log.debug "#{self.class.name}.connect(#{@connId}): #{$PROGRAM_NAME} #{ARGV.join(' ')}" if $vim_log.debug?
		@connLock.synchronize(:EX) do
			return if @connected
			login(@sic.sessionManager, @username, @password)
			@connected = true
		end
	end
	
	def disconnect
		$vim_log.debug "#{self.class.name}.disconnect(#{@connId}): #{$PROGRAM_NAME} #{ARGV.join(' ')}" if $vim_log.debug?
		@connLock.synchronize(:EX) do
			return if !@connected
			logout(@sic.sessionManager)
			@connected = false
		end
	end
	
	def currentServerTime
	    DateTime.parse(currentTime)
    end
	
	def acquireCloneTicket
		super(@sic.sessionManager)
	end

	def verify_callback(is_ok, ctx)
        if $DEBUG
            puts "#{ is_ok ? 'ok' : 'ng' }: #{ctx.current_cert.subject}"
        end
        if !is_ok
            depth = ctx.error_depth
            code = ctx.error
            msg = ctx.error_string
            STDERR.puts "at depth #{depth} - #{code}: #{msg}" if $DEBUG
        end
        is_ok
    end
end # class MiqVimClientBase