Class: Chef::Provider::Deploy

Inherits:
Chef::Provider show all
Includes:
Mixin::Command, Mixin::FromFile
Defined in:
lib/chef/provider/deploy.rb,
lib/chef/provider/deploy/revision.rb,
lib/chef/provider/deploy/timestamped.rb

Direct Known Subclasses

Revision, Timestamped

Defined Under Namespace

Classes: Revision, Timestamped

Instance Attribute Summary collapse

Attributes inherited from Chef::Provider

#current_resource, #new_resource, #run_context

Instance Method Summary collapse

Methods included from Mixin::Command

#chdir_or_tmpdir, #handle_command_failures, #not_if, #only_if, #output_of_command, #run_command, #run_command_with_systems_locale

Methods included from Mixin::Command::Windows

#popen4

Methods included from Mixin::Command::Unix

#popen4

Methods included from Mixin::FromFile

#class_from_file, #from_file

Methods inherited from Chef::Provider

#action_nothing, build_from_file, #cookbook_name, #node, #resource_collection

Methods included from Mixin::ConvertToClassName

#convert_to_class_name, #convert_to_snake_case, #filename_to_qualified_string, #snake_case_basename

Methods included from Mixin::RecipeDefinitionDSLCore

#method_missing

Methods included from Mixin::Language

#data_bag, #data_bag_item, #platform?, #search, #value_for_platform

Constructor Details

#initialize(new_resource, run_context) ⇒ Deploy

Returns a new instance of Deploy.



33
34
35
36
37
38
39
40
41
42
 
# File 'lib/chef/provider/deploy.rb', line 33

def initialize(new_resource, run_context)
  super(new_resource, run_context)
  
  @scm_provider = new_resource.scm_provider.new(new_resource, run_context)
  
  # @configuration is not used by Deploy, it is only for backwards compat with
  # chef-deploy or capistrano hooks that might use it to get environment information
  @configuration = @new_resource.to_hash
  @configuration[:environment] = @configuration[:environment] && @configuration[:environment]["RAILS_ENV"]
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class Chef::Mixin::RecipeDefinitionDSLCore

Instance Attribute Details

#release_path ⇒ Object (readonly)

Returns the value of attribute release_path.



31
32
33
 
# File 'lib/chef/provider/deploy.rb', line 31

def release_path
  @release_path
end

#scm_provider ⇒ Object (readonly)

Returns the value of attribute scm_provider.



31
32
33
 
# File 'lib/chef/provider/deploy.rb', line 31

def scm_provider
  @scm_provider
end

Instance Method Details

#action_deploy ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/chef/provider/deploy.rb', line 61

def action_deploy
  if all_releases.include?(release_path)
    if all_releases[-1] == release_path
      Chef::Log.debug("Already deployed app at #{release_path}, and it is the latest revision.  Use action :force_deploy to re-deploy this revision.")
    else
      Chef::Log.info("Already deployed app at #{release_path}.  Rolling back to it - use action :force_deploy to re-checkout this revision.")
      action_rollback
    end
  else
    deploy
    @new_resource.updated_by_last_action(true)
  end
end

#action_force_deploy ⇒ Object 



75
76
77
78
79
80
81
82
 
# File 'lib/chef/provider/deploy.rb', line 75

def action_force_deploy
  if all_releases.include?(release_path)
    Chef::Log.info("Already deployed app at #{release_path}, forcing.")
    FileUtils.rm_rf(release_path)
  end
  deploy
  @new_resource.updated_by_last_action(true)
end

#action_rollback ⇒ Object 



84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
# File 'lib/chef/provider/deploy.rb', line 84

def action_rollback
  if release_path
    rp_index = all_releases.index(release_path)
    raise RuntimeError, "There is no release to rollback to!" unless rp_index
    rp_index += 1
    releases_to_nuke = all_releases[rp_index..-1]
  else
    @release_path = all_releases[-2] 
    raise RuntimeError, "There is no release to rollback to!" unless @release_path
    releases_to_nuke = [ all_releases.last ]
  end

  Chef::Log.info "rolling back to previous release: #{release_path}"
  symlink
  Chef::Log.info "restarting with previous release"
  restart
  releases_to_nuke.each do |i|
    Chef::Log.info "Removing release: #{i}"
    FileUtils.rm_rf i 
    release_deleted(i)
  end
  @new_resource.updated_by_last_action(true)
