employeeNumber

Author: tacxou

src/_common/validators/uniqueness-example.validator.ts

@@ -0,0 +1,67 @@
+import { Injectable } from '@nestjs/common'
+import { InjectConnection } from '@nestjs/mongoose'
+import {
+  ValidationArguments,
+  ValidationOptions,
+  ValidatorConstraint,
+  ValidatorConstraintInterface,
+  registerDecorator,
+} from 'class-validator'
+import { Connection } from 'mongoose'
+import { get } from 'radash'
+
+@ValidatorConstraint({ name: 'UniquenessMailValidator', async: true })
+@Injectable()
+export class UniquenessMailValidator implements ValidatorConstraintInterface {
+  public constructor(@InjectConnection() private connection: Connection) { }
+  public async validate(
+    value: any,
+    args?: ValidationArguments
+  ): Promise<boolean> {
+    for (const contraint of args.constraints) {
+      const $ne = get(args.object, contraint.primaryKey)
+      const val = get(value, contraint.key)
+      const count = await this.connection.collection(contraint.collection).countDocuments({
+        [contraint.primaryKey]: { $ne },
+        [contraint.key]: val,
+      })
+
+      console.log('count', count)
+      console.log('debug', {
+        [contraint.primaryKey]: { $ne },
+        [contraint.key]: val,
+      })
+
+      if (count > 0) {
+        return false
+      }
+    }
+
+    return true
+  }
+
+  defaultMessage(validationArguments?: ValidationArguments): string {
+    // return custom field message
+    const field: string = validationArguments.property
+    return `${field} is already exist`
+  }
+}
+
+export type UniquenessMailInterface = {
+  collection: string
+  primaryKey: string
+  key: string
+}
+
+export function isUnique(options: UniquenessMailInterface, validationOptions?: ValidationOptions) {
+  return function (object: any, propertyName: string) {
+    registerDecorator({
+      name: 'isUnique',
+      target: object.constructor,
+      propertyName: propertyName,
+      options: validationOptions,
+      constraints: [options],
+      validator: UniquenessMailValidator,
+    })
+  }
+}

src/main.ts

@@ -12,6 +12,7 @@ import { readFileSync } from 'fs';
 import * as http from 'http';
 import * as https from 'https';
 import { ShutdownObserver } from './_common/observers/shutdown.observer';
+import { useContainer } from 'class-validator';
 
 declare const module: any;
 (async (): Promise<void> => {
@@ -22,8 +23,6 @@ declare const module: any;
   });
   await logger.initialize();
 
-  console.log('cfg', cfg.application);
-
   let extraOptions = <any>{};
   if (cfg.application?.https?.enabled) {
     try {
@@ -56,6 +55,8 @@ declare const module: any;
     await (await import('./swagger')).default(app);
   }
 
+  useContainer(app.select(AppModule), { fallbackOnErrors: true });
+
   await app.init();
 
   const shutdownObserver = app.get(ShutdownObserver);