bridge-mongo - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

dist/Lib/db.d.ts

@@ -7,4 +7,12 @@ import { BridgeMongoModelI } from './types';
     mongoModel: MongoModel<ModelI>;
+    private hasCreateListener;
+    private hasUpdateListener;
+    private hasDeleteListener;
     constructor(mongoModel: MongoModel<ModelI>);
-    onCreate: BMMI<ModelI>['onCreate'];
+    private onCreate;
+    private onUpdate;
+    private onDelete;
+    addCreateListener: (listener: (d: ModelI) => Promise<void>) => void;
+    addUpdateListener: (listener: (before: ModelI, after: ModelI) => Promise<void>) => void;
+    addDeleteListener: (listener: (d: ModelI) => Promise<void>) => void;
     aggregate: () => AggI<ModelI, DBI>;
@@ -11,0 +19,0 @@ create: BMMI<ModelI>['create'];

dist/Lib/db.js

@@ -7,2 +7,5 @@ "use strict";
     mongoModel;
+    hasCreateListener = false;
+    hasUpdateListener = false;
+    hasDeleteListener = false;
     constructor(mongoModel) {
@@ -12,2 +15,16 @@ this.mongoModel = mongoModel;
     onCreate = async (data) => { };
+    onUpdate = async (before, after) => { };
+    onDelete = async (data) => { };
+    addCreateListener = (listener) => {
+        this.hasCreateListener = true;
+        this.onCreate = listener;
+    };
+    addUpdateListener = (listener) => {
+        this.hasUpdateListener = true;
+        this.onUpdate = listener;
+    };
+    addDeleteListener = (listener) => {
+        this.hasDeleteListener = true;
+        this.onDelete = listener;
+    };
     aggregate = () => new aggregate_1.Aggregate(this.mongoModel);
@@ -18,3 +35,3 @@ create = async (data, opts) => {
             const res = (await this.mongoModel.create([data], options))[0].toJSON();
-            this.onCreate(res);
+            this.hasCreateListener && this.onCreate(res);
             return res;
@@ -34,3 +51,3 @@ }
             const res = (await this.mongoModel.create(data, options)).map((obj) => obj.toJSON());
-            res.forEach((obj) => this.onCreate(obj));
+            this.hasCreateListener && res.forEach((obj) => this.onCreate(obj));
             return res;
@@ -55,2 +72,3 @@ }
     updateOne = async (filter, dataToUpdate, opts) => {
+        const objectBeforeUpdate = this.hasUpdateListener ? await this.findOne(filter) : null;
         const options = opts?.session ? { session: opts.session, new: true } : { new: true };
@@ -63,7 +81,26 @@ const promise = this.mongoModel.findOneAndUpdate(filter, dataToUpdate, options);
             return { error: { status: 404, name: 'Document not found' } };
+        this.hasUpdateListener &&
+            objectBeforeUpdate &&
+            !('error' in objectBeforeUpdate) &&
+            this.onUpdate(objectBeforeUpdate, res);
         return res;
     };
     updateMany = async (filter, dataToUpdate, opts) => {
+        const listObjectBeforeUpdate = this.hasUpdateListener
+            ? (await this.aggregate()
+                .match(filter)
+                .sort({ _id: 1 })
+                .paginate(0, 10000)).data
+            : [];
         const options = opts?.session ? { session: opts.session } : {};
         const res = await this.mongoModel.updateMany(filter, dataToUpdate, options);
+        const listObjectAfterUpdate = this.hasUpdateListener
+            ? (await this.aggregate()
+                .match(filter)
+                .sort({ _id: 1 })
+                .paginate(0, 10000)).data
+            : [];
+        res.modifiedCount !== 0 &&
+            this.hasUpdateListener &&
+            listObjectBeforeUpdate.forEach((obj, index) => this.onUpdate(obj, listObjectAfterUpdate[index]));
         return { modifiedCount: res.modifiedCount };
@@ -78,2 +115,3 @@ };
     deleteOne = async (filter, opts) => {
+        const objectBeforeDelete = this.hasDeleteListener ? await this.findOne(filter) : null;
         const options = opts?.session ? { session: opts.session } : {};
@@ -83,7 +121,12 @@ const res = await this.mongoModel.deleteOne(filter, options);
             throw new Error('Rollback transaction');
+        this.hasDeleteListener && objectBeforeDelete && !('error' in objectBeforeDelete) && this.onDelete(objectBeforeDelete);
         return { deleted: res.deletedCount !== 0 };
     };
     deleteMany = async (filter, opts) => {
+        const listObjectBeforeDelete = this.hasDeleteListener
+            ? (await this.aggregate().match(filter).paginate(0, 10000)).data
+            : [];
         const options = opts?.session ? { session: opts.session } : {};
-        const res = await this.mongoModel.deleteOne(filter, options);
+        const res = await this.mongoModel.deleteMany(filter, options);
+        res.deletedCount !== 0 && this.hasDeleteListener && listObjectBeforeDelete.forEach((obj) => this.onDelete(obj));
         return { deletedCount: res.deletedCount };
@@ -90,0 +133,0 @@ };

dist/Lib/types.d.ts

 import { CreateData, CreateDataParam, Projection, FilterParam, Filter, UpdateData, UpdateDataParam } from './utility';
 import { ClientSession } from 'mongoose';
 export interface BridgeMongoModelI<ModelI> {
-    onCreate: (data: ModelI) => Promise<void>;
     create: <Crea extends CreateData<ModelI>>(p: CreateDataParam<Crea, ModelI>, opts?: {
@@ -6,0 +5,0 @@ session?: ClientSession;

package.json

 {
   "name": "bridge-mongo",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "description": "A mongodb ORM on top of mongoose that match perfectly with the bridgets framework",
@@ -5,0 +5,0 @@ "main": "dist/Lib/index.js",

No alert changes

Improved metrics

Total package byte prevSize

69627

increased by7.05%

Lines of code

899

increased by5.89%

No dependency changes