huginn/app/models/agent_log.rb

# AgentLogs are temporary records of Agent activity, intended for debugging and error tracking.  They can be viewed
# in Agents' detail pages.  AgentLogs with a `level` of 4 or greater are considered "errors" and automatically update
# Agents' `last_error_log_at` column.  These are often used to determine if an Agent is `working?`.
class AgentLog < ActiveRecord::Base
  attr_accessible :agent, :inbound_event, :level, :message, :outbound_event

  belongs_to :agent
  belongs_to :inbound_event, :class_name => "Event"
  belongs_to :outbound_event, :class_name => "Event"

  validates_presence_of :agent, :message
  validates_numericality_of :level, :only_integer => true, :greater_than_or_equal_to => 0, :less_than => 5

  before_validation :scrub_message
  before_save :truncate_message

  scope :errors, lambda { where('level > 3') }

  def self.log_for_agent(agent, message, options = {})
    puts "Agent##{agent.id}: #{message}" unless Rails.env.test?

    log = agent.logs.create! options.merge(:message => message)
    if agent.logs.count > log_length
      oldest_id_to_keep = agent.logs.limit(1).offset(log_length - 1).pluck("agent_logs.id")
      agent.logs.where("agent_logs.id < ?", oldest_id_to_keep).delete_all
    end

    agent.update_column :last_error_log_at, Time.now if log.level >= 4

    log
  end

  def self.log_length
    ENV['AGENT_LOG_LENGTH'].present? ? ENV['AGENT_LOG_LENGTH'].to_i : 200
  end

  protected

  def scrub_message
    if message_changed? && !message.nil?
      self.message = message.inspect unless message.is_a?(String)
      self.message.scrub!{ |bytes| "<#{bytes.unpack('H*')[0]}>" }
    end
    true
  end

  def truncate_message
    self.message = message[0...10_000] if message.present?
  end
end