chore(): upgrade to mongoose v6

Author: kamilmysliwiec

lib/factories/schema.factory.ts

@@ -1,5 +1,6 @@
 import { Type } from '@nestjs/common';
 import * as mongoose from 'mongoose';
+import { SchemaDefinition, SchemaDefinitionType } from 'mongoose';
 import { TypeMetadataStorage } from '../storages/type-metadata.storage';
 import { DefinitionsFactory } from './definitions.factory';
 
@@ -8,14 +9,13 @@ export class SchemaFactory {
     TClass extends any = any,
     TDocument extends mongoose.Document = TClass extends mongoose.Document
       ? TClass
-      : mongoose.Document<TClass>
+      : mongoose.Document<TClass>,
   >(target: Type<TClass>): mongoose.Schema<TDocument> {
     const schemaDefinition = DefinitionsFactory.createForClass(target);
-    const schemaMetadata = TypeMetadataStorage.getSchemaMetadataByTarget(
-      target,
-    );
+    const schemaMetadata =
+      TypeMetadataStorage.getSchemaMetadataByTarget(target);
     return new mongoose.Schema<TDocument>(
-      schemaDefinition,
+      schemaDefinition as SchemaDefinition<SchemaDefinitionType<TDocument>>,
       schemaMetadata && schemaMetadata.options,
     );
   }

lib/mongoose-core.module.ts

@@ -10,7 +10,7 @@ import {
 } from '@nestjs/common';
 import { ModuleRef } from '@nestjs/core';
 import * as mongoose from 'mongoose';
-import { defer } from 'rxjs';
+import { defer, lastValueFrom } from 'rxjs';
 import { getConnectionToken, handleRetry } from './common/mongoose.utils';
 import {
   MongooseModuleAsyncOptions,
@@ -53,18 +53,14 @@ export class MongooseCoreModule implements OnApplicationShutdown {
     const connectionProvider = {
       provide: mongooseConnectionName,
       useFactory: async (): Promise<any> =>
-        await defer(async () =>
-          mongooseConnectionFactory(
-            mongoose.createConnection(uri, {
-              useNewUrlParser: true,
-              useUnifiedTopology: true,
-              ...mongooseOptions,
-            }),
-            mongooseConnectionName,
-          ),
-        )
-          .pipe(handleRetry(retryAttempts, retryDelay))
-          .toPromise(),
+        await lastValueFrom(
+          defer(async () =>
+            mongooseConnectionFactory(
+              mongoose.createConnection(uri, mongooseOptions),
+              mongooseConnectionName,
+            ),
+          ).pipe(handleRetry(retryAttempts, retryDelay)),
+        ),
     };
     return {
       module: MongooseCoreModule,
@@ -98,23 +94,22 @@ export class MongooseCoreModule implements OnApplicationShutdown {
         const mongooseConnectionFactory =
           connectionFactory || ((connection) => connection);
 
-        return await defer(async () =>
-          mongooseConnectionFactory(
-            mongoose.createConnection(mongooseModuleOptions.uri as string, {
-              useNewUrlParser: true,
-              useUnifiedTopology: true,
-              ...mongooseOptions,
-            }),
-            mongooseConnectionName,
-          ),
-        )
-          .pipe(
+        return await lastValueFrom(
+          defer(async () =>
+            mongooseConnectionFactory(
+              mongoose.createConnection(
+                mongooseModuleOptions.uri as string,
+                mongooseOptions,
+              ),
+              mongooseConnectionName,
+            ),
+          ).pipe(
             handleRetry(
               mongooseModuleOptions.retryAttempts,
               mongooseModuleOptions.retryDelay,
             ),
-          )
-          .toPromise();
+          ),
+        );
       },
       inject: [MONGOOSE_MODULE_OPTIONS],
     };