each() { |id, [:draft, :inbox]| ... }
click to toggle source
def each
ids = get_ids
ids.each do |id|
if id >= cur_offset
self.cur_offset = id + 1
yield [id, [:draft, :inbox]]
end
end
end
each_raw_message_line(offset) { |gets until eof?| ... }
click to toggle source
def each_raw_message_line offset
File.open(fn_for_offset(offset)) do |f|
yield f.gets until f.eof?
end
end
end_offset()
click to toggle source
def end_offset
ids = get_ids
ids.empty? ? 0 : (ids.last + 1)
end
fn_for_offset(o;)
click to toggle source
def fn_for_offset o; File.join(@dir, o.to_s); end
gen_offset()
click to toggle source
def gen_offset
i = cur_offset
while File.exists? fn_for_offset(i)
i += 1
end
i
end
id()
click to toggle source
def id; DraftManager.source_id; end
load_message(offset)
click to toggle source
def load_message offset
File.open fn_for_offset(offset) do |f|
RMail::Mailbox::MBoxReader.new(f).each_message do |input|
return RMail::Parser.read(input)
end
end
end
raw_message(offset)
click to toggle source
def raw_message offset
IO.read(fn_for_offset(offset))
end
start_offset()
click to toggle source
to_s()
click to toggle source
def to_s; DraftManager.source_name; end
uri()
click to toggle source
def uri; DraftManager.source_name; end