class TwitterFriendly::TFLogSubscriber

Public Instance Methods

collect(event) click to toggle source
# File lib/twitter_friendly/log_subscriber.rb, line 59
def collect(event)
  debug do
    payload = event.payload
    payload.delete(:name)
    operation = payload.delete(:operation)
    name = "  TW::#{operation.capitalize} #{payload[:args].last[:super_operation]} in #{payload[:args][0]} (#{event.duration.round(1)}ms)"
    name = color(name, BLUE, true)
    "  #{name}"
  end
end
complete_processing(event) click to toggle source
# File lib/twitter_friendly/log_subscriber.rb, line 46
def complete_processing(event)
  info do
    payload = event.payload
    operation = payload.delete(:operation)

    if payload.empty?
      "TF::Completed #{operation} in #{event.duration.round(1)}ms"
    else
      "TF::Completed #{operation} in #{event.duration.round(1)}ms #{truncated_payload(payload)}"
    end
  end
end
start_processing(event) click to toggle source
# File lib/twitter_friendly/log_subscriber.rb, line 33
def start_processing(event)
  info do
    payload = event.payload
    operation = payload.delete(:operation)

    if payload[:super_operation]
      "TF::Started #{operation} in #{payload[:super_operation][0]} at #{Time.now}"
    else
      "TF::Started #{operation} at #{Time.now}"
    end
  end
end
twitter_friendly_any(event) click to toggle source
# File lib/twitter_friendly/log_subscriber.rb, line 70
def twitter_friendly_any(event)
  debug do
    payload = event.payload
    payload.delete(:name)
    operation = payload.delete(:operation).capitalize
    args = payload[:args]
    method_name = args.shift

    name = "  TW::#{operation} #{method_name} (#{event.duration.round(1)}ms)"
    c = (%i(Encode Decode).include?(operation.to_sym)) ? YELLOW : CYAN
    name = color(name, c, true)

    if args.size == 1 && args[0].is_a?(Hash) && args[0].empty?
      "  #{name}"
    else
      "  #{name} #{args[1]}"
    end
  end
end