@Injectable()
export class PrismaProvider
  extends PrismaClient
  implements OnModuleInit, OnModuleDestroy {
  constructor(
    readonly config: ConfigService, // TODO: check if this can be private?!
    readonly cls: ClsService, // TODO: check if this can be private?!
    @Inject(CACHE_MANAGER)
    private cacheManager: Cache,
  ) {
    const url = new URL(config.getOrThrow<string>('DATABASE_URL'));
    url.searchParams.append('connection_limit', '80'); // should be the number of maximal concurrent requests => TODO: maybe replace with env

    super({
      datasources: {
        db: {
          url: url.toString(),
        },
      },
    });
  }

  withExtensions() {
    return this.$extends(prismaExistsFnExtension)
      .$extends(cacheExtension({ cache: this.cacheManager })) // this may require to use Prisma.Args<PrismaService['file'], 'findMany'>['include'] for several places
      .$extends(prismaSessionAuthExtension(this))
      .$extends(prismaAddressGeocodeExtension(this));
  }
}

const buildPrismaService = () => {
  return class {
    constructor(provider: PrismaProvider) {
      return provider.withExtensions();
    }
  } as Type<ReturnType<PrismaProvider['withExtensions']>>;
};

@Injectable()
export class PrismaService extends buildPrismaService() {
  constructor(private readonly provider: PrismaProvider) {
    super(provider);
  }
}

@Injectable()
export class PrismaProvider
  extends PrismaClient
  implements OnModuleInit, OnModuleDestroy {
  constructor(
    readonly config: ConfigService, // TODO: check if this can be private?!
    readonly cls: ClsService, // TODO: check if this can be private?!
    @Inject(CACHE_MANAGER)
    private cacheManager: Cache,
  ) {
    const url = new URL(config.getOrThrow<string>('DATABASE_URL'));
    url.searchParams.append('connection_limit', '80'); // should be the number of maximal concurrent requests => TODO: maybe replace with env

    super({
      datasources: {
        db: {
          url: url.toString(),
        },
      },
    });
  }

  withExtensions() {
    return this.$extends(prismaExistsFnExtension)
      .$extends(cacheExtension({ cache: this.cacheManager })) // this may require to use Prisma.Args<PrismaService['file'], 'findMany'>['include'] for several places
      .$extends(prismaSessionAuthExtension(this))
      .$extends(prismaAddressGeocodeExtension(this));
  }
}

const buildPrismaService = () => {
  return class {
    constructor(provider: PrismaProvider) {
      return provider.withExtensions();
    }
  } as Type<ReturnType<PrismaProvider['withExtensions']>>;
};

@Injectable()
export class PrismaService extends buildPrismaService() {
  constructor(private readonly provider: PrismaProvider) {
    super(provider);
  }
}