feat: send xgeeks board phase to slack

backend/src/libs/constants/slack.ts

@@ -3,3 +3,5 @@ export const SLACK_API_BOT_TOKEN = 'slack.botToken';
 export const SLACK_CHANNEL_PREFIX = 'slack.channelPrefix';
 
 export const SLACK_MASTER_CHANNEL_ID = 'slack.masterChannelId';
+
+export const SLACK_ENABLE = 'slack.enable';

backend/src/modules/boards/controller/boards.controller.spec.ts

@@ -1,3 +1,5 @@
+import { ConfigService } from '@nestjs/config';
+import configService from 'src/libs/test-utils/mocks/configService.mock';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { getModelToken } from '@nestjs/mongoose';
 import { SchedulerRegistry } from '@nestjs/schedule';
@@ -84,6 +86,10 @@ describe('BoardsController', () => {
 					provide: getModelToken('TeamUser'),
 					useValue: {}
 				},
+				{
+					provide: ConfigService,
+					useValue: configService
+				},
 				{
 					provide: getModelToken('Schedules'),
 					useValue: {
@@ -101,6 +107,12 @@ describe('BoardsController', () => {
 					useValue: {
 						execute: jest.fn()
 					}
+				},
+				{
+					provide: CommunicationsType.TYPES.services.SlackSendMessageService,
+					useValue: {
+						execute: jest.fn()
+					}
 				}
 			]
 		}).compile();

backend/src/modules/boards/services/update.board.service.ts

@@ -34,6 +34,12 @@ import { BOARD_PHASE_SERVER_UPDATED } from 'src/libs/constants/phase';
 import { EventEmitter2 } from '@nestjs/event-emitter';
 import { BoardPhaseDto } from 'src/libs/dto/board-phase.dto';
 import PhaseChangeEvent from 'src/modules/socket/events/user-updated-phase.event';
+import { SendMessageServiceInterface } from 'src/modules/communication/interfaces/send-message.service.interface';
+import { SlackMessageDto } from 'src/modules/communication/dto/slack.message.dto';
+import { SLACK_ENABLE, SLACK_MASTER_CHANNEL_ID } from 'src/libs/constants/slack';
+import { ConfigService } from '@nestjs/config';
+import { BoardPhases } from 'src/libs/enum/board.phases';
+
 
 @Injectable()
 export default class UpdateBoardServiceImpl implements UpdateBoardServiceInterface {
@@ -43,14 +49,19 @@ export default class UpdateBoardServiceImpl implements UpdateBoardServiceInterfa
 		private getTeamService: GetTeamServiceInterface,
 		@Inject(CommunicationsType.TYPES.services.SlackCommunicationService)
 		private slackCommunicationService: CommunicationServiceInterface,
+		@Inject(CommunicationsType.TYPES.services.SlackSendMessageService)
+		private slackSendMessageService: SendMessageServiceInterface,
+
 		@InjectModel(BoardUser.name)
 		private boardUserModel: Model<BoardUserDocument>,
 		private socketService: SocketGateway,
 		@Inject(Cards.TYPES.services.DeleteCardService)
 		private deleteCardService: DeleteCardService,
 		@Inject(Boards.TYPES.repositories.BoardRepository)
 		private readonly boardRepository: BoardRepositoryInterface,
-		private eventEmitter: EventEmitter2
+		private eventEmitter: EventEmitter2,
+		private configService: ConfigService
+
 	) {}
 
 	/**
@@ -483,7 +494,7 @@ export default class UpdateBoardServiceImpl implements UpdateBoardServiceInterfa
 	async updatePhase(boardPhaseDto: BoardPhaseDto) {
 		try {
 			const { boardId, phase } = boardPhaseDto;
-			await this.boardModel
+			const board = await this.boardModel
 				.findOneAndUpdate(
 					{
 						_id: boardId
@@ -495,11 +506,46 @@ export default class UpdateBoardServiceImpl implements UpdateBoardServiceInterfa
 				.exec();
 
 			this.eventEmitter.emit(BOARD_PHASE_SERVER_UPDATED, new PhaseChangeEvent(boardPhaseDto));
+			const team = await this.getTeamService.getTeam((board.team as ObjectId).toString());
+
+			//Sends message to SLACK
+			if (
+				team.name === 'xgeeks' &&
+				board.slackEnable === true &&
+				board.phase !== BoardPhases.ADDCARDS &&
+				this.configService.getOrThrow(SLACK_ENABLE)
+			) {
+				const message = this.generateMessage(phase, boardId);
+				const slackMessageDto = new SlackMessageDto(
+					this.configService.getOrThrow(SLACK_MASTER_CHANNEL_ID),
+					message
+				);
+				this.slackSendMessageService.execute(slackMessageDto);
+			}
 		} catch (err) {
 			throw new BadRequestException(UPDATE_FAILED);
 		}
 	}
 
+	private generateMessage(phase: string, boardId: string): string {
+		const today = new Date();
+
+		if (phase === BoardPhases.VOTINGPHASE) {
+			return `Hello team, <https://split.kigroup.de/boards/${boardId}|here> is the ${today.toLocaleString(
+				'default',
+				{
+					month: 'long'
+				}
+			)} Retro Board \n\n <https://split.kigroup.de/boards/${boardId}> \n\n Take a look and please add your votes. \n\nThank you for your collaboration! :ok_hand: Keep rocking :rocket:`;
+		}
+
+		if (phase == BoardPhases.SUBMITED) {
+			return `Hello team, the  ${today.toLocaleString('default', {
+				month: 'long'
+			})} Retro Board was submited \n\nThank you for your collaboration! :ok_hand: Keep rocking :rocket:`;
+		}
+	}
+
 	private async addBoardUsers(boardUsers: BoardUserDto[]) {
 		const createdBoardUsers = await this.boardUserModel.insertMany(boardUsers);
 

backend/src/modules/columns/controller/columns.controller.spec.ts

@@ -1,3 +1,5 @@
+import { ConfigService } from '@nestjs/config';
+import configService from 'src/libs/test-utils/mocks/configService.mock';
 import { EventEmitterModule } from '@nestjs/event-emitter';
 import { getModelToken } from '@nestjs/mongoose';
 import { SchedulerRegistry } from '@nestjs/schedule';
@@ -84,6 +86,10 @@ describe('ColumnsController', () => {
 					provide: getModelToken('TeamUser'),
 					useValue: {}
 				},
+				{
+					provide: ConfigService,
+					useValue: configService
+				},
 				{
 					provide: getModelToken('Schedules'),
 					useValue: {
@@ -101,6 +107,12 @@ describe('ColumnsController', () => {
 					useValue: {
 						execute: jest.fn()
 					}
+				},
+				{
+					provide: CommunicationsType.TYPES.services.SlackSendMessageService,
+					useValue: {
+						execute: jest.fn()
+					}
 				}
 			]
 		}).compile();

backend/src/modules/communication/applications/slack-communication.application.ts

@@ -8,6 +8,7 @@ import { ChatHandlerInterface } from 'src/modules/communication/interfaces/chat.
 import { CommunicationApplicationInterface } from 'src/modules/communication/interfaces/communication.application.interface';
 import { ConversationsHandlerInterface } from 'src/modules/communication/interfaces/conversations.handler.interface';
 import { UsersHandlerInterface } from 'src/modules/communication/interfaces/users.handler.interface';
+import { SlackMessageDto } from '../dto/slack.message.dto';
 
 export class SlackCommunicationApplication implements CommunicationApplicationInterface {
 	private logger = new Logger(SlackCommunicationApplication.name);
@@ -30,6 +31,10 @@ export class SlackCommunicationApplication implements CommunicationApplicationIn
 		return teams;
 	}
 
+	public async postMessageOnChannel(data: SlackMessageDto): Promise<void> {
+		this.chatHandler.postMessage(data.slackChannelId, data.message);
+	}
+
 	private async postMessageOnMasterChannel(teams: TeamDto[]): Promise<void> {
 		const textGeneralTeams = teams
 			.filter((i) => i.for === BoardRoles.MEMBER)

backend/src/modules/communication/communication.module.ts

@@ -13,6 +13,7 @@ import {
 	ConversationsHandler,
 	MergeBoardApplication,
 	ResponsibleApplication,
+	SendMessageService,
 	UsersHandler
 } from 'src/modules/communication/communication.providers';
 import { SlackArchiveChannelConsumer } from 'src/modules/communication/consumers/slack-archive-channel.consumer';
@@ -22,9 +23,11 @@ import { SlackCommunicationProducer } from 'src/modules/communication/producers/
 import { SlackAddUserToChannelConsumer } from './consumers/slack-add-user-channel.consummer';
 import { SlackMergeBoardConsumer } from './consumers/slack-merge-board.consumer';
 import { SlackResponsibleConsumer } from './consumers/slack-responsible.consumer';
+import { SlackSendMessageConsumer } from './consumers/slack-send-message.consumer';
 import { SlackAddUserToChannelProducer } from './producers/slack-add-user-channel.producer';
 import { SlackMergeBoardProducer } from './producers/slack-merge-board.producer';
 import { SlackResponsibleProducer } from './producers/slack-responsible.producer';
+import { SlackSendMessageProducer } from './producers/slack-send-message-channel.producer';
 
 @Module({
 	imports: [
@@ -85,13 +88,25 @@ import { SlackResponsibleProducer } from './producers/slack-responsible.producer
 							removeOnComplete: SlackAddUserToChannelProducer.REMOVE_ON_COMPLETE,
 							priority: SlackAddUserToChannelProducer.PRIORITY
 						}
+					}),
+					BullModule.registerQueue({
+						name: SlackSendMessageProducer.QUEUE_NAME,
+						defaultJobOptions: {
+							attempts: SlackSendMessageProducer.ATTEMPTS,
+							backoff: SlackSendMessageProducer.BACKOFF,
+							delay: SlackSendMessageProducer.DELAY,
+							removeOnFail: SlackSendMessageProducer.REMOVE_ON_FAIL,
+							removeOnComplete: SlackSendMessageProducer.REMOVE_ON_COMPLETE,
+							priority: SlackSendMessageProducer.PRIORITY
+						}
 					})
 			  ]
 			: [])
 	],
 	providers: [
 		CommunicationService,
 		ArchiveChannelService,
+		SendMessageService,
 		...(configuration().slack.enable
 			? [
 					CommunicationGateAdapter,
@@ -103,6 +118,8 @@ import { SlackResponsibleProducer } from './producers/slack-responsible.producer
 					ResponsibleApplication,
 					MergeBoardApplication,
 					AddUserIntoChannelApplication,
+					SlackSendMessageConsumer,
+					SlackSendMessageProducer,
 					SlackCommunicationProducer,
 					SlackCommunicationConsumer,
 					SlackResponsibleProducer,
@@ -116,6 +133,6 @@ import { SlackResponsibleProducer } from './producers/slack-responsible.producer
 			  ]
 			: [])
 	],
-	exports: [CommunicationService, ArchiveChannelService]
+	exports: [CommunicationService, ArchiveChannelService, SendMessageService]
 })
 export class CommunicationModule {}

backend/src/modules/communication/communication.providers.ts

@@ -23,6 +23,7 @@ import { SlackCommunicationService } from 'src/modules/communication/services/sl
 import { SlackDisabledCommunicationService } from 'src/modules/communication/services/slack-disabled-communication.service';
 import { SlackAddUserIntoChannelApplication } from './applications/slack-add-user-channel.application';
 import { UsersSlackHandler } from './handlers/users-slack.handler';
+import { SlackSendMessageService } from './services/slack-send-messages.service';
 
 export const CommunicationGateAdapter = {
 	provide: SlackCommunicationGateAdapter,
@@ -146,3 +147,10 @@ export const ArchiveChannelService = {
 		? SlackArchiveChannelService
 		: SlackDisabledCommunicationService
 };
+
+export const SendMessageService = {
+	provide: TYPES.services.SlackSendMessageService,
+	useClass: configuration().slack.enable
+		? SlackSendMessageService
+		: SlackDisabledCommunicationService
+};

backend/src/modules/communication/consumers/slack-send-message.consumer.ts

@@ -0,0 +1,33 @@
+import { Process, Processor } from '@nestjs/bull';
+import { SlackSendMessageProducer } from '../producers/slack-send-message-channel.producer';
+import { SlackMessageType } from 'src/modules/communication/dto/types';
+import { TYPES } from 'src/modules/communication/interfaces/types';
+import { Job } from 'bull';
+import { Inject, Logger } from '@nestjs/common';
+import { SlackCommunicationEventListeners } from './slack-communication-event-listeners';
+import { CommunicationApplicationInterface } from 'src/modules/communication/interfaces/communication.application.interface';
+
+@Processor(SlackSendMessageProducer.QUEUE_NAME)
+export class SlackSendMessageConsumer extends SlackCommunicationEventListeners<
+	SlackMessageType,
+	SlackMessageType
+> {
+	constructor(
+		@Inject(TYPES.application.SlackCommunicationApplication)
+		private readonly application: CommunicationApplicationInterface
+	) {
+		const logger = new Logger(SlackSendMessageProducer.name);
+		super(logger);
+	}
+
+	@Process()
+	override async communication(job: Job<SlackMessageType>) {
+		const { slackChannelId } = job.data;
+
+		this.logger.verbose(
+			`execute communication for board with id: "${slackChannelId}" and Job id: "${job.id}" (pid ${process.pid})`
+		);
+
+		this.application.postMessageOnChannel(job.data);
+	}
+}

backend/src/modules/communication/dto/slack.message.dto.ts

@@ -0,0 +1,9 @@
+export class SlackMessageDto {
+	slackChannelId!: string;
+	message!: string;
+
+	constructor(slackChannelId: string, message: string) {
+		this.slackChannelId = slackChannelId;
+		this.message = message;
+	}
+}

backend/src/modules/communication/dto/types.ts

@@ -83,3 +83,8 @@ export type ArchiveChannelData = {
 export type AddUserMainChannelType = {
 	email: string;
 };
+
+export type SlackMessageType = {
+	slackChannelId: string;
+	message: string;
+};

backend/src/modules/communication/interfaces/communication.application.interface.ts

@@ -1,6 +1,7 @@
 import { TeamDto } from 'src/modules/communication/dto/team.dto';
-import { BoardType } from 'src/modules/communication/dto/types';
+import { BoardType, SlackMessageType } from 'src/modules/communication/dto/types';
 
 export interface CommunicationApplicationInterface {
 	execute(board: BoardType): Promise<TeamDto[]>;
+	postMessageOnChannel(slackMessage: SlackMessageType): Promise<void>;
 }

backend/src/modules/communication/interfaces/send-message.service.interface.ts

@@ -0,0 +1,5 @@
+import { SlackMessageType } from '../dto/types';
+
+export interface SendMessageServiceInterface {
+	execute(data: SlackMessageType): Promise<void>;
+}

backend/src/modules/communication/interfaces/types.ts

@@ -8,6 +8,7 @@ export const TYPES = {
 	},
 	services: {
 		SlackCommunicationService: 'SlackCommunicationService',
-		SlackArchiveChannelService: 'SlackArchiveChannelService'
+		SlackArchiveChannelService: 'SlackArchiveChannelService',
+		SlackSendMessageService: 'SlackSendMessageService'
 	}
 };

backend/src/modules/communication/producers/slack-send-message-channel.producer.ts

@@ -0,0 +1,39 @@
+import { InjectQueue } from '@nestjs/bull';
+import { Injectable, Logger } from '@nestjs/common';
+import { Job, Queue } from 'bull';
+import { SlackMessageType } from 'src/modules/communication/dto/types';
+
+@Injectable()
+export class SlackSendMessageProducer {
+	private logger = new Logger(SlackSendMessageProducer.name);
+
+	public static readonly QUEUE_NAME = SlackSendMessageProducer.name;
+
+	public static readonly ATTEMPTS = 3;
+
+	public static readonly BACKOFF = 3;
+
+	public static readonly DELAY = 0;
+
+	public static readonly REMOVE_ON_COMPLETE = true;
+
+	public static readonly REMOVE_ON_FAIL = true;
+
+	public static readonly PRIORITY = 1;
+
+	constructor(
+		@InjectQueue(SlackSendMessageProducer.QUEUE_NAME)
+		private readonly queue: Queue
+	) {}
+
+	// Job Options https://docs.nestjs.com/techniques/queues#job-options
+	async send(data: SlackMessageType): Promise<Job<SlackMessageType>> {
+		const job = await this.queue.add(data);
+
+		this.logger.verbose(
+			`Add SlackMessage with SlackChannelid: "${data.slackChannelId}" to queue with Job id: "${job.id}"`
+		);
+
+		return job;
+	}
+}

backend/src/modules/communication/services/slack-send-messages.service.ts

@@ -0,0 +1,17 @@
+import { Inject, Injectable } from '@nestjs/common';
+import { SlackMessageType } from '../dto/types';
+import { SendMessageServiceInterface } from '../interfaces/send-message.service.interface';
+import { SlackSendMessageProducer } from '../producers/slack-send-message-channel.producer';
+
+@Injectable()
+export class SlackSendMessageService implements SendMessageServiceInterface {
+	constructor(
+		@Inject(SlackSendMessageProducer)
+		private readonly slackSendMessageProducer: SlackSendMessageProducer
+	) {}
+
+	//TODO: send message to the producer
+	public async execute(data: SlackMessageType): Promise<void> {
+		this.slackSendMessageProducer.send(data);
+	}
+}