diff options
Diffstat (limited to 'web/react/stores/user_store.jsx')
| -rw-r--r-- | web/react/stores/user_store.jsx | 328 |
1 files changed, 328 insertions, 0 deletions
diff --git a/web/react/stores/user_store.jsx b/web/react/stores/user_store.jsx new file mode 100644 index 000000000..bbca92c84 --- /dev/null +++ b/web/react/stores/user_store.jsx @@ -0,0 +1,328 @@ +// Copyright (c) 2015 Spinpunch, Inc. All Rights Reserved. +// See License.txt for license information. + +var AppDispatcher = require('../dispatcher/app_dispatcher.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 CHANGE_EVENT_SESSIONS = 'change_sessions'; +var CHANGE_EVENT_AUDITS = 'change_audits'; +var CHANGE_EVENT_TEAMS = 'change_teams'; +var CHANGE_EVENT_STATUSES = 'change_statuses'; + +var UserStore = assign({}, EventEmitter.prototype, { + + emitChange: function(userId) { + this.emit(CHANGE_EVENT, userId); + }, + addChangeListener: function(callback) { + this.on(CHANGE_EVENT, callback); + }, + removeChangeListener: function(callback) { + this.removeListener(CHANGE_EVENT, callback); + }, + emitSessionsChange: function() { + this.emit(CHANGE_EVENT_SESSIONS); + }, + addSessionsChangeListener: function(callback) { + this.on(CHANGE_EVENT_SESSIONS, callback); + }, + removeSessionsChangeListener: function(callback) { + this.removeListener(CHANGE_EVENT_SESSIONS, callback); + }, + emitAuditsChange: function() { + this.emit(CHANGE_EVENT_AUDITS); + }, + addAuditsChangeListener: function(callback) { + this.on(CHANGE_EVENT_AUDITS, callback); + }, + removeAuditsChangeListener: function(callback) { + this.removeListener(CHANGE_EVENT_AUDITS, callback); + }, + emitTeamsChange: function() { + this.emit(CHANGE_EVENT_TEAMS); + }, + addTeamsChangeListener: function(callback) { + this.on(CHANGE_EVENT_TEAMS, callback); + }, + removeTeamsChangeListener: function(callback) { + this.removeListener(CHANGE_EVENT_TEAMS, callback); + }, + emitStatusesChange: function() { + this.emit(CHANGE_EVENT_STATUSES); + }, + addStatusesChangeListener: function(callback) { + this.on(CHANGE_EVENT_STATUSES, callback); + }, + removeStatusesChangeListener: function(callback) { + this.removeListener(CHANGE_EVENT_STATUSES, callback); + }, + setCurrentId: function(id) { + if (id == null) + sessionStorage.removeItem("current_user_id"); + else + sessionStorage.setItem("current_user_id", id); + }, + getCurrentId: function(skipFetch) { + var current_id = sessionStorage.current_user_id; + + // this is a speical case to force fetch the + // current user if it's missing + // it's synchronous to block rendering + if (current_id == null && !skipFetch) { + var me = client.getMeSynchronous(); + if (me != null) { + this.setCurrentUser(me); + current_id = me.id; + } + } + + return current_id; + }, + getCurrentUser: function(skipFetch) { + if (this.getCurrentId(skipFetch) == null) { + return null; + } + + return this._getProfiles()[this.getCurrentId()]; + }, + setCurrentUser: function(user) { + this.saveProfile(user); + this.setCurrentId(user.id); + }, + getLastDomain: function() { + return localStorage.last_domain; + }, + setLastDomain: function(domain) { + localStorage.setItem("last_domain", domain); + }, + getLastEmail: function() { + return localStorage.last_email; + }, + setLastEmail: function(email) { + localStorage.setItem("last_email", email); + }, + removeCurrentUser: function() { + this.setCurrentId(null); + }, + hasProfile: function(userId) { + return this._getProfiles()[userId] != null; + }, + getProfile: function(userId) { + return this._getProfiles()[userId]; + }, + getProfileByUsername: function(username) { + return this._getProfilesUsernameMap()[username]; + }, + getProfilesUsernameMap: function() { + return this._getProfilesUsernameMap(); + }, + getProfiles: function() { + + return this._getProfiles(); + }, + getActiveOnlyProfiles: function() { + active = {}; + current = this._getProfiles(); + + for (var key in current) { + if (current[key].delete_at == 0) { + active[key] = current[key]; + } + } + + return active; + }, + saveProfile: function(profile) { + var ps = this._getProfiles(); + ps[profile.id] = profile; + this._storeProfiles(ps); + }, + _storeProfiles: function(profiles) { + sessionStorage.setItem("profiles", JSON.stringify(profiles)); + var profileUsernameMap = {}; + for (var id in profiles) { + profileUsernameMap[profiles[id].username] = profiles[id]; + } + sessionStorage.setItem("profileUsernameMap", JSON.stringify(profileUsernameMap)); + }, + _getProfiles: function() { + var profiles = {}; + try { + profiles = JSON.parse(sessionStorage.getItem("profiles")); + + if (profiles == null) { + profiles = {}; + } + } + catch (err) { + } + + return profiles; + }, + _getProfilesUsernameMap: function() { + var profileUsernameMap = {}; + try { + profileUsernameMap = JSON.parse(sessionStorage.getItem("profileUsernameMap")); + + if (profileUsernameMap == null) { + profileUsernameMap = {}; + } + } + catch (err) { + } + + return profileUsernameMap; + }, + setSessions: function(sessions) { + sessionStorage.setItem("sessions", JSON.stringify(sessions)); + }, + getSessions: function() { + var sessions = []; + try { + sessions = JSON.parse(sessionStorage.getItem("sessions")); + + if (sessions == null) { + sessions = []; + } + } + catch (err) { + } + + return sessions; + }, + setAudits: function(audits) { + sessionStorage.setItem("audits", JSON.stringify(audits)); + }, + getAudits: function() { + var audits = []; + try { + audits = JSON.parse(sessionStorage.getItem("audits")); + + if (audits == null) { + audits = []; + } + } + catch (err) { + } + + return audits; + }, + setTeams: function(teams) { + sessionStorage.setItem("teams", JSON.stringify(teams)); + }, + getTeams: function() { + var teams = []; + try { + teams = JSON.parse(sessionStorage.getItem("teams")); + + if (teams == null) { + teams = []; + } + } + catch (err) { + } + + return teams; + }, + getCurrentMentionKeys: function() { + var user = this.getCurrentUser(); + if (user.notify_props && user.notify_props.mention_keys) { + var keys = user.notify_props.mention_keys.split(','); + + if (user.full_name.length > 0 && user.notify_props.first_name === "true") { + var first = user.full_name.split(' ')[0]; + if (first.length > 0) keys.push(first); + } + + return keys; + } else { + return []; + } + }, + getLastVersion: function() { + return sessionStorage.last_version; + }, + setLastVersion: function(version) { + sessionStorage.setItem("last_version", version); + }, + setStatuses: function(statuses) { + this._setStatuses(statuses); + this.emitStatusesChange(); + }, + _setStatuses: function(statuses) { + sessionStorage.setItem("statuses", JSON.stringify(statuses)); + }, + setStatus: function(user_id, status) { + var statuses = this.getStatuses(); + statuses[user_id] = status; + this._setStatuses(statuses); + this.emitStatusesChange(); + }, + getStatuses: function() { + var statuses = {}; + try { + statuses = JSON.parse(sessionStorage.getItem("statuses")); + + if (statuses == null) { + statuses = {}; + } + } + catch (err) { + } + + return statuses; + }, + getStatus: function(id) { + return this.getStatuses()[id]; + } +}); + +UserStore.dispatchToken = AppDispatcher.register(function(payload) { + var action = payload.action; + + switch(action.type) { + case ActionTypes.RECIEVED_PROFILES: + for(var id in action.profiles) { + // profiles can have incomplete data, so don't overwrite current user + if (id === UserStore.getCurrentId()) continue; + var profile = action.profiles[id]; + UserStore.saveProfile(profile); + UserStore.emitChange(profile.id); + } + break; + case ActionTypes.RECIEVED_ME: + UserStore.setCurrentUser(action.me); + UserStore.emitChange(action.me.id); + break; + case ActionTypes.RECIEVED_SESSIONS: + UserStore.setSessions(action.sessions); + UserStore.emitSessionsChange(); + break; + case ActionTypes.RECIEVED_AUDITS: + UserStore.setAudits(action.audits); + UserStore.emitAuditsChange(); + break; + case ActionTypes.RECIEVED_TEAMS: + UserStore.setTeams(action.teams); + UserStore.emitTeamsChange(); + break; + case ActionTypes.RECIEVED_STATUSES: + UserStore._setStatuses(action.statuses); + UserStore.emitStatusesChange(); + break; + + default: + } +}); + +UserStore.setMaxListeners(0); +global.window.UserStore = UserStore; +module.exports = UserStore; + + |