test: regression tests for n_indexopts_{get,set}_decrypt_policy
[notmuch] / vim / notmuch.vim
1 if exists("g:loaded_notmuch")
2         finish
3 endif
4
5 if !has("ruby") || version < 700
6         finish
7 endif
8
9 let g:loaded_notmuch = "yep"
10
11 let g:notmuch_folders_maps = {
12         \ '<Enter>':    'folders_show_search()',
13         \ 's':          'folders_search_prompt()',
14         \ '=':          'folders_refresh()',
15         \ 'c':          'compose()',
16         \ }
17
18 let g:notmuch_search_maps = {
19         \ 'q':          'kill_this_buffer()',
20         \ '<Enter>':    'search_show_thread(1)',
21         \ '<Space>':    'search_show_thread(2)',
22         \ 'A':          'search_tag("-inbox -unread")',
23         \ 'I':          'search_tag("-unread")',
24         \ 't':          'search_tag("")',
25         \ 's':          'search_search_prompt()',
26         \ '=':          'search_refresh()',
27         \ '?':          'search_info()',
28         \ 'c':          'compose()',
29         \ }
30
31 let g:notmuch_show_maps = {
32         \ 'q':          'kill_this_buffer()',
33         \ 'A':          'show_tag("-inbox -unread")',
34         \ 'I':          'show_tag("-unread")',
35         \ 't':          'show_tag("")',
36         \ 'o':          'show_open_msg()',
37         \ 'e':          'show_extract_msg()',
38         \ 's':          'show_save_msg()',
39         \ 'p':          'show_save_patches()',
40         \ 'r':          'show_reply()',
41         \ '?':          'show_info()',
42         \ '<Tab>':      'show_next_msg()',
43         \ 'c':          'compose()',
44         \ }
45
46 let g:notmuch_compose_maps = {
47         \ ',s':         'compose_send()',
48         \ ',q':         'compose_quit()',
49         \ }
50
51 let s:notmuch_folders_default = [
52         \ [ 'new', 'tag:inbox and tag:unread' ],
53         \ [ 'inbox', 'tag:inbox' ],
54         \ [ 'unread', 'tag:unread' ],
55         \ ]
56
57 let s:notmuch_date_format_default = '%d.%m.%y'
58 let s:notmuch_datetime_format_default = '%d.%m.%y %H:%M:%S'
59 let s:notmuch_reader_default = 'mutt -f %s'
60 let s:notmuch_sendmail_default = 'sendmail'
61 let s:notmuch_folders_count_threads_default = 0
62 let s:notmuch_compose_start_insert_default = 1
63
64 function! s:new_file_buffer(type, fname)
65         exec printf('edit %s', a:fname)
66         execute printf('set filetype=notmuch-%s', a:type)
67         execute printf('set syntax=notmuch-%s', a:type)
68         ruby $curbuf.init(VIM::evaluate('a:type'))
69 endfunction
70
71 function! s:on_compose_delete()
72         if b:compose_done
73                 return
74         endif
75         if input('[s]end/[q]uit? ') =~ '^s'
76                 call s:compose_send()
77         endif
78 endfunction
79
80 "" actions
81
82 function! s:compose_quit()
83         let b:compose_done = 1
84         call s:kill_this_buffer()
85 endfunction
86
87 function! s:compose_send()
88         let b:compose_done = 1
89         let fname = expand('%')
90         let lines = getline(5, '$')
91
92 ruby << EOF
93         # Generate proper mail to send
94         text = VIM::evaluate('lines').join("\n")
95         fname = VIM::evaluate('fname')
96         transport = Mail.new(text)
97         transport.message_id = generate_message_id
98         transport.charset = 'utf-8'
99         File.write(fname, transport.to_s)
100 EOF
101
102         let cmdtxt = g:notmuch_sendmail . ' -t -f ' . s:reply_from . ' < ' . fname
103         let out = system(cmdtxt)
104         let err = v:shell_error
105         if err
106                 echohl Error
107                 echo 'Eeek! unable to send mail'
108                 echo out
109                 echohl None
110                 return
111         endif
112         call delete(fname)
113         echo 'Mail sent successfully.'
114         call s:kill_this_buffer()
115 endfunction
116
117 function! s:show_next_msg()
118 ruby << EOF
119         r, c = $curwin.cursor
120         n = $curbuf.line_number
121         i = $messages.index { |m| n >= m.start && n <= m.end }
122         m = $messages[i + 1]
123         if m
124                 r = m.body_start + 1
125                 VIM::command("normal #{m.start}zt")
126                 $curwin.cursor = r, c
127         end
128 EOF
129 endfunction
130
131 function! s:show_reply()
132         ruby open_reply get_message.mail
133         let b:compose_done = 0
134         call s:set_map(g:notmuch_compose_maps)
135         autocmd BufDelete <buffer> call s:on_compose_delete()
136         if g:notmuch_compose_start_insert
137                 startinsert!
138         end
139 endfunction
140
141 function! s:compose()
142         ruby open_compose
143         let b:compose_done = 0
144         call s:set_map(g:notmuch_compose_maps)
145         autocmd BufDelete <buffer> call s:on_compose_delete()
146         if g:notmuch_compose_start_insert
147                 startinsert!
148         end
149 endfunction
150
151 function! s:show_info()
152         ruby vim_puts get_message.inspect
153 endfunction
154
155 function! s:show_extract_msg()
156 ruby << EOF
157         m = get_message
158         m.mail.attachments.each do |a|
159                 File.open(a.filename, 'w') do |f|
160                         f.write a.body.decoded
161                         print "Extracted '#{a.filename}'"
162                 end
163         end
164 EOF
165 endfunction
166
167 function! s:show_open_msg()
168 ruby << EOF
169         m = get_message
170         mbox = File.expand_path('~/.notmuch/vim_mbox')
171         cmd = VIM::evaluate('g:notmuch_reader') % mbox
172         system "notmuch show --format=mbox id:#{m.message_id} > #{mbox} && #{cmd}"
173 EOF
174 endfunction
175
176 function! s:show_save_msg()
177         let file = input('File name: ')
178 ruby << EOF
179         file = VIM::evaluate('file')
180         m = get_message
181         system "notmuch show --format=mbox id:#{m.message_id} > #{file}"
182 EOF
183 endfunction
184
185 function! s:show_save_patches()
186 ruby << EOF
187         q = $curbuf.query($cur_thread)
188         t = q.search_threads.first
189         n = 0
190         t.toplevel_messages.first.replies.each do |m|
191                 next if not m['subject'] =~ /^\[PATCH.*\]/
192                 file = "%04d.patch" % [n += 1]
193                 system "notmuch show --format=mbox id:#{m.message_id} > #{file}"
194         end
195         vim_puts "Saved #{n} patches"
196 EOF
197 endfunction
198
199 function! s:show_tag(intags)
200         if empty(a:intags)
201                 let tags = input('tags: ')
202         else
203                 let tags = a:intags
204         endif
205         ruby do_tag(get_cur_view, VIM::evaluate('l:tags'))
206         call s:show_next_thread()
207 endfunction
208
209 function! s:search_search_prompt()
210         let text = input('Search: ')
211         if text == ""
212           return
213         endif
214         setlocal modifiable
215 ruby << EOF
216         $cur_search = VIM::evaluate('text')
217         $curbuf.reopen
218         search_render($cur_search)
219 EOF
220         setlocal nomodifiable
221 endfunction
222
223 function! s:search_info()
224         ruby vim_puts get_thread_id
225 endfunction
226
227 function! s:search_refresh()
228         setlocal modifiable
229         ruby $curbuf.reopen
230         ruby search_render($cur_search)
231         setlocal nomodifiable
232 endfunction
233
234 function! s:search_tag(intags)
235         if empty(a:intags)
236                 let tags = input('tags: ')
237         else
238                 let tags = a:intags
239         endif
240         ruby do_tag(get_thread_id, VIM::evaluate('l:tags'))
241         norm j
242 endfunction
243
244 function! s:folders_search_prompt()
245         let text = input('Search: ')
246         call s:search(text)
247 endfunction
248
249 function! s:folders_refresh()
250         setlocal modifiable
251         ruby $curbuf.reopen
252         ruby folders_render()
253         setlocal nomodifiable
254 endfunction
255
256 "" basic
257
258 function! s:show_cursor_moved()
259 ruby << EOF
260         if $render.is_ready?
261                 VIM::command('setlocal modifiable')
262                 $render.do_next
263                 VIM::command('setlocal nomodifiable')
264         end
265 EOF
266 endfunction
267
268 function! s:show_next_thread()
269         call s:kill_this_buffer()
270         if line('.') != line('$')
271                 norm j
272                 call s:search_show_thread(0)
273         else
274                 echo 'No more messages.'
275         endif
276 endfunction
277
278 function! s:kill_this_buffer()
279 ruby << EOF
280         $curbuf.close
281         VIM::command("bdelete!")
282 EOF
283 endfunction
284
285 function! s:set_map(maps)
286         nmapclear <buffer>
287         for [key, code] in items(a:maps)
288                 let cmd = printf(":call <SID>%s<CR>", code)
289                 exec printf('nnoremap <buffer> %s %s', key, cmd)
290         endfor
291 endfunction
292
293 function! s:new_buffer(type)
294         enew
295         setlocal buftype=nofile bufhidden=hide
296         keepjumps 0d
297         execute printf('set filetype=notmuch-%s', a:type)
298         execute printf('set syntax=notmuch-%s', a:type)
299         ruby $curbuf.init(VIM::evaluate('a:type'))
300 endfunction
301
302 function! s:set_menu_buffer()
303         setlocal nomodifiable
304         setlocal cursorline
305         setlocal nowrap
306 endfunction
307
308 "" main
309
310 function! s:show(thread_id)
311         call s:new_buffer('show')
312         setlocal modifiable
313 ruby << EOF
314         thread_id = VIM::evaluate('a:thread_id')
315         $cur_thread = thread_id
316         $messages.clear
317         $curbuf.render do |b|
318                 q = $curbuf.query(get_cur_view)
319                 q.sort = Notmuch::SORT_OLDEST_FIRST
320                 msgs = q.search_messages
321                 msgs.each do |msg|
322                         m = Mail.read(msg.filename)
323                         part = m.find_first_text
324                         nm_m = Message.new(msg, m)
325                         $messages << nm_m
326                         date_fmt = VIM::evaluate('g:notmuch_datetime_format')
327                         date = Time.at(msg.date).strftime(date_fmt)
328                         nm_m.start = b.count
329                         b << "%s %s (%s)" % [msg['from'], date, msg.tags]
330                         b << "Subject: %s" % [msg['subject']]
331                         b << "To: %s" % msg['to']
332                         b << "Cc: %s" % msg['cc']
333                         b << "Date: %s" % msg['date']
334                         nm_m.body_start = b.count
335                         b << "--- %s ---" % part.mime_type
336                         part.convert.each_line do |l|
337                                 b << l.chomp
338                         end
339                         b << ""
340                         nm_m.end = b.count
341                 end
342                 b.delete(b.count)
343         end
344         $messages.each_with_index do |msg, i|
345                 VIM::command("syntax region nmShowMsg#{i}Desc start='\\%%%il' end='\\%%%il' contains=@nmShowMsgDesc" % [msg.start, msg.start + 1])
346                 VIM::command("syntax region nmShowMsg#{i}Head start='\\%%%il' end='\\%%%il' contains=@nmShowMsgHead" % [msg.start + 1, msg.body_start])
347                 VIM::command("syntax region nmShowMsg#{i}Body start='\\%%%il' end='\\%%%dl' contains=@nmShowMsgBody" % [msg.body_start, msg.end])
348         end
349 EOF
350         setlocal nomodifiable
351         call s:set_map(g:notmuch_show_maps)
352 endfunction
353
354 function! s:search_show_thread(mode)
355 ruby << EOF
356         mode = VIM::evaluate('a:mode')
357         id = get_thread_id
358         case mode
359         when 0;
360         when 1; $cur_filter = nil
361         when 2; $cur_filter = $cur_search
362         end
363         VIM::command("call s:show('#{id}')")
364 EOF
365 endfunction
366
367 function! s:search(search)
368         call s:new_buffer('search')
369 ruby << EOF
370         $cur_search = VIM::evaluate('a:search')
371         search_render($cur_search)
372 EOF
373         call s:set_menu_buffer()
374         call s:set_map(g:notmuch_search_maps)
375         autocmd CursorMoved <buffer> call s:show_cursor_moved()
376 endfunction
377
378 function! s:folders_show_search()
379 ruby << EOF
380         n = $curbuf.line_number
381         s = $searches[n - 1]
382         VIM::command("call s:search('#{s}')")
383 EOF
384 endfunction
385
386 function! s:folders()
387         call s:new_buffer('folders')
388         ruby folders_render()
389         call s:set_menu_buffer()
390         call s:set_map(g:notmuch_folders_maps)
391 endfunction
392
393 "" root
394
395 function! s:set_defaults()
396         if !exists('g:notmuch_date_format')
397                 if exists('g:notmuch_rb_date_format')
398                         let g:notmuch_date_format = g:notmuch_rb_date_format
399                 else
400                         let g:notmuch_date_format = s:notmuch_date_format_default
401                 endif
402         endif
403
404         if !exists('g:notmuch_datetime_format')
405                 if exists('g:notmuch_rb_datetime_format')
406                         let g:notmuch_datetime_format = g:notmuch_rb_datetime_format
407                 else
408                         let g:notmuch_datetime_format = s:notmuch_datetime_format_default
409                 endif
410         endif
411
412         if !exists('g:notmuch_reader')
413                 if exists('g:notmuch_rb_reader')
414                         let g:notmuch_reader = g:notmuch_rb_reader
415                 else
416                         let g:notmuch_reader = s:notmuch_reader_default
417                 endif
418         endif
419
420         if !exists('g:notmuch_sendmail')
421                 if exists('g:notmuch_rb_sendmail')
422                         let g:notmuch_sendmail = g:notmuch_rb_sendmail
423                 else
424                         let g:notmuch_sendmail = s:notmuch_sendmail_default
425                 endif
426         endif
427
428         if !exists('g:notmuch_folders_count_threads')
429                 if exists('g:notmuch_rb_count_threads')
430                         let g:notmuch_count_threads = g:notmuch_rb_count_threads
431                 else
432                         let g:notmuch_folders_count_threads = s:notmuch_folders_count_threads_default
433                 endif
434         endif
435
436         if !exists('g:notmuch_compose_start_insert')
437                 let g:notmuch_compose_start_insert = s:notmuch_compose_start_insert_default
438         endif
439
440         if !exists('g:notmuch_custom_search_maps') && exists('g:notmuch_rb_custom_search_maps')
441                 let g:notmuch_custom_search_maps = g:notmuch_rb_custom_search_maps
442         endif
443
444         if !exists('g:notmuch_custom_show_maps') && exists('g:notmuch_rb_custom_show_maps')
445                 let g:notmuch_custom_show_maps = g:notmuch_rb_custom_show_maps
446         endif
447
448         if exists('g:notmuch_custom_search_maps')
449                 call extend(g:notmuch_search_maps, g:notmuch_custom_search_maps)
450         endif
451
452         if exists('g:notmuch_custom_show_maps')
453                 call extend(g:notmuch_show_maps, g:notmuch_custom_show_maps)
454         endif
455
456         if !exists('g:notmuch_folders')
457                 if exists('g:notmuch_rb_folders')
458                         let g:notmuch_folders = g:notmuch_rb_folders
459                 else
460                         let g:notmuch_folders = s:notmuch_folders_default
461                 endif
462         endif
463 endfunction
464
465 function! s:NotMuch(...)
466         call s:set_defaults()
467
468 ruby << EOF
469         require 'notmuch'
470         require 'rubygems'
471         require 'tempfile'
472         require 'socket'
473         begin
474                 require 'mail'
475         rescue LoadError
476         end
477
478         $db_name = nil
479         $email = $email_name = $email_address = nil
480         $exclude_tags = []
481         $searches = []
482         $threads = []
483         $messages = []
484         $mail_installed = defined?(Mail)
485
486         def get_config_item(item)
487                 result = ''
488                 IO.popen(['notmuch', 'config', 'get', item]) { |out|
489                         result = out.read
490                 }
491                 return result.rstrip
492         end
493
494         def get_config
495                 $db_name = get_config_item('database.path')
496                 $email_name = get_config_item('user.name')
497                 $email_address = get_config_item('user.primary_email')
498                 $email_name = get_config_item('user.name')
499                 $email = "%s <%s>" % [$email_name, $email_address]
500                 ignore_tags = get_config_item('search.exclude_tags')
501                 $exclude_tags = ignore_tags.split("\n")
502         end
503
504         def vim_puts(s)
505                 VIM::command("echo '#{s.to_s}'")
506         end
507
508         def vim_p(s)
509                 VIM::command("echo '#{s.inspect}'")
510         end
511
512         def author_filter(a)
513                 # TODO email format, aliases
514                 a.strip!
515                 a.gsub!(/[\.@].*/, '')
516                 a.gsub!(/^ext /, '')
517                 a.gsub!(/ \(.*\)/, '')
518                 a
519         end
520
521         def get_thread_id
522                 n = $curbuf.line_number - 1
523                 return "thread:%s" % $threads[n]
524         end
525
526         def get_message
527                 n = $curbuf.line_number
528                 return $messages.find { |m| n >= m.start && n <= m.end }
529         end
530
531         def get_cur_view
532                 if $cur_filter
533                         return "#{$cur_thread} and (#{$cur_filter})"
534                 else
535                         return $cur_thread
536                 end
537         end
538
539         def generate_message_id
540                 t = Time.now
541                 random_tag = sprintf('%x%x_%x%x%x',
542                         t.to_i, t.tv_usec,
543                         $$, Thread.current.object_id.abs, rand(255))
544                 return "<#{random_tag}@#{Socket.gethostname}.notmuch>"
545         end
546
547         def open_compose_helper(lines, cur)
548                 help_lines = [
549                         'Notmuch-Help: Type in your message here; to help you use these bindings:',
550                         'Notmuch-Help:   ,s    - send the message (Notmuch-Help lines will be removed)',
551                         'Notmuch-Help:   ,q    - abort the message',
552                         ]
553
554                 dir = File.expand_path('~/.notmuch/compose')
555                 FileUtils.mkdir_p(dir)
556                 Tempfile.open(['nm-', '.mail'], dir) do |f|
557                         f.puts(help_lines)
558                         f.puts
559                         f.puts(lines)
560
561                         sig_file = File.expand_path('~/.signature')
562                         if File.exists?(sig_file)
563                                 f.puts("-- ")
564                                 f.write(File.read(sig_file))
565                         end
566
567                         f.flush
568
569                         cur += help_lines.size + 1
570
571                         VIM::command("let s:reply_from='%s'" % $email_address)
572                         VIM::command("call s:new_file_buffer('compose', '#{f.path}')")
573                         VIM::command("call cursor(#{cur}, 0)")
574                 end
575         end
576
577         def open_reply(orig)
578                 reply = orig.reply do |m|
579                         # fix headers
580                         if not m[:reply_to]
581                                 m.to = [orig[:from].to_s, orig[:to].to_s]
582                         end
583                         m.cc = orig[:cc]
584                         m.from = $email
585                         m.charset = 'utf-8'
586                 end
587
588                 lines = []
589
590                 body_lines = []
591                 if $mail_installed
592                         addr = Mail::Address.new(orig[:from].value)
593                         name = addr.name
594                         name = addr.local + "@" if name.nil? && !addr.local.nil?
595                 else
596                         name = orig[:from]
597                 end
598                 name = "somebody" if name.nil?
599
600                 body_lines << "%s wrote:" % name
601                 part = orig.find_first_text
602                 part.convert.each_line do |l|
603                         body_lines << "> %s" % l.chomp
604                 end
605                 body_lines << ""
606                 body_lines << ""
607                 body_lines << ""
608
609                 reply.body = body_lines.join("\n")
610
611                 lines += reply.present.lines.map { |e| e.chomp }
612                 lines << ""
613
614                 cur = lines.count - 1
615
616                 open_compose_helper(lines, cur)
617         end
618
619         def open_compose()
620                 lines = []
621
622                 lines << "From: #{$email}"
623                 lines << "To: "
624                 cur = lines.count
625
626                 lines << "Cc: "
627                 lines << "Bcc: "
628                 lines << "Subject: "
629                 lines << ""
630                 lines << ""
631                 lines << ""
632
633                 open_compose_helper(lines, cur)
634         end
635
636         def folders_render()
637                 $curbuf.render do |b|
638                         folders = VIM::evaluate('g:notmuch_folders')
639                         count_threads = VIM::evaluate('g:notmuch_folders_count_threads') == 1
640                         $searches.clear
641                         folders.each do |name, search|
642                                 q = $curbuf.query(search)
643                                 $exclude_tags.each { |t|
644                                         q.add_tag_exclude(t)
645                                 }
646                                 $searches << search
647                                 count = count_threads ? q.count_threads : q.count_messages
648                                 b << "%9d %-20s (%s)" % [count, name, search]
649                         end
650                 end
651         end
652
653         def search_render(search)
654                 date_fmt = VIM::evaluate('g:notmuch_date_format')
655                 q = $curbuf.query(search)
656                 q.sort = Notmuch::SORT_NEWEST_FIRST
657                 $exclude_tags.each { |t|
658                         q.add_tag_exclude(t)
659                 }
660                 $threads.clear
661                 t = q.search_threads
662
663                 $render = $curbuf.render_staged(t) do |b, items|
664                         items.each do |e|
665                                 authors = e.authors.to_utf8.split(/[,|]/).map { |a| author_filter(a) }.join(",")
666                                 date = Time.at(e.newest_date).strftime(date_fmt)
667                                 subject = e.messages.first['subject']
668                                 if $mail_installed
669                                         subject = Mail::Field.new("Subject: " + subject).to_s
670                                 else
671                                         subject = subject.force_encoding('utf-8')
672                                 end
673                                 b << "%-12s %3s %-20.20s | %s (%s)" % [date, e.matched_messages, authors, subject, e.tags]
674                                 $threads << e.thread_id
675                         end
676                 end
677         end
678
679         def do_tag(filter, tags)
680                 $curbuf.do_write do |db|
681                         q = db.query(filter)
682                         q.search_messages.each do |e|
683                                 e.freeze
684                                 tags.split.each do |t|
685                                         case t
686                                         when /^-(.*)/
687                                                 e.remove_tag($1)
688                                         when /^\+(.*)/
689                                                 e.add_tag($1)
690                                         when /^([^\+^-].*)/
691                                                 e.add_tag($1)
692                                         end
693                                 end
694                                 e.thaw
695                                 e.tags_to_maildir_flags
696                         end
697                         q.destroy!
698                 end
699         end
700
701         module DbHelper
702                 def init(name)
703                         @name = name
704                         @db = Notmuch::Database.new($db_name)
705                         @queries = []
706                 end
707
708                 def query(*args)
709                         q = @db.query(*args)
710                         @queries << q
711                         q
712                 end
713
714                 def close
715                         @queries.delete_if { |q| ! q.destroy! }
716                         @db.close
717                 end
718
719                 def reopen
720                         close if @db
721                         @db = Notmuch::Database.new($db_name)
722                 end
723
724                 def do_write
725                         db = Notmuch::Database.new($db_name, :mode => Notmuch::MODE_READ_WRITE)
726                         begin
727                                 yield db
728                         ensure
729                                 db.close
730                         end
731                 end
732         end
733
734         class Message
735                 attr_accessor :start, :body_start, :end
736                 attr_reader :message_id, :filename, :mail
737
738                 def initialize(msg, mail)
739                         @message_id = msg.message_id
740                         @filename = msg.filename
741                         @mail = mail
742                         @start = 0
743                         @end = 0
744                         mail.import_headers(msg) if not $mail_installed
745                 end
746
747                 def to_s
748                         "id:%s" % @message_id
749                 end
750
751                 def inspect
752                         "id:%s, file:%s" % [@message_id, @filename]
753                 end
754         end
755
756         class StagedRender
757                 def initialize(buffer, enumerable, block)
758                         @b = buffer
759                         @enumerable = enumerable
760                         @block = block
761                         @last_render = 0
762
763                         @b.render { do_next }
764                 end
765
766                 def is_ready?
767                         @last_render - @b.line_number <= $curwin.height
768                 end
769
770                 def do_next
771                         items = @enumerable.take($curwin.height * 2)
772                         return if items.empty?
773                         @block.call @b, items
774                         @last_render = @b.count
775                 end
776         end
777
778         class VIM::Buffer
779                 include DbHelper
780
781                 def <<(a)
782                         append(count(), a)
783                 end
784
785                 def render_staged(enumerable, &block)
786                         StagedRender.new(self, enumerable, block)
787                 end
788
789                 def render
790                         old_count = count
791                         yield self
792                         (1..old_count).each do
793                                 delete(1)
794                         end
795                 end
796         end
797
798         class Notmuch::Tags
799                 def to_s
800                         to_a.join(" ")
801                 end
802         end
803
804         class Notmuch::Message
805                 def to_s
806                         "id:%s" % message_id
807                 end
808         end
809
810         # workaround for bug in vim's ruby
811         class Object
812                 def flush
813                 end
814         end
815
816         module SimpleMessage
817                 class Header < Array
818                         def self.parse(string)
819                                 return nil if string.empty?
820                                 return Header.new(string.split(/,\s+/))
821                         end
822
823                         def to_s
824                                 self.join(', ')
825                         end
826                 end
827
828                 def initialize(string = nil)
829                         @raw_source = string
830                         @body = nil
831                         @headers = {}
832
833                         return if not string
834
835                         if string =~ /(.*?(\r\n|\n))\2/m
836                                 head, body = $1, $' || '', $2
837                         else
838                                 head, body = string, ''
839                         end
840                         @body = body
841                 end
842
843                 def [](name)
844                         @headers[name.to_sym]
845                 end
846
847                 def []=(name, value)
848                         @headers[name.to_sym] = value
849                 end
850
851                 def format_header(value)
852                         value.to_s.tr('_', '-').gsub(/(\w+)/) { $1.capitalize }
853                 end
854
855                 def to_s
856                         buffer = ''
857                         @headers.each do |key, value|
858                                 buffer << "%s: %s\r\n" %
859                                         [format_header(key), value]
860                         end
861                         buffer << "\r\n"
862                         buffer << @body
863                         buffer
864                 end
865
866                 def body=(value)
867                         @body = value
868                 end
869
870                 def from
871                         @headers[:from]
872                 end
873
874                 def decoded
875                         @body
876                 end
877
878                 def mime_type
879                         'text/plain'
880                 end
881
882                 def multipart?
883                         false
884                 end
885
886                 def reply
887                         r = Mail::Message.new
888                         r[:from] = self[:to]
889                         r[:to] = self[:from]
890                         r[:cc] = self[:cc]
891                         r[:in_reply_to] = self[:message_id]
892                         r[:references] = self[:references]
893                         r
894                 end
895
896                 HEADERS = [ :from, :to, :cc, :references, :in_reply_to, :reply_to, :message_id ]
897
898                 def import_headers(m)
899                         HEADERS.each do |e|
900                                 dashed = format_header(e)
901                                 @headers[e] = Header.parse(m[dashed])
902                         end
903                 end
904         end
905
906         module Mail
907
908                 if not $mail_installed
909                         puts "WARNING: Install the 'mail' gem, without it support is limited"
910
911                         def self.read(filename)
912                                 Message.new(File.open(filename, 'rb') { |f| f.read })
913                         end
914
915                         class Message
916                                 include SimpleMessage
917                         end
918                 end
919
920                 class Message
921
922                         def find_first_text
923                                 return self if not multipart?
924                                 return text_part || html_part
925                         end
926
927                         def convert
928                                 if mime_type != "text/html"
929                                         text = decoded
930                                 else
931                                         IO.popen(VIM::evaluate('exists("g:notmuch_html_converter") ? ' +
932                                                         'g:notmuch_html_converter : "elinks --dump"'), "w+") do |pipe|
933                                                 pipe.write(decode_body)
934                                                 pipe.close_write
935                                                 text = pipe.read
936                                         end
937                                 end
938                                 text
939                         end
940
941                         def present
942                                 buffer = ''
943                                 header.fields.each do |f|
944                                         buffer << "%s: %s\r\n" % [f.name, f.to_s]
945                                 end
946                                 buffer << "\r\n"
947                                 buffer << body.to_s
948                                 buffer
949                         end
950                 end
951         end
952
953         class String
954                 def to_utf8
955                         RUBY_VERSION >= "1.9" ? force_encoding('utf-8') : self
956                 end
957         end
958
959         get_config
960 EOF
961         if a:0
962           call s:search(join(a:000))
963         else
964           call s:folders()
965         endif
966 endfunction
967
968 command -nargs=* NotMuch call s:NotMuch(<f-args>)
969
970 " vim: set noexpandtab: