Class: Atig::Db::Lists
Constant Summary
Constants included
from Listenable
Atig::Db::Listenable::SingleThread
Instance Method Summary
collapse
#debug, #init, #transaction
daemon, safe
Methods included from Listenable
#listen
Constructor Details
#initialize(name) ⇒ Lists
Returns a new instance of Lists.
11
12
13
14
15
16
|
# File 'lib/atig/db/lists.rb', line 11
def initialize(name)
@name = name
@lists = {}
@on_invalidated = lambda{|*_| }
@members = nil
end
|
Instance Method Details
#[](name) ⇒ Object
48
49
50
|
# File 'lib/atig/db/lists.rb', line 48
def [](name)
@lists[name]
end
|
#each(&f) ⇒ Object
69
70
71
72
73
|
# File 'lib/atig/db/lists.rb', line 69
def each(&f)
@lists.each do|name,users|
f.call name,users.users
end
end
|
#find_by_list_name(name) ⇒ Object
65
66
67
|
# File 'lib/atig/db/lists.rb', line 65
def find_by_list_name(name)
@lists[name].users
end
|
#find_by_screen_name(name) ⇒ Object
60
61
62
63
|
# File 'lib/atig/db/lists.rb', line 60
def find_by_screen_name(name)
return [] unless @members
@members[name]
end
|
#invalidate(name) ⇒ Object
52
53
54
|
# File 'lib/atig/db/lists.rb', line 52
def invalidate(name)
@on_invalidated.call name
end
|
#on_invalidated(&f) ⇒ Object
56
57
58
|
# File 'lib/atig/db/lists.rb', line 56
def on_invalidated(&f)
@on_invalidated = f
end
|
#update(lists) ⇒ Object
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
|
# File 'lib/atig/db/lists.rb', line 18
def update(lists)
@members = Hash.new{|hash,key|
hash[key] = []
}
(lists.keys - @lists.keys).each do|name|
list = Followings.new(@name % name)
list.listen{|kind,users|
notify kind,name,users
}
@lists[name] = list
notify :new, name
end
(@lists.keys - lists.keys).each do|x|
@lists.delete x
notify :del,x
end
lists.each do|name,users|
@lists[name].update users
end
lists.each do|list, users|
users.each do|user|
@members[user.screen_name] << list
end
end
end
|