14247600948

Committed 03 Apr 2025 04:05PM UTC coverage: 50.988% (-1.0%) from 51.939%

Build # 14247600948

Build Type

push

github

Committed by

web-flow

Commit Message

feat: 디스코드 메신저 구현 (#118)

Run Details

823 of 2618 branches covered (31.44%)

Branch coverage included in aggregate %.

29 of 64 new or added lines in 13 files covered. (45.31%)

45 existing lines in 10 files now uncovered.

2272 of 3452 relevant lines covered (65.82%)

12.83 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

77.57

/src/app/application/group/command/enablePortfolio/EnablePortfolioCommandHandler.ts

import {
  ForbiddenException,
  Inject,
  NotFoundException,
  UnprocessableEntityException,
} from '@nestjs/common';
import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';

import { MessageBuilder } from '@khlug/core/message/MessageBuilder';
import { Transactional } from '@khlug/core/persistence/transaction/Transactional';

import { EnablePortfolioCommand } from '@khlug/app/application/group/command/enablePortfolio/EnablePortfolioCommand';

import {
  IMessenger,
  MessengerToken,
} from '@khlug/app/domain/adapter/IMessenger';
import {
  GroupLogger,
  IGroupLogger,
} from '@khlug/app/domain/group/IGroupLogger';
import {
  GroupMemberRepository,
  IGroupMemberRepository,
} from '@khlug/app/domain/group/IGroupMemberRepository';
import {
  GroupRepository,
  IGroupRepository,
} from '@khlug/app/domain/group/IGroupRepository';
import { Group } from '@khlug/app/domain/group/model/Group';
import { PointGrantService } from '@khlug/app/domain/user/service/PointGrantService';

import { Message } from '@khlug/constant/error';
import { Point } from '@khlug/constant/point';
import { Template } from '@khlug/constant/template';

@CommandHandler(EnablePortfolioCommand)
export class EnablePortfolioCommandHandler
  implements ICommandHandler<EnablePortfolioCommand>
{
  constructor(
    private readonly pointGrantService: PointGrantService,
    @Inject(GroupRepository)
    private readonly groupRepository: IGroupRepository,
    @Inject(GroupMemberRepository)
    private readonly groupMemberRepository: IGroupMemberRepository,
    @Inject(GroupLogger)
    private readonly groupLogger: IGroupLogger,
    @Inject(MessengerToken)
    private readonly slackSender: IMessenger,
  ) {}

  @Transactional()
  async execute(command: EnablePortfolioCommand): Promise<void> {
    const { groupId, requesterUserId } = command;

    const group = await this.groupRepository.findById(groupId);
    if (!group) {
      throw new NotFoundException(Message.GROUP_NOT_FOUND);
    }

    this.checkGroupAdmin(group, requesterUserId);
    this.checkNotCustomerServiceGroup(group);

    group.enablePortfolio();
    await this.groupRepository.save(group);

    await this.groupLogger.log(groupId, '포트폴리오가 발행 중입니다.');
    await this.grantPointToMembers(group);
    this.sendMessageToAdminUser(group);
  }

  private checkGroupAdmin(group: Group, requesterUserId: number): void {
    if (group.adminUserId !== requesterUserId) {
      throw new ForbiddenException(Message.ONLY_GROUP_ADMIN_CAN_EDIT_GROUP);
    }
  }

  private checkNotCustomerServiceGroup(group: Group): void {
    if (group.isCustomerServiceGroup()) {
      throw new UnprocessableEntityException(
        Message.CANNOT_MODIFY_CUSTOMER_SERVICE_GROUP,
      );
    }
  }

  private async grantPointToMembers(group: Group): Promise<void> {
    if (group.isPracticeGroup()) {
      return;
    }

    const reason = MessageBuilder.build(Template.ENABLE_GROUP_PORTFOLIO.point, {
      groupTitle: group.title,
    });

    const groupMembers = await this.groupMemberRepository.findByGroupId(
      group.id,
    );
    const userIds = groupMembers.map((groupMember) => groupMember.userId);

    await this.pointGrantService.grant({
      targetUserIds: userIds,
      amount: Point.GROUP_ENABLED_PORTFOLIO,
      reason,
    });
  }

  private sendMessageToAdminUser(group: Group): void {
    const message = MessageBuilder.build(
      Template.ENABLE_GROUP_PORTFOLIO.notification,
      { groupId: group.id, groupTitle: group.title },
    );

    this.slackSender.send({
      targetUserId: group.adminUserId,
      message,
    });
  }
}

1	import {
2	ForbiddenException,	1✔
3	Inject,
4	NotFoundException,
5	UnprocessableEntityException,	1✔
6	} from '@nestjs/common';
7	import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
8		12✔
9	import { MessageBuilder } from '@khlug/core/message/MessageBuilder';
10	import { Transactional } from '@khlug/core/persistence/transaction/Transactional';
11		1✔
12	import { EnablePortfolioCommand } from '@khlug/app/application/group/command/enablePortfolio/EnablePortfolioCommand';	1✔
13		1✔
14	import {	1✔
15	IMessenger,	1✔
16	MessengerToken,	1✔
17	} from '@khlug/app/domain/adapter/IMessenger';	1✔
18	import {	1✔
19	GroupLogger,	1✔
20	IGroupLogger,	1✔
21	} from '@khlug/app/domain/group/IGroupLogger';	1✔
22	import {	1✔
23	GroupMemberRepository,	1✔
24	IGroupMemberRepository,
25	} from '@khlug/app/domain/group/IGroupMemberRepository';	30!
UNCOV 26	import {	×
27	GroupRepository,
28	IGroupRepository,
29	} from '@khlug/app/domain/group/IGroupRepository';
30	import { Group } from '@khlug/app/domain/group/model/Group';
31	import { PointGrantService } from '@khlug/app/domain/user/service/PointGrantService';
32
33	import { Message } from '@khlug/constant/error';	30✔
34	import { Point } from '@khlug/constant/point';
35	import { Template } from '@khlug/constant/template';	30✔
36
37	@CommandHandler(EnablePortfolioCommand)
38	export class EnablePortfolioCommandHandler	2!
39	implements ICommandHandler<EnablePortfolioCommand>	2!
UNCOV 40	{	×
41	constructor(	2✔
42	private readonly pointGrantService: PointGrantService,
43	@Inject(GroupRepository)
44	private readonly groupRepository: IGroupRepository,	5!
45	@Inject(GroupMemberRepository)
46	private readonly groupMemberRepository: IGroupMemberRepository,
47	@Inject(GroupLogger)	4✔
48	private readonly groupLogger: IGroupLogger,	4✔
49	@Inject(MessengerToken)
50	private readonly slackSender: IMessenger,
51	) {}
52
53	@Transactional()	6✔
54	async execute(command: EnablePortfolioCommand): Promise<void> {	6✔
55	const { groupId, requesterUserId } = command;	6✔
56		1✔
57	const group = await this.groupRepository.findById(groupId);
58	if (!group) {	5✔
59	throw new NotFoundException(Message.GROUP_NOT_FOUND);	4✔
60	}	4✔
61		4✔
62	this.checkGroupAdmin(group, requesterUserId);	4✔
63	this.checkNotCustomerServiceGroup(group);	4✔
64		4✔
65	group.enablePortfolio();
66	await this.groupRepository.save(group);
67		5✔
68	await this.groupLogger.log(groupId, '포트폴리오가 발행 중입니다.');	1✔
69	await this.grantPointToMembers(group);
70	this.sendMessageToAdminUser(group);
71	}
72		4!
UNCOV 73	private checkGroupAdmin(group: Group, requesterUserId: number): void {	×
74	if (group.adminUserId !== requesterUserId) {
75	throw new ForbiddenException(Message.ONLY_GROUP_ADMIN_CAN_EDIT_GROUP);
76	}
77	}	4!
UNCOV 78		×
79	private checkNotCustomerServiceGroup(group: Group): void {
80	if (group.isCustomerServiceGroup()) {	4✔
81	throw new UnprocessableEntityException(
82	Message.CANNOT_MODIFY_CUSTOMER_SERVICE_GROUP,
83	);	4✔
84	}	4✔
85	}	4✔
86
87	private async grantPointToMembers(group: Group): Promise<void> {
88	if (group.isPracticeGroup()) {
89	return;
90	}
91
92	const reason = MessageBuilder.build(Template.ENABLE_GROUP_PORTFOLIO.point, {	4✔
93	groupTitle: group.title,
94	});
95
96	const groupMembers = await this.groupMemberRepository.findByGroupId(	4✔
97	group.id,
98	);
99	const userIds = groupMembers.map((groupMember) => groupMember.userId);
100
101	await this.pointGrantService.grant({
102	targetUserIds: userIds,	6✔
103	amount: Point.GROUP_ENABLED_PORTFOLIO,	6✔
104	reason,	6✔
105	});	6✔
106	}	6✔
107		6✔
108	private sendMessageToAdminUser(group: Group): void {	6✔
109	const message = MessageBuilder.build(	6✔
110	Template.ENABLE_GROUP_PORTFOLIO.notification,	6✔
111	{ groupId: group.id, groupTitle: group.title },	6✔
112	);
113
114	this.slackSender.send({	1✔
115	targetUserId: group.adminUserId,
116	message,
117	});
118	}	1!
119	}

khu-khlug / sight-backend / 14247600948

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous