X-Git-Url: https://git.cworth.org/git?a=blobdiff_plain;f=lib%2Fsup%2Fbuffer.rb;h=df5d23c455fbaeb9fa53a5d9d66305249d9d6f17;hb=8039b8594c5246338406b284ab9b2c4974b77937;hp=df1ecc753d6fb173180a8f565945174d74123404;hpb=779a90fa2de7c8165f505d85b6fc5d5e76d293a7;p=sup diff --git a/lib/sup/buffer.rb b/lib/sup/buffer.rb index df1ecc7..df5d23c 100644 --- a/lib/sup/buffer.rb +++ b/lib/sup/buffer.rb @@ -25,17 +25,24 @@ module Ncurses def mutex; @mutex ||= Mutex.new; end def sync &b; mutex.synchronize(&b); end - ## magically, this stuff seems to work now. i could swear it didn't - ## before. hm. def nonblocking_getch - if IO.select([$stdin], nil, nil, 1) - Ncurses.getch - else - nil + ## INSANTIY + ## it is NECESSARY to wrap Ncurses.getch in a select() otherwise all + ## background threads will be BLOCKED. (except in very modern versions + ## of libncurses-ruby. the current one on ubuntu seems to work well.) + if IO.select([$stdin], nil, nil, 0.5) + c = Ncurses.getch end end - module_function :rows, :cols, :curx, :nonblocking_getch, :mutex, :sync + ## pretends ctrl-c's are ctrl-g's + def safe_nonblocking_getch + nonblocking_getch + rescue Interrupt + KEY_CANCEL + end + + module_function :rows, :cols, :curx, :nonblocking_getch, :safe_nonblocking_getch, :mutex, :sync remove_const :KEY_ENTER remove_const :KEY_CANCEL @@ -51,8 +58,8 @@ module Redwood class InputSequenceAborted < StandardError; end class Buffer - attr_reader :mode, :x, :y, :width, :height, :title - bool_reader :dirty + attr_reader :mode, :x, :y, :width, :height, :title, :atime + bool_reader :dirty, :system bool_accessor :force_to_top def initialize window, mode, width, height, opts={} @@ -63,12 +70,14 @@ class Buffer @title = opts[:title] || "" @force_to_top = opts[:force_to_top] || false @x, @y, @width, @height = 0, 0, width, height + @atime = Time.at 0 + @system = opts[:system] || false end def content_height; @height - 1; end def content_width; @width; end - def resize rows, cols + def resize rows, cols return if cols == @width && rows == @height @width = cols @height = rows @@ -97,6 +106,7 @@ class Buffer @mode.draw draw_status status commit + @atime = Time.now end ## s nil means a blank line! @@ -105,10 +115,16 @@ class Buffer @w.attrset Colormap.color_for(opts[:color] || :none, opts[:highlight]) s ||= "" - maxl = @width - x - @w.mvaddstr y, x, s[0 ... maxl] - unless s.length >= maxl || opts[:no_fill] - @w.mvaddstr(y, x + s.length, " " * (maxl - s.length)) + maxl = @width - x # maximum display width width + stringl = maxl # string "length" + ## the next horribleness is thanks to ruby's lack of widechar support + stringl += 1 while stringl < s.length && s[0 ... stringl].display_length < maxl + @w.mvaddstr y, x, s[0 ... stringl] + unless opts[:no_fill] + l = s.display_length + unless l >= maxl + @w.mvaddstr(y, x + l, " " * (maxl - l)) + end end end @@ -165,6 +181,15 @@ called at least once per keystroke, so excessive computation is discouraged. Variables: the same as status-bar-text hook. Return value: a string to be used as the terminal title. +EOS + + HookManager.register "extra-contact-addresses", <" entries. + +Variables: none +Return value: an array of email address strings. EOS def initialize @@ -178,10 +203,13 @@ EOS @flash = nil @shelled = @asking = false @in_x = ENV["TERM"] =~ /(xterm|rxvt|screen)/ - - self.class.i_am_the_instance self + @sigwinch_happened = false + @sigwinch_mutex = Mutex.new end + def sigwinch_happened!; @sigwinch_mutex.synchronize { @sigwinch_happened = true } end + def sigwinch_happened?; @sigwinch_mutex.synchronize { @sigwinch_happened } end + def buffers; @name_map.to_a; end def focus_on buf @@ -212,14 +240,20 @@ EOS ## have to change this. but it's not clear that we will ever actually ## do that. def roll_buffers - @buffers.last.force_to_top = false - raise_to_front @buffers.first + bufs = rollable_buffers + bufs.last.force_to_top = false + raise_to_front bufs.first end def roll_buffers_backwards - return unless @buffers.length > 1 - @buffers.last.force_to_top = false - raise_to_front @buffers[@buffers.length - 2] + bufs = rollable_buffers + return unless bufs.length > 1 + bufs.last.force_to_top = false + raise_to_front bufs[bufs.length - 2] + end + + def rollable_buffers + @buffers.select { |b| !b.system? || @buffers.last == b } end def handle_input c @@ -243,6 +277,14 @@ EOS def completely_redraw_screen return if @shelled + ## this magic makes Ncurses get the new size of the screen + Ncurses.endwin + Ncurses.stdscr.keypad 1 + Ncurses.curs_set 0 + Ncurses.refresh + @sigwinch_mutex.synchronize { @sigwinch_happened = false } + debug "new screen size is #{Ncurses.rows} x #{Ncurses.cols}" + status, title = get_status_and_title(@focus_buf) # must be called outside of the ncurses lock Ncurses.sync do @@ -263,7 +305,8 @@ EOS get_status_and_title @focus_buf # must be called outside of the ncurses lock end - print "\033]2;#{title}\07" if title && @in_x + ## http://rtfm.etla.org/xterm/ctlseq.html (see Operating System Controls) + print "\033]0;#{title}\07" if title && @in_x Ncurses.mutex.lock unless opts[:sync] == false @@ -328,7 +371,7 @@ EOS ## w = Ncurses::WINDOW.new(height, width, (opts[:top] || 0), ## (opts[:left] || 0)) w = Ncurses.stdscr - b = Buffer.new w, mode, width, height, :title => realtitle, :force_to_top => (opts[:force_to_top] || false) + b = Buffer.new w, mode, width, height, :title => realtitle, :force_to_top => opts[:force_to_top], :system => opts[:system] mode.buffer = b @name_map[realtitle] = b @@ -347,7 +390,7 @@ EOS draw_screen until mode.done? - c = Ncurses.nonblocking_getch + c = Ncurses.safe_nonblocking_getch next unless c # getch timeout break if c == Ncurses::KEY_CANCEL begin @@ -423,7 +466,7 @@ EOS prefix, target = partial.split_on_commas_with_remainder target ||= prefix.pop || "" prefix = prefix.join(", ") + (prefix.empty? ? "" : ", ") - completions.select { |x| x =~ /^#{Regexp::escape target}/i }.map { |x| [prefix + x, x] } + completions.select { |x| x =~ /^#{Regexp::escape target}/i }.sort_by { |c| [ContactManager.contact_for(c) ? 0 : 1, c] }.map { |x| [prefix + x, x] } end end @@ -449,7 +492,7 @@ EOS end if answer - answer = + answer = if answer.empty? spawn_modal "file browser", FileBrowserMode.new elsif File.directory?(answer) @@ -465,16 +508,18 @@ EOS ## returns an array of labels def ask_for_labels domain, question, default_labels, forbidden_labels=[] default_labels = default_labels - forbidden_labels - LabelManager::RESERVED_LABELS - default = default_labels.join(" ") + default = default_labels.to_a.join(" ") default += " " unless default.empty? - applyable_labels = (LabelManager.applyable_labels - forbidden_labels).map { |l| LabelManager.string_for l }.sort_by { |s| s.downcase } + # here I would prefer to give more control and allow all_labels instead of + # user_defined_labels only + applyable_labels = (LabelManager.user_defined_labels - forbidden_labels).map { |l| LabelManager.string_for l }.sort_by { |s| s.downcase } answer = ask_many_with_completions domain, question, applyable_labels, default return unless answer - user_labels = answer.split(/\s+/).map { |l| l.intern } + user_labels = answer.to_set_of_symbols user_labels.each do |l| if forbidden_labels.include?(l) || LabelManager::RESERVED_LABELS.include?(l) BufferManager.flash "'#{l}' is a reserved label!" @@ -487,15 +532,16 @@ EOS def ask_for_contacts domain, question, default_contacts=[] default = default_contacts.map { |s| s.to_s }.join(" ") default += " " unless default.empty? - + recent = Index.load_contacts(AccountManager.user_emails, :num => 10).map { |c| [c.full_address, c.email] } contacts = ContactManager.contacts.map { |c| [ContactManager.alias_for(c), c.full_address, c.email] } - completions = (recent + contacts).flatten.uniq.sort + completions = (recent + contacts).flatten.uniq + completions += HookManager.run("extra-contact-addresses") || [] answer = BufferManager.ask_many_emails_with_completions domain, question, completions, default if answer - answer.split_on_commas.map { |x| ContactManager.contact_for(x.downcase) || PersonManager.person_for(x) } + answer.split_on_commas.map { |x| ContactManager.contact_for(x) || Person.from_address(x) } end end @@ -520,7 +566,7 @@ EOS end while true - c = Ncurses.nonblocking_getch + c = Ncurses.safe_nonblocking_getch next unless c # getch timeout break unless tf.handle_input c # process keystroke @@ -557,7 +603,6 @@ EOS def ask_getch question, accept=nil raise "impossible!" if @asking - @asking = true accept = accept.split(//).map { |x| x[0] } if accept @@ -570,10 +615,11 @@ EOS Ncurses.refresh end + @asking = true ret = nil done = false until done - key = Ncurses.nonblocking_getch or next + key = Ncurses.safe_nonblocking_getch or next if key == Ncurses::KEY_CANCEL done = true elsif accept.nil? || accept.empty? || accept.member?(key) @@ -701,6 +747,7 @@ EOS Ncurses.sync do Ncurses.endwin system command + Ncurses.stdscr.keypad 1 Ncurses.refresh Ncurses.curs_set 0 end