9 ## save a message 'm' to an open file pointer 'fp'
11 m.source.each_raw_message_line(m.source_info) { |l| fp.print l }
14 $stderr.puts "Error: #{msg}"
18 opts = Trollop::options do
19 version "sup-sync-back (sup #{Redwood::VERSION})"
21 Drop or move messages from Sup sources that are marked as deleted or
22 spam in the Sup index.
24 Currently only works with mbox sources.
27 sup-sync-back [options] <source>*
29 where <source>* is zero or more source URIs. If no sources are given,
30 sync back all usual sources.
32 You almost certainly want to run sup-sync --changed after this command.
33 Running this does not change the index.
37 opt :drop_deleted, "Drop deleted messages.", :default => false, :short => "d"
38 opt :move_deleted, "Move deleted messages to a local mbox file.", :type => String, :short => :none
39 opt :drop_spam, "Drop spam messages.", :default => false, :short => "s"
40 opt :move_spam, "Move spam messages to a local mbox file.", :type => String, :short => :none
42 opt :with_dotlockfile, "Specific dotlockfile location (mbox files only).", :default => "/usr/bin/dotlockfile", :short => :none
43 opt :dont_use_dotlockfile, "Don't use dotlockfile to lock mbox files. Dangerous if other processes modify them concurrently.", :default => false, :short => :none
45 opt :verbose, "Print message ids as they're processed."
46 opt :dry_run, "Don't actually modify the index. Probably only useful with --verbose.", :short => "-n"
47 opt :version, "Show version information", :short => :none
49 conflicts :drop_deleted, :move_deleted
50 conflicts :drop_spam, :move_spam
53 unless opts[:drop_deleted] || opts[:move_deleted] || opts[:drop_spam] || opts[:move_spam]
55 Nothing to do. Please specify at least one of --drop-deleted, --move-deleted,
56 --drop-spam, or --move-spam.
63 index = Redwood::Index.new
66 deleted_fp, spam_fp = nil
68 deleted_fp = File.open(opts[:move_deleted], "a") if opts[:move_deleted]
69 spam_fp = File.open(opts[:move_spam], "a") if opts[:move_spam]
72 dotlockfile = opts[:with_dotlockfile] || "/usr/bin/dotlockfile"
77 sources = ARGV.map do |uri|
78 s = index.source_for(uri) or die "unknown source: #{uri}. Did you add it with sup-add first?"
79 s.is_a?(Redwood::MBox::Loader) or die "#{uri} is not an mbox source."
84 sources = index.usual_sources.select { |s| s.is_a? Redwood::MBox::Loader }
87 unless sources.all? { |s| s.file_path.nil? } || File.executable?(dotlockfile) || opts[:dont_use_dotlockfile]
89 can't execute dotlockfile binary: #{dotlockfile}. Specify --with-dotlockfile
90 if it's in a nonstandard location, or, if you want to live dangerously, try
91 --dont-use-dotlockfile
96 sources.each do |source|
97 $stderr.puts "Scanning #{source}..."
99 unless ((opts[:drop_deleted] || opts[:move_deleted]) && index.has_any_from_source_with_label?(source, :deleted)) || ((opts[:drop_spam] || opts[:move_spam]) && index.has_any_from_source_with_label?(source, :spam))
100 $stderr.puts "Nothing to do from this source; skipping"
105 num_dropped = num_moved = num_scanned = 0
107 out_fp = Tempfile.new "sup-sync-back-#{source.id}"
108 Redwood::PollManager.add_messages_from source do |m, offset, entry|
112 labels = entry[:label].symbolistize.to_boolean_h
114 if labels.member? :deleted
115 if opts[:drop_deleted]
116 puts "Dropping deleted message #{source}##{offset}" if opts[:verbose]
118 elsif opts[:move_deleted] && labels.member?(:deleted)
119 puts "Moving deleted message #{source}##{offset}" if opts[:verbose]
120 save m, deleted_fp unless opts[:dry_run]
124 elsif labels.member? :spam
126 puts "Dropping spam message #{source}##{offset}" if opts[:verbose]
128 elsif opts[:move_spam] && labels.member?(:spam)
129 puts "Moving spam message #{source}##{offset}" if opts[:verbose]
130 save m, spam_fp unless opts[:dry_run]
134 save m, out_fp unless opts[:dry_run]
137 save m, out_fp unless opts[:dry_run]
140 nil # don't actually add anything!
142 $stderr.puts "Scanned #{num_scanned}, dropped #{num_dropped}, moved #{num_moved} messages from #{source}."
143 modified_sources << source if num_dropped > 0 || num_moved > 0
144 out_fp.close unless opts[:dry_run]
146 unless opts[:dry_run] || (num_dropped == 0 && num_moved == 0)
147 deleted_fp.flush if deleted_fp
148 spam_fp.flush if spam_fp
149 unless opts[:dont_use_dotlockfile]
150 puts "Locking #{source.file_path}..."
151 system "#{opts[:dotlockfile]} -l #{source.file_path}"
152 puts "Writing #{source.file_path}..."
153 FileUtils.cp out_fp.path, source.file_path
154 puts "Unlocking #{source.file_path}..."
155 system "#{opts[:dotlockfile]} -u #{source.file_path}"
160 unless opts[:dry_run]
161 deleted_fp.close if deleted_fp
162 spam_fp.close if spam_fp
166 unless modified_sources.empty?
167 $stderr.puts "You should now run: sup-sync --changed #{modified_sources.join(' ')}"
169 rescue Exception => e
170 File.open("sup-exception-log.txt", "w") { |f| f.puts e.backtrace }