Class: CapistranoMulticonfigParallel::Application

Inherits:
Object
  • Object
show all
Includes:
ApplicationHelper, Celluloid, Celluloid::Logger
Defined in:
lib/capistrano_multiconfig_parallel/application.rb

Overview

finds app dependencies, shows menu and delegates jobs to celluloid manager

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from ApplicationHelper

action_confirmed?, fetch_parsed_string, fetch_remaining_arguments, find_remaining_args, get_question_details, msg_for_stdin?, msg_for_task?, parse_task_string, percent_of, regex_last_match, setup_command_line_standard, wrap_string

Methods included from CapistranoHelper

env_key_format, env_prefix, filtered_env_keys_format, trace_flag

Methods included from GemHelper

fetch_gem_version, find_loaded_gem, find_loaded_gem_property, get_parsed_version, verify_gem_version

Methods included from StagesHelper

check_stage_path, checks_paths, fetch_stages_paths, sorted_paths, stages, stages_paths

Methods included from ParseHelper

check_hash_set, check_numeric, strip_characters_from_string, value_is_array?, verify_array_of_strings, verify_empty_options, warn_array_without_strings

Methods included from CoreHelper

app_debug_enabled?, ask_confirm, ask_stdout_confirmation, check_terminal_tty, debug_websocket?, error_filtered?, execute_with_rescue, find_worker_log, force_confirmation, format_error, log_error, log_output_error, log_to_file, multi_fetch_argv, print_to_log_file, rescue_error, rescue_interrupt, setup_filename_logger, setup_logger_formatter, show_warning, terminal_actor, terminal_errors?, websocket_config, websocket_server_config

Methods included from InternalHelper

arg_is_in_default_config?, check_file, config_file, create_log_file, custom_commands, default_config_keys, default_internal_config, default_internal_configuration_params, detect_root, enable_main_log_file, fail_capfile_not_found, fetch_default_internal_config, find_config_type, find_env_multi_cap_root, find_file_in_directory, internal_config_directory, internal_config_file, log_directory, main_log_file, multi_level_prop, pathname_is_root?, pwd_directory, pwd_parent_dir, root, setup_default_configuration_types, sliced_default_config, try_detect_capfile

Constructor Details

#initialize ⇒ Application

Returns a new instance of Application.



10
11
12
13
14
15
16
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 10

def initialize
  Celluloid.boot
  CapistranoMulticonfigParallel.enable_logging
  @stage_apps = multi_apps? ? stages.map { |stage| stage.split(':').reverse[1] }.uniq : []
  collect_command_line_tasks(CapistranoMulticonfigParallel.original_args)
  @jobs = []
end

Instance Attribute Details

#application ⇒ Object (readonly)

Returns the value of attribute application.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def application
  @application
end

#args ⇒ Object (readonly)

Returns the value of attribute args.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def args
  @args
end

#argv ⇒ Object (readonly)

Returns the value of attribute argv.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def argv
  @argv
end

#condition ⇒ Object (readonly)

Returns the value of attribute condition.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def condition
  @condition
end

#default_stage ⇒ Object (readonly)

Returns the value of attribute default_stage.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def default_stage
  @default_stage
end

#dependency_tracker ⇒ Object (readonly)

Returns the value of attribute dependency_tracker.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def dependency_tracker
  @dependency_tracker
end

#jobs ⇒ Object (readonly)

Returns the value of attribute jobs.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def jobs
  @jobs
end

#manager ⇒ Object (readonly)

Returns the value of attribute manager.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def manager
  @manager
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def name
  @name
end

#stage ⇒ Object (readonly)

Returns the value of attribute stage.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def stage
  @stage
end

#stage_apps ⇒ Object (readonly)

Returns the value of attribute stage_apps.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def stage_apps
  @stage_apps
end

#top_level_tasks ⇒ Object (readonly)

Returns the value of attribute top_level_tasks.



8
9
10
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 8

def top_level_tasks
  @top_level_tasks
end

Instance Method Details

#action_key ⇒ Object 



88
89
90
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 88

def action_key
  capistrano_version_2? ? 'action' : 'ACTION'
end

#boxes_key ⇒ Object 



180
181
182
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 180

def boxes_key
  capistrano_version_2? ? 'box' : 'BOX'
end

#call_task_deploy_app(options = {}) ⇒ Object 



184
185
186
187
188
189
190
191
192
193
194
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 184

def call_task_deploy_app(options = {})
  options = options.stringify_keys
  main_box_name = @argv[boxes_key].blank? ? '' : @argv[boxes_key]
  boxes = strip_characters_from_string(main_box_name).split(',').compact
  stage = options.fetch('stage', @default_stage)
  if configuration.development_stages.include?(stage) && boxes.present?
    execute_on_multiple_boxes(boxes, options)
  else
    prepare_job(options)
  end
end

#can_tag_staging? ⇒ Boolean

Returns:

  • (Boolean) 


141
142
143
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 141

