feat: channel destroy hook

Author: Sebastian-Iwanczyszyn

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nestjstools/messaging",
-  "version": "2.20.3",
+  "version": "2.21.0",
   "description": "Simplifies asynchronous and synchronous message handling with support for buses, handlers, channels, and consumers. Build scalable, decoupled applications with ease and reliability.",
   "author": "Sebastian Iwanczyszyn",
   "license": "MIT",

src/channel/channel.ts

@@ -2,4 +2,6 @@ import { ChannelConfig } from '../config';
 
 export class Channel<T extends ChannelConfig> {
   constructor(public readonly config: T) {}
+
+  async onChannelDestroy(): Promise<void> {};
 }

src/messaging.module.ts

@@ -3,7 +3,7 @@ import {
   FactoryProvider,
   Logger as NestCommonLogger,
   Module,
-  OnApplicationBootstrap,
+  OnApplicationBootstrap, OnApplicationShutdown, OnModuleDestroy,
   Provider,
 } from '@nestjs/common';
 import {
@@ -44,7 +44,7 @@ import { ExceptionListenerRegistry } from './exception-listener/exception-listen
 import { ExceptionListenerHandler } from './exception-listener/exception-listener-handler';
 
 @Module({})
-export class MessagingModule implements OnApplicationBootstrap {
+export class MessagingModule implements OnApplicationBootstrap, OnModuleDestroy {
   static forRoot(options: MessagingModuleOptions): DynamicModule {
     const channels = options.channels ?? [];
 
@@ -238,4 +238,12 @@ export class MessagingModule implements OnApplicationBootstrap {
     const consumer = this.moduleRef.get(DistributedConsumer);
     consumer.run();
   }
+
+  async onModuleDestroy(): Promise<any> {
+    const channels: Channel<ChannelConfig>[] = this.moduleRef.get(Service.CHANNELS);
+
+    for (const channel of channels) {
+      await channel.onChannelDestroy();
+    }
+  }
 }