mattermost/web/react/stores/user_store.jsx

// 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);
      }

      if (user.notify_props.all === "true") keys.push('@all');
      if (user.notify_props.channel === "true") keys.push('@channel');

      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;