Class: Chap::Runner

Inherits:
Object
  • Object
show all
Includes:
Benchmarking, SpecialMethods
Defined in:
lib/chap/runner.rb

Constant Summary

Constants included from SpecialMethods

SpecialMethods::SPECIAL_METHODS

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Benchmarking

#benchmarks, included, #report_benchmarks, #shorten_name

Methods included from SpecialMethods

included

Constructor Details

#initialize(options = {}) ⇒ Runner

Returns a new instance of Runner.



7
8
9
10
 
# File 'lib/chap/runner.rb', line 7

def initialize(options={})
  @options = options
  @config = Config.new(options)
end

Instance Attribute Details

#config ⇒ Object (readonly)

Returns the value of attribute config.



6
7
8
 
# File 'lib/chap/runner.rb', line 6

def config
  @config
end

#options ⇒ Object (readonly)

Returns the value of attribute options.



6
7
8
 
# File 'lib/chap/runner.rb', line 6

def options
  @options
end

Instance Method Details

#camel_case(string) ⇒ Object 



69
70
71
72
 
# File 'lib/chap/runner.rb', line 69

def camel_case(string)
  return string if string !~ /_/ && string =~ /[A-Z]+.*/
  string.split('_').map{|e| e.capitalize}.join
end

#cleanup ⇒ Object 



108
109
110
111
112
 
# File 'lib/chap/runner.rb', line 108

def cleanup
  log "Cleaning up".colorize(:green)
  remove_old_releases
  logrotate
end

#deploy ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/chap/runner.rb', line 12

def deploy
  puts "Deploy started" unless options[:silence]
  deploy_to_symlink
  deploy_from_symlink
  report_benchmarks
  puts "Deploy finished" unless options[:silence]
end

#deploy_from_symlink(use_previous = false) ⇒ Object 



28
29
30
31
32
33
 
# File 'lib/chap/runner.rb', line 28

def deploy_from_symlink(use_previous=false)
  use_previous_timestamp if use_previous
  symlink_current
  hook(:restart)
  cleanup
end

#deploy_to_symlink ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/chap/runner.rb', line 20

def deploy_to_symlink
  setup
  deploy_via_strategy
  symlink_shared
  rm_rvmrc
  hook(:deploy)
end

#deploy_via_strategy ⇒ Object 



65
66
67
 
# File 'lib/chap/runner.rb', line 65

def deploy_via_strategy
  strategy.deploy
end

#hook(name) ⇒ Object 



163
164
165
166
167
168
169
170
171
 
# File 'lib/chap/runner.rb', line 163

def hook(name)
  log "Running hook: #{name}".colorize(:green)
  path = "#{release_path}/chap/#{name}"
  if File.exist?(path)
    Hook.new(path, @config).evaluate
  else
    log "chap/#{name} hook does not exist".colorize(:red)
  end
end

#logrotate ⇒ Object 



124
125
126
 
# File 'lib/chap/runner.rb', line 124

def logrotate
  logrotate_file(config.chap_log_path)
end

#logrotate_file(log_path) ⇒ Object 



132
133
134
135
136
137
138
139
140
141
142
 
# File 'lib/chap/runner.rb', line 132

def logrotate_file(log_path)
  dirname = File.dirname(log_path)
  basename = File.basename(log_path, '.log')
  archive = "#{dirname}/#{basename}-#{logrotate_timestamp}.log"
  FileUtils.cp(log_path, archive) if File.exist?(log_path)
  logs = Dir.glob("#{dirname}/#{basename}-*.log").sort.reverse
  delete = logs - logs[0..9] # keep last 10 chap logs
  delete.each do |old_log|
    FileUtils.rm_f(old_log)
  end
end

#logrotate_timestamp ⇒ Object 



128
129
130
 
# File 'lib/chap/runner.rb', line 128

def logrotate_timestamp
  @logrotate_timestamp ||= Time.now.strftime("%Y-%m-%d-%H-%M-%S")
end

#remove_old_releases ⇒ Object 



114
115
116
117
118
119
120
121
122
 
# File 'lib/chap/runner.rb', line 114

def remove_old_releases
  dirname = File.dirname(release_path)
  releases = Dir.glob("#{dirname}/*").sort.reverse
  keep = config.chap[:keep] || 5
  delete = releases - releases[0..keep-1]
  delete.each do |old_release|
    FileUtils.rm_rf(old_release)
  end
end

#rm_rvmrc ⇒ Object 



101
102
103
104
105
106
 
# File 'lib/chap/runner.rb', line 101

def rm_rvmrc
  %w[.rvmrc .ruby-version].each do |file|
    path = "#{release_path}/#{file}"
    run "rm -f #{path}" if File.exist?(path)
  end
end

#setup ⇒ Object 



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/chap/runner.rb', line 40

def setup
  user = config.chap[:user] || ENV['USER']
  group = config.chap[:group]
  begin
    FileUtils.mkdir_p(deploy_to)
    FileUtils.chown_R user, group, deploy_to
  rescue Exception
    # retry to create deploy_to folder with sudo
    user_group = [user,group].compact.join(':')
    raise unless system("sudo mkdir -p #{deploy_to}")
    raise unless system("sudo chown -R #{user_group} #{deploy_to}")
  end
  dirs = ["#{deploy_to}/releases"]
  dirs += shared_dirs
  dirs.each do |dir|
    FileUtils.mkdir_p(dir)
  end
end

#shared_dirs ⇒ Object 



144
145
146
147
148
149
150
151
 
# File 'lib/chap/runner.rb', line 144

def shared_dirs
  dirs = config.chap[:shared_dirs] || [
    "system",
    "log",
    "tmp/pids"
  ]
  dirs.map! {|p| "#{shared_path}/#{p}"}
end

#strategy ⇒ Object 



59
60
61
62
63
 
# File 'lib/chap/runner.rb', line 59

def strategy
  strategy = config.strategy
  klass = Strategy.const_get(camel_case(strategy))
  @strategy ||= klass.new(:config => @config)
end

#symlink ⇒ Object 



35
36
37
38
 
# File 'lib/chap/runner.rb', line 35

def symlink
  use_previous_timestamp
  symlink_current
end

#symlink_current ⇒ Object 



95
96
97
98
99
 
# File 'lib/chap/runner.rb', line 95

def symlink_current
  FileUtils.rm(current_path) if File.exist?(current_path)
  FileUtils.ln_s(release_path, current_path)
  log "Current symlink updated".colorize(:green)
end

#symlink_shared ⇒ Object 



74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/chap/runner.rb', line 74

def symlink_shared
  shared_dirs.each do |path|
    src = path
    relative_path = path.sub("#{shared_path}/",'')
    dest = if relative_path == "system"
             "#{release_path}/public/#{relative_path}"
           else
             "#{release_path}/#{relative_path}"
           end
    # make sure the directory exist for symlink creation
    dirname = File.dirname(dest)
    FileUtils.mkdir_p(dirname) unless File.exist?(dirname)
    if File.symlink?(dest)
      File.delete(dest)
    elsif File.exist?(dest)
      FileUtils.rm_rf(dest)
    end
    FileUtils.ln_s(src,dest)
  end
end

#test_hook(name) ⇒ Object 



153
154
155
156
 
# File 'lib/chap/runner.rb', line 153

def test_hook(name)
  use_previous_timestamp
  hook(name)
end

#use_previous_timestamp ⇒ Object 



158
159
160
161
 
# File 'lib/chap/runner.rb', line 158

def use_previous_timestamp
  timestamp = File.basename(latest_release)
  config.override_timestamp(timestamp)
end