]> git.cworth.org Git - sup/blob - lib/sup.rb
yet more better intra-saving exception resilience
[sup] / lib / sup.rb
1 require 'rubygems'
2 require 'yaml'
3 require 'zlib'
4 require 'thread'
5 require 'fileutils'
6
7 class Object
8   ## this is for debugging purposes because i keep calling #id on the
9   ## wrong object and i want it to throw an exception
10   def id
11     raise "wrong id called on #{self.inspect}"
12   end
13 end
14
15 class Module
16   def yaml_properties *props
17     props = props.map { |p| p.to_s }
18     vars = props.map { |p| "@#{p}" }
19     klass = self
20     path = klass.name.gsub(/::/, "/")
21     
22     klass.instance_eval do
23       define_method(:to_yaml_properties) { vars }
24       define_method(:to_yaml_type) { "!#{Redwood::YAML_DOMAIN},#{Redwood::YAML_DATE}/#{path}" }
25     end
26
27     YAML.add_domain_type("#{Redwood::YAML_DOMAIN},#{Redwood::YAML_DATE}", path) do |type, val|
28       klass.new(*props.map { |p| val[p] })
29     end
30   end
31 end
32
33 module Redwood
34   VERSION = "0.0.8"
35
36   BASE_DIR   = ENV["SUP_BASE"] || File.join(ENV["HOME"], ".sup")
37   CONFIG_FN  = File.join(BASE_DIR, "config.yaml")
38   SOURCE_FN  = File.join(BASE_DIR, "sources.yaml")
39   LABEL_FN   = File.join(BASE_DIR, "labels.txt")
40   PERSON_FN  = File.join(BASE_DIR, "people.txt")
41   CONTACT_FN = File.join(BASE_DIR, "contacts.txt")
42   DRAFT_DIR  = File.join(BASE_DIR, "drafts")
43   SENT_FN    = File.join(BASE_DIR, "sent.mbox")
44   LOCK_FN    = File.join(BASE_DIR, "lock")
45   SUICIDE_FN = File.join(BASE_DIR, "please-kill-yourself")
46
47   YAML_DOMAIN = "masanjin.net"
48   YAML_DATE = "2006-10-01"
49
50 ## record exceptions thrown in threads nicely
51   $exception = nil
52   def reporting_thread
53     if $opts[:no_threads]
54       yield
55     else
56       ::Thread.new do
57         begin
58           yield
59         rescue Exception => e
60           File.open("sup-exception-log.txt", "w") do |f|
61             f.puts "--- #{e.class.name} at #{Time.now}"
62             f.puts e.message, e.backtrace
63           end
64           $exception ||= e
65           raise
66         end
67       end
68     end
69   end
70   module_function :reporting_thread
71
72 ## one-stop shop for yamliciousness
73   def save_yaml_obj object, fn, safe=false
74     if safe
75       safe_fn = "#{File.dirname fn}/safe_#{File.basename fn}"
76       mode = File.stat(fn) if File.exists? fn
77       File.open(safe_fn, "w", mode) { |f| f.puts object.to_yaml }
78       FileUtils.mv safe_fn, fn
79     else
80       File.open(fn, "w") { |f| f.puts object.to_yaml }
81     end
82   end
83
84   def load_yaml_obj fn, compress=false
85     if File.exists? fn
86       if compress
87         Zlib::GzipReader.open(fn) { |f| YAML::load f }
88       else
89         YAML::load_file fn
90       end
91     end
92   end
93
94   def start
95     Redwood::PersonManager.new Redwood::PERSON_FN
96     Redwood::SentManager.new Redwood::SENT_FN
97     Redwood::ContactManager.new Redwood::CONTACT_FN
98     Redwood::LabelManager.new Redwood::LABEL_FN
99     Redwood::AccountManager.new $config[:accounts]
100     Redwood::DraftManager.new Redwood::DRAFT_DIR
101     Redwood::UpdateManager.new
102     Redwood::PollManager.new
103     Redwood::SuicideManager.new Redwood::SUICIDE_FN
104   end
105
106   def finish
107     Redwood::LabelManager.save if Redwood::LabelManager.instantiated?
108     Redwood::ContactManager.save if Redwood::ContactManager.instantiated?
109     Redwood::PersonManager.save if Redwood::PersonManager.instantiated?
110     Redwood::BufferManager.deinstantiate! if Redwood::BufferManager.instantiated?
111   end
112
113   ## not really a good place for this, so I'll just dump it here.
114   def report_broken_sources opts={}
115     return unless BufferManager.instantiated?
116
117     broken_sources = Index.usual_sources.select { |s| s.error.is_a? FatalSourceError }
118     unless broken_sources.empty?
119       BufferManager.spawn "Broken source notification", TextMode.new(<<EOM), opts
120 Source error notification
121 -------------------------
122
123 Hi there. It looks like one or more message sources is reporting
124 errors. Until this is corrected, messages from these sources cannot
125 be viewed, and new messages will not be detected.
126
127 #{broken_sources.map { |s| "Source: " + s.to_s + "\n Error: " + s.error.message.wrap(70).join("\n        ")}.join("\n\n")}
128 EOM
129 #' stupid ruby-mode
130     end
131
132     desynced_sources = Index.usual_sources.select { |s| s.error.is_a? OutOfSyncSourceError }
133     unless desynced_sources.empty?
134       BufferManager.spawn "Out-of-sync source notification", TextMode.new(<<EOM), opts
135 Out-of-sync source notification
136 -------------------------------
137
138 Hi there. It looks like one or more sources has fallen out of sync
139 with my index. This can happen when you modify these sources with
140 other email clients. (Sorry, I don't play well with others.)
141
142 Until this is corrected, messages from these sources cannot be viewed,
143 and new messages will not be detected. Luckily, this is easy to correct!
144
145 #{desynced_sources.map do |s|
146   "Source: " + s.to_s + 
147    "\n Error: " + s.error.message.wrap(70).join("\n        ") + 
148    "\n   Fix: sup-sync --changed #{s.to_s}"
149   end}
150 EOM
151 #' stupid ruby-mode
152     end
153   end
154
155   module_function :save_yaml_obj, :load_yaml_obj, :start, :finish,
156                   :report_broken_sources
157 end
158
159 ## set up default configuration file
160 if File.exists? Redwood::CONFIG_FN
161   $config = Redwood::load_yaml_obj Redwood::CONFIG_FN
162 else
163   require 'etc'
164   require 'socket'
165   name = Etc.getpwnam(ENV["USER"]).gecos.split(/,/).first
166   email = ENV["USER"] + "@" + 
167     begin
168       Socket.gethostbyname(Socket.gethostname).first
169     rescue SocketError
170       Socket.gethostname
171     end
172
173   $config = {
174     :accounts => {
175       :default => {
176         :name => name,
177         :email => email,
178         :alternates => [],
179         :sendmail => "/usr/sbin/sendmail -oem -ti",
180         :signature => File.join(ENV["HOME"], ".signature")
181       }
182     },
183     :editor => ENV["EDITOR"] || "/usr/bin/vim -f -c 'setlocal spell spelllang=en_us' -c 'set filetype=mail'",
184     :thread_by_subject => false,
185   }
186   begin
187     FileUtils.mkdir_p Redwood::BASE_DIR
188     Redwood::save_yaml_obj $config, Redwood::CONFIG_FN
189   rescue StandardError => e
190     $stderr.puts "warning: #{e.message}"
191   end
192 end
193
194 require "sup/util"
195 require "sup/update"
196 require "sup/suicide"
197 require "sup/message"
198 require "sup/source"
199 require "sup/mbox"
200 require "sup/maildir"
201 require "sup/imap"
202 require "sup/person"
203 require "sup/account"
204 require "sup/thread"
205 require "sup/index"
206 require "sup/textfield"
207 require "sup/buffer"
208 require "sup/keymap"
209 require "sup/mode"
210 require "sup/colormap"
211 require "sup/label"
212 require "sup/contact"
213 require "sup/tagger"
214 require "sup/draft"
215 require "sup/poll"
216 require "sup/modes/scroll-mode"
217 require "sup/modes/text-mode"
218 require "sup/modes/line-cursor-mode"
219 require "sup/modes/help-mode"
220 require "sup/modes/edit-message-mode"
221 require "sup/modes/compose-mode"
222 require "sup/modes/resume-mode"
223 require "sup/modes/forward-mode"
224 require "sup/modes/reply-mode"
225 require "sup/modes/label-list-mode"
226 require "sup/modes/contact-list-mode"
227 require "sup/modes/thread-view-mode"
228 require "sup/modes/thread-index-mode"
229 require "sup/modes/label-search-results-mode"
230 require "sup/modes/search-results-mode"
231 require "sup/modes/person-search-results-mode"
232 require "sup/modes/inbox-mode"
233 require "sup/modes/buffer-list-mode"
234 require "sup/modes/log-mode"
235 require "sup/modes/poll-mode"
236 require "sup/logger"
237 require "sup/sent"
238
239 module Redwood
240   def log s; Logger.log s; end
241   module_function :log
242 end
243
244 $:.each do |base|
245   d = File.join base, "sup/share/modes/"
246   Redwood::Mode.load_all_modes d if File.directory? d
247 end