12 def self.source_name; "sup://drafts"; end
13 def self.source_id; 9999; end
14 def new_source; @source = Recoverable.new DraftLoader.new; end
17 offset = @source.gen_offset
18 fn = @source.fn_for_offset offset
19 File.open(fn, "w") { |f| yield f }
22 PollManager.each_message_from(@source) do |m|
23 PollManager.add_new_message m
31 raise ArgumentError, "not a draft: source id #{m.source.id.inspect}, should be #{DraftManager.source_id.inspect} for #{m.id.inspect}" unless m.source.id.to_i == DraftManager.source_id
33 File.delete @source.fn_for_offset(m.source_info)
34 UpdateManager.relay self, :single_message_deleted, m
38 class DraftLoader < Source
40 yaml_properties :cur_offset
42 def initialize cur_offset=0
43 dir = Redwood::DRAFT_DIR
44 Dir.mkdir dir unless File.exists? dir
45 super DraftManager.source_name, cur_offset, true, false
49 def id; DraftManager.source_id; end
50 def to_s; DraftManager.source_name; end
51 def uri; DraftManager.source_name; end
57 self.cur_offset = id + 1
58 yield [id, [:draft, :inbox]]
65 while File.exists? fn_for_offset(i)
71 def fn_for_offset o; File.join(@dir, o.to_s); end
73 def load_header offset
74 File.open(fn_for_offset(offset)) { |f| parse_raw_email_header f }
77 def load_message offset
78 File.open fn_for_offset(offset) do |f|
79 RMail::Mailbox::MBoxReader.new(f).each_message do |input|
80 return RMail::Parser.read(input)
87 File.open fn_for_offset(offset) do |f|
88 until f.eof? || (l = f.gets) =~ /^$/
95 def each_raw_message_line offset
96 File.open(fn_for_offset(offset)) do |f|
97 yield f.gets until f.eof?
101 def raw_message offset
102 IO.read(fn_for_offset(offset))
105 def start_offset; 0; end
108 ids.empty? ? 0 : (ids.last + 1)
114 Dir.entries(@dir).select { |x| x =~ /^\d+$/ }.map { |x| x.to_i }.sort