7335

pending completion

Build # 7335

Build Type

cron

travis-ci-com

Committed by

Fryguy

Commit Message

<a href="https://github.com/ManageIQ/manageiq-providers-vmware/commit/<a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/<a class="double-link" href="https://git"><a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/<a class="double-link" href="https://git"><a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/<a class="double-link" href="https://git"><a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/<a class="double-link" href="https://git"><a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/<a class="double-link" href="https://git"><a class=hub.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5">f1505e7e7">&lt;a href=&quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/</a><a class="double-link" href="https://github.com/ManageIQ/manageiq-providers-vmware/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/ManageIQ/manageiq-providers-vmware/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/ManageIQ/manageiq-providers-vmware/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/ManageIQ/manageiq-providers-vmware/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5">f1505e7e7</a><a href="https://github.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5">&lt;a href=&quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/&amp;amp;lt;a class=&amp;amp;quot;double-link&amp;amp;quot; href=&amp;amp;quot;https://git&amp;quot;&amp;gt;&amp;amp;lt;a class=&amp;lt;/a&amp;gt;hub.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5&amp;quot;&amp;gt;f1505e7e7&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/ManageIQ/manageiq-providers-vmware/commit/f1505e7e720749dd960b1500d262d37545ee81e5&amp;amp;quot;&amp;amp;gt;&amp;amp;amp;quot;&amp;amp;amp;gt;Merge pull request #783 from ... (continued)

Run Details

758 of 6577 relevant lines covered (11.53%)

0.12 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

22.03

/app/models/manageiq/providers/vmware/infra_manager/vm/remote_console.rb

module ManageIQ::Providers::Vmware::InfraManager::Vm::RemoteConsole
  def console_supported?(type)
    %w(VMRC VNC WEBMKS).include?(type.upcase)
  end

  def validate_remote_console_acquire_ticket(protocol, options = {})
    raise(MiqException::RemoteConsoleNotSupportedError, "#{protocol} remote console requires the vm to be registered with a management system.") if ext_management_system.nil?

    raise(MiqException::RemoteConsoleNotSupportedError, "remote console requires console credentials") if ext_management_system.authentication_type(:console).nil? && protocol == "vmrc"

    options[:check_if_running] = true unless options.key?(:check_if_running)
    raise(MiqException::RemoteConsoleNotSupportedError, "#{protocol} remote console requires the vm to be running.") if options[:check_if_running] && state != "on"
  end

  def remote_console_acquire_ticket(userid, originating_server, protocol)
    send("remote_console_#{protocol.to_s.downcase}_acquire_ticket", userid, originating_server)
  end

  def remote_console_acquire_ticket_queue(protocol, userid)
    task_opts = {
      :action => "acquiring Vm #{name} #{protocol.to_s.upcase} remote console ticket for user #{userid}",
      :userid => userid
    }

    queue_opts = {
      :class_name  => self.class.name,
      :instance_id => id,
      :method_name => 'remote_console_acquire_ticket',
      :queue_name  => queue_name_for_ems_operations,
      :priority    => MiqQueue::HIGH_PRIORITY,
      :role        => 'ems_operations',
      :zone        => my_zone,
      :args        => [userid, MiqServer.my_server.id, protocol]
    }

    MiqTask.generic_action_with_callback(task_opts, queue_opts)
  end

  #
  # VMRC
  #

  def remote_console_vmrc_acquire_ticket(_userid = nil, _originating_server = nil)
    validate_remote_console_acquire_ticket("vmrc")
    ticket = ext_management_system.remote_console_vmrc_acquire_ticket

    {
      :ticket     => ticket.to_s, # Ensure ticket is a basic String not a VimString
      :remote_url => build_vmrc_url(ticket),
      :proto      => 'remote'
    }
  end

  def validate_remote_console_vmrc_support
    validate_remote_console_acquire_ticket("vmrc")
    ext_management_system.validate_remote_console_vmrc_support
    true
  end

  #
  # WebMKS
  #

  def remote_console_webmks_acquire_ticket(userid, originating_server = nil)
    validate_remote_console_acquire_ticket("webmks")
    ticket = ext_management_system.vm_remote_console_webmks_acquire_ticket(self)

    SystemConsole.force_vm_invalid_token(id)

    console_args = {
      :user       => User.find_by(:userid => userid),
      :vm_id      => id,
      :ssl        => true,
      :protocol   => 'webmks',
      :secret     => ticket['ticket'].to_s, # Ensure ticket is a basic String not a VimString
      :url_secret => SecureRandom.hex,
    }

    SystemConsole.launch_proxy_if_not_local(console_args, originating_server, ticket['host'].to_s, ticket['port'].to_i)
  end

  def validate_remote_console_webmks_support
    validate_remote_console_acquire_ticket("webmks")
    ext_management_system.validate_remote_console_webmks_support
    true
  end

  #
  # HTML5 selects the best available console type (VNC or WebMKS)
  #
  def remote_console_html5_acquire_ticket(userid, originating_server = nil)
    protocol = 'vnc' if ext_management_system.api_version.to_f < 6.0 # Force VNC protocol for API version lower than 6.0
    protocol ||= with_provider_object { |v| v.extraConfig["RemoteDisplay.vnc.enabled"] == "true" } ? 'vnc' : 'webmks'
    send("remote_console_#{protocol}_acquire_ticket", userid, originating_server)
  end

  #
  # VNC
  #
  def remote_console_vnc_acquire_ticket(userid, originating_server)
    require 'securerandom'

    validate_remote_console_acquire_ticket("vnc")

    password     = SecureRandom.base64[0, 8] # Random password from the Base64 character set
    host_port    = host.reserve_next_available_vnc_port

    # Determine if any Vms on this Host already have this port, and if so, disable them
    old_vms = host.vms_and_templates.where(:vnc_port => host_port)
    old_vms.each do |old_vm|
      _log.info "Disabling VNC on #{old_vm.class.name} id: [#{old_vm.id}] name: [#{old_vm.name}], since the port is being reused."
      old_vm.with_provider_object do |vim_vm|
        vim_vm.setRemoteDisplayVncAttributes(:enabled => false, :port => nil, :password => nil)
      end
    end
    old_vms.update_all(:vnc_port => nil)

    # Enable on this Vm with the requested port and random password
    _log.info "Enabling VNC on #{self.class.name} id: [#{id}] name: [#{name}]"
    with_provider_object do |vim_vm|
      vim_vm.setRemoteDisplayVncAttributes(:enabled => true, :port => host_port, :password => password)
    end
    update(:vnc_port => host_port)

    SystemConsole.force_vm_invalid_token(id)

    console_args = {
      :user       => User.find_by(:userid => userid),
      :vm_id      => id,
      :ssl        => false,
      :protocol   => 'vnc',
      :secret     => password,
      :url_secret => SecureRandom.hex
    }
    host_address = host.hostname

    SystemConsole.launch_proxy_if_not_local(console_args, originating_server, host_address, host_port)
  end

  private

  # Method to generate the remote URI for the VMRC console
  def build_vmrc_url(ticket)
    url = URI::Generic.build(:scheme   => "vmrc",
                             :userinfo => "clone:#{ticket}",
                             :host     => ext_management_system.hostname || ext_management_system.ipaddress,
                             :port     => 443,
                             :path     => "/",
                             :query    => "moid=#{ems_ref}").to_s
    # VMRC doesn't like brackets around IPv6 addresses
    url.sub(/(.*)\[/, '\1').sub(/(.*)\]/, '\1')
  end
