Function apiCall

shared/api.ts:41–84

(cmd: string, params?: Dict, options: ApiCallOptions={})

type ApiData<FT> = Jsonify<FT extends (...args: any[]) => infer R ? SanitizeReturn<R> : SanitizeReturn<FT>>
type SanitizeReturn<R> = Exclude<Awaited<R>, BackendApiError | Readable | AsyncGenerator<any>>
export function apiCall<FT=any>(cmd: string, params?: Dict, options: ApiCallOptions={}) {
    _.defaults(options, defaultApiCallOptions)
    const stop = options.modal?.(cmd, params)
    const controller = window.AbortController ? new AbortController() : undefined
    let aborted = ''
    const ms = 1000 * (timeoutByApi[cmd] ?? options.timeout ?? 10)
    const timeout = ms && setTimeout(() => {
        controller?.abort(aborted = 'timeout')
        console.debug('API TIMEOUT', cmd, params??'')
    }, ms)
    const asRest = options.restUri
    const started = new Date
    // rebuilding the whole url makes it resistant to url-with-credentials
    return Object.assign(fetch(`${location.origin}${asRest || (getPrefixUrl() + API_URL + cmd)}`, {
        method: asRest ? cmd : (options.method || 'POST'),
        headers: { 'content-type': 'application/json', 'x-hfs-anti-csrf': '1' },
        signal: controller?.signal,
        body: params && JSON.stringify(params),
    }).then(async res => {
        stop?.()
        let body: any = await res.text()
        let data: ApiData<FT>
        try { data = options.skipParse ? body : JSON.parse(body) }
        catch { data = body }
        if (!options?.skipLog)
            console.debug(res.ok ? 'API' : 'API FAILED', cmd, params??'', '>>', data, { started: formatTime(started), duration: (Date.now() - +started) })
        await options.onResponse?.(res, data)
        if (!res.ok)
            throw new ApiError(res.status, data === body ? body : `Failed API ${cmd}: ${res.statusText}`, data)
        return data
    }, err => {
        stop?.()
        if (err?.message?.includes('fetch')) {
            console.error(err.message)
            throw Error("Server unreachable")
        }
        throw aborted || err
    }).finally(() => clearTimeout(timeout)), {
        abort() {
            controller?.abort(aborted='cancel')
        },
        aborted: () => controller?.signal.aborted
    })
}

export class ApiError extends Error {
    constructor(readonly code:number, message: string, data?: any) {