diff --git a/apps/azkaban-gateway/src/app/core/twitch-message-service.module.ts b/apps/azkaban-gateway/src/app/core/twitch-message-service.module.ts new file mode 100644 index 00000000..633bfd24 --- /dev/null +++ b/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 {} diff --git a/apps/azkaban-gateway/src/app/version/twitch-versions.service.ts b/apps/azkaban-gateway/src/app/version/twitch-versions.service.ts index ce8efbe6..d2112d8b 100644 --- a/apps/azkaban-gateway/src/app/version/twitch-versions.service.ts +++ b/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, }; } } diff --git a/apps/azkaban-gateway/src/app/version/version.module.ts b/apps/azkaban-gateway/src/app/version/version.module.ts index 13f28d65..0d2ae6b3 100644 --- a/apps/azkaban-gateway/src/app/version/version.module.ts +++ b/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: [