feat: add logger support

src/operations/create.ts

@@ -33,6 +33,12 @@ export default function createFn<TDocument extends DocumentBase>(
 			throw new Error('CREATE_OPERATION_FAILED')
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'create', duration)
+		}
+
 		return (repositoryOptions &&
 			(repositoryOptions.skipIdTransformations && !repositoryOptions.enableIdMapping))
 			? doc

src/operations/createMany.ts

@@ -43,6 +43,12 @@ export default function createManyFn<TDocument extends DocumentBase>(
 			throw new Error('CREATE_OPERATION_FAILED')
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'createMany', duration)
+		}
+
 		return insertedCount
 	}
 }

src/operations/delete.ts

@@ -68,6 +68,12 @@ export default function deleteFn<TDocument extends DocumentBase>(
 			throw new Error('SOFT_DELETE_DOCUMENTS_FAILED')
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'delete', duration)
+		}
+
 		return modifiedCount
 	}
 }

src/operations/get.ts

@@ -13,6 +13,8 @@ export default function getFn<TDocument extends DocumentBase>(
 		let idParam: string | undefined
 		let doc: any
 
+		const now = new Date()
+
 		const session = (repositoryOptions && repositoryOptions.session) || undefined
 
 		if (repositoryOptions && repositoryOptions.skipIdTransformations) {
@@ -35,6 +37,12 @@ export default function getFn<TDocument extends DocumentBase>(
 			}, { session })
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'get', duration)
+		}
+
 		return (repositoryOptions &&
 			(repositoryOptions.skipIdTransformations && !repositoryOptions.enableIdMapping))
 			? doc

src/operations/query.ts

@@ -14,6 +14,8 @@ export default function queryFn<TDocument extends DocumentBase>(
 		options: FindOneOptions & ExtendOptionProps = {},
 	): Promise<TDocument[]> {
 
+		const now = new Date()
+
 		if (repositoryOptions && repositoryOptions.query) {
 			if (repositoryOptions.query.defaultLimit) {
 				// tslint:disable-next-line
@@ -61,6 +63,16 @@ export default function queryFn<TDocument extends DocumentBase>(
 					.filter(x => !!x)
 					.map(x => <TDocument>x),
 			)
+			.then(result => {
+
+				if (repositoryOptions && repositoryOptions.logger) {
+					const duration = Date.now() - now.getTime()
+
+					repositoryOptions.logger(collectionName, 'query', duration)
+				}
+
+				return result
+			})
 	}
 }
 

src/operations/update.ts

@@ -73,6 +73,12 @@ export default function updateFn<TDocument extends DocumentBase>(
 			throw new Error('UPDATE_DOCUMENTS_FAILED')
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'update', duration)
+		}
+
 		return <TDocument>mapObject(value)
 	}
 }

src/operations/updateMany.ts

@@ -67,6 +67,12 @@ export default function updateManyFn<TDocument extends DocumentBase>(
 			throw new Error('UPDATE_DOCUMENTS_FAILED')
 		}
 
+		if (repositoryOptions && repositoryOptions.logger) {
+			const duration = Date.now() - now.getTime()
+
+			repositoryOptions.logger(collectionName, 'updateMany', duration)
+		}
+
 		return modifiedCount
 	}
 }

src/types.ts

@@ -17,8 +17,11 @@ export interface RepositoryOptions {
 	query?: QueryOptions
 	update?: UpdateOptions
 	delete?: DeleteOptions
+	logger?: MangoLogger
 }
 
+export type MangoLogger = (collectionName: string, action: string, duration: number) => void
+
 export interface QueryOptions {
 	defaultLimit: number
 }