61 lines
1.3 KiB
Ruby
61 lines
1.3 KiB
Ruby
|
|
module LogAn
|
|
module Inc
|
|
module FileParser
|
|
module Base
|
|
def emit v
|
|
@logdb.push @sid, line
|
|
end
|
|
|
|
def seeks read
|
|
inode, seek = (@store[ :seeks, @sid] || "\0\0\0\0\0\0\0\0").unpack 'a4N'
|
|
@store[ :seeks, @sid] = [inode, read + seek].pack( 'a4N')
|
|
end
|
|
end
|
|
|
|
class Line
|
|
extend Base
|
|
attr_reader :sid, :delimiter, :buffer, :linebuffer
|
|
@@fileparser = []
|
|
|
|
def self.[] sid
|
|
@@fileparser[sid] ||= self.new sid
|
|
end
|
|
|
|
def initialize logdb, store, sid, delimiter = nil
|
|
@logdb, @store, @sid, @delimiter = logdb, store, 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
|