14190117854

Committed 01 Apr 2025 07:47AM UTC coverage: 51.423%. Remained the same

Build # 14190117854

Build Type

push

github

Committed by

web-flow

Commit Message

refactor: 메시지 전송 클래스 구현을 위해 기존 클래스 및 파일 이름 변경 (#115)

Run Details

796 of 2513 branches covered (31.68%)

Branch coverage included in aggregate %.

29 of 34 new or added lines in 18 files covered. (85.29%)

36 existing lines in 6 files now uncovered.

2222 of 3356 relevant lines covered (66.21%)

13.1 hits per line

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

77.78

/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 { INotifier, NotifierToken } from '@khlug/app/domain/adapter/INotifier';
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 { NotificationCategory } from '@khlug/constant/notification';
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(NotifierToken)
    private readonly slackSender: INotifier,
  ) {}

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

khu-khlug / sight-backend / 14190117854

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