move messaging to its own module

src/modules/message-publisher/message-publisher.module.ts

@@ -1,16 +0,0 @@
-import { Module, Provider } from '@nestjs/common';
-import { MESSAGE_PUBLISHER } from './message-publisher.di-tokens';
-import { MessageBrokerPublisher } from '@mobicoop/message-broker-module';
-
-const messagePublishers: Provider[] = [
-  {
-    provide: MESSAGE_PUBLISHER,
-    useClass: MessageBrokerPublisher,
-  },
-];
-
-@Module({
-  providers: [...messagePublishers],
-  exports: [MESSAGE_PUBLISHER],
-})
-export class MessagePublisherModule {}

src/modules/messager/messager.module.ts

@@ -0,0 +1,46 @@
+import { Module, Provider } from '@nestjs/common';
+import { MESSAGE_PUBLISHER } from './messager.di-tokens';
+import {
+  MessageBrokerModule,
+  MessageBrokerModuleOptions,
+  MessageBrokerPublisher,
+} from '@mobicoop/message-broker-module';
+import { ConfigModule, ConfigService } from '@nestjs/config';
+
+const imports = [
+  MessageBrokerModule.forRootAsync({
+    imports: [ConfigModule],
+    inject: [ConfigService],
+    useFactory: async (
+      configService: ConfigService,
+    ): Promise<MessageBrokerModuleOptions> => ({
+      uri: configService.get<string>('MESSAGE_BROKER_URI'),
+      exchange: configService.get<string>('MESSAGE_BROKER_EXCHANGE'),
+      name: 'auth',
+      handlers: {
+        userUpdated: {
+          routingKey: 'user.updated',
+          queue: 'auth-user-updated',
+        },
+        userDeleted: {
+          routingKey: 'user.deleted',
+          queue: 'auth-user-deleted',
+        },
+      },
+    }),
+  }),
+];
+
+const providers: Provider[] = [
+  {
+    provide: MESSAGE_PUBLISHER,
+    useClass: MessageBrokerPublisher,
+  },
+];
+
+@Module({
+  imports,
+  providers,
+  exports: [MESSAGE_PUBLISHER],
+})
+export class MessagerModule {}