Unit of work pattern with prisma

prisma.uow.ts

import { Injectable } from '@nestjs/common';
import { PrismaClient } from '@prisma/client';
import { DefaultArgs, PrismaClientOptions } from '@prisma/client/runtime/library';
import { PrismaService } from '@shared/infrastructure/services';
import { LoggerServicePort, UnitOfWorkPort } from '@shared/infrastructure/ports';
import { ClsService } from 'nestjs-cls';

type TransactionFn = Parameters<PrismaClient['$transaction']>[0];

type TransactionOptions = Parameters<PrismaClient['$transaction']>[1];

export abstract class UowRepository implements UnitOfWorkPort {
    abstract execute<T>(handler: () => Promise<T>): Promise<T>;

    abstract getTransaction(): Omit<
        PrismaClient<PrismaClientOptions, never, DefaultArgs>,
        '$transaction' | '$connect' | '$disconnect' | '$on' | '$use' | '$extends'
    >;
}

@Injectable()
export class PrismaUowAdapter extends UowRepository {
    constructor(
        private prisma: PrismaService,
        private cls: ClsService,
        private logger: LoggerServicePort,
    ) {
        super();
    }

    async execute<T>(fn: TransactionFn, options?: TransactionOptions): Promise<T> {
        this.logger.setContext(this.constructor.name);

        return this.prisma.$transaction(async (tx) => {
            this.cls.set('prismaTX', tx);

            return (await fn(tx)) as Promise<T>;
        }, options);
    }

    public getTransaction(): Omit<
        PrismaClient<PrismaClientOptions, never, DefaultArgs>,
        '$transaction' | '$connect' | '$disconnect' | '$on' | '$use' | '$extends'
    > {
        const transaction = this.cls.get('prismaTX');

        if (!transaction) {
            throw new Error(`database transaction not exist`);
        }

        return transaction;
    }
}