Method execute

framework/framework/api.ts:147–181

(
        context: ApiExecutionContext, callOrName: ApiCall<ApiType, any, any> | string,
        rawArgs: any, emitHook?: any, project?: any, sendPayload?: (payload: any) => void,
    )

    }

    async execute(
        context: ApiExecutionContext, callOrName: ApiCall<ApiType, any, any> | string,
        rawArgs: any, emitHook?: any, project?: any, sendPayload?: (payload: any) => void,
    ) {
        const call = typeof callOrName === 'string' ? APIS[callOrName] : callOrName;
        if (!call) throw new NotFoundError(callOrName);
        const { input, func, hooks } = call;
        // eslint-disable-next-line no-await-in-loop
        for (const hook of hooks) await this.execute(context, hook, rawArgs);

        let args: any;
        try {
            args = input ? input(rawArgs as any) : rawArgs;
        } catch (e) {
            throw new BadRequestError(e.message);
        }
        if (typeof callOrName === 'string') {
            await emitHook?.('api/before', args);
            await emitHook?.(`api/before/${callOrName}`, args);
        }
        let result = await func(context, args as any, sendPayload);
        if (result && typeof result === 'object' && 'next' in result) {
            const it = result as AsyncGenerator<any, any, never>;
            while (true) {
                const value = await it.next(); // eslint-disable-line no-await-in-loop
                if (value.done) {
                    result = value;
                    break;
                } else {
                    sendPayload?.(value.value);
                }
            }
        }
        return (project && typeof result === 'object' && result !== null) ? projection(result, project, context) : result;
    }
}

declare module 'cordis' {