...
|
...
|
@@ -9,8 +9,7 @@ class WsRosterController < WebsocketRails::BaseController
|
9
|
9
|
|
10
|
10
|
def initialize_storage
|
11
|
11
|
@storages.each do |storage|
|
12
|
|
- connection_store[storage] = {} if connection_store[storage].nil?
|
13
|
|
- connection_store[storage][client_id] = []
|
|
12
|
+ connection_store[storage] = []
|
14
|
13
|
end
|
15
|
14
|
end
|
16
|
15
|
|
...
|
...
|
@@ -24,8 +23,8 @@ class WsRosterController < WebsocketRails::BaseController
|
24
|
24
|
client = Signin.try_login(credentials["jid"], credentials["pass"])
|
25
|
25
|
client.send(Jabber::Presence.new.set_type(:available))
|
26
|
26
|
|
27
|
|
- connection_store[:clients][client_id] << client
|
28
|
|
- connection_store[:rosters][client_id] << Jabber::Roster::Helper.new(client)
|
|
27
|
+ connection_store[:clients] << client
|
|
28
|
+ connection_store[:rosters] << Jabber::Roster::Helper.new(client)
|
29
|
29
|
rescue Signin::LoginError
|
30
|
30
|
trigger_failure msg: credentials["jid"]
|
31
|
31
|
end
|
...
|
...
|
@@ -37,7 +36,7 @@ class WsRosterController < WebsocketRails::BaseController
|
37
|
37
|
def get_contacts
|
38
|
38
|
all_contacts = []
|
39
|
39
|
|
40
|
|
- connection_store[:rosters][client_id].each do |roster|
|
|
40
|
+ connection_store[:rosters].each do |roster|
|
41
|
41
|
roster.wait_for_roster
|
42
|
42
|
roster.get_roster()
|
43
|
43
|
|
...
|
...
|
@@ -52,8 +51,8 @@ class WsRosterController < WebsocketRails::BaseController
|
52
|
52
|
end
|
53
|
53
|
|
54
|
54
|
def disconnect
|
55
|
|
- if connection_store[:clients][client_id]
|
56
|
|
- connection_store[:clients][client_id].each do |client|
|
|
55
|
+ if connection_store[:clients]
|
|
56
|
+ connection_store[:clients].each do |client|
|
57
|
57
|
client.send(Jabber::Presence.new.set_type(:unavailable))
|
58
|
58
|
end
|
59
|
59
|
end
|