Class: Cheftacular::Auditor

Inherits:
Object
  • Object
show all
Defined in:
lib/cheftacular/auditor.rb

Instance Method Summary collapse

Constructor Details

#initialize(options, config) ⇒ Auditor

Returns a new instance of Auditor.



4
5
6
 
# File 'lib/cheftacular/auditor.rb', line 4

def initialize options, config
  @options, @config = options, config
end

Instance Method Details

#audit_run ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/cheftacular/auditor.rb', line 8

def audit_run
  current_day  = Time.now.strftime('%Y%m%d')
  current_time = Time.now.strftime('%H:%M')

  audit_data = audit_run_as_hash

  @config[@options['env']]['audit_bag_hash']['audit_log'][current_day] ||= {}
  @config[@options['env']]['audit_bag_hash']['audit_log'][current_day][current_time] ||= []
  @config[@options['env']]['audit_bag_hash']['audit_log'][current_day][current_time] << audit_data

  @config['ChefDataBag'].save_audit_bag

  audit_command_to_slack_queue(audit_data) unless @config['cheftacular']['slack']['notify_on_command_execute'].blank?
end

#audit_run_as_hash(ret_hash = {}, options_to_ignore = []) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/cheftacular/auditor.rb', line 23

def audit_run_as_hash ret_hash={}, options_to_ignore=[]
  ret_hash['hostname']  = Socket.gethostname
  ret_hash['directory'] = @config['locs']['root']
  ret_hash['version']   = Cheftacular::VERSION
  ret_hash['command']   = return_true_command(@options['command'])
  
  options_to_ignore << :preferred_cloud        if @options['preferred_cloud'] == @config['cheftacular']['preferred_cloud']
  options_to_ignore << :preferred_cloud_image  if @options['preferred_cloud_image'] == @config['cheftacular']['preferred_cloud_image']
  options_to_ignore << :preferred_cloud_region if @options['preferred_cloud_region'] == @config['cheftacular']['preferred_cloud_region']
  options_to_ignore << :virtualization_mode    if @options['virtualization_mode'] == @config['cheftacular']['virtualization_mode']
  options_to_ignore << :route_dns_changes_via  if @options['route_dns_changes_via'] == @config['cheftacular']['route_dns_changes_via']
  options_to_ignore << :role                   unless @options['repository'].nil?
  options_to_ignore << :role                   if @config['helper'].is_stateless_command?(@options['command'])
  options_to_ignore << :repository             if @config['helper'].is_stateless_command?(@options['command'])
  options_to_ignore << :sub_env
  options_to_ignore << :command

  ret_hash['options']   = @options.dup.delete_if { |key, value| options_to_ignore.include?(key.to_sym) }

  ret_hash['arguments'] = ARGV[1..ARGV.length]

  ret_hash
end

#compile_audit_hash_entry_as_array(audit_hash, entry_number = 0, mode = 'normal', ret_array = [], directory_content = '', version_content = '') ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/cheftacular/auditor.rb', line 47

def compile_audit_hash_entry_as_array audit_hash, entry_number=0, mode='normal', ret_array=[], directory_content='', version_content=''
  directory_content = " (#{ audit_hash['directory'] })" if audit_hash.has_key?('directory')
  version_content   = " [#{ audit_hash['version'] }]"   if audit_hash.has_key?('version')

  ret_array << "#{ (entry_number.to_s + '. ') unless entry_number == 0 }#{ audit_hash['command'] }" if mode =~ /normal/
  ret_array << "  Hostname:  #{ audit_hash['hostname'] }#{ directory_content }#{ version_content }"

  if mode =~ /normal/
    arg_opts_string = ''
    arg_opts_string << "  Arguments: #{ audit_hash['arguments'] }".ljust(38) if !audit_hash['arguments'].nil? && !audit_hash['arguments'].empty?
    arg_opts_string << "  Options:   #{ audit_hash['options'].to_hash }" unless audit_hash['options'].empty?
    ret_array       << arg_opts_string
  end
  
  ret_array = ret_array.map { |entry| entry.prepend('    ')} unless entry_number == 0

  ret_array
end

#notify_slack_on_completion(msg) ⇒ Object 



66
67
68
 
# File 'lib/cheftacular/auditor.rb', line 66

def notify_slack_on_completion msg
  audit_command_to_slack_queue(audit_run_as_hash, 'short', msg)
end

#notify_slack_on_completion_for_deploy(node_name_array, logs_bag_hash, msg = '', failed_node_names = []) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/cheftacular/auditor.rb', line 70

def notify_slack_on_completion_for_deploy node_name_array, logs_bag_hash, msg='', failed_node_names=[]
  node_name_array.each do |node_name|
    if logs_bag_hash.has_key?("#{ node_name }-deploy") && logs_bag_hash["#{ node_name }-deploy"]['exit_status'] == 1
      failed_node_names << node_name_array.delete(node_name)
    end
  end

  msg << "deploy run succeeded on #{ node_name_array.join(', ') }" unless node_name_array.empty?

  msg << "#{ 'and ' unless msg.blank? }deploy run FAILED on #{ failed_node_names.join(', ') }" unless failed_node_names.empty?

  msg << "\n"

  audit_command_to_slack_queue(audit_run_as_hash, 'short', msg)
end

#return_true_command(command) ⇒ Object 



86
87
88
89
90
91
92
93
94
95
96
97
 
# File 'lib/cheftacular/auditor.rb', line 86

def return_true_command command
  final_command = command

  if aliased_command_hash.values.flatten.include?(command)
    aliased_command_hash.each_pair do |full_command, alias_array|

      final_command = full_command if alias_array.include?(command)
    end
  end

  final_command
end