end

#all_releases ⇒ Object 



188
189
190
 
# File 'lib/chef/provider/deploy.rb', line 188

def all_releases
  Dir.glob(@new_resource.deploy_to + "/releases/*").sort
end

#callback(what, callback_code = nil) ⇒ Object 



125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
 
# File 'lib/chef/provider/deploy.rb', line 125

def callback(what, callback_code=nil)
  @collection = Chef::ResourceCollection.new
  case callback_code
  when Proc
    Chef::Log.info "Running callback #{what} code block"
    recipe_eval(&callback_code)
  when String
    callback_file = "#{release_path}/#{callback_code}"
    unless ::File.exist?(callback_file)
      raise RuntimeError, "Can't find your callback file #{callback_file}"
    end
    run_callback_from_file(callback_file)
  when nil
    run_callback_from_file("#{release_path}/deploy/#{what}.rb")
  else
    raise RuntimeError, "You gave me a callback I don't know what to do with: #{callback_code.inspect}"
  end
end

#cleanup! ⇒ Object 



180
181
182
183
184
185
186
 
# File 'lib/chef/provider/deploy.rb', line 180

def cleanup!
  all_releases[0..-6].each do |old_release|
    Chef::Log.info "Removing old release #{old_release}"
    FileUtils.rm_rf(old_release)
    release_deleted(old_release)
  end
end

#copy_cached_repo ⇒ Object 



210
211
212
213
214
215
 
# File 'lib/chef/provider/deploy.rb', line 210

def copy_cached_repo
  Chef::Log.info "copying the cached checkout to #{release_path}"
  FileUtils.mkdir_p(@new_resource.deploy_to + "/releases")
  run_command(:command => "cp -RPp #{::File.join(@new_resource.destination, ".")} #{release_path}")
  release_created(release_path)
end

#create_dirs_before_symlink ⇒ Object 



251
252
 
# File 'lib/chef/provider/deploy.rb', line 251

def create_dirs_before_symlink
end

#deploy ⇒ Object 



108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'lib/chef/provider/deploy.rb', line 108

def deploy
  Chef::Log.info "deploying branch: #{@new_resource.branch}"
  enforce_ownership
  update_cached_repo
  copy_cached_repo
  install_gems
  enforce_ownership
  callback(:before_migrate, @new_resource.before_migrate)
  migrate
  callback(:before_symlink, @new_resource.before_symlink)
  symlink
  callback(:before_restart, @new_resource.before_restart)
  restart
  callback(:after_restart, @new_resource.after_restart)
  cleanup!
end

#enforce_ownership ⇒ Object 



217
218
219
220
 
# File 'lib/chef/provider/deploy.rb', line 217

def enforce_ownership
  Chef::Log.info "ensuring proper ownership"
  FileUtils.chown_R(@new_resource.user, @new_resource.group, @new_resource.deploy_to)
end

#link_current_release_to_production ⇒ Object 



222
223
224
225
226
227
 
# File 'lib/chef/provider/deploy.rb', line 222

def link_current_release_to_production
  Chef::Log.info "Linking release #{release_path} into production at #{@new_resource.current_path}"
  FileUtils.rm_f(@new_resource.current_path)
  FileUtils.ln_sf(release_path, @new_resource.current_path)
  enforce_ownership
end

#link_tempfiles_to_current_release ⇒ Object 



237
238
239
240
241
242
243
244
245
246
247
248
249
 
# File 'lib/chef/provider/deploy.rb', line 237

def link_tempfiles_to_current_release
  dirs_info = @new_resource.create_dirs_before_symlink.join(",")
  Chef::Log.info("creating directories before symlink: #{dirs_info}")
  @new_resource.create_dirs_before_symlink.each { |dir| FileUtils.mkdir_p(release_path + "/#{dir}") }
  
  links_info = @new_resource.symlinks.map { |src, dst| "#{src} => #{dst}" }.join(", ")
  Chef::Log.info("Linking shared paths into current release: #{links_info}")
  @new_resource.symlinks.each do |src, dest|
    FileUtils.ln_sf(@new_resource.shared_path + "/#{src}",  release_path + "/#{dest}")
  end
  run_symlinks_before_migrate
  enforce_ownership
