Class: Bolt::Outputter::JSON

Inherits:
Bolt::Outputter show all
Defined in:
lib/bolt/outputter/json.rb

Instance Method Summary collapse

Methods inherited from Bolt::Outputter

for_format

Constructor Details

#initialize(color, verbose, trace, stream = $stdout) ⇒ JSON

Returns a new instance of JSON.



6
7
8
9
10
11
 
# File 'lib/bolt/outputter/json.rb', line 6

def initialize(color, verbose, trace, stream = $stdout)
  super
  @items_open = false
  @object_open = false
  @preceding_item = false
end

Instance Method Details

#fatal_error(err) ⇒ Object 



112
113
114
115
116
117
118
119
120
121
122
 
# File 'lib/bolt/outputter/json.rb', line 112

def fatal_error(err)
  @stream.puts "],\n" if @items_open
  @stream.puts '"_error": ' if @object_open
  err_obj = err.to_h
  if @trace && err.backtrace
    err_obj[:details] ||= {}
    err_obj[:details][:backtrace] = err.backtrace
  end
  @stream.puts err_obj.to_json
  @stream.puts '}' if @object_open
end

#handle_event(event) ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/bolt/outputter/json.rb', line 20

def handle_event(event)
  case event[:type]
  when :node_result
    print_result(event[:result])
  when :message
    print_message_event(event)
  end
end

#print_apply_result(apply_result, _elapsed_time) ⇒ Object 



77
78
79
 
# File 'lib/bolt/outputter/json.rb', line 77

def print_apply_result(apply_result, _elapsed_time)
  @stream.puts apply_result.to_json
end

#print_groups(groups) ⇒ Object 



106
107
108
109
110
 
# File 'lib/bolt/outputter/json.rb', line 106

def print_groups(groups)
  count = groups.count
  @stream.puts({ "groups": groups,
                 "count": count }.to_json)
end

#print_head ⇒ Object 



13
14
15
16
17
18
 
# File 'lib/bolt/outputter/json.rb', line 13

def print_head
  @stream.puts '{ "items": ['
  @preceding_item = false
  @items_open = true
  @object_open = true
end

#print_message(message) ⇒ Object 



128
129
130
 
# File 'lib/bolt/outputter/json.rb', line 128

def print_message(message)
  $stderr.puts(message)
end

#print_message_event(event) ⇒ Object 



124
125
126
 
# File 'lib/bolt/outputter/json.rb', line 124

def print_message_event(event)
  print_message(event[:message])
end

#print_plan_info(plan) ⇒ Object 



63
64
65
66
67
68
69
70
71
 
# File 'lib/bolt/outputter/json.rb', line 63

def print_plan_info(plan)
  path = plan.delete('module')
  plan['module_dir'] = if path.start_with?(Bolt::PAL::MODULES_PATH)
                         "built-in module"
                       else
                         path
                       end
  @stream.puts plan.to_json
end

#print_plan_result(result) ⇒ Object 



81
82
83
84
 
# File 'lib/bolt/outputter/json.rb', line 81

def print_plan_result(result)
  # Ruby JSON patches most objects to have a to_json method.
  @stream.puts result.to_json
end

#print_plans(plans, modulepath) ⇒ Object 



73
74
75
 
# File 'lib/bolt/outputter/json.rb', line 73

def print_plans(plans, modulepath)
  print_table('plans' => plans, 'modulepath' => modulepath)
end

#print_puppetfile_result(success, puppetfile, moduledir) ⇒ Object 



86
87
88
89
90
 
# File 'lib/bolt/outputter/json.rb', line 86

def print_puppetfile_result(success, puppetfile, moduledir)
  @stream.puts({ "success": success,
                 "puppetfile": puppetfile,
                 "moduledir": moduledir }.to_json)
end

#print_result(result) ⇒ Object 



29
30
31
32
33
 
# File 'lib/bolt/outputter/json.rb', line 29

def print_result(result)
  @stream.puts ',' if @preceding_item
  @stream.puts result.to_json
  @preceding_item = true
end

#print_summary(results, elapsed_time) ⇒ Object 



35
36
37
38
39
40
41
42
 
# File 'lib/bolt/outputter/json.rb', line 35

def print_summary(results, elapsed_time)
  @stream.puts "],\n"
  @preceding_item = false
  @items_open = false
  @stream.puts format('"target_count": %<size>d, "elapsed_time": %<elapsed>d }',
                      size: results.size,
                      elapsed: elapsed_time)
end

#print_table(results) ⇒ Object Also known as: print_module_list 



44
45
46
 
# File 'lib/bolt/outputter/json.rb', line 44

def print_table(results)
  @stream.puts results.to_json
end

#print_target_info(targets) ⇒ Object 



99
100
101
102
103
104
 
# File 'lib/bolt/outputter/json.rb', line 99

def print_target_info(targets)
  @stream.puts ::JSON.pretty_generate(
    "targets": targets.map(&:detail),
    "count": targets.count
  )
end

#print_targets(targets) ⇒ Object 



92
93
94
95
96
97
 
# File 'lib/bolt/outputter/json.rb', line 92

def print_targets(targets)
  @stream.puts ::JSON.pretty_generate(
    "targets": targets.map(&:name),
    "count": targets.count
  )
end

#print_task_info(task) ⇒ Object 



49
50
51
52
53
54
55
56
57
 
# File 'lib/bolt/outputter/json.rb', line 49

def print_task_info(task)
  path = task.files.first['path'].chomp("/tasks/#{task.files.first['name']}")
  module_dir = if path.start_with?(Bolt::PAL::MODULES_PATH)
                 "built-in module"
               else
                 path
               end
  @stream.puts task.to_h.merge(module_dir: module_dir).to_json
end

#print_tasks(tasks, modulepath) ⇒ Object 



59
60
61
 
# File 'lib/bolt/outputter/json.rb', line 59

def print_tasks(tasks, modulepath)
  print_table('tasks' => tasks, 'modulepath' => modulepath)
end