Function createPromise

packages/orm/src/client/client-impl.ts:613–673

(
        operation: CoreCrudOperations,
        nominalOperation: AllCrudOperations,
        args: unknown,
        handler: BaseOperationHandler<any>,
        postProcess = false,
        throwIfNoResult = false,
    )

    const hasAnyExtResult = hasExtResultFieldDefs(plugins);

    const createPromise = (
        operation: CoreCrudOperations,
        nominalOperation: AllCrudOperations,
        args: unknown,
        handler: BaseOperationHandler<any>,
        postProcess = false,
        throwIfNoResult = false,
    ) => {
        return createZenStackPromise(async (txClient?: ClientContract<any>) => {
            let proceed = async (_args: unknown) => {
                // prepare args for ext result: strip ext result field names from select/omit,
                // inject needs fields into select (recursively handles nested relations)
                const shouldApplyExtResult = hasAnyExtResult && EXT_RESULT_OPERATIONS.has(operation);
                const processedArgs = shouldApplyExtResult
                    ? prepareArgsForExtResult(_args, model, schema, plugins)
                    : _args;

                const _handler = txClient ? handler.withClient(txClient) : handler;
                const r = await _handler.handle(operation, processedArgs);
                if (!r && throwIfNoResult) {
                    throw createNotFoundError(model);
                }
                let result: unknown;
                if (r && postProcess) {
                    result = resultProcessor.processResult(r, model, processedArgs);
                } else {
                    result = r ?? null;
                }

                // compute ext result fields (recursively handles nested relations)
                if (result && shouldApplyExtResult) {
                    result = applyExtResult(result, model, _args, schema, plugins);
                }

                return result;
            };

            // apply plugins
            const plugins = [...(client.$options.plugins ?? [])];
            for (const plugin of plugins) {
                const onQuery = plugin.onQuery;
                if (onQuery) {
                    const _proceed = proceed;
                    proceed = (_args: unknown) => {
                        const ctx: any = {
                            client,
                            model,
                            operation: nominalOperation,
                            // reflect the latest override if provided
                            args: _args,
                            // ensure inner overrides are propagated to the previous proceed
                            proceed: (nextArgs: unknown) => _proceed(nextArgs),
                        };
                        return (onQuery as (ctx: any) => Promise<unknown>)(ctx);
                    };
                }
            }