superdesk/superdesk-client-core

import {httpRequestJsonLocal, httpRequestRawLocal} from 'core/helpers/network';
import {Cancelable, throttle} from 'lodash';
import {IArticle, IAuthoringAutoSave} from 'superdesk-api';
import {omitFields} from './data-layer';

export class AutoSaveHttp implements IAuthoringAutoSave<IArticle> {
    autoSaveThrottled: ((getItem: () => IArticle, callback: (autosaved: IArticle) => void) => void) & Cancelable;
    private autosavePromise: Promise<void> | null;

    constructor(delay: number) {
        this.autoSaveThrottled = throttle(
            (getItem, callback) => {
                const item = getItem();

                this.autosavePromise = httpRequestJsonLocal<IArticle>({
                    method: 'POST',
                    path: '/archive_autosave',
                    payload: omitFields(item),
                }).then((res) => {
                    this.autosavePromise = null;
                    callback(res);
                });
            },
            delay,
            {leading: false},
        );
    }

    get(id: IArticle['_id']) {
        return httpRequestJsonLocal<IArticle>({
            method: 'GET',
            path: `/archive_autosave/${id}`,
        });
    }

    delete(id: IArticle['_id'], etag: IArticle['_etag']) {
        return httpRequestRawLocal<IArticle>({
            method: 'DELETE',
            path: `/archive_autosave/${id}`,
            headers: {
                'If-Match': etag,
            },
        }).then(() => undefined);
    }

    schedule(getItem: () => IArticle, callback: (autosaved: IArticle) => void) {
        this.autoSaveThrottled(getItem, callback);
    }

    flush(): Promise<void> {
        this.autoSaveThrottled.flush();

        return new Promise((resolve) => {
            if (this.autosavePromise == null) {
                resolve();
            } else {
                this.autosavePromise.then(() => resolve());
            }
        });
    }

    cancel() {
        this.autoSaveThrottled.cancel();
    }
}