diff options
Diffstat (limited to 'web/react/utils/async_client.jsx')
| -rw-r--r-- | web/react/utils/async_client.jsx | 357 |
1 files changed, 357 insertions, 0 deletions
diff --git a/web/react/utils/async_client.jsx b/web/react/utils/async_client.jsx new file mode 100644 index 000000000..bb7ca458f --- /dev/null +++ b/web/react/utils/async_client.jsx @@ -0,0 +1,357 @@ +// Copyright (c) 2015 Spinpunch, Inc. All Rights Reserved. +// See License.txt for license information. + +var client = require('./client.jsx'); +var AppDispatcher = require('../dispatcher/app_dispatcher.jsx'); +var ChannelStore = require('../stores/channel_store.jsx'); +var PostStore = require('../stores/post_store.jsx'); +var UserStore = require('../stores/user_store.jsx'); +var utils = require('./utils.jsx'); + +var Constants = require('./constants.jsx'); +var ActionTypes = Constants.ActionTypes; + +// Used to track in progress async calls +var callTracker = {}; + +var dispatchError = function(err, method) { + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_ERROR, + err: err, + method: method + }); +}; + +var isCallInProgress = function(callName) { + if (!(callName in callTracker)) return false; + + if (callTracker[callName] === 0) return false; + + if (utils.getTimestamp() - callTracker[callName] > 5000) { + console.log("AsyncClient call " + callName + " expired after more than 5 seconds"); + return false; + } + + return true; +}; + +module.exports.dispatchError = dispatchError; + +module.exports.getChannels = function(force, updateLastViewed, checkVersion) { + if (isCallInProgress("getChannels")) return; + + if (ChannelStore.getAll().length == 0 || force) { + callTracker["getChannels"] = utils.getTimestamp(); + client.getChannels( + function(data, textStatus, xhr) { + callTracker["getChannels"] = 0; + + if (updateLastViewed && ChannelStore.getCurrentId() != null) { + module.exports.updateLastViewedAt(); + } + + if (checkVersion) { + var serverVersion = xhr.getResponseHeader("X-Version-ID"); + + if (UserStore.getLastVersion() == undefined) { + UserStore.setLastVersion(serverVersion); + } + + if (serverVersion != UserStore.getLastVersion()) { + UserStore.setLastVersion(serverVersion); + window.location.href = window.location.href; + console.log("Detected version update refreshing the page"); + } + } + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_CHANNELS, + channels: data.channels, + members: data.members + }); + + }, + function(err) { + callTracker["getChannels"] = 0; + dispatchError(err, "getChannels"); + } + ); + } +} + +module.exports.updateLastViewedAt = function() { + if (isCallInProgress("updateLastViewed")) return; + + if (ChannelStore.getCurrentId() == null) return; + + callTracker["updateLastViewed"] = utils.getTimestamp(); + client.updateLastViewedAt( + ChannelStore.getCurrentId(), + function(data) { + callTracker["updateLastViewed"] = 0; + }, + function(err) { + callTracker["updateLastViewed"] = 0; + dispatchError(err, "updateLastViewedAt"); + } + ); +} + +module.exports.getMoreChannels = function(force) { + if (isCallInProgress("getMoreChannels")) return; + + if (ChannelStore.getMoreAll().length == 0 || force) { + + callTracker["getMoreChannels"] = utils.getTimestamp(); + client.getMoreChannels( + function(data, textStatus, xhr) { + callTracker["getMoreChannels"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_MORE_CHANNELS, + channels: data.channels, + members: data.members + }); + }, + function(err) { + callTracker["getMoreChannels"] = 0; + dispatchError(err, "getMoreChannels"); + } + ); + } +} + +module.exports.getChannelExtraInfo = function(force) { + var channelId = ChannelStore.getCurrentId(); + + if (channelId != null) { + if (isCallInProgress("getChannelExtraInfo_"+channelId)) return; + var minMembers = ChannelStore.getCurrent() && ChannelStore.getCurrent().type === 'D' ? 1 : 0; + + if (ChannelStore.getCurrentExtraInfo().members.length <= minMembers || force) { + callTracker["getChannelExtraInfo_"+channelId] = utils.getTimestamp(); + client.getChannelExtraInfo( + channelId, + function(data, textStatus, xhr) { + callTracker["getChannelExtraInfo_"+channelId] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_CHANNEL_EXTRA_INFO, + extra_info: data + }); + }, + function(err) { + callTracker["getChannelExtraInfo_"+channelId] = 0; + dispatchError(err, "getChannelExtraInfo"); + } + ); + } + } +} + +module.exports.getProfiles = function() { + if (isCallInProgress("getProfiles")) return; + + callTracker["getProfiles"] = utils.getTimestamp(); + client.getProfiles( + function(data, textStatus, xhr) { + callTracker["getProfiles"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_PROFILES, + profiles: data + }); + }, + function(err) { + callTracker["getProfiles"] = 0; + dispatchError(err, "getProfiles"); + } + ); +} + +module.exports.getSessions = function() { + if (isCallInProgress("getSessions")) return; + + callTracker["getSessions"] = utils.getTimestamp(); + client.getSessions( + UserStore.getCurrentId(), + function(data, textStatus, xhr) { + callTracker["getSessions"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_SESSIONS, + sessions: data + }); + }, + function(err) { + callTracker["getSessions"] = 0; + dispatchError(err, "getSessions"); + } + ); +} + +module.exports.getAudits = function() { + if (isCallInProgress("getAudits")) return; + + callTracker["getAudits"] = utils.getTimestamp(); + client.getAudits( + UserStore.getCurrentId(), + function(data, textStatus, xhr) { + callTracker["getAudits"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_AUDITS, + audits: data + }); + }, + function(err) { + callTracker["getAudits"] = 0; + dispatchError(err, "getAudits"); + } + ); +} + +module.exports.findTeams = function(email) { + if (isCallInProgress("findTeams_"+email)) return; + + var user = UserStore.getCurrentUser(); + if (user) { + callTracker["findTeams_"+email] = utils.getTimestamp(); + client.findTeams( + user.email, + function(data, textStatus, xhr) { + callTracker["findTeams_"+email] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_TEAMS, + teams: data + }); + }, + function(err) { + callTracker["findTeams_"+email] = 0; + dispatchError(err, "findTeams"); + } + ); + } +} + +module.exports.search = function(terms) { + if (isCallInProgress("search_"+String(terms))) return; + + callTracker["search_"+String(terms)] = utils.getTimestamp(); + client.search( + terms, + function(data, textStatus, xhr) { + callTracker["search_"+String(terms)] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_SEARCH, + results: data + }); + }, + function(err) { + callTracker["search_"+String(terms)] = 0; + dispatchError(err, "search"); + } + ); +} + +module.exports.getPosts = function(force, id) { + if (PostStore.getCurrentPosts() == null || force) { + var channelId = id ? id : ChannelStore.getCurrentId(); + + if (isCallInProgress("getPosts_"+channelId)) return; + + var post_list = PostStore.getCurrentPosts(); + // if we already have more than POST_CHUNK_SIZE posts, + // let's get the amount we have but rounded up to next multiple of POST_CHUNK_SIZE, + // with a max at 180 + var numPosts = post_list && post_list.order.length > 0 ? Math.min(180, Constants.POST_CHUNK_SIZE * Math.ceil(post_list.order.length / Constants.POST_CHUNK_SIZE)) : Constants.POST_CHUNK_SIZE; + + if (channelId != null) { + callTracker["getPosts_"+channelId] = utils.getTimestamp(); + client.getPosts( + channelId, + 0, + numPosts, + function(data, textStatus, xhr) { + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_POSTS, + id: channelId, + post_list: data + }); + + module.exports.getProfiles(); + }, + function(err) { + dispatchError(err, "getPosts"); + }, + function() { + callTracker["getPosts_"+channelId] = 0; + } + ); + } + } +} + +module.exports.getMe = function() { + if (isCallInProgress("getMe")) return; + + callTracker["getMe"] = utils.getTimestamp(); + client.getMeSynchronous( + function(data, textStatus, xhr) { + callTracker["getMe"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_ME, + me: data + }); + }, + function(err) { + callTracker["getMe"] = 0; + dispatchError(err, "getMe"); + } + ); +} + +module.exports.getStatuses = function() { + if (isCallInProgress("getStatuses")) return; + + callTracker["getStatuses"] = utils.getTimestamp(); + client.getStatuses( + function(data, textStatus, xhr) { + callTracker["getStatuses"] = 0; + + if (xhr.status === 304 || !data) return; + + AppDispatcher.handleServerAction({ + type: ActionTypes.RECIEVED_STATUSES, + statuses: data + }); + }, + function(err) { + callTracker["getStatuses"] = 0; + dispatchError(err, "getStatuses"); + } + ); +} |