// @flow import { observable, action, map, runInAction } from 'mobx'; import { client } from 'utils/ApiClient'; import _ from 'lodash'; import invariant from 'invariant'; import stores from 'stores'; import Document from 'models/Document'; import ErrorsStore from 'stores/ErrorsStore'; class DocumentsStore { @observable recentlyViewedIds: Array = []; @observable data: Map = map([]); @observable isLoaded: boolean = false; errors: ErrorsStore; /* Actions */ @action fetchAll = async (request: string = 'list'): Promise<*> => { try { const res = await client.post(`/documents.${request}`); invariant(res && res.data, 'Document list not available'); const { data } = res; runInAction('DocumentsStore#fetchAll', () => { data.forEach(document => { this.data.set(document.id, new Document(document)); }); this.isLoaded = true; }); return data; } catch (e) { this.errors.add('Failed to load documents'); } }; @action fetchRecentlyEdited = async (): Promise<*> => { await this.fetchAll('recent'); }; @action fetchRecentlyViewed = async (): Promise<*> => { const data = await this.fetchAll('viewed'); runInAction('DocumentsStore#fetchRecentlyViewed', () => { this.recentlyViewedIds = _.pick(data, 'id'); }); }; @action fetch = async (id: string): Promise<*> => { try { const res = await client.post('/documents.info', { id }); invariant(res && res.data, 'Document not available'); const { data } = res; runInAction('DocumentsStore#fetch', () => { this.data.set(data.id, new Document(data)); this.isLoaded = true; }); } catch (e) { this.errors.add('Failed to load documents'); } }; @action add = (document: Document): void => { this.data.set(document.id, document); }; @action remove = (id: string): void => { this.data.delete(id); }; getById = (id: string): ?Document => { return this.data.get(id); }; constructor() { this.errors = stores.errors; } } export default DocumentsStore;