Sha256: 5d1f28f7f9f6231bb6b18192dbd5044820df88021cf42b6e991abe66aaf2f935
Contents?: true
Size: 1.9 KB
Versions: 2
Compression:
Stored size: 1.9 KB
Contents
require "logger" module CukeForker class LoggingListener < AbstractListener TIME_FORMAT = "%Y-%m-%d %H:%M:%S" def initialize(io = STDOUT) @io = io @running = [] end def on_run_starting log.info "[ run ] starting" end def on_worker_starting(worker) @running << worker.id log.info "[ worker #{worker.id.to_s.ljust 3} ] starting: #{worker.feature}" end def on_worker_forked(worker) log.info "[ worker #{worker.id.to_s.ljust 3} ] forked : #{worker.feature}" end def on_worker_finished(worker) @running.delete(worker.id) log.info "[ worker #{worker.id.to_s.ljust 3} ] #{status_string(worker.failed?).ljust(8)}: #{worker.feature}" end def on_run_finished(failed) log.info "[ run ] finished, #{status_string failed}" end def on_run_interrupted puts "\n" log.info "[ run ] interrupted - please wait" end def on_display_fetched(server) log.info "[ display #{server.display.to_s.ljust(3)} ] fetched" end def on_display_released(server) log.info "[ display #{server.display.to_s.ljust(3)} ] released" end def on_display_starting(server) log.info "[ display #{server.display.to_s.ljust(3)} ] starting" end def on_display_stopping(server) log.info "[ display #{server.display.to_s.ljust(3)} ] stopping" end def on_eta(eta, remaining, finished) counts = "#{remaining}/#{finished}".ljust(6) log.info "[ eta #{counts}] #{eta.strftime TIME_FORMAT}" log.info "[ running ] #{@running}" end private def status_string(failed) failed ? 'failed' : 'passed' end def log @log ||= ( log = Logger.new @io log.datetime_format = TIME_FORMAT log ) end end # LoggingListener end # CukeForker
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
cukeforker-2.1.1 | lib/cukeforker/logging_listener.rb |
cukeforker-1.1.0 | lib/cukeforker/logging_listener.rb |