1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
|
# -*- 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
|