def can_tag_staging?
  wants_deploy_production? && tag_staging_exists? && fetch_multi_stages.include?('staging')
end

#check_before_starting ⇒ Object 



97
98
99
100
101
102
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 97

def check_before_starting
  @dependency_tracker = CapistranoMulticonfigParallel::DependencyTracker.new(Actor.current)
  @default_stage = configuration.development_stages.present? ? configuration.development_stages.first : 'development'
  @condition = Celluloid::Condition.new
  @manager = CapistranoMulticonfigParallel::CelluloidManager.new(Actor.current)
end

#check_multi_stages(custom_stages) ⇒ Object 



145
146
147
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 145

def check_multi_stages(custom_stages)
  can_tag_staging? ? custom_stages.reject { |u| u == 'production' } : custom_stages
end

#collect_command_line_tasks(args) ⇒ Object

:nodoc:



75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 75

def collect_command_line_tasks(args) # :nodoc:
  @argv = {}
  @top_level_tasks = []
  args.each do |arg|
    if arg =~ /^(\w+)=(.*)$/m
      @argv[Regexp.last_match(1)] = Regexp.last_match(2)
    else
      @top_level_tasks << arg unless arg =~ /^-/
    end
  end
  @top_level_tasks.push(Rake.application.default_task_name) if @top_level_tasks.blank?
end

#collect_jobs(options = {}, &_block) ⇒ Object 



104
105
106
107
108
109
110
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 104

def collect_jobs(options = {}, &_block)
  options = prepare_options(options)
  options = options.stringify_keys
  apps = @dependency_tracker.fetch_apps_needed_for_deployment(options['app'], options['action'])
  deploy_multiple_apps(apps, options)
  deploy_app(options) if !custom_command? || !multi_apps?
end

#custom_command? ⇒ Boolean

Returns:

  • (Boolean) 


50
51
52
53
54
55
56
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 50

def custom_command?
  if multi_apps?
    !stages.include?(@top_level_tasks.first) && custom_commands.include?(@top_level_tasks.first)
  else
    !stages.include?(@top_level_tasks.second) && stages.include?(@top_level_tasks.first) && custom_commands.include?(@top_level_tasks.second)
  end
end

#deploy_app(options = {}) ⇒ Object 



149
150
151
152
153
154
155
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 149

def deploy_app(options = {})
  options = options.stringify_keys
  call_task_deploy_app({
    app: options['app'],
    action: options['action']
  }.reverse_merge(options))
end

#deploy_multiple_apps(applications, options) ⇒ Object 



42
43
44
45
46
47
48
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 42

def deploy_multiple_apps(applications, options)
  options = options.stringify_keys
  return unless applications.present?
  applications.each do |app|
    deploy_app(options.merge('app' => app['app']))
  end
end

#execute_on_multiple_boxes(boxes, options) ⇒ Object 



258
259
260
261
262
263
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 258

def execute_on_multiple_boxes(boxes, options)
  boxes.each do |box_name|
    options['env_options'][boxes_key] = box_name
    prepare_job(options)
  end
end

#fetch_app_additional_env_options(variable) ⇒ Object 



248
249
250
251
252
253
254
255
256
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 248

def fetch_app_additional_env_options(variable)
  options = {}
  return options if variable.blank?
  env_options = strip_characters_from_string(variable)
  env_options = env_options.split(' ')
  options = multi_fetch_argv(env_options)
  options.stringify_keys!
  options
end

#fetch_multi_stages ⇒ Object 



130
131
132
133
134
135
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 130

def fetch_multi_stages
  custom_stages = @argv[stages_key].blank? ? '' : @argv[stages_key]
  custom_stages = strip_characters_from_string(custom_stages).split(',').compact if custom_stages.present?
  custom_stages = custom_stages.present? ? custom_stages : [@default_stage]
  custom_stages
end

#get_app_additional_env_options(app, app_message) ⇒ Object 



157
158
159
160
161
162
163
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 157

def get_app_additional_env_options(app, app_message)
  app_name = (app.is_a?(Hash) && app[:app].present?) ? app[:app].camelcase : app
  app_name = app_name.present? ? app_name : 'current application'
  message = "Please write additional ENV options for #{app_name} for #{app_message}"
  app_additional_env_options = ask_confirm(message, nil)
  fetch_app_additional_env_options(app_additional_env_options)
end

#initialize_data ⇒ Object 



68
69
70
71
72
73
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 68

def initialize_data
  @application = custom_command? ? nil : @top_level_tasks.first.split(':').reverse[1]
  @stage = custom_command? ? nil : @top_level_tasks.first.split(':').reverse[0]
  @stage = @stage.present? ? @stage : @default_stage
  @name, @args = parse_task_string(@top_level_tasks.second)
end

#multi_apps? ⇒ Boolean

Returns:

  • (Boolean) 


58
59
60
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 58

def multi_apps?
  stages.find { |stage| stage.include?(':') }.present?
end

#prepare_job(options) ⇒ Object 



219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 219

