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
|
# -*- coding: utf-8 -*-
miquire :lib, 'weakstorage'
miquire :lib, 'uithreadonly'
require 'gtk2'
=begin rdoc
TimeLineオブジェクト用のメソッド集
以下のメソッドをinclude元に要求する
- block_add
- each
=end
module Gtk::TimeLineUtils
include UiThreadOnly
include Enumerable
def self.included(obj)
class << obj
# 存在するタイムラインを全て返す
def timelines
@timelines = (@timelines || []).select{ |tl| not tl.destroyed? }.freeze end
def get_active_mumbles
Set.new end
alias :old_new_Ak6FV :new
def new(*args)
result = old_new_Ak6FV(*args)
@timelines = MIKU::Cons.new(result, @timelines || nil).freeze
result end
def wayofopenlink
@wayofopenlink ||= MIKU::Cons.list([URI.regexp(['http','https']), lambda{ |url, cancel|
Gtk.openurl(url) }].freeze).freeze end
def addopenway(condition, &open)
if(type_check(condition => :===, open => :call))
@wayofopenlink = MIKU::Cons.new([condition, open].freeze, wayofopenlink).freeze
true end end
def openurl(url)
gen_openurl_proc(url).call
false end
def gen_openurl_proc(url, way_of_open_link = wayofopenlink)
way_of_open_link.freeze
expanded = (Plugin.filtering(:expand_url, [url]).first.first rescue url)
lambda{
way_of_open_link.each_with_index{ |way, index|
condition, open = *way
if(condition === expanded)
open.call(url, gen_openurl_proc(url, way_of_open_link[(index+1)..(way_of_open_link.size)]))
break end } } end
def addwidgetrule(reg, &proc)
end end end
# このタイムラインに保存できるメッセージの最大数。超えれば古いものから捨てられる。
attr_accessor :timeline_max
# _message_ が新たに _user_ のお気に入りに追加された時に呼ばれる
def favorite(user, message)
mumble = get_mumble_by(message)
mumble.on_favorited(user) if mumble
self
end
# _message_ が _user_ のお気に入りから削除された時に呼ばれる
def unfavorite(user, message)
mumble = get_mumble_by(message)
mumble.on_unfavorited(user) if mumble
self
end
# _message_ が更新された時に呼ばれる
def modified(message)
end
# _message_ を追加する。配列で複数のMessageオブジェクトを渡すこともできる。
def add(message)
if message.is_a?(Enumerable)
self.block_add_all(Plugin.filtering(:show_filter, message).first)
else
m = Plugin.filtering(:show_filter, [message]).first.first
self.block_add(m) if m.is_a?(Message) end
self end
# つぶやきが削除されたときに呼ばれる
def remove_if_exists_all(msgs)
end
# リツイートを受信したときにそれを引数に呼ばれる
def add_retweets(messages)
end
protected
# 配列で複数のMessageオブジェクトを受け取って適切に処理する。
# 削除されたつぶやきに関しては _remove_if_exists_all_ を呼び、リツイートだった場合は _add_retweets_ を呼ぶ。
def block_add_all(messages)
removes, appends = *messages.partition{ |m| m[:rule] == :destroy }
remove_if_exists_all(removes)
retweets, appends = *messages.partition{ |m| m[:retweet] }
add_retweets(retweets)
appends.each(&method(:block_add))
end
end
|
