summaryrefslogtreecommitdiffstats
path: root/web/react/stores/socket_store.jsx
blob: c3c331828e3084e38a12f9d6f58dde16a7b39bcf (plain)
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
// Copyright (c) 2015 Spinpunch, Inc. All Rights Reserved.
// See License.txt for license information.

var AppDispatcher = require('../dispatcher/app_dispatcher.jsx');
var UserStore = require('./user_store.jsx')
var EventEmitter = require('events').EventEmitter;
var assign = require('object-assign');
var client = require('../utils/client.jsx');

var Constants = require('../utils/constants.jsx');
var ActionTypes = Constants.ActionTypes;

var CHANGE_EVENT = 'change';

var conn;

var SocketStore = assign({}, EventEmitter.prototype, {
    initialize: function() {
        if (!UserStore.getCurrentId()) {
            return;
        }

        var self = this;
        self.setMaxListeners(0);

        if (window.WebSocket && !conn) {
            var protocol = 'ws://';
            var port = '';
            if (window.location.protocol === 'https:') {
                protocol = 'wss://';
                port = ':8443';
            }
            var connUrl = protocol + location.host + port + '/api/v1/websocket';
            console.log('connecting to ' + connUrl);
            conn = new WebSocket(connUrl);

            conn.onclose = function closeConn(evt) {
                console.log('websocket closed');
                console.log(evt);
                conn = null;
                setTimeout(
                    function reconnect() {
                        self.initialize();
                    },
                    3000
                );
            };

            conn.onerror = function connError(evt) {
                console.log('websocket error');
                console.log(evt);
            };

            conn.onmessage = function connMessage(evt) {
                AppDispatcher.handleServerAction({
                    type: ActionTypes.RECIEVED_MSG,
                    msg: JSON.parse(evt.data)
                });
            };
        }
    },
    emitChange: function(msg) {
        this.emit(CHANGE_EVENT, msg);
    },
    addChangeListener: function(callback) {
        this.on(CHANGE_EVENT, callback);
    },
    removeChangeListener: function(callback) {
        this.removeListener(CHANGE_EVENT, callback);
    },
    sendMessage: function(msg) {
        if (conn && conn.readyState === WebSocket.OPEN) {
            conn.send(JSON.stringify(msg));
        } else if (!conn || conn.readyState === WebSocket.Closed) {
            conn = null;
            this.initialize();
        }
    }
});

SocketStore.dispatchToken = AppDispatcher.register(function(payload) {
    var action = payload.action;

    switch (action.type) {
        case ActionTypes.RECIEVED_MSG:
        SocketStore.emitChange(action.msg);
        break;

        default:
    }
});

SocketStore.initialize();
module.exports = SocketStore;