module Redwood
class IMAP < Source
- attr_reader :labels, :broken_msg
+ attr_reader :labels
def initialize uri, username, password, last_uid=nil, usual=true, archived=false, id=nil
raise ArgumentError, "username and password must be specified" unless username && password
@imap.examine mailbox
Redwood::log "successfully connected to #{@parsed_uri}, mailbox #{mailbox}"
rescue Exception => e
- self.broken = true
+ self.broken = e.message.chomp # fucking chomp! fuck!!!
@imap = nil
- @broken_msg = e.message.chomp # fucking chomp! fuck!!!
- Redwood::log "error connecting to IMAP server: #{@broken_msg}"
+ Redwood::log "error connecting to IMAP server: #{self.broken}"
end
end.join
## load the full header text
def raw_header uid
begin
- connect or return broken_msg
+ connect or return broken
rescue Exception => e
raise "wtf: #{e.inspect}"
end
end
def raw_full_message uid
- connect or return broken_msg
+ connect or return broken
@imap.uid_fetch(uid, 'RFC822')[0].attr['RFC822'].gsub(/\r\n/, "\n")
end
def each
- connect or return broken_msg
+ connect or return broken
uids = @imap.uid_search ['UID', "#{cur_offset}:#{end_offset}"]
uids.each do |uid|
@last_uid = uid
@mutex.synchronize do
@f.seek offset
l = @f.gets
- raise SourceError, "offset mismatch in mbox file offset #{offset.inspect}: #{l.inspect}. Run 'sup-import --rebuild #{to_s}' to correct this." unless l =~ BREAK_RE
+ unless l =~ BREAK_RE
+ self.broken = "offset mismatch in mbox file offset #{offset.inspect}: #{l.inspect}. Run 'sup-import --rebuild #{to_s}' to correct this."
+ raise SourceError, self.broken
+ end
header = MBox::read_header @f
end
header
##
## broken? means no message can be loaded (e.g. IMAP server is
## down), so don't even bother.
- bool_reader :usual, :archived, :dirty, :broken
- attr_reader :cur_offset
+ bool_reader :usual, :archived, :dirty
+ attr_reader :cur_offset, :broken
attr_accessor :id
## You should implement:
@archived = archived
@id = id
@dirty = false
- @broken = false
+ @broken = nil
end
+ def broken?; !@broken.nil?; end
def to_s; @uri; end
def seek_to! o; self.cur_offset = o; end
def reset!; seek_to! start_offset; end