LogAn/lib/logan/inc/fileparser.rb
2010-03-30 00:32:50 +02:00

60 lines
1.2 KiB
Ruby

module LogAn
module Inc
module FileParser
module Base
class <<self
attr_accessor :logdb, :store
end
def emit v
@@logdb.push @sid, line
end
def seeks read
inode, seek = @@store[ :seeks][@sid]
@@store[ :seeks][@sid] = [inode, read + seek]
end
end
class Line
extend Base
attr_reader :sid, :delimiter, :buffer, :linebuffer
def initialize sid, delimiter = nil
@sid, @delimiter = sid, delimiter || "\n"
@delimiter = Regexp.new "^.*?#{@delimiter}"
@buffer, @linebuffer = Select::Buffer.new( ''), Select::Buffer.new( '')
end
def event_read str, sock
@buffer += str
@buffer.each! @delimiter do |line|
emit line
seeks line.length
end
end
end
class Multiline < Line
def initialize sid, delimiter = nil, multiline = nil
super sid, delimiter
@multiline = multiline || /^\d\d-\d\d-\d\d:/
end
def event_read str, sock
@buffer += str
@buffer.each! @delimiter do |line|
if line =~ @multiline
emit @linebuffer.to_s
seeks @linebuffer.length
@linebuffer.replace line
else @linebuffer += line
end
end
end
end
end
end
end