// Copyright: Ankitects Pty Ltd and contributors
// License: GNU AGPL, version 3 or later; http://www.gnu.org/licenses/agpl.html

import { Readable, derived } from "svelte/store";

interface AsyncReactiveData<T, E> {
    value: Readable<T | null>;
    error: Readable<E | null>;
    loading: Readable<boolean>;
}

function useAsyncReactive<T, E>(
    asyncFunction: () => Promise<T>,
    dependencies: [Readable<unknown>, ...Readable<unknown>[]]
): AsyncReactiveData<T, E> {
    const promise = derived(
        dependencies,
        (_, set: (value: Promise<T> | null) => void): void => set(asyncFunction()),
        // initialize with null to avoid duplicate fetch on init
        null
    );

    const value = derived(
        promise,
        ($promise, set: (value: T) => void): void => {
            $promise?.then((value: T) => set(value));
        },
        null
    );

    const error = derived(
        promise,
        ($promise, set: (error: E | null) => void): (() => void) => {
            $promise?.catch((error: E) => set(error));
            return (): void => set(null);
        },
        null
    );

    const loading = derived(
        promise,
        ($promise, set: (value: boolean) => void): (() => void) => {
            $promise?.finally(() => set(false));
            return (): void => set(true);
        },
        true
    );

    return { value, error, loading };
}

export default useAsyncReactive;