end

1	module ManageIQ::Providers::Vmware::InfraManager::Vm::RemoteConsole	1✔
2	def console_supported?(type)	1✔
3	%w(VMRC VNC WEBMKS).include?(type.upcase)	×
4	end
5
6	def validate_remote_console_acquire_ticket(protocol, options = {})	1✔
7	raise(MiqException::RemoteConsoleNotSupportedError, "#{protocol} remote console requires the vm to be registered with a management system.") if ext_management_system.nil?	×
8
9	raise(MiqException::RemoteConsoleNotSupportedError, "remote console requires console credentials") if ext_management_system.authentication_type(:console).nil? && protocol == "vmrc"	×
10
11	options[:check_if_running] = true unless options.key?(:check_if_running)	×
12	raise(MiqException::RemoteConsoleNotSupportedError, "#{protocol} remote console requires the vm to be running.") if options[:check_if_running] && state != "on"	×
13	end
14
15	def remote_console_acquire_ticket(userid, originating_server, protocol)	1✔
16	send("remote_console_#{protocol.to_s.downcase}_acquire_ticket", userid, originating_server)	×
17	end
18
19	def remote_console_acquire_ticket_queue(protocol, userid)	1✔
20	task_opts = {
21	:action => "acquiring Vm #{name} #{protocol.to_s.upcase} remote console ticket for user #{userid}",	×
22	:userid => userid
23	}
24
25	queue_opts = {
26	:class_name => self.class.name,	×
27	:instance_id => id,
28	:method_name => 'remote_console_acquire_ticket',
29	:queue_name => queue_name_for_ems_operations,
30	:priority => MiqQueue::HIGH_PRIORITY,
31	:role => 'ems_operations',
32	:zone => my_zone,
33	:args => [userid, MiqServer.my_server.id, protocol]
34	}
35
36	MiqTask.generic_action_with_callback(task_opts, queue_opts)	×
37	end
38
39	#
40	# VMRC
41	#
42
43	def remote_console_vmrc_acquire_ticket(_userid = nil, _originating_server = nil)	1✔
44	validate_remote_console_acquire_ticket("vmrc")	×
45	ticket = ext_management_system.remote_console_vmrc_acquire_ticket	×
46
47	{
48	:ticket => ticket.to_s, # Ensure ticket is a basic String not a VimString	×
49	:remote_url => build_vmrc_url(ticket),
50	:proto => 'remote'
51	}
52	end
53
54	def validate_remote_console_vmrc_support	1✔
55	validate_remote_console_acquire_ticket("vmrc")	×
56	ext_management_system.validate_remote_console_vmrc_support	×
57	true	×
58	end
59
60	#
61	# WebMKS
62	#
63
64	def remote_console_webmks_acquire_ticket(userid, originating_server = nil)	1✔
65	validate_remote_console_acquire_ticket("webmks")	×
66	ticket = ext_management_system.vm_remote_console_webmks_acquire_ticket(self)	×
67
68	SystemConsole.force_vm_invalid_token(id)	×
69
70	console_args = {
71	:user => User.find_by(:userid => userid),	×
72	:vm_id => id,
73	:ssl => true,
74	:protocol => 'webmks',
75	:secret => ticket['ticket'].to_s, # Ensure ticket is a basic String not a VimString
76	:url_secret => SecureRandom.hex,
77	}
78
79	SystemConsole.launch_proxy_if_not_local(console_args, originating_server, ticket['host'].to_s, ticket['port'].to_i)	×
80	end
81
82	def validate_remote_console_webmks_support	1✔
83	validate_remote_console_acquire_ticket("webmks")	×
84	ext_management_system.validate_remote_console_webmks_support	×
85	true	×
86	end
87
88	#
89	# HTML5 selects the best available console type (VNC or WebMKS)
90	#
91	def remote_console_html5_acquire_ticket(userid, originating_server = nil)	1✔
92	protocol = 'vnc' if ext_management_system.api_version.to_f < 6.0 # Force VNC protocol for API version lower than 6.0	×
93	protocol \|\|= with_provider_object { \|v\| v.extraConfig["RemoteDisplay.vnc.enabled"] == "true" } ? 'vnc' : 'webmks'	×
94	send("remote_console_#{protocol}_acquire_ticket", userid, originating_server)	×
95	end
96
97	#
98	# VNC
99	#
100	def remote_console_vnc_acquire_ticket(userid, originating_server)	1✔
101	require 'securerandom'	×
102
103	validate_remote_console_acquire_ticket("vnc")	×
104
105	password = SecureRandom.base64[0, 8] # Random password from the Base64 character set	×
106	host_port = host.reserve_next_available_vnc_port	×
107
108	# Determine if any Vms on this Host already have this port, and if so, disable them
109	old_vms = host.vms_and_templates.where(:vnc_port => host_port)	×
110	old_vms.each do \|old_vm\|	×
111	_log.info "Disabling VNC on #{old_vm.class.name} id: [#{old_vm.id}] name: [#{old_vm.name}], since the port is being reused."	×
112	old_vm.with_provider_object do \|vim_vm\|	×
113	vim_vm.setRemoteDisplayVncAttributes(:enabled => false, :port => nil, :password => nil)	×
114	end
115	end
116	old_vms.update_all(:vnc_port => nil)	×
117
118	# Enable on this Vm with the requested port and random password
119	_log.info "Enabling VNC on #{self.class.name} id: [#{id}] name: [#{name}]"	×
120	with_provider_object do \|vim_vm\|	×
121	vim_vm.setRemoteDisplayVncAttributes(:enabled => true, :port => host_port, :password => password)	×
122	end
123	update(:vnc_port => host_port)	×
124
125	SystemConsole.force_vm_invalid_token(id)	×
126
127	console_args = {
128	:user => User.find_by(:userid => userid),	×
129	:vm_id => id,
130	:ssl => false,
131	:protocol => 'vnc',
132	:secret => password,
133	:url_secret => SecureRandom.hex
134	}
135	host_address = host.hostname	×
136
137	SystemConsole.launch_proxy_if_not_local(console_args, originating_server, host_address, host_port)	×
138	end
139
140	private	1✔
141
142	# Method to generate the remote URI for the VMRC console
143	def build_vmrc_url(ticket)	1✔
144	url = URI::Generic.build(:scheme => "vmrc",	×
145	:userinfo => "clone:#{ticket}",
146	:host => ext_management_system.hostname \|\| ext_management_system.ipaddress,
147	:port => 443,
148	:path => "/",
149	:query => "moid=#{ems_ref}").to_s
150	# VMRC doesn't like brackets around IPv6 addresses
151	url.sub(/(.)\[/, '\1').sub(/(.)\]/, '\1')	×
152	end
153	end

ManageIQ / manageiq-providers-vmware / 7335

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous