@nestjs/mongoose
Advanced tools
Comparing version 9.0.3 to 9.1.0
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
@@ -1,2 +0,2 @@ | ||
export declare const InjectModel: (model: string) => (target: object, key: string | symbol, index?: number | undefined) => void; | ||
export declare const InjectModel: (model: string, connectionName?: string | undefined) => (target: object, key: string | symbol, index?: number | undefined) => void; | ||
export declare const InjectConnection: (name?: string | undefined) => (target: object, key: string | symbol, index?: number | undefined) => void; |
@@ -6,5 +6,5 @@ "use strict"; | ||
const mongoose_utils_1 = require("./mongoose.utils"); | ||
const InjectModel = (model) => (0, common_1.Inject)((0, mongoose_utils_1.getModelToken)(model)); | ||
const InjectModel = (model, connectionName) => (0, common_1.Inject)((0, mongoose_utils_1.getModelToken)(model, connectionName)); | ||
exports.InjectModel = InjectModel; | ||
const InjectConnection = (name) => (0, common_1.Inject)((0, mongoose_utils_1.getConnectionToken)(name)); | ||
exports.InjectConnection = InjectConnection; |
import { Observable } from 'rxjs'; | ||
export declare function getModelToken(model: string): string; | ||
export declare function getModelToken(model: string, connectionName?: string): string; | ||
export declare function getConnectionToken(name?: string): string; | ||
export declare function handleRetry(retryAttempts?: number, retryDelay?: number): <T>(source: Observable<T>) => Observable<T>; |
@@ -7,4 +7,7 @@ "use strict"; | ||
const mongoose_constants_1 = require("../mongoose.constants"); | ||
function getModelToken(model) { | ||
return `${model}Model`; | ||
function getModelToken(model, connectionName) { | ||
if (connectionName === undefined) { | ||
return `${model}Model`; | ||
} | ||
return `${getConnectionToken(connectionName)}/${model}Model`; | ||
} | ||
@@ -11,0 +14,0 @@ exports.getModelToken = getModelToken; |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
import { Type } from '@nestjs/common'; | ||
import * as mongoose from 'mongoose'; | ||
export declare class SchemaFactory { | ||
static createForClass<TClass extends any = any, TDocument extends mongoose.Document = TClass extends mongoose.Document ? TClass : mongoose.Document<TClass>>(target: Type<TClass>): mongoose.Schema<TDocument>; | ||
static createForClass<TClass = any, _TDeprecatedTypeArgument = any>(target: Type<TClass>): mongoose.Schema<TClass>; | ||
} |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
@@ -5,2 +5,3 @@ import { Schema } from 'mongoose'; | ||
schema: Schema; | ||
value?: string; | ||
}; | ||
@@ -7,0 +8,0 @@ export declare type ModelDefinition = { |
@@ -13,2 +13,4 @@ import { ModuleMetadata, Type } from '@nestjs/common'; | ||
} | ||
export interface MongooseModuleFactoryOptions extends Omit<MongooseModuleOptions, 'connectionName'> { | ||
} | ||
export interface MongooseModuleAsyncOptions extends Pick<ModuleMetadata, 'imports'> { | ||
@@ -18,4 +20,4 @@ connectionName?: string; | ||
useClass?: Type<MongooseOptionsFactory>; | ||
useFactory?: (...args: any[]) => Promise<MongooseModuleOptions> | MongooseModuleOptions; | ||
useFactory?: (...args: any[]) => Promise<MongooseModuleFactoryOptions> | MongooseModuleFactoryOptions; | ||
inject?: any[]; | ||
} |
@@ -79,9 +79,9 @@ "use strict"; | ||
useFactory: (mongooseModuleOptions) => __awaiter(this, void 0, void 0, function* () { | ||
const { retryAttempts, retryDelay, connectionName, uri, connectionFactory } = mongooseModuleOptions, mongooseOptions = __rest(mongooseModuleOptions, ["retryAttempts", "retryDelay", "connectionName", "uri", "connectionFactory"]); | ||
const { retryAttempts, retryDelay, uri, connectionFactory } = mongooseModuleOptions, mongooseOptions = __rest(mongooseModuleOptions, ["retryAttempts", "retryDelay", "uri", "connectionFactory"]); | ||
const mongooseConnectionFactory = connectionFactory || ((connection) => connection); | ||
return yield (0, rxjs_1.lastValueFrom)((0, rxjs_1.defer)(() => __awaiter(this, void 0, void 0, function* () { | ||
return mongooseConnectionFactory(yield mongoose | ||
.createConnection(mongooseModuleOptions.uri, mongooseOptions) | ||
.createConnection(uri, mongooseOptions) | ||
.asPromise(), mongooseConnectionName); | ||
})).pipe((0, mongoose_utils_1.handleRetry)(mongooseModuleOptions.retryAttempts, mongooseModuleOptions.retryDelay))); | ||
})).pipe((0, mongoose_utils_1.handleRetry)(retryAttempts, retryDelay))); | ||
}), | ||
@@ -88,0 +88,0 @@ inject: [mongoose_constants_1.MONGOOSE_MODULE_OPTIONS], |
@@ -18,8 +18,8 @@ "use strict"; | ||
...(option.discriminators || []).map((d) => ({ | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name), | ||
useFactory: (model) => model.discriminator(d.name, d.schema), | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name)], | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name, connectionName), | ||
useFactory: (model) => model.discriminator(d.name, d.schema, d.value), | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name, connectionName)], | ||
})), | ||
{ | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name, connectionName), | ||
useFactory: (connection) => { | ||
@@ -39,3 +39,3 @@ const model = connection.model(option.name, option.schema, option.collection); | ||
{ | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name), | ||
provide: (0, mongoose_utils_1.getModelToken)(option.name, connectionName), | ||
useFactory: (connection, ...args) => __awaiter(this, void 0, void 0, function* () { | ||
@@ -49,5 +49,5 @@ const schema = yield option.useFactory(...args); | ||
...(option.discriminators || []).map((d) => ({ | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name), | ||
useFactory: (model) => model.discriminator(d.name, d.schema), | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name)], | ||
provide: (0, mongoose_utils_1.getModelToken)(d.name, connectionName), | ||
useFactory: (model) => model.discriminator(d.name, d.schema, d.value), | ||
inject: [(0, mongoose_utils_1.getModelToken)(option.name, connectionName)], | ||
})), | ||
@@ -54,0 +54,0 @@ ]; |
"use strict"; | ||
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) { | ||
if (k2 === undefined) k2 = k; | ||
Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } }); | ||
var desc = Object.getOwnPropertyDescriptor(m, k); | ||
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) { | ||
desc = { enumerable: true, get: function() { return m[k]; } }; | ||
} | ||
Object.defineProperty(o, k2, desc); | ||
}) : (function(o, m, k, k2) { | ||
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k; |
{ | ||
"name": "@nestjs/mongoose", | ||
"version": "9.0.3", | ||
"version": "9.1.0", | ||
"description": "Nest - modern, fast, powerful node.js web framework (@mongoose)", | ||
@@ -23,28 +23,28 @@ "author": "Kamil Mysliwiec", | ||
"devDependencies": { | ||
"@commitlint/cli": "16.2.1", | ||
"@commitlint/config-angular": "16.2.1", | ||
"@nestjs/common": "8.4.1", | ||
"@nestjs/core": "8.4.1", | ||
"@nestjs/platform-express": "8.4.1", | ||
"@nestjs/testing": "8.4.1", | ||
"@types/jest": "27.4.1", | ||
"@types/node": "16.11.26", | ||
"@typescript-eslint/eslint-plugin": "5.15.0", | ||
"@typescript-eslint/parser": "5.15.0", | ||
"eslint": "8.11.0", | ||
"@commitlint/cli": "17.0.0", | ||
"@commitlint/config-angular": "17.0.0", | ||
"@nestjs/common": "8.4.5", | ||
"@nestjs/core": "8.4.5", | ||
"@nestjs/platform-express": "8.4.5", | ||
"@nestjs/testing": "8.4.5", | ||
"@types/jest": "27.5.1", | ||
"@types/node": "16.11.36", | ||
"@typescript-eslint/eslint-plugin": "5.25.0", | ||
"@typescript-eslint/parser": "5.25.0", | ||
"eslint": "8.15.0", | ||
"eslint-config-prettier": "8.5.0", | ||
"eslint-plugin-import": "2.25.4", | ||
"eslint-plugin-import": "2.26.0", | ||
"eslint-plugin-prettier": "4.0.0", | ||
"husky": "7.0.4", | ||
"jest": "27.5.1", | ||
"lint-staged": "12.3.5", | ||
"mongoose": "6.2.6", | ||
"prettier": "2.5.1", | ||
"husky": "8.0.1", | ||
"jest": "28.1.0", | ||
"lint-staged": "12.4.1", | ||
"mongoose": "6.3.4", | ||
"prettier": "2.6.2", | ||
"reflect-metadata": "0.1.13", | ||
"release-it": "14.12.5", | ||
"release-it": "15.0.0", | ||
"rxjs": "7.5.5", | ||
"supertest": "6.2.2", | ||
"ts-jest": "27.1.3", | ||
"supertest": "6.2.3", | ||
"ts-jest": "28.0.2", | ||
"ts-node": "10.7.0", | ||
"typescript": "4.6.2" | ||
"typescript": "4.6.4" | ||
}, | ||
@@ -51,0 +51,0 @@ "peerDependencies": { |
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
84370
1385