Class: Actions::RemoteExecution::RunHostJob

Inherits:
EntryAction
  • Object
show all
Includes:
Dynflow::Action::Cancellable
Defined in:
app/lib/actions/remote_execution/run_host_job.rb

Instance Method Summary collapse

Instance Method Details

#all_host_proxies(host) ⇒ Object 



80
81
82
83
84
85
86
87
88
89
90
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 80

def all_host_proxies(host)
  Enumerator.new do |e|
    host.interfaces.each do |interface|
      if interface.subnet
        e << ::SmartProxy.where(:id => interface.subnet.proxies.map(&:id))
      end
    end
    e << host.smart_proxies
    e << ::SmartProxy.authorized if Setting[:remote_execution_global_proxy]
  end
end

#available_providers(job_invocation, host) ⇒ Object 



64
65
66
67
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 64

def available_providers(job_invocation, host)
  # TODO: determine from the host and job_invocation details
  return ['Ssh']
end

#find_ip_or_hostname(host) ⇒ Object 



57
58
59
60
61
62
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 57

def find_ip_or_hostname(host)
  host.interfaces.each do |interface|
    return interface.ip unless interface.ip.blank?
  end
  return host.name
end

#find_proxy(template_invocation, host) ⇒ Object 



69
70
71
72
73
74
75
76
77
78
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 69

def find_proxy(template_invocation, host)
  provider = template_invocation.template.provider_type.to_s
  all_host_proxies(host).each do |proxies|
    if proxy = proxies.joins(:features).where("features.name = ?", provider).first
      return proxy
    end
  end
  raise _("Could not use any proxy: assign a proxy with provider '%{provider}' to the host or set '%{global_proxy_setting}' in settings") %\
      { :provider => provider, :global_proxy_setting => 'remote_execution_global_proxy' }
end

#find_template_invocation(job_invocation, host) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 44

def find_template_invocation(job_invocation, host)
  providers = available_providers(job_invocation, host)
  providers.each do |provider|
    job_invocation.template_invocations.each do |template_invocation|
      if template_invocation.template.provider_type == provider
        return template_invocation
      end
    end
  end

  raise _("Could not use any template used in the job invocation")
end

#humanized_name ⇒ Object 



40
41
42
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 40

def humanized_name
  _('Run %{job_name} on %{host}') % { :job_name => input[:job_name], :host => input[:host][:name] }
end

#humanized_output ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 28

def humanized_output
  host_run_action = planned_actions(RunProxyCommand).first
  proxy_output = host_run_action && host_run_action.output[:proxy_output]
  return unless proxy_output
  output = []
  if proxy_output[:result]
    output << proxy_output[:result].map { |o| o[:output] }.join("")
  end
  output << "Exit status: #{host_run_action.exit_status}" if host_run_action.exit_status
  return output.join("\n")
end

#plan(job_invocation, host) ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 11

def plan(job_invocation, host)
  action_subject(host, :job_name => job_invocation.job_name)

  template_invocation = find_template_invocation(job_invocation, host)
  hostname = find_ip_or_hostname(host)
  proxy = find_proxy(template_invocation, host)

  renderer = InputTemplateRenderer.new(template_invocation.template, host, template_invocation)
  script = renderer.render
  raise _("Failed rendering template: %s") % renderer.error_message unless script

  link!(job_invocation)
  link!(template_invocation)

  plan_action(RunProxyCommand, proxy, hostname, script)
end

#resource_locks ⇒ Object 



5
6
7
 
# File 'app/lib/actions/remote_execution/run_host_job.rb', line 5

def resource_locks
  :link
end