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
|
# -*- coding: utf-8 -*-
require 'set'
Plugin.create :smartthread do
counter = gen_counter 1
@timelines = {} # slug => [message]
# messagesの中で、タイムライン _slug_ に入れるべきものがあれば入れる
# ==== Args
# [slug] タイムラインスラッグ
# [messages] 入れるMessageの配列
def scan(slug, messages)
seeds = @timelines[slug]
i_timeline = timeline(slug)
if i_timeline and seeds
SerialThread.new do
messages.each{ |message|
message.each_ancestors { |cur|
if seeds.include? cur
i_timeline << message end } } end end end
command(:smartthread,
name: _('会話スレッドを表示'),
icon: Skin.get("list.png"),
condition: lambda{ |opt| not opt.messages.empty? and opt.messages.all? &:repliable? },
visible: true,
role: :timeline){ |opt|
serial = counter.call
slug = "conversation#{serial}".to_sym
tab slug, _("会話%{serial_id}") % {serial_id: serial} do
set_deletable true
set_icon Skin.get("list.png")
temporary_tab
timeline slug do
order do |message|
message[:created].to_i end end end
@timelines[slug] = opt.messages.map(&:ancestor).uniq
timeline(slug) << opt.messages.map(&:around).flatten
tl = timeline(slug)
@timelines[slug].each{ |message|
Thread.new{
message.each_ancestors(true){ |child|
tl << child } }.trap{|e| error e} }
timeline(slug).active!
}
onappear do |messages|
@timelines.keys.each{ |slug|
scan slug, messages } end
on_gui_destroy do |widget|
if widget.is_a? Plugin::GUI::Timeline
if @timelines.delete(widget.slug)
notice "smartthread removed :#{widget.slug}" end end end
end
|
