diff options
Diffstat (limited to 'webapp/client/websocket_client.jsx')
| -rw-r--r-- | webapp/client/websocket_client.jsx | 196 |
1 files changed, 0 insertions, 196 deletions
diff --git a/webapp/client/websocket_client.jsx b/webapp/client/websocket_client.jsx deleted file mode 100644 index eaa059197..000000000 --- a/webapp/client/websocket_client.jsx +++ /dev/null @@ -1,196 +0,0 @@ -// Copyright (c) 2016-present Mattermost, Inc. All Rights Reserved. -// See License.txt for license information. - -const MAX_WEBSOCKET_FAILS = 7; -const MIN_WEBSOCKET_RETRY_TIME = 3000; // 3 sec -const MAX_WEBSOCKET_RETRY_TIME = 300000; // 5 mins - -export default class WebSocketClient { - constructor() { - this.conn = null; - this.connectionUrl = null; - this.sequence = 1; - this.eventSequence = 0; - this.connectFailCount = 0; - this.eventCallback = null; - this.responseCallbacks = {}; - this.firstConnectCallback = null; - this.reconnectCallback = null; - this.missedEventCallback = null; - this.errorCallback = null; - this.closeCallback = null; - } - - initialize(connectionUrl = this.connectionUrl, token) { - if (this.conn) { - return; - } - - if (connectionUrl == null) { - console.log('websocket must have connection url'); //eslint-disable-line no-console - return; - } - - if (this.connectFailCount === 0) { - console.log('websocket connecting to ' + connectionUrl); //eslint-disable-line no-console - } - - this.conn = new WebSocket(connectionUrl); - this.connectionUrl = connectionUrl; - - this.conn.onopen = () => { - this.eventSequence = 0; - - if (token) { - this.sendMessage('authentication_challenge', {token}); - } - - if (this.connectFailCount > 0) { - console.log('websocket re-established connection'); //eslint-disable-line no-console - if (this.reconnectCallback) { - this.reconnectCallback(); - } - } else if (this.firstConnectCallback) { - this.firstConnectCallback(); - } - - this.connectFailCount = 0; - }; - - this.conn.onclose = () => { - this.conn = null; - this.sequence = 1; - - if (this.connectFailCount === 0) { - console.log('websocket closed'); //eslint-disable-line no-console - } - - this.connectFailCount++; - - if (this.closeCallback) { - this.closeCallback(this.connectFailCount); - } - - let retryTime = MIN_WEBSOCKET_RETRY_TIME; - - // If we've failed a bunch of connections then start backing off - if (this.connectFailCount > MAX_WEBSOCKET_FAILS) { - retryTime = MIN_WEBSOCKET_RETRY_TIME * this.connectFailCount * this.connectFailCount; - if (retryTime > MAX_WEBSOCKET_RETRY_TIME) { - retryTime = MAX_WEBSOCKET_RETRY_TIME; - } - } - - setTimeout( - () => { - this.initialize(connectionUrl, token); - }, - retryTime - ); - }; - - this.conn.onerror = (evt) => { - if (this.connectFailCount <= 1) { - console.log('websocket error'); //eslint-disable-line no-console - console.log(evt); //eslint-disable-line no-console - } - - if (this.errorCallback) { - this.errorCallback(evt); - } - }; - - this.conn.onmessage = (evt) => { - const msg = JSON.parse(evt.data); - if (msg.seq_reply) { - if (msg.error) { - console.log(msg); //eslint-disable-line no-console - } - - if (this.responseCallbacks[msg.seq_reply]) { - this.responseCallbacks[msg.seq_reply](msg); - Reflect.deleteProperty(this.responseCallbacks, msg.seq_reply); - } - } else if (this.eventCallback) { - if (msg.seq !== this.eventSequence && this.missedEventCallback) { - console.log('missed websocket event, act_seq=' + msg.seq + ' exp_seq=' + this.eventSequence); //eslint-disable-line no-console - this.missedEventCallback(); - } - this.eventSequence = msg.seq + 1; - this.eventCallback(msg); - } - }; - } - - setEventCallback(callback) { - this.eventCallback = callback; - } - - setFirstConnectCallback(callback) { - this.firstConnectCallback = callback; - } - - setReconnectCallback(callback) { - this.reconnectCallback = callback; - } - - setMissedEventCallback(callback) { - this.missedEventCallback = callback; - } - - setErrorCallback(callback) { - this.errorCallback = callback; - } - - setCloseCallback(callback) { - this.closeCallback = callback; - } - - close() { - this.connectFailCount = 0; - this.sequence = 1; - if (this.conn && this.conn.readyState === WebSocket.OPEN) { - this.conn.onclose = () => {}; //eslint-disable-line no-empty-function - this.conn.close(); - this.conn = null; - console.log('websocket closed'); //eslint-disable-line no-console - } - } - - sendMessage(action, data, responseCallback) { - const msg = { - action, - seq: this.sequence++, - data - }; - - if (responseCallback) { - this.responseCallbacks[msg.seq] = responseCallback; - } - - if (this.conn && this.conn.readyState === WebSocket.OPEN) { - this.conn.send(JSON.stringify(msg)); - } else if (!this.conn || this.conn.readyState === WebSocket.CLOSED) { - this.conn = null; - this.initialize(); - } - } - - userTyping(channelId, parentId, callback) { - const data = {}; - data.channel_id = channelId; - data.parent_id = parentId; - - this.sendMessage('user_typing', data, callback); - } - - getStatuses(callback) { - this.sendMessage('get_statuses', null, callback); - } - - getStatusesByIds(userIds, callback) { - const data = {}; - data.user_ids = userIds; - this.sendMessage('get_statuses_by_ids', data, callback); - } -} |