lib/sup/source.rb in sup-0.13.2.1 vs lib/sup/source.rb in sup-0.14.0

- old
+ new

@@ -20,47 +20,39 @@ ## ## In particular, Sup doesn't need to move messages, mark them as ## read, delete them, or anything else. (Well, it's nice to be able ## to delete them, but that is optional.) ## - ## On the other hand, Sup assumes that you can assign each message a - ## unique integer id, such that newer messages have higher ids than - ## earlier ones, and that those ids stay constant across sessions - ## (in the absence of some other client going in and fucking - ## everything up). For example, for mboxes I use the file offset of - ## the start of the message. If a source does NOT have that - ## capability, e.g. IMAP, then you have to do a little more work to - ## simulate it. + ## Messages are identified internally based on the message id, and stored + ## with an unique document id. Along with the message, source information + ## that can contain arbitrary fields (set up by the source) is stored. This + ## information will be passed back to the source when a message in the + ## index (Sup database) needs to be identified to its source, e.g. when + ## re-reading or modifying a unique message. ## ## To write a new source, subclass this class, and implement: ## - ## - start_offset - ## - end_offset (exclusive!) (or, #done?) + ## - initialize ## - load_header offset ## - load_message offset ## - raw_header offset ## - raw_message offset - ## - check (optional) + ## - store_message (optional) + ## - poll (loads new messages) ## - go_idle (optional) - ## - next (or each, if you prefer): should return a message and an - ## array of labels. ## - ## ... where "offset" really means unique id. (You can tell I - ## started with mbox.) - ## ## All exceptions relating to accessing the source must be caught ## and rethrown as FatalSourceErrors or OutOfSyncSourceErrors. ## OutOfSyncSourceErrors should be used for problems that a call to ## sup-sync will fix (namely someone's been playing with the source ## from another client); FatalSourceErrors can be used for anything ## else (e.g. the imap server is down or the maildir is missing.) ## ## Finally, be sure the source is thread-safe, since it WILL be ## pummelled from multiple threads at once. ## - ## Examples for you to look at: mbox/loader.rb, imap.rb, and - ## maildir.rb. + ## Examples for you to look at: mbox.rb and maildir.rb. bool_accessor :usual, :archived attr_reader :uri attr_accessor :id, :poll_lock @@ -209,12 +201,12 @@ @sources = Hash[*(source_array).map { |s| [s.id, s] }.flatten] @sources_dirty = false end end - def save_sources fn=Redwood::SOURCE_FN + def save_sources fn=Redwood::SOURCE_FN, force=false @source_mutex.synchronize do - if @sources_dirty + if @sources_dirty || force Redwood::save_yaml_obj sources, fn, false, true end @sources_dirty = false end end