72 lines
1.8 KiB
JavaScript
72 lines
1.8 KiB
JavaScript
// @flow
|
|
import { action, runInAction } from 'mobx';
|
|
import { filter } from 'lodash';
|
|
import invariant from 'invariant';
|
|
import { client } from 'utils/ApiClient';
|
|
import BaseStore from 'stores/BaseStore';
|
|
import RootStore from 'stores/RootStore';
|
|
import Revision from 'models/Revision';
|
|
import type { FetchOptions, PaginationParams } from 'types';
|
|
|
|
export default class RevisionsStore extends BaseStore<Revision> {
|
|
actions = ['list'];
|
|
|
|
constructor(rootStore: RootStore) {
|
|
super(rootStore, Revision);
|
|
}
|
|
|
|
getDocumentRevisions(documentId: string): Revision[] {
|
|
return filter(this.orderedData, { documentId });
|
|
}
|
|
|
|
@action
|
|
fetch = async (
|
|
documentId: string,
|
|
options?: FetchOptions
|
|
): Promise<?Revision> => {
|
|
this.isFetching = true;
|
|
const id = options && options.revisionId;
|
|
if (!id) throw new Error('revisionId is required');
|
|
|
|
try {
|
|
const rev = this.data.get(id);
|
|
if (rev) return rev;
|
|
|
|
const res = await client.post('/documents.revision', {
|
|
id: documentId,
|
|
revisionId: id,
|
|
});
|
|
invariant(res && res.data, 'Revision not available');
|
|
const { data } = res;
|
|
|
|
runInAction('RevisionsStore#fetch', () => {
|
|
this.data.set(data.id, data);
|
|
this.isLoaded = true;
|
|
});
|
|
|
|
return data;
|
|
} finally {
|
|
this.isFetching = false;
|
|
}
|
|
};
|
|
|
|
@action
|
|
fetchPage = async (options: ?PaginationParams): Promise<*> => {
|
|
this.isFetching = true;
|
|
|
|
try {
|
|
const res = await client.post('/documents.revisions', options);
|
|
invariant(res && res.data, 'Document revisions not available');
|
|
runInAction('RevisionsStore#fetchPage', () => {
|
|
res.data.forEach(revision => {
|
|
this.data.set(revision.id, revision);
|
|
});
|
|
this.isLoaded = true;
|
|
});
|
|
return res.data;
|
|
} finally {
|
|
this.isFetching = false;
|
|
}
|
|
};
|
|
}
|