class Evidence::ActionParser

Public Class Methods

new(pid, message, action_patterns) click to toggle source
# File lib/evidence/action_parser.rb, line 4
def initialize(pid, message, action_patterns)
  @pid, @message = pid, message
  @processes = Hash.new
  @start_action_pattern, @end_action_pattern = action_patterns[:start], action_patterns[:end]
end

Public Instance Methods

end_action?(msg) click to toggle source
# File lib/evidence/action_parser.rb, line 45
def end_action?(msg)
  msg =~ @end_action_pattern
end
parse_action_logs(logs) click to toggle source
# File lib/evidence/action_parser.rb, line 37
def parse_action_logs(logs)
  {
    request: request(@message[logs[0]]),
    response: response(@message[logs[-1]]),
    logs: logs
  }
end
request(msg) click to toggle source
# File lib/evidence/action_parser.rb, line 53
def request(msg)
  to_hash(@start_action_pattern.match(msg))
end
response(msg) click to toggle source
# File lib/evidence/action_parser.rb, line 57
def response(msg)
  to_hash(@end_action_pattern.match(msg))
end
start_action?(msg) click to toggle source
# File lib/evidence/action_parser.rb, line 49
def start_action?(msg)
  msg =~ @start_action_pattern
end
to_hash(m) click to toggle source
# File lib/evidence/action_parser.rb, line 61
def to_hash(m)
  Hash[m.names.map(&:to_sym).zip(m.captures)]
end
to_proc() click to toggle source
# File lib/evidence/action_parser.rb, line 10
def to_proc
  lambda do |log|
    pid = @pid[log]
    msg = @message[log]
    if @processes.has_key?(pid)
      if start_action?(msg)
        warn "[WARN] Found start action following another start action: #{msg}"
        warn "[WARN] Ignore logs: #{@processes.delete(pid).inspect}"
        @processes[pid] = [log]
        nil
      else
        @processes[pid] << log
        if end_action?(msg)
          parse_action_logs(@processes.delete(pid))
        end
      end
    else
      if start_action?(msg)
        @processes[pid] = [log]
      else
        warn "[WARN] Ignore a log that is not start action and also not after a start action: #{log.inspect}"
      end
      nil
    end
  end
end