Sha256: f3d8ca4b44d7c96041c0a0675e650b264a0f7f12da2b9480015250ac2e256878
Contents?: true
Size: 1.71 KB
Versions: 8
Compression:
Stored size: 1.71 KB
Contents
# frozen_string_literal: true
module Bolt
class Outputter
class JSON < Bolt::Outputter
def initialize(color, stream = $stdout)
@items_open = false
@object_open = false
@preceding_item = false
super(color, stream)
end
def print_head
@stream.puts '{ "items": ['
@preceding_item = false
@items_open = true
@object_open = true
end
def print_event(event)
case event[:type]
when :node_result
print_result(event[:result])
end
end
def print_result(result)
@stream.puts ',' if @preceding_item
@stream.puts result.status_hash.to_json
@preceding_item = true
end
def print_summary(results, elapsed_time)
@stream.puts "],\n"
@preceding_item = false
@items_open = false
@stream.puts format('"node_count": %<size>d, "elapsed_time": %<elapsed>d }',
size: results.size,
elapsed: elapsed_time)
end
def print_table(results)
@stream.puts results.to_json
end
def print_task_info(task)
replace_data_type(task['parameters'])
@stream.puts task.to_json
end
def print_plan_info(plan)
@stream.puts plan.to_json
end
def print_plan_result(result)
# Ruby JSON patches most objects to have a to_json method.
@stream.puts result.to_json
end
def fatal_error(err)
@stream.puts "],\n" if @items_open
@stream.puts '"_error": ' if @object_open
@stream.puts err.to_json
@stream.puts '}' if @object_open
end
def print_message(message); end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems