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
|
# -*- coding: utf-8 -*-
require File.expand_path File.join(File.dirname(__FILE__), 'userlist')
require File.expand_path File.join(File.dirname(__FILE__), 'sender')
require File.expand_path File.join(File.dirname(__FILE__), 'dmlistview')
module Plugin::DirectMessage
Plugin.create(:direct_message) do
def userlist
@userlist ||= UserList.new end
# user_id => [Direct Message...]
@dm_store = Hash.new{|h, k|
Plugin.call(:direct_message_add_user, k)
h[k] = [] }
# user_id => created_at(Integer)
userlist.dm_last_date = @dm_last_date = Hash.new
@dm_lock = Mutex.new
@counter = gen_counter
ul = userlist
userlist.listview.ssc(:row_activated) { |this, path, column|
iter = this.model.get_iter(path)
if iter
Plugin.call(:show_profile, Service.primary, iter[Gtk::InnerUserList::COL_USER]) end }
tab(:directmessage, _("DM")) do
set_icon Skin.get("directmessage.png")
expand
nativewidget ul
end
profiletab(:directmessage, _("DM")) do
set_icon Skin.get("directmessage.png")
nativewidget Plugin.create(:direct_message).dm_list_widget(user)
end
onperiod do
if 0 == (@counter.call % UserConfig[:retrieve_interval_direct_messages])
rewind end end
filter_direct_messages do |service, dms|
if defined? dms.sort_by
result = []
@dm_lock.synchronize do
dms.sort_by{ |s| Time.parse(s[:created_at]) rescue Time.now }.each { |dm|
if add_dm(dm, dm[:sender]) and (dm[:sender] == dm[:recipient] || add_dm(dm, dm[:recipient]))
result << dm end } end
[service, result]
else
[service, dms] end end
on_direct_message_add_user do |user_id|
user = User.findbyid(user_id)
if user.is_a? User
userlist.add_user(Users.new([user])) end end
def rewind
service = Service.primary_service
if service
Deferred.when(service.direct_messages, service.sent_direct_messages).next{ |dm, sent|
result = dm + sent
Plugin.call(:direct_messages, service, result) if result and not result.empty?
}.trap{ |e|
error e
raise e
}.terminate end end
def add_dm(dm, user)
unless @dm_store[user[:id]].any?{ |stored| stored[:id] == dm[:id] }
created_at = Time.parse(dm[:created_at]).to_i
if not(@dm_last_date.has_key?(user.id)) or @dm_last_date[user.id] < created_at
@dm_last_date[user.id] = created_at
Delayer.new{ userlist.reorder(user) } end
@dm_store[user[:id]] << dm end
end
def dm_list_widget(user)
container = ::Gtk::VBox.new
tl = DirectMessage.new(self)
scrollbar = ::Gtk::VScrollbar.new(tl.vadjustment)
model = tl.model
@dm_lock.synchronize do
if @dm_store.has_key?(user[:id])
@dm_store[user[:id]].each { |dm|
iter = model.append
iter[DirectMessage::C_CREATED] = Time.parse(dm[:created_at]).to_i
iter[DirectMessage::C_ICON] = Gdk::WebImageLoader.pixbuf(dm[:sender][:profile_image_url], 16, 16) { |pixbuf|
iter[DirectMessage::C_ICON] = pixbuf }
iter[DirectMessage::C_TEXT] = dm[:text]
iter[DirectMessage::C_RAW] = dm } end end
event = on_direct_messages do |service, dms|
if not tl.destroyed?
dms.each{ |dm|
if user[:id].to_i == dm[:sender][:id].to_i or user[:id].to_i == dm[:recipient][:id].to_i
iter = model.append
iter[DirectMessage::C_CREATED] = Time.parse(dm[:created_at]).to_i
iter[DirectMessage::C_ICON] = Gdk::WebImageLoader.pixbuf(dm[:sender][:profile_image_url], 16, 16) { |pixbuf|
iter[DirectMessage::C_ICON] = pixbuf }
iter[DirectMessage::C_TEXT] = dm[:text]
iter[DirectMessage::C_RAW] = dm end } end end
tl.ssc(:scroll_event){ |this, e|
case e.direction
when Gdk::EventScroll::UP
this.vadjustment.value -= this.vadjustment.step_increment
when Gdk::EventScroll::DOWN
this.vadjustment.value += this.vadjustment.step_increment end
false }
tl.ssc(:destroy){
detach(:direct_message, event)
}
mumbles = ::Gtk::VBox.new(false, 0)
postbox = ::Gtk::PostBox.new(Sender.new(user), :postboxstorage => mumbles, :delegate_other => true)
mumbles.pack_start(postbox)
container.closeup(mumbles).add(::Gtk::HBox.new.add(tl).closeup(scrollbar))
container
end
rewind
end
end
|
