Function createModelCrudHandler

packages/orm/src/client/client-impl.ts:602–909

(
    client: ClientContract<any>,
    model: string,
    inputValidator: InputValidator<any>,
    resultProcessor: ResultProcessor<any>,
)

}

function createModelCrudHandler(
    client: ClientContract<any>,
    model: string,
    inputValidator: InputValidator<any>,
    resultProcessor: ResultProcessor<any>,
): ModelOperations<any, any> {
    // check if any plugin defines ext result fields
    const plugins = client.$options.plugins ?? [];
    const schema = client.$schema;
    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,