Refactor event emitter event names in AbstractServiceSchema and add before state tracking for create, update, and delete operations

Author: tacxou

src/_common/abstracts/abstract.service.schema.ts

@@ -221,7 +221,7 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
     let created = document.save(options)
     if (this.eventEmitter) {
       const afterEvents = await this.eventEmitter?.emitAsync(
-        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterFindAndCount'].join(EventEmitterSeparator),
+        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterCreate'].join(EventEmitterSeparator),
         { created },
       )
       for (const afterEvent of afterEvents) {
@@ -255,6 +255,7 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
         if (beforeEvent?.options) options = { ...options, ...beforeEvent.options }
       }
     }
+    const before = await this._model.findOne<Query<T | null, T, any, T>>({ _id }).exec();
     let updated = await this._model
       .findOneAndUpdate<Query<T | null, T, any, T>>(
         { _id },
@@ -283,8 +284,8 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
     }
     if (this.eventEmitter) {
       const afterEvents = await this.eventEmitter?.emitAsync(
-        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterFindAndCount'].join(EventEmitterSeparator),
-        { updated },
+        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterUpdate'].join(EventEmitterSeparator),
+        { before, updated },
       )
       for (const afterEvent of afterEvents) {
         if (afterEvent?.updated) updated = { ...updated, ...afterEvent.updated }
@@ -367,15 +368,16 @@ export abstract class AbstractServiceSchema extends AbstractService implements S
         if (beforeEvent?.options) options = { ...options, ...beforeEvent.options }
       }
     }
+    const before = await this._model.findOne<Query<T | null, T, any, T>>({ _id }).exec();
     let deleted = await this._model.findByIdAndDelete<Query<T | null, T, any, T>>({ _id }, options).exec()
     if (!deleted) {
       this.logger.debug(['findById', JSON.stringify(Object.values(arguments))].join(' '))
       throw new NotFoundException()
     }
     if (this.eventEmitter) {
       const afterEvents = await this.eventEmitter?.emitAsync(
-        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterFindAndCount'].join(EventEmitterSeparator),
-        { deleted },
+        [this.moduleName.toLowerCase(), this.serviceName.toLowerCase(), 'service', 'afterDelete'].join(EventEmitterSeparator),
+        { before, deleted },
       )
       for (const afterEvent of afterEvents) {
         if (afterEvent?.deleted) deleted = { ...deleted, ...afterEvent.deleted }

src/management/lifecycle/lifecycle.module.ts

@@ -3,6 +3,7 @@ import { MongooseModule } from '@nestjs/mongoose';
 import { Lifecycle, LifecycleSchema } from './_schemas/lifecycle.schema';
 import { LifecycleController } from './lifecycle.controller';
 import { LifecycleService } from './lifecycle.service';
+import { IdentitiesModule } from '../identities/identities.module';
 
 @Module({
   imports: [
@@ -12,6 +13,7 @@ import { LifecycleService } from './lifecycle.service';
         schema: LifecycleSchema,
       },
     ]),
+    IdentitiesModule,
   ],
   providers: [LifecycleService],
   controllers: [LifecycleController],