186 lines
4.8 KiB
JavaScript
186 lines
4.8 KiB
JavaScript
// @flow
|
|
import { observable, action, computed, autorun, runInAction } from 'mobx';
|
|
import invariant from 'invariant';
|
|
import { getCookie, setCookie, removeCookie } from 'tiny-cookie';
|
|
import { client } from 'utils/ApiClient';
|
|
import { getCookieDomain } from 'shared/utils/domains';
|
|
import RootStore from 'stores/RootStore';
|
|
import User from 'models/User';
|
|
import Team from 'models/Team';
|
|
|
|
const AUTH_STORE = 'AUTH_STORE';
|
|
|
|
export default class AuthStore {
|
|
@observable user: ?User;
|
|
@observable team: ?Team;
|
|
@observable token: ?string;
|
|
@observable isSaving: boolean = false;
|
|
@observable isSuspended: boolean = false;
|
|
@observable suspendedContactEmail: ?string;
|
|
rootStore: RootStore;
|
|
|
|
constructor(rootStore: RootStore) {
|
|
// Rehydrate
|
|
let data = {};
|
|
try {
|
|
data = JSON.parse(localStorage.getItem(AUTH_STORE) || '{}');
|
|
} catch (_) {
|
|
// no-op Safari private mode
|
|
}
|
|
|
|
this.rootStore = rootStore;
|
|
this.user = new User(data.user);
|
|
this.team = new Team(data.team);
|
|
this.token = getCookie('accessToken');
|
|
|
|
if (this.token) setImmediate(() => this.fetch());
|
|
|
|
autorun(() => {
|
|
try {
|
|
localStorage.setItem(AUTH_STORE, this.asJson);
|
|
} catch (_) {
|
|
// no-op Safari private mode
|
|
}
|
|
});
|
|
}
|
|
|
|
addPolicies = policies => {
|
|
if (policies) {
|
|
policies.forEach(policy => this.rootStore.policies.add(policy));
|
|
}
|
|
};
|
|
|
|
@computed
|
|
get authenticated(): boolean {
|
|
return !!this.token;
|
|
}
|
|
|
|
@computed
|
|
get asJson(): string {
|
|
return JSON.stringify({
|
|
user: this.user,
|
|
team: this.team,
|
|
});
|
|
}
|
|
|
|
@action
|
|
fetch = async () => {
|
|
try {
|
|
const res = await client.post('/auth.info');
|
|
invariant(res && res.data, 'Auth not available');
|
|
|
|
runInAction('AuthStore#fetch', () => {
|
|
this.addPolicies(res.policies);
|
|
const { user, team } = res.data;
|
|
this.user = new User(user);
|
|
this.team = new Team(team);
|
|
|
|
if (window.Sentry) {
|
|
Sentry.configureScope(function(scope) {
|
|
scope.setUser({ id: user.id });
|
|
scope.setExtra('team', team.name);
|
|
scope.setExtra('teamId', team.id);
|
|
});
|
|
}
|
|
|
|
// If we came from a redirect then send the user immediately there
|
|
const postLoginRedirectPath = getCookie('postLoginRedirectPath');
|
|
if (postLoginRedirectPath) {
|
|
removeCookie('postLoginRedirectPath');
|
|
window.location.href = postLoginRedirectPath;
|
|
}
|
|
});
|
|
} catch (err) {
|
|
if (err.error === 'user_suspended') {
|
|
this.isSuspended = true;
|
|
this.suspendedContactEmail = err.data.adminEmail;
|
|
}
|
|
}
|
|
};
|
|
|
|
@action
|
|
deleteUser = async () => {
|
|
await client.post(`/users.delete`, { confirmation: true });
|
|
|
|
runInAction('AuthStore#updateUser', () => {
|
|
this.user = null;
|
|
this.team = null;
|
|
this.token = null;
|
|
});
|
|
};
|
|
|
|
@action
|
|
updateUser = async (params: { name?: string, avatarUrl: ?string }) => {
|
|
this.isSaving = true;
|
|
|
|
try {
|
|
const res = await client.post(`/users.update`, params);
|
|
invariant(res && res.data, 'User response not available');
|
|
|
|
runInAction('AuthStore#updateUser', () => {
|
|
this.addPolicies(res.policies);
|
|
this.user = res.data;
|
|
});
|
|
} finally {
|
|
this.isSaving = false;
|
|
}
|
|
};
|
|
|
|
@action
|
|
updateTeam = async (params: {
|
|
name?: string,
|
|
avatarUrl?: ?string,
|
|
sharing?: boolean,
|
|
}) => {
|
|
this.isSaving = true;
|
|
|
|
try {
|
|
const res = await client.post(`/team.update`, params);
|
|
invariant(res && res.data, 'Team response not available');
|
|
|
|
runInAction('AuthStore#updateTeam', () => {
|
|
this.addPolicies(res.policies);
|
|
this.team = new Team(res.data);
|
|
});
|
|
} finally {
|
|
this.isSaving = false;
|
|
}
|
|
};
|
|
|
|
@action
|
|
logout = async (savePath: boolean = false) => {
|
|
// remove user and team from localStorage
|
|
localStorage.setItem(
|
|
AUTH_STORE,
|
|
JSON.stringify({
|
|
user: null,
|
|
team: null,
|
|
})
|
|
);
|
|
|
|
// if this logout was forced from an authenticated route then
|
|
// save the current path so we can go back there once signed in
|
|
if (savePath) {
|
|
setCookie('postLoginRedirectPath', window.location.pathname);
|
|
}
|
|
|
|
// remove authentication token itself
|
|
removeCookie('accessToken', { path: '/' });
|
|
|
|
// remove session record on apex cookie
|
|
const team = this.team;
|
|
if (team) {
|
|
const sessions = JSON.parse(getCookie('sessions') || '{}');
|
|
delete sessions[team.id];
|
|
|
|
setCookie('sessions', JSON.stringify(sessions), {
|
|
domain: getCookieDomain(window.location.hostname),
|
|
});
|
|
this.team = null;
|
|
}
|
|
|
|
// add a timestamp to force reload from server
|
|
window.location.href = `${BASE_URL}?done=${new Date().getTime()}`;
|
|
};
|
|
}
|