Class: Log::FileReader

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/log/filereader.rb

Defined Under Namespace

Classes: Filter

Instance Method Summary collapse

Methods included from Enumerable

#join

Constructor Details

#initialize(file) ⇒ FileReader

Returns a new instance of FileReader.



32
33
34
35
36
37
 
# File 'lib/log/filereader.rb', line 32

def initialize(file)
	@file    = ::File.open(file, "r")
	@pos     = 0
	@cache   = {}
	@filters = []
end

Instance Method Details

#add_filter(type, *args) ⇒ Object 



39
40
41
 
# File 'lib/log/filereader.rb', line 39

def add_filter(type, *args)
	@filters << Filter.new(type, *args)
end

#each ⇒ Object 



74
75
76
77
78
79
 
# File 'lib/log/filereader.rb', line 74

def each
	while line = @file.gets
		entry = Log::Entry.deserialize(line)
		yield(entry) if matches(entry)
	end
end

#head(n) ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/log/filereader.rb', line 47

def head(n)
	i = 0
	while line = @file.gets and i < n
		entry = Log::Entry.deserialize(line)
		if matches(entry) then
			yield(entry)
			i+=1
		end
	end
	entries
end

#matches(entry) ⇒ Object 



43
44
45
 
# File 'lib/log/filereader.rb', line 43

def matches(entry)
	@filters.all? { |filter| filter =~ entry }
end

#tail(n, &block) ⇒ Object 



59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/log/filereader.rb', line 59

def tail(n, &block)
	entries = []
	while line = @file.gets and entries.length < n
		entry = Log::Entry.deserialize(line)
		entries.push entry if matches(entry)
	end
	while line = @file.gets
		entry = Log::Entry.deserialize(line)
		entries.push entry if matches(entry)
		entries.shift
	end
	entries.compact
	entries.each(&block)
end