GitList
Raw Blame History 
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
 
class WsRosterController < WebsocketRails::BaseController
    require 'xmpp4r/roster'
    require 'xmpp4r/vcard'
 
    def initialize
        super
 
        @storages_arr = [:clients, :rosters]
        @storages_hash = [:link_roster_client, :presences]
    end
 
    def initialize_storage
        @storages_arr.each do |storage|
            connection_store[storage] = []
        end
 
        @storages_hash.each do |storage|
            connection_store[storage] = {}
        end
    end
 
    ##
    # Pripoj sa na jabber ucty.
    def connect
        initialize_storage()
 
        clients = Token.fing_user_accounts_having_to_token(session[:token])
 
        clients.each do |credentials|
            begin
                client = Signin.try_login(credentials["jid"], credentials["pass"])
                connection_store[:clients] << client
            rescue Signin::LoginError
                send_message 'app.client.cannot_connect', true
            end
        end
    end
 
    ##
    # Inicializuj roster so zoznamom ludi v nom.
    # Vrat zoznam ludi (ich JID).
    def init_roster
        all_jids = []
 
        connection_store[:clients].each do |client|
            roster = Jabber::Roster::Helper.new(client)
 
            connection_store[:rosters] << roster
            connection_store[:link_roster_client][roster] = client
 
            roster.get_roster()
            roster.wait_for_roster()
 
            roster.items.each do |jid, contact|
                all_jids << jid.to_s
            end
        end
 
        trigger_success contacts: all_jids
    end
 
    ##
    # Stiahni vcard ludi v rosteri
    def start_fetching_vcards
        connection_store[:rosters].each do |roster|
            client = connection_store[:link_roster_client][roster]
 
            roster.items.each do |jid, contact|
                Thread.new do
                    vcard = get_vcard(client, jid.to_s)
                    send_message 'app.roster.vcard', jid: jid.to_s, vcard: vcard
                end
            end
        end
    end
 
    ##
    # Zacni pocuvat zmeny stavov v rosteri
    def start_polling_contacts_state
        connection_store[:rosters].each do |roster|
            roster.add_presence_callback do |roster_item, old_presence, new_presence|
                if new_presence.type == :unavailable
                    result = {status: :offline, message: ''}
                else
                    status = uniform_presence(new_presence.show)
                    result = { status: status, message: new_presence.status.to_s }
                end
 
                send_message 'app.roster.statusChanged',
                             jid: roster_item.jid.strip.to_s, status: result
            end
        end
    end
 
    ##
    # Nastav ma ako online
    #
    # Musi sa zavolat az po start_polling_contacts_state, inak sa nemusia
    # zachytit stavy ostatnych v rosteri.
    def set_presence
        connection_store[:clients].each do |client|
            presence = Jabber::Presence.new.set_type(:available)
            client.send(presence)