'use strict';

/**
 * A future similar to Python's asyncio.Future. Allows to resolve or reject
 * outside of the executor and query the current status.
 */
class Future extends Promise {
    constructor(executor) {
        const resolve = (...args) => {
            this.resolve(...args);
        };
        const reject = (...args) => {
            this.reject(...args);
        };
        let innerResolve, innerReject;

        super((resolveFunc, rejectFunc) => {
            innerResolve = resolveFunc;
            innerReject = rejectFunc;
            if (executor) {
                return executor(resolve, reject);
            }
        });

        this._done = false;
        console.assert(innerResolve !== undefined && innerReject !== undefined, 'THERE IS NO HOPE!');
        this._resolve = innerResolve;
        this._reject = innerReject;
    }

    /**
     * Wrap a promise to ensure it does not resolve before a minimum
     * duration.
     *
     * Note: The promise will still reject immediately. Furthermore, be
     *       aware that the promise does not resolve/reject inside of
     *       an AngularJS digest cycle.
     *
     * @param promise the promise or future to be wrapped
     * @param minDuration the minimum duration before it should be resolved
     * @returns {Future}
     */
    static withMinDuration(promise, minDuration) {
        const start = new Date();
        return new Future((resolve, reject) => {
            promise
                .then((result) => {
                    const timediff = new Date() - start;
                    const delay = Math.max(minDuration - timediff, 0);
                    self.setTimeout(() => resolve(result), delay);
                })
                .catch((error) => reject(error));
        });
    }

    /**
     * Return whether the future is done (resolved or rejected).
     */
    get done() {
        return this._done;
    }

    /**
     * Resolve the future.
     */
    resolve(...args) {
        this._done = true;
        return this._resolve(...args);
    }

    /**
     * Reject the future.
     */
    reject(...args) {
        this._done = true;
        return this._reject(...args);
    }
}