Method: Wakame::Actions::DeployApplication#run

Defined in:
lib/wakame/actions/deploy_application.rb

#run ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/wakame/actions/deploy_application.rb', line 8

def run
  Wakame.log.debug("#{self.class}: run() Begin:")
  #raise "CloudHost is not mapped Agent: CloudHost.id=#{@svc.cloud_host.id}" unless @svc.cloud_host.mapped?

  repo_data = Models::ApplicationRepository.find(:app_name=>@app_name) || raise
  deploy_opts={}
  if repo_data[:repo_type] == 's3'
    deploy_opts[:aws_access_key] ||= Wakame.config.aws_access_key
    deploy_opts[:aws_secret_key] ||= Wakame.config.aws_secret_key
  end
  deploy_ticket = Wakame::Util.gen_id


  resclass_names = []
  svc_lst = []
  cluster.each_instance { |svc|
    next  unless svc.resource.tags.member?(repo_data.resource_tag.to_sym)
    resclass_names << svc.resource.class.to_s
    svc_lst << svc
  }

  if svc_lst.empty?
    return
  end

  resclass_names.uniq!
  acquire_lock(resclass_names)
  
  # Checkout apps from each repository
  svc_lst.each { |svc|
    trigger_action {|action|
      action.actor_request(svc.cloud_host.agent_id, '/deploy/checkout',
                           deploy_ticket,
                           repo_data[:repo_type],
                           repo_data[:repo_uri],
                           repo_data[:revision],
                           svc.resource.application_root_path,
                           repo_data[:app_name],
                           deploy_opts
                           ).request.wait
    }
  }
  flush_subactions

  # Reload Appserver
  svc_lst.each { |svc|
    actor_request(svc.cloud_host.agent_id, '/deploy/swap_current_link', svc.resource.application_root_path, repo_data[:app_name]).request.wait
    svc.resource.on_reload_application(svc, self, repo_data)
  }
end