3 class ThreadIndexMode < LineCursorMode
4 DATE_WIDTH = Time::TO_NICE_S_MAX_LEN
6 LOAD_MORE_THREAD_NUM = 20
9 k.add :toggle_archived, "Toggle archived status", 'a'
10 k.add :toggle_starred, "Star or unstar all messages in thread", '*'
11 k.add :toggle_new, "Toggle new/read status of all messages in thread", 'N'
12 k.add :edit_labels, "Edit or add labels for a thread", 'l'
13 k.add :edit_message, "Edit message (drafts only)", 'e'
14 k.add :mark_as_spam, "Mark thread as spam", 'S'
15 k.add :kill, "Kill thread (never to be seen in inbox again)", 'K'
16 k.add :save, "Save changes now", '$'
17 k.add :jump_to_next_new, "Jump to next new thread", :tab
18 k.add :reply, "Reply to a thread", 'r'
19 k.add :forward, "Forward a thread", 'f'
20 k.add :toggle_tagged, "Tag/untag current line", 't'
21 k.add :apply_to_tagged, "Apply next command to all tagged threads", ';'
24 def initialize required_labels=[], hidden_labels=[]
27 @required_labels = required_labels
28 @hidden_labels = hidden_labels + LabelManager::HIDDEN_LABELS
29 @date_width = DATE_WIDTH
30 @from_width = FROM_WIDTH
33 @tags = Tagger.new self
38 UpdateManager.register self
41 def lines; @text.length; end
42 def [] i; @text[i]; end
44 ## open up a thread view window
47 t = @threads[this_curpos]
49 ## TODO: don't regen text completely
50 Redwood::reporting_thread do
51 Redwood::log "loading messages for thread"
52 mode = ThreadViewMode.new t, @hidden_labels
53 BufferManager.spawn t.subj, mode
54 BufferManager.draw_screen
58 def handle_starred_update m
59 return unless(t = @ts.thread_for m)
60 @starred_cache[t] = t.has_label? :starred
61 update_text_for_line @lines[t]
64 def handle_read_update m
65 return unless(t = @ts.thread_for m)
67 update_text_for_line @lines[t]
71 def is_relevant? m; false; end
73 def handle_add_update m
74 if is_relevant?(m) || @ts.is_relevant?(m)
75 @ts.load_thread_for_message m
80 def handle_delete_update mid
81 if @ts.contains_id? mid
88 ## let's see you do THIS in python
89 @threads = @ts.threads.select { |t| !@hidden_threads[t] }.sort_by { |t| t.date }.reverse
90 @size_width = (@threads.map { |t| t.size }.max || 0).num_digits
95 t = @threads[curpos] or return
96 message, *crap = t.find { |m, *o| m.has_label? :draft }
98 mode = ResumeMode.new message
99 BufferManager.spawn "Edit message", mode
101 BufferManager.flash "Not a draft message!"
106 t = @threads[curpos] or return
107 @starred_cache[t] = t.toggle_label :starred
108 update_text_for_line curpos
112 def multi_toggle_starred threads
113 threads.each { |t| @starred_cache[t] = t.toggle_label :starred }
118 return unless(t = @threads[curpos])
119 t.toggle_label :inbox
120 update_text_for_line curpos
124 def multi_toggle_archived threads
125 threads.each { |t| t.toggle_label :inbox }
130 t = @threads[curpos] or return
131 @new_cache[t] = t.toggle_label :unread
132 update_text_for_line curpos
136 def multi_toggle_new threads
137 threads.each { |t| @new_cache[t] = t.toggle_label :unread }
141 def multi_toggle_tagged threads
147 t = @threads[curpos] or return
148 n = ((curpos + 1) .. lines).find { |i| @new_cache[@threads[i]] }
149 n = (0 ... curpos).find { |i| @new_cache[@threads[i]] } unless n
153 BufferManager.flash "No new messages"
158 t = @threads[curpos] or return
159 multi_mark_as_spam [t]
162 def multi_mark_as_spam threads
171 t = @threads[curpos] or return
175 def multi_kill threads
177 t.apply_label :killed
184 threads = @threads + @hidden_threads.keys
185 mbid = BufferManager.say "Saving threads..."
186 threads.each_with_index do |t, i|
188 BufferManager.say "Saving thread #{i + 1} of #{threads.length}...",
193 BufferManager.clear mbid
197 UpdateManager.unregister self
201 BufferManager.clear @mbid if @mbid
202 sleep 0.1 # TODO: necessary?
203 BufferManager.erase_flash
210 t = @threads[curpos] or return
211 @tags.toggle_tag_for t
212 update_text_for_line curpos
216 def apply_to_tagged; @tags.apply_to_tagged; end
219 thread = @threads[curpos]
220 speciall = (@hidden_labels + LabelManager::RESERVED_LABELS).uniq
221 keepl, modifyl = thread.labels.partition { |t| speciall.member? t }
222 label_string = modifyl.join(" ")
224 answer = BufferManager.ask :edit_labels, "edit labels: ", label_string
226 user_labels = answer.split(/\s+/).map { |l| l.intern }
228 hl = user_labels.select { |l| speciall.member? l }
230 thread.labels = keepl + user_labels
231 user_labels.each { |l| LabelManager << l }
233 BufferManager.flash "'#{hl}' is a reserved label!"
235 update_text_for_line curpos
238 def multi_edit_labels threads
239 answer = BufferManager.ask :add_labels, "add labels: "
241 user_labels = answer.split(/\s+/).map { |l| l.intern }
243 hl = user_labels.select { |l| @hidden_labels.member? l }
245 threads.each { |t| user_labels.each { |l| t.apply_label l } }
246 user_labels.each { |l| LabelManager << l }
248 BufferManager.flash "'#{hl}' is a reserved label!"
254 t = @threads[curpos] or return
256 return if m.nil? # probably won't happen
257 mode = ReplyMode.new m
258 BufferManager.spawn "Reply to #{m.subj}", mode
262 t = @threads[curpos] or return
264 return if m.nil? # probably won't happen
265 mode = ForwardMode.new m
266 BufferManager.spawn "Forward of #{m.subj}", mode
270 def load_n_threads_background n=LOAD_MORE_THREAD_NUM, opts={}
271 return if @load_thread
272 @load_thread = Redwood::reporting_thread do
273 num = load_n_threads n, opts
274 opts[:when_done].call(num) if opts[:when_done]
279 def load_n_threads n=LOAD_MORE_THREAD_NUM, opts={}
280 @mbid = BufferManager.say "Searching for threads..."
282 @ts.load_n_threads(@ts.size + n, opts) do |i|
283 BufferManager.say "Loaded #{i} threads...", @mbid
286 BufferManager.draw_screen
289 @ts.threads.each { |th| th.labels.each { |l| LabelManager << l } }
292 BufferManager.clear @mbid
294 BufferManager.draw_screen
299 "line #{curpos + 1} of #{lines} #{dirty? ? '*modified*' : ''}"
304 def cursor_thread; @threads[curpos]; end
312 def remove_label_and_hide_thread t, label
318 raise "already hidden" if @hidden_threads[t]
319 @hidden_threads[t] = true
324 def update_text_for_line l
325 return unless l # not sure why this happens, but it does, occasionally
326 @text[l] = text_for_thread @threads[l]
327 buffer.mark_dirty if buffer
331 @text = @threads.map_with_index { |t, i| text_for_thread t }
332 @lines = @threads.map_with_index { |t, i| [t, i] }.to_h
333 buffer.mark_dirty if buffer
336 def author_text_for_thread t
337 if t.authors.size == 1
338 t.authors.first.mediumname
340 t.authors.map { |p| AccountManager.is_account?(p) ? "me" : p.shortname }.join ", "
344 def text_for_thread t
345 date = (@date_cache[t] ||= t.date.to_nice_s(Time.now))
346 from = (@who_cache[t] ||= author_text_for_thread(t))
347 if from.length > @from_width
348 from = from[0 ... (@from_width - 1)]
349 from += "." unless from[-1] == ?\s
352 new = @new_cache.member?(t) ? @new_cache[t] : @new_cache[t] = t.has_label?(:unread)
353 starred = @starred_cache.member?(t) ? @starred_cache[t] : @starred_cache[t] = t.has_label?(:starred)
355 dp = (@dp_cache[t] ||= t.direct_participants.any? { |p| AccountManager.is_account? p })
356 p = (@p_cache[t] ||= (dp || t.participants.any? { |p| AccountManager.is_account? p }))
358 base_color = (new ? :index_new_color : :index_old_color)
360 [:tagged_color, @tags.tagged?(t) ? ">" : " "],
361 [:none, sprintf("%#{@date_width}s ", date)],
362 [base_color, sprintf("%-#{@from_width}s", from)],
363 [:starred_color, starred ? "*" : " "],
364 [:none, t.size == 1 ? " " * (@size_width + 2) : sprintf("(%#{@size_width}d)", t.size)],
365 [:to_me_color, dp ? " >" : (p ? ' +' : " ")],
366 [base_color, t.subj + (t.subj.empty? ? "" : " ")],
368 (t.labels - @hidden_labels).map { |label| [:label_color, "+#{label} "] } +
369 [[:snippet_color, t.snippet]
373 def dirty?; (@hidden_threads.keys + @threads).any? { |t| t.dirty? }; end
377 def initialize_threads
378 @ts = ThreadSet.new Index.instance