end

#load_current_resource ⇒ Object 



44
45
46
 
# File 'lib/chef/provider/deploy.rb', line 44

def load_current_resource
  @release_path = @new_resource.deploy_to + "/releases/#{release_slug}"
end

#migrate ⇒ Object 



144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
 
# File 'lib/chef/provider/deploy.rb', line 144

def migrate
  run_symlinks_before_migrate
  
  if @new_resource.migrate
    enforce_ownership
    
    environment = @new_resource.environment
    env_info = environment && environment.map do |key_and_val| 
      "#{key_and_val.first}='#{key_and_val.last}'"
    end.join(" ")
    
    Chef::Log.info  "Migrating: running #{@new_resource.migration_command} as #{@new_resource.user} " +
                    "with environment #{env_info}"
    run_command(run_options(:command => @new_resource.migration_command, :cwd=>release_path))
  end
end

#purge_tempfiles_from_current_release ⇒ Object 



254
255
256
257
258
 
# File 'lib/chef/provider/deploy.rb', line 254

def purge_tempfiles_from_current_release
  log_info = @new_resource.purge_before_symlink.join(", ")
  Chef::Log.info("Purging directories in checkout #{log_info}")
  @new_resource.purge_before_symlink.each { |dir| FileUtils.rm_rf(release_path + "/#{dir}") }
end

#restart ⇒ Object 



168
169
170
171
172
173
174
175
176
177
178
 
# File 'lib/chef/provider/deploy.rb', line 168

def restart
  if restart_cmd = @new_resource.restart_command
    if restart_cmd.kind_of?(Proc)
      Chef::Log.info("Restarting app with embedded recipe")
      recipe_eval(&restart_cmd)
    else
      Chef::Log.info("Restarting app with #{@new_resource.restart_command} in #{@new_resource.current_path}")
      run_command(run_options(:command => @new_resource.restart_command, :cwd => @new_resource.current_path))
    end
  end
end

#run(command, &block) ⇒ Object 



52
53
54
55
56
57
58
59
 
# File 'lib/chef/provider/deploy.rb', line 52

def run(command, &block)
  exec = execute(command, &block)
  exec.user(@new_resource.user) if @new_resource.user
  exec.group(@new_resource.group) if @new_resource.group
  exec.cwd(release_path) unless exec.cwd
  exec.environment(@new_resource.environment) unless exec.environment 
  exec
end

#run_scm_sync ⇒ Object 



200
201
202
203
 
# File 'lib/chef/provider/deploy.rb', line 200

def run_scm_sync
  Chef::Log.info "updating the cached checkout"
  @scm_provider.action_sync
end

#run_symlinks_before_migrate ⇒ Object 



229
230
231
232
233
234
235
 
# File 'lib/chef/provider/deploy.rb', line 229

def run_symlinks_before_migrate
  links_info = @new_resource.symlink_before_migrate.map { |src, dst| "#{src} => #{dst}" }.join(", ")
  Chef::Log.info "Making pre-migration symlinks: #{links_info}"
  @new_resource.symlink_before_migrate.each do |src, dest|
    FileUtils.ln_sf(@new_resource.shared_path + "/#{src}", release_path + "/#{dest}")
  end
end

#sudo(command, &block) ⇒ Object 



48
49
50
 
# File 'lib/chef/provider/deploy.rb', line 48

def sudo(command,&block)
  execute(command, &block)
end

#svn_force_export ⇒ Object 



205
206
207
208
 
# File 'lib/chef/provider/deploy.rb', line 205

def svn_force_export
  Chef::Log.info "exporting source repository to #{@new_resource.destination}"
  @scm_provider.action_force_export
end

#symlink ⇒ Object 



161
162
163
164
165
166
 
# File 'lib/chef/provider/deploy.rb', line 161

def symlink
  Chef::Log.info "Symlinking"
  purge_tempfiles_from_current_release
  link_tempfiles_to_current_release
  link_current_release_to_production
end

#update_cached_repo ⇒ Object 



192
193
194
195
196
197
198
 
# File 'lib/chef/provider/deploy.rb', line 192

def update_cached_repo
  if @new_resource.svn_force_export
    svn_force_export
  else
    run_scm_sync
  end
end