# -*- coding: utf-8 -*- require File.expand_path File.join(File.dirname(__FILE__), 'edit_window') require File.expand_path File.join(File.dirname(__FILE__), 'extract_tab_list') Plugin.create :extract do DEFINED_TIME = Time.new.freeze # 抽出タブオブジェクト。各キーは抽出タブIDで、値は以下のようなオブジェクト # name :: タブの名前 # sexp :: 条件式（S式） # source :: どこのツイートを見るか（イベント名、配列で複数） # slug :: タイムラインとタブのスラッグ # id :: 抽出タブのID def extract_tabs @extract_tabs ||= {} end settings _("抽出タブ") do tablist = Plugin::Extract::ExtractTabList.new(Plugin[:extract]) pack_start(Gtk::HBox.new. add(tablist). closeup(Gtk::VBox.new(false, 4). closeup(Gtk::Button.new(Gtk::Stock::ADD).tap{ |button| button.ssc(:clicked) { Plugin.call :extract_tab_open_create_dialog true } }). closeup(Gtk::Button.new(Gtk::Stock::EDIT).tap{ |button| button.ssc(:clicked) { id = tablist.selected_id if id Plugin.call(:extract_open_edit_dialog, id) end true } }). closeup(Gtk::Button.new(Gtk::Stock::DELETE).tap{ |button| button.ssc(:clicked) { id = tablist.selected_id if id Plugin.call(:extract_tab_delete_with_confirm, id) end true } }))) Plugin.create :extract do add_tab_observer = on_extract_tab_create(&tablist.method(:add_record)) delete_tab_observer = on_extract_tab_delete(&tablist.method(:remove_record)) tablist.ssc(:destroy) do detach add_tab_observer detach delete_tab_observer end end end command(:extract_edit, name: _('抽出条件を編集'), condition: lambda{ |opt| opt.widget.slug.to_s =~ /\Aextract_(?:.+)\Z/ }, visible: true, role: :tab) do |opt| extract_id = opt.widget.slug.to_s.match(/\Aextract_(.+)\Z/)[1].to_i Plugin.call(:extract_open_edit_dialog, extract_id) if extract_tabs[extract_id] end on_extract_tab_create do |record| record[:id] = Time.now.to_i unless record[:id] slug = "extract_#{record[:id]}".to_sym record = record.melt record[:slug] = slug extract_tabs[record[:id]] = record.freeze tab(slug, record[:name]) do set_icon record[:icon] if record[:icon].is_a? String timeline slug end modify_extract_tabs end on_extract_tab_update do |record| extract_tabs[record[:id]] = record.freeze tab(record[:slug]).set_icon record[:icon] if record[:icon].is_a? String modify_extract_tabs end on_extract_tab_delete do |id| if extract_tabs.has_key? id deleted_tab = extract_tabs[id] tab(deleted_tab[:slug]).destroy extract_tabs.delete(id) modify_extract_tabs end end on_extract_tab_delete_with_confirm do |id| extract = extract_tabs[id] if extract message = _("本当に抽出タブ「%{name}」を削除しますか？") % {name: extract[:name]} dialog = Gtk::MessageDialog.new(nil, Gtk::Dialog::DESTROY_WITH_PARENT, Gtk::MessageDialog::QUESTION, Gtk::MessageDialog::BUTTONS_YES_NO, message) dialog.run{ |response| if Gtk::Dialog::RESPONSE_YES == response Plugin.call :extract_tab_delete, id end dialog.close } end end on_extract_tab_open_create_dialog do dialog = Gtk::Dialog.new(_("抽出タブを作成 - %{mikutter}") % {mikutter: Environment::NAME}, nil, nil, [Gtk::Stock::OK, Gtk::Dialog::RESPONSE_ACCEPT], [Gtk::Stock::CANCEL, Gtk::Dialog::RESPONSE_REJECT]) prompt = Gtk::Entry.new dialog.vbox. add(Gtk::HBox.new(false, 8). closeup(Gtk::Label.new(_("名前"))). add(prompt).show_all) dialog.run{ |response| if Gtk::Dialog::RESPONSE_ACCEPT == response Plugin.call :extract_tab_create, name: prompt.text end dialog.destroy prompt = dialog = nil } end on_extract_open_edit_dialog do |extract_id| ::Plugin::Extract::EditWindow.new(extract_tabs[extract_id], self) end on_appear do |messages| Plugin.call :extract_receive_message, :appear, messages end on_update do |service, messages| Plugin.call :extract_receive_message, :update, messages if service service_datasource = "home_timeline-#{service.user_obj.id}".to_sym if active_datasources.include? service_datasource Plugin.call :extract_receive_message, service_datasource, messages end end end on_mention do |service, messages| Plugin.call :extract_receive_message, :mention, messages service_datasource = "mentions-#{service.user_obj.id}".to_sym if active_datasources.include? service_datasource Plugin.call :extract_receive_message, service_datasource, messages end end on_extract_receive_message do |source, messages| append_message source, messages end filter_extract_tabs_get do |tabs| [tabs + extract_tabs.values] end filter_extract_datasources do |datasources| datasources = { appear: _("受信したすべての投稿"), update: _("ホームタイムライン(全てのアカウント)"), mention: _("自分宛ての投稿(全てのアカウント)") }.merge datasources Service.map{ |service| user = service.user_obj datasources.merge!({ "home_timeline-#{user.id}".to_sym => "@#{user.idname}/" + _("Home Timeline"), "mentions-#{user.id}".to_sym => "@#{user.idname}/" + _("Mentions") }) } [datasources] end # 抽出タブの現在の内容を保存する def modify_extract_tabs UserConfig[:extract_tabs] = extract_tabs.values self end # 使用されているデータソースのSetを返す def active_datasources @active_datasources ||= extract_tabs.values.inject(Set.new){|set,tab| set.merge(tab[:sources]) }.freeze end def compile(tab_id, code) atomic do @compiled ||= {} if code.empty? @compiled[tab_id] ||= ret_nth else @compiled[tab_id] ||= ->(assign,evaluated){ assign += " user = message.idname\n" if evaluated.include? "user" assign += " body = message.to_s\n" if evaluated.include? "body" assign += " source = message[:source]\n" if evaluated.include? "source" notice "tab code: lambda{ |message|\n" + assign + " " + evaluated + "\n}" eval("lambda{ |message|\n" + assign + " " + evaluated + "\n}") }.("",MIKU::Primitive.new(:to_ruby_ne).call(MIKU::SymbolTable.new, code)) end end end def destroy_compile_cache atomic do @compiled = {} end end def append_message(source, messages) type_strict source => Symbol, messages => Enumerable tabs = extract_tabs.values.select{ |r| r[:sources] && r[:sources].include?(source) } return if tabs.empty? converted_messages = Messages.new(messages.map{ |message| message.retweet_source ? message.retweet_source : message }) tabs.deach{ |record| begin filtered_messages = converted_messages.select(&compile(record[:id], record[:sexp])).freeze unless filtered_messages.empty? timeline(record[:slug]) << filtered_messages notificate_messages = lazy{ filtered_messages.select{|message| message[:created] > DEFINED_TIME} } if record[:popup] notificate_messages.each do |message| notice message.user.idname + " " + message.to_show Plugin.call(:popup_notify, message.user, message.to_show) end end if record[:sound].is_a?(String) and not notificate_messages.empty? and FileTest.exist?(record[:sound]) Plugin.call(:play_sound, record[:sound]) end end rescue Exception => e error "filter '#{record[:name]}' crash: #{e.to_s}" end } end (UserConfig[:extract_tabs] or []).each{ |record| extract_tabs[record[:id]] = record.freeze Plugin.call(:extract_tab_create, record) } extract_tabs_watcher = UserConfig.connect :extract_tabs do |key, val, before_val, id| destroy_compile_cache @active_datasources = nil end on_unload do UserConfig.disconnect(extract_tabs_watcher) end end