8 yaml_properties :uri, :cur_offset, :usual, :archived, :id, :labels
10 ## uri_or_fp is horrific. need to refactor.
11 def initialize uri_or_fp, start_offset=nil, usual=true, archived=false, id=nil, labels=[]
13 @labels = ((labels || []) - LabelManager::RESERVED_LABELS).uniq.freeze
17 uri = URI(Source.expand_filesystem_uri(uri_or_fp))
18 raise ArgumentError, "not an mbox uri" unless uri.scheme == "mbox"
19 raise ArgumentError, "mbox URI ('#{uri}') cannot have a host: #{uri.host}" if uri.host
20 raise ArgumentError, "mbox URI must have a path component" unless uri.path
21 @f = File.open uri.path
25 @path = uri_or_fp.path
28 super uri_or_fp, start_offset, usual, archived, id
31 def file_path; @path end
32 def is_source_for? uri; super || (self.uri.is_a?(String) && (URI(Source.expand_filesystem_uri(uri)) == URI(Source.expand_filesystem_uri(self.uri)))) end
34 def self.suggest_labels_for path
35 ## heuristic: use the filename as a label, unless the file
36 ## has a path that probably represents an inbox.
37 if File.dirname(path) =~ /\b(var|usr|spool)\b/
40 [File.basename(path).intern]
45 if (cur_offset ||= start_offset) > end_offset
46 raise OutOfSyncSourceError, "mbox file is smaller than last recorded message offset. Messages have probably been deleted by another client."
50 def start_offset; 0; end
51 def end_offset; File.size @f; end
53 def load_header offset
59 raise OutOfSyncSourceError, "mismatch in mbox file offset #{offset.inspect}: #{l.inspect}."
61 header = MBox::read_header @f
66 def load_message offset
70 RMail::Mailbox::MBoxReader.new(@f).each_message do |input|
71 return RMail::Parser.read(input)
73 rescue RMail::Parser::Error => e
74 raise FatalSourceError, "error parsing mbox file: #{e.message}"
83 until @f.eof? || (l = @f.gets) =~ /^$/
90 def raw_message offset
92 each_raw_message_line(offset) { |l| ret += l }
96 ## apparently it's a million times faster to call this directly if
97 ## we're just moving messages around on disk, than reading things
98 ## into memory with raw_message.
100 ## i hoped never to have to move shit around on disk but
101 ## sup-sync-back has to do it.
102 def each_raw_message_line offset
103 @mutex.synchronize do
106 until @f.eof? || (l = @f.gets) =~ BREAK_RE
113 returned_offset = nil
114 next_offset = cur_offset
117 @mutex.synchronize do
120 ## cur_offset could be at one of two places here:
122 ## 1. before a \n and a mbox separator, if it was previously at
123 ## EOF and a new message was added; or,
124 ## 2. at the beginning of an mbox separator (in all other
127 l = @f.gets or raise "next while at EOF"
128 if l =~ /^\s*$/ # case 1
129 returned_offset = @f.tell
130 @f.gets # now we're at a BREAK_RE, so skip past it
132 returned_offset = cur_offset
133 ## we've already skipped past the BREAK_RE, so just go
136 while(line = @f.gets)
137 break if line =~ BREAK_RE
138 next_offset = @f.tell
141 rescue SystemCallError, IOError => e
142 raise FatalSourceError, "Error reading #{@f.path}: #{e.message}"
145 self.cur_offset = next_offset
146 [returned_offset, (@labels + [:unread]).uniq]