Class: Objectify::Rails::LogSubscriber

Inherits:
ActiveSupport::LogSubscriber
  • Object
show all
Defined in:
lib/objectify/rails/log_subscriber.rb

Instance Method Summary collapse

Instance Method Details

#duration(event) ⇒ Object 



52
53
54
 
# File 'lib/objectify/rails/log_subscriber.rb', line 52

def duration(event)
  "#{"(%.1fms)" % event.duration}"
end

#executor(event) ⇒ Object 



35
36
37
38
39
40
 
# File 'lib/objectify/rails/log_subscriber.rb', line 35

def executor(event)
  if logger.debug?
    type = event.payload[:type].to_s.capitalize
    logger.debug("    [#{type}] Executed #{event.payload[:name]} " + duration(event))
  end
end

#executor_start(event) ⇒ Object 



28
29
30
31
32
33
 
# File 'lib/objectify/rails/log_subscriber.rb', line 28

def executor_start(event)
  if logger.debug?
    type = event.payload[:type].to_s.capitalize
    logger.debug("    [#{type}] Executing #{event.payload[:name]} " + duration(event))
  end
end

#inject(event) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/objectify/rails/log_subscriber.rb', line 10

def inject(event)
  if logger.debug?
    object     = event.payload[:object]
    method     = event.payload[:method]
    parameters = event.payload[:parameters].map do |req, param|
      param if req == :req
    end.compact
    resolvers  = Hash[*parameters.zip(event.payload[:resolvers].map(&:class)).flatten]
    arguments  = event.payload[:arguments].map(&:class).inspect[1..-2]

    message = "      [Injector] Invoking #{object}.#{method}(#{arguments}). "
    message << "Resolutions: #{resolvers}. " if !resolvers.empty?
    message << duration(event)

    logger.debug(message)
  end
end

#logger ⇒ Object 



48
49
50
 
# File 'lib/objectify/rails/log_subscriber.rb', line 48

def logger
  ::Rails.logger
end

#policy_chain_halted(event) ⇒ Object 



42
43
44
45
46
 
# File 'lib/objectify/rails/log_subscriber.rb', line 42

def policy_chain_halted(event)
  if logger.debug?
    logger.debug("    [Policy] Chain halted at #{event.payload[:policy]}. Responding with #{event.payload[:responder]}." + duration(event))
  end
end

#start_processing(event) ⇒ Object 



6
7
8
 
# File 'lib/objectify/rails/log_subscriber.rb', line 6

def start_processing(event)
  logger.debug("    [Objectify] Started #{event.payload[:route]}")
end