diff options
Diffstat (limited to 'webapp/client')
-rw-r--r-- | webapp/client/websocket_client.jsx | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/webapp/client/websocket_client.jsx b/webapp/client/websocket_client.jsx index 035e30be5..760c62b59 100644 --- a/webapp/client/websocket_client.jsx +++ b/webapp/client/websocket_client.jsx @@ -18,7 +18,7 @@ export default class WebSocketClient { this.closeCallback = null; } - initialize(connectionUrl) { + initialize(connectionUrl, token) { if (this.conn) { return; } @@ -30,6 +30,10 @@ export default class WebSocketClient { this.conn = new WebSocket(connectionUrl); this.conn.onopen = () => { + 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) { @@ -68,7 +72,7 @@ export default class WebSocketClient { setTimeout( () => { - this.initialize(connectionUrl); + this.initialize(connectionUrl, token); }, retryTime ); @@ -152,12 +156,12 @@ export default class WebSocketClient { } } - userTyping(channelId, parentId) { + userTyping(channelId, parentId, callback) { const data = {}; data.channel_id = channelId; data.parent_id = parentId; - this.sendMessage('user_typing', data); + this.sendMessage('user_typing', data, callback); } getStatuses(callback) { |