feat: add twitch message version

apps/azkaban-gateway/src/app/core/twitch-message-service.module.ts

@@ -0,0 +1,25 @@
+import { Module } from '@nestjs/common';
+import { ClientsModule } from '@nestjs/microservices';
+import {
+	clientProvider,
+	twitch_messages,
+	twitch_vhost,
+} from '@toxictoast/azkaban-broker-rabbitmq';
+import { brokerDefaultSettings } from './broker-defaults';
+
+@Module({
+	imports: [
+		ClientsModule.register([
+			{
+				name: 'TWITCH_MESSAGE_SERVICE',
+				...clientProvider({
+					queueName: twitch_messages,
+					brokerVHost: twitch_vhost,
+					...brokerDefaultSettings,
+				}),
+			},
+		]),
+	],
+	exports: [ClientsModule],
+})
+export class TwitchMessageServiceModule {}

apps/azkaban-gateway/src/app/version/twitch-versions.service.ts

@@ -4,6 +4,7 @@ import {
 	TwitchBotTopics,
 	RmqRecordBuilderHelper,
 	TwitchViewerTopics,
+	TwitchMessageTopics,
 } from '@toxictoast/azkaban-broker-rabbitmq';
 
 @Injectable()
@@ -12,6 +13,8 @@ export class TwitchVersionsService {
 		@Inject('TWITCH_BOT_SERVICE') private readonly botClient: ClientProxy,
 		@Inject('TWITCH_VIEWER_SERVICE')
 		private readonly viewerClient: ClientProxy,
+		@Inject('TWITCH_MESSAGE_SERVICE')
+		private readonly messageClient: ClientProxy,
 	) {}
 
 	private async getBotVersion() {
@@ -28,13 +31,22 @@ export class TwitchVersionsService {
 			.toPromise();
 	}
 
+	private async getMessageVersion() {
+		const payload = RmqRecordBuilderHelper({});
+		return await this.messageClient
+			.send(TwitchMessageTopics.VERSION, payload)
+			.toPromise();
+	}
+
 	async getTwitchVersions() {
 		const bot = await this.getBotVersion();
 		const viewer = await this.getViewerVersion();
+		const message = await this.getMessageVersion();
 		//
 		return {
 			bot,
 			viewer,
+			message,
 		};
 	}
 }

apps/azkaban-gateway/src/app/version/version.module.ts

@@ -27,6 +27,7 @@ import { AzkabanVersionsService } from './azkaban-versions.service';
 import { TwitchBotServiceModule } from '../core/twitch-bot-service.module';
 import { TwitchVersionsService } from './twitch-versions.service';
 import { TwitchViewerServiceModule } from '../core/twitch-viewer-service.module';
+import { TwitchMessageServiceModule } from '../core/twitch-message-service.module';
 
 @Module({
 	imports: [
@@ -55,6 +56,7 @@ import { TwitchViewerServiceModule } from '../core/twitch-viewer-service.module'
 		// Twitch Services
 		TwitchBotServiceModule,
 		TwitchViewerServiceModule,
+		TwitchMessageServiceModule,
 	],
 	controllers: [VersionController],
 	providers: [