class Riserva::Listeners::ApplicationListener

Attributes

files[R]

Public Class Methods

new() click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 7
def initialize
  @files = Set.new
end

Public Instance Methods

failed(file = nil) click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 25
def failed(file = nil)
  Riserva.logger.error(progname) { ['Failed', file].compact.join(': ') }
end
invalid(message = nil) click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 21
def invalid(message = nil)
  Riserva.logger.debug(progname) { ['Invalid', message].compact.join(': ') }
end
ok(file, *args) click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 15
def ok(file, *args)
  @files << Pathname.new(file)

  Riserva.logger.info(progname) { ["OK: #{file}", *args].join(': ') }
end
start(*args) click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 11
def start(*args)
  Riserva.logger.info(progname) { ['Starting', *args].join(': ') }
end

Protected Instance Methods

progname() click to toggle source
# File lib/riserva/listeners/application_listener.rb, line 31
def progname
  command = self.class.name.split('::').last
  worker = Parallel.worker_number.presence

  [command, worker].compact.join(' ')
end