@source.each do |thisoffset, theselabels|
m = Message.new :source => @source, :source_info => thisoffset, :labels => theselabels
Index.sync_message m
- UpdateManager.relay self, :add, m
+ UpdateManager.relay self, :added, m
my_message = m if thisoffset == offset
end
my_message
end
- def discard mid
- docid, entry = Index.load_entry_for_id mid
- raise ArgumentError, "can't find entry for draft: #{mid.inspect}" unless entry
- raise ArgumentError, "not a draft: source id #{entry[:source_id].inspect}, should be #{DraftManager.source_id.inspect} for #{mid.inspect} / docno #{docid}" unless entry[:source_id].to_i == DraftManager.source_id
+ def discard m
+ docid, entry = Index.load_entry_for_id m.id
+ unless entry
+ Redwood::log "can't find entry for draft: #{m.id.inspect}. You probably already discarded it."
+ return
+ end
+ raise ArgumentError, "not a draft: source id #{entry[:source_id].inspect}, should be #{DraftManager.source_id.inspect} for #{m.id.inspect} / docno #{docid}" unless entry[:source_id].to_i == DraftManager.source_id
Index.drop_entry docid
File.delete @source.fn_for_offset(entry[:source_info])
- UpdateManager.relay self, :delete, mid
+ UpdateManager.relay self, :single_message_deleted, m
end
end
def initialize cur_offset=0
dir = Redwood::DRAFT_DIR
Dir.mkdir dir unless File.exists? dir
- super "draft://#{dir}", cur_offset, true, false
+ super DraftManager.source_name, cur_offset, true, false
@dir = dir
end
def fn_for_offset o; File.join(@dir, o.to_s); end
def load_header offset
- File.open fn_for_offset(offset) do |f|
- return MBox::read_header(f)
- end
+ File.open(fn_for_offset(offset)) { |f| parse_raw_email_header f }
end
def load_message offset
ret
end
- def raw_full_message offset
- IO.readlines(fn_for_offset(offset)).join
+ def each_raw_message_line offset
+ File.open(fn_for_offset(offset)) do |f|
+ yield f.gets until f.eof?
+ end
+ end
+
+ def raw_message offset
+ IO.read(fn_for_offset(offset))
end
def start_offset; 0; end