119 lines
3.0 KiB
JavaScript
119 lines
3.0 KiB
JavaScript
// @flow
|
|
import { filter, orderBy } from 'lodash';
|
|
import { computed, action, runInAction } from 'mobx';
|
|
import invariant from 'invariant';
|
|
import { client } from 'utils/ApiClient';
|
|
import BaseStore from './BaseStore';
|
|
import RootStore from './RootStore';
|
|
import User from 'models/User';
|
|
|
|
export default class UsersStore extends BaseStore<User> {
|
|
constructor(rootStore: RootStore) {
|
|
super(rootStore, User);
|
|
}
|
|
|
|
@computed
|
|
get active(): User[] {
|
|
return filter(
|
|
this.orderedData,
|
|
user => !user.isSuspended && user.lastActiveAt
|
|
);
|
|
}
|
|
|
|
@computed
|
|
get suspended(): User[] {
|
|
return filter(this.orderedData, user => user.isSuspended);
|
|
}
|
|
|
|
@computed
|
|
get invited(): User[] {
|
|
return filter(this.orderedData, user => !user.lastActiveAt);
|
|
}
|
|
|
|
@computed
|
|
get admins(): User[] {
|
|
return filter(this.orderedData, user => user.isAdmin);
|
|
}
|
|
|
|
@computed
|
|
get all(): User[] {
|
|
return filter(this.orderedData, user => user.lastActiveAt);
|
|
}
|
|
|
|
@computed
|
|
get orderedData(): User[] {
|
|
return orderBy(Array.from(this.data.values()), 'name', 'asc');
|
|
}
|
|
|
|
@action
|
|
promote = (user: User) => {
|
|
return this.actionOnUser('promote', user);
|
|
};
|
|
|
|
@action
|
|
demote = (user: User) => {
|
|
return this.actionOnUser('demote', user);
|
|
};
|
|
|
|
@action
|
|
suspend = (user: User) => {
|
|
return this.actionOnUser('suspend', user);
|
|
};
|
|
|
|
@action
|
|
activate = (user: User) => {
|
|
return this.actionOnUser('activate', user);
|
|
};
|
|
|
|
@action
|
|
invite = async (invites: { email: string, name: string }[]) => {
|
|
const res = await client.post(`/users.invite`, { invites });
|
|
invariant(res && res.data, 'Data should be available');
|
|
runInAction(`invite`, () => {
|
|
res.data.users.forEach(this.add);
|
|
});
|
|
return res.data;
|
|
};
|
|
|
|
notInCollection = (collectionId: string, query: string = '') => {
|
|
const memberships = filter(
|
|
this.rootStore.memberships.orderedData,
|
|
member => member.collectionId === collectionId
|
|
);
|
|
const userIds = memberships.map(member => member.userId);
|
|
const users = filter(this.orderedData, user => !userIds.includes(user.id));
|
|
if (!query) return users;
|
|
|
|
return filter(users, user =>
|
|
user.name.toLowerCase().match(query.toLowerCase())
|
|
);
|
|
};
|
|
|
|
inCollection = (collectionId: string, query: string) => {
|
|
const memberships = filter(
|
|
this.rootStore.memberships.orderedData,
|
|
member => member.collectionId === collectionId
|
|
);
|
|
const userIds = memberships.map(member => member.userId);
|
|
const users = filter(this.orderedData, user => userIds.includes(user.id));
|
|
|
|
if (!query) return users;
|
|
|
|
return filter(users, user =>
|
|
user.name.toLowerCase().match(query.toLowerCase())
|
|
);
|
|
};
|
|
|
|
actionOnUser = async (action: string, user: User) => {
|
|
const res = await client.post(`/users.${action}`, {
|
|
id: user.id,
|
|
});
|
|
invariant(res && res.data, 'Data should be available');
|
|
|
|
runInAction(`UsersStore#${action}`, () => {
|
|
this.addPolicies(res.policies);
|
|
this.add(res.data);
|
|
});
|
|
};
|
|
}
|