def prepare_job(options)
  options = options.stringify_keys
  app = options.fetch('app', '')
  box = options['env_options'][boxes_key]
  message = box.present? ? "BOX #{box}:" : "stage #{options['stage']}:"
  env_opts = get_app_additional_env_options(app, message)

  options['env_options'] = options['env_options'].reverse_merge(env_opts)

  env_options = options['env_options']
  job_env_options = custom_command? ? env_options.except(action_key) : env_options
  job = CapistranoMulticonfigParallel::Job.new(Actor.current, options.merge(
                                                                action: custom_command? && env_options[action_key].present? ? env_options[action_key] : options['action'],
                                                                env_options: job_env_options

  ))
  @jobs << job
end

#prepare_options(options) ⇒ Object 



238
239
240
241
242
243
244
245
246
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 238

def prepare_options(options)
  options = options.stringify_keys
  options['app'] = options.fetch('app', @application.to_s.clone)
  options['action'] = options.fetch('action', @name.to_s.clone)
  options['stage'] = options.fetch('stage', @stage.to_s.clone)
  options['env_options'] = options.fetch('env_options', @argv.clone)
  options['task_arguments'] = options.fetch('task_arguments', @args.clone)
  options
end

#process_jobs ⇒ Object 



112
113
114
115
116
117
118
119
120
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 112

def process_jobs
  return unless @jobs.present?
  FileUtils.rm Dir["#{log_directory}/worker_*.log"]
  if configuration.multi_secvential.to_s.downcase == 'true'
    @jobs.each(&:execute_standard_deploy)
  else
    run_async_jobs
  end
end

#run ⇒ Object 



169
170
171
172
173
174
175
176
177
178
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 169

def run
  options = {}
  if custom_command?
    options = verify_options_custom_command(options)
    run_custom_command(options)
  else
    collect_jobs(options)
  end
  process_jobs
end

#run_async_jobs ⇒ Object 



196
197
198
199
200
201
202
203
204
205
206
207
208
209
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 196

def run_async_jobs
  return unless @jobs.present?
  @jobs.pmap do |job|
    @manager.async.delegate_job(job)
  end
  unless can_tag_staging?
    until @manager.registration_complete
      sleep(0.1) # keep current thread alive
    end
    return unless @manager.registration_complete
    @manager.async.process_jobs
  end
  wait_jobs_termination
end

#run_custom_command(options) ⇒ Object 



33
34
35
36
37
38
39
40
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 33

def run_custom_command(options)
  custom_stages = fetch_multi_stages
  return if custom_stages.blank?
  custom_stages = check_multi_stages(custom_stages)
  custom_stages.each do |stage|
    collect_jobs(options.merge('stage' => stage))
  end
end

#stages_key ⇒ Object 



126
127
128
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 126

def stages_key
  capistrano_version_2? ? 'stages' : 'STAGES'
end

#start ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 18

def start
  verify_app_dependencies if multi_apps? && configuration.application_dependencies.present?
  verify_valid_data
  check_before_starting
  initialize_data
  run
end

#tag_staging_exists? ⇒ Boolean

check exists task from capistrano-gitflow

Returns:

  • (Boolean) 


122
123
124
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 122

def tag_staging_exists? # check exists task from capistrano-gitflow
  find_loaded_gem('capistrano-gitflow').present?
end

#verify_app_dependencies ⇒ Object

Raises:

  • (ArgumentError) 


26
27
28
29
30
31
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 26

def verify_app_dependencies
  wrong = configuration.application_dependencies.find do |hash|
    !@stage_apps.include?(hash[:app]) || (hash[:dependencies].present? && hash[:dependencies].find { |val| !@stage_apps.include?(val) })
  end
  raise ArgumentError, "Invalid configuration for #{wrong.inspect}".red if wrong.present?
end

#verify_options_custom_command(options) ⇒ Object 



92
93
94
95
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 92

def verify_options_custom_command(options)
  options[:action] = @argv[action_key].present? ? @argv[action_key] : 'deploy'
  options
end

#verify_valid_data ⇒ Object 



62
63
64
65
66
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 62

def verify_valid_data
  return  if  @top_level_tasks != ['default']
  puts 'Invalid execution, please call something such as `multi_cap production deploy`, where production is a stage you have defined'.red
  exit(false)
end

#wait_jobs_termination ⇒ Object 



211
212
213
214
215
216
217
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 211

def wait_jobs_termination
  return if configuration.multi_secvential.to_s.downcase == 'true'
  result = @condition.wait
  return unless result.present?
  @manager.terminate
  terminate
end

#wants_deploy_production? ⇒ Boolean

Returns:

  • (Boolean) 


137
138
139
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 137

def wants_deploy_production?
  (!custom_command? && @stage == 'production') || (custom_command? && fetch_multi_stages.include?('production'))
end

#worker_environments ⇒ Object 



165
166
167
 
# File 'lib/capistrano_multiconfig_parallel/application.rb', line 165

def worker_environments
  @jobs.map { |job| job['env'] }
end