@nestjs/mongoose
Advanced tools
Comparing version 8.0.1 to 9.0.0
@@ -6,5 +6,5 @@ "use strict"; | ||
const mongoose_utils_1 = require("./mongoose.utils"); | ||
const InjectModel = (model) => common_1.Inject(mongoose_utils_1.getModelToken(model)); | ||
const InjectModel = (model) => (0, common_1.Inject)((0, mongoose_utils_1.getModelToken)(model)); | ||
exports.InjectModel = InjectModel; | ||
const InjectConnection = (name) => common_1.Inject(mongoose_utils_1.getConnectionToken(name)); | ||
const InjectConnection = (name) => (0, common_1.Inject)((0, mongoose_utils_1.getConnectionToken)(name)); | ||
exports.InjectConnection = InjectConnection; |
@@ -19,3 +19,3 @@ "use strict"; | ||
const logger = new common_1.Logger('MongooseModule'); | ||
return (source) => source.pipe(operators_1.retryWhen((e) => e.pipe(operators_1.scan((errorCount, error) => { | ||
return (source) => source.pipe((0, operators_1.retryWhen)((e) => e.pipe((0, operators_1.scan)((errorCount, error) => { | ||
logger.error(`Unable to connect to the database. Retrying (${errorCount + 1})...`, ''); | ||
@@ -26,4 +26,4 @@ if (errorCount + 1 >= retryAttempts) { | ||
return errorCount + 1; | ||
}, 0), operators_1.delay(retryDelay)))); | ||
}, 0), (0, operators_1.delay)(retryDelay)))); | ||
} | ||
exports.handleRetry = handleRetry; |
@@ -16,3 +16,3 @@ "use strict"; | ||
let parent = target; | ||
while (!shared_utils_1.isUndefined(parent.prototype)) { | ||
while (!(0, shared_utils_1.isUndefined)(parent.prototype)) { | ||
if (parent === Function.prototype) { | ||
@@ -19,0 +19,0 @@ break; |
@@ -51,3 +51,3 @@ "use strict"; | ||
const mongooseConnectionFactory = connectionFactory || ((connection) => connection); | ||
const mongooseConnectionName = mongoose_utils_1.getConnectionToken(connectionName); | ||
const mongooseConnectionName = (0, mongoose_utils_1.getConnectionToken)(connectionName); | ||
const mongooseConnectionNameProvider = { | ||
@@ -60,7 +60,5 @@ provide: mongoose_constants_1.MONGOOSE_CONNECTION_NAME, | ||
useFactory: () => __awaiter(this, void 0, void 0, function* () { | ||
return yield rxjs_1.defer(() => __awaiter(this, void 0, void 0, function* () { | ||
return mongooseConnectionFactory(mongoose.createConnection(uri, Object.assign({ useNewUrlParser: true, useUnifiedTopology: true }, mongooseOptions)), mongooseConnectionName); | ||
})) | ||
.pipe(mongoose_utils_1.handleRetry(retryAttempts, retryDelay)) | ||
.toPromise(); | ||
return yield (0, rxjs_1.lastValueFrom)((0, rxjs_1.defer)(() => __awaiter(this, void 0, void 0, function* () { | ||
return mongooseConnectionFactory(mongoose.createConnection(uri, mongooseOptions), mongooseConnectionName); | ||
})).pipe((0, mongoose_utils_1.handleRetry)(retryAttempts, retryDelay))); | ||
}), | ||
@@ -75,3 +73,3 @@ }; | ||
static forRootAsync(options) { | ||
const mongooseConnectionName = mongoose_utils_1.getConnectionToken(options.connectionName); | ||
const mongooseConnectionName = (0, mongoose_utils_1.getConnectionToken)(options.connectionName); | ||
const mongooseConnectionNameProvider = { | ||
@@ -86,7 +84,5 @@ provide: mongoose_constants_1.MONGOOSE_CONNECTION_NAME, | ||
const mongooseConnectionFactory = connectionFactory || ((connection) => connection); | ||
return yield rxjs_1.defer(() => __awaiter(this, void 0, void 0, function* () { | ||
return mongooseConnectionFactory(mongoose.createConnection(mongooseModuleOptions.uri, Object.assign({ useNewUrlParser: true, useUnifiedTopology: true }, mongooseOptions)), mongooseConnectionName); | ||
})) | ||
.pipe(mongoose_utils_1.handleRetry(mongooseModuleOptions.retryAttempts, mongooseModuleOptions.retryDelay)) | ||
.toPromise(); | ||
return yield (0, rxjs_1.lastValueFrom)((0, rxjs_1.defer)(() => __awaiter(this, void 0, void 0, function* () { | ||
return mongooseConnectionFactory(mongoose.createConnection(mongooseModuleOptions.uri, mongooseOptions), mongooseConnectionName); | ||
})).pipe((0, mongoose_utils_1.handleRetry)(mongooseModuleOptions.retryAttempts, mongooseModuleOptions.retryDelay))); | ||
}), | ||
@@ -145,7 +141,7 @@ inject: [mongoose_constants_1.MONGOOSE_MODULE_OPTIONS], | ||
MongooseCoreModule = MongooseCoreModule_1 = __decorate([ | ||
common_1.Global(), | ||
common_1.Module({}), | ||
__param(0, common_1.Inject(mongoose_constants_1.MONGOOSE_CONNECTION_NAME)), | ||
(0, common_1.Global)(), | ||
(0, common_1.Module)({}), | ||
__param(0, (0, common_1.Inject)(mongoose_constants_1.MONGOOSE_CONNECTION_NAME)), | ||
__metadata("design:paramtypes", [String, core_1.ModuleRef]) | ||
], MongooseCoreModule); | ||
exports.MongooseCoreModule = MongooseCoreModule; |
@@ -28,3 +28,3 @@ "use strict"; | ||
static forFeature(models = [], connectionName) { | ||
const providers = mongoose_providers_1.createMongooseProviders(connectionName, models); | ||
const providers = (0, mongoose_providers_1.createMongooseProviders)(connectionName, models); | ||
return { | ||
@@ -37,5 +37,5 @@ module: MongooseModule_1, | ||
static forFeatureAsync(factories = [], connectionName) { | ||
const providers = mongoose_providers_1.createMongooseAsyncProviders(connectionName, factories); | ||
const providers = (0, mongoose_providers_1.createMongooseAsyncProviders)(connectionName, factories); | ||
const imports = factories.map((factory) => factory.imports || []); | ||
const uniqImports = new Set(common_1.flatten(imports)); | ||
const uniqImports = new Set((0, common_1.flatten)(imports)); | ||
return { | ||
@@ -50,4 +50,4 @@ module: MongooseModule_1, | ||
MongooseModule = MongooseModule_1 = __decorate([ | ||
common_1.Module({}) | ||
(0, common_1.Module)({}) | ||
], MongooseModule); | ||
exports.MongooseModule = MongooseModule; |
@@ -18,8 +18,8 @@ "use strict"; | ||
...(option.discriminators || []).map((d) => ({ | ||
provide: mongoose_utils_1.getModelToken(d.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name), | ||
useFactory: (model) => model.discriminator(d.name, d.schema), | ||
inject: [mongoose_utils_1.getModelToken(option.name)], | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name)], | ||
})), | ||
{ | ||
provide: mongoose_utils_1.getModelToken(option.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name), | ||
useFactory: (connection) => { | ||
@@ -29,3 +29,3 @@ const model = connection.model(option.name, option.schema, option.collection); | ||
}, | ||
inject: [mongoose_utils_1.getConnectionToken(connectionName)], | ||
inject: [(0, mongoose_utils_1.getConnectionToken)(connectionName)], | ||
}, | ||
@@ -40,3 +40,3 @@ ], []); | ||
{ | ||
provide: mongoose_utils_1.getModelToken(option.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name), | ||
useFactory: (connection, ...args) => __awaiter(this, void 0, void 0, function* () { | ||
@@ -47,8 +47,8 @@ const schema = yield option.useFactory(...args); | ||
}), | ||
inject: [mongoose_utils_1.getConnectionToken(connectionName), ...(option.inject || [])], | ||
inject: [(0, mongoose_utils_1.getConnectionToken)(connectionName), ...(option.inject || [])], | ||
}, | ||
...(option.discriminators || []).map((d) => ({ | ||
provide: mongoose_utils_1.getModelToken(d.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name), | ||
useFactory: (model) => model.discriminator(d.name, d.schema), | ||
inject: [mongoose_utils_1.getModelToken(option.name)], | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name)], | ||
})), | ||
@@ -55,0 +55,0 @@ ]; |
export declare type TargetHost = Record<'target', Function>; | ||
export declare function isTargetEqual<T extends TargetHost, U extends TargetHost>(a: T, b: U): boolean; | ||
export declare function isTargetEqual<T extends TargetHost, U extends TargetHost>(a: T, b: U): any; |
@@ -5,4 +5,6 @@ "use strict"; | ||
function isTargetEqual(a, b) { | ||
return a.target === b.target; | ||
return a.target === b.target || (a.target.prototype ? | ||
isTargetEqual({ target: a.target.__proto__ }, b) : | ||
false); | ||
} | ||
exports.isTargetEqual = isTargetEqual; |
{ | ||
"name": "@nestjs/mongoose", | ||
"version": "8.0.1", | ||
"version": "9.0.0", | ||
"description": "Nest - modern, fast, powerful node.js web framework (@mongoose)", | ||
@@ -25,25 +25,26 @@ "author": "Kamil Mysliwiec", | ||
"@commitlint/config-angular": "13.1.0", | ||
"@nestjs/common": "8.0.6", | ||
"@nestjs/core": "8.0.6", | ||
"@nestjs/platform-express": "8.0.6", | ||
"@nestjs/testing": "8.0.6", | ||
"@types/jest": "27.0.1", | ||
"@types/node": "14.17.9", | ||
"@typescript-eslint/eslint-plugin": "4.29.1", | ||
"@typescript-eslint/parser": "4.29.1", | ||
"@nestjs/common": "8.0.7", | ||
"@nestjs/core": "8.0.7", | ||
"@nestjs/platform-express": "8.0.7", | ||
"@nestjs/testing": "8.0.7", | ||
"@types/jest": "27.0.2", | ||
"@types/node": "14.17.19", | ||
"@typescript-eslint/eslint-plugin": "4.31.2", | ||
"@typescript-eslint/parser": "4.31.2", | ||
"eslint": "7.32.0", | ||
"eslint-config-prettier": "8.3.0", | ||
"eslint-plugin-import": "2.24.0", | ||
"husky": "7.0.1", | ||
"jest": "27.0.6", | ||
"eslint-plugin-import": "2.24.2", | ||
"eslint-plugin-prettier": "4.0.0", | ||
"husky": "7.0.2", | ||
"jest": "27.2.2", | ||
"lint-staged": "11.1.2", | ||
"mongoose": "5.13.7", | ||
"prettier": "2.3.2", | ||
"mongoose": "6.0.2", | ||
"prettier": "2.4.1", | ||
"reflect-metadata": "0.1.13", | ||
"release-it": "14.11.5", | ||
"release-it": "14.11.6", | ||
"rxjs": "7.3.0", | ||
"supertest": "6.1.5", | ||
"ts-jest": "27.0.4", | ||
"ts-node": "10.2.0", | ||
"typescript": "4.3.5" | ||
"supertest": "6.1.6", | ||
"ts-jest": "27.0.5", | ||
"ts-node": "10.2.1", | ||
"typescript": "4.4.3" | ||
}, | ||
@@ -53,3 +54,3 @@ "peerDependencies": { | ||
"@nestjs/core": "^6.0.0 || ^7.0.0 || ^8.0.0", | ||
"mongoose": "^5.11.15 || ^5.12.4", | ||
"mongoose": "^6.0.2", | ||
"reflect-metadata": "^0.1.12", | ||
@@ -56,0 +57,0 @@ "rxjs": "^6.0.0 || ^7.0.0" |
@@ -177,3 +177,3 @@ import * as mongoose from 'mongoose'; | ||
expect(err).toBeInstanceOf(CannotDetermineTypeError); | ||
expect(err.message).toEqual( | ||
expect((err as Error).message).toEqual( | ||
'Cannot determine a type for the "AmbiguousField.randomField" field (union/intersection/ambiguous type was used). Make sure your property is decorated with a "@Prop({ type: TYPE_HERE })" decorator.', | ||
@@ -180,0 +180,0 @@ ); |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
75442
26
1331