fix:format code
This commit is contained in:
1 parent
88a39fe502
commit
1706012e54
4 files changed
+19
-11
No files matched your search
@@ -410,12 +410,12 @@ class MonitorController {
|
||||
// Verify all requested notification IDs actually belong to this team
|
||||
const teamNotifications = await this.notificationsService.findNotificationsByTeamId(teamId);
|
||||
const validNotificationIds = teamNotifications.map((n) => n.id);
|
||||
|
||||
|
||||
const invalidIds = notificationIds.filter((id: string) => !validNotificationIds.includes(id));
|
||||
if (invalidIds.length > 0) {
|
||||
throw new AppError({
|
||||
message: `The following notification IDs are invalid or do not belong to your team: ${invalidIds.join(", ")}`,
|
||||
status: 403
|
||||
throw new AppError({
|
||||
message: `The following notification IDs are invalid or do not belong to your team: ${invalidIds.join(", ")}`,
|
||||
status: 403,
|
||||
});
|
||||
}
|
||||
|
||||
@@ -423,7 +423,7 @@ class MonitorController {
|
||||
teamId,
|
||||
monitorIds,
|
||||
notificationIds,
|
||||
action
|
||||
action,
|
||||
});
|
||||
|
||||
return res.status(200).json({
|
||||
|
||||
@@ -126,7 +126,6 @@ class NotificationController {
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
testAllNotifications = async (req: Request, res: Response, next: NextFunction) => {
|
||||
try {
|
||||
const validatedBody = testAllNotificationsBodyValidation.parse(req.body);
|
||||
|
||||
@@ -17,7 +17,6 @@ class NotificationRoutes {
|
||||
|
||||
this.router.get("/team", this.notificationController.getNotificationsByTeamId);
|
||||
|
||||
|
||||
this.router.get("/:id", this.notificationController.getNotificationById);
|
||||
this.router.delete("/:id", this.notificationController.deleteNotification);
|
||||
this.router.patch("/:id", this.notificationController.editNotification);
|
||||
|
||||
@@ -438,15 +438,25 @@ export class MonitorService implements IMonitorService {
|
||||
return editedMonitor;
|
||||
};
|
||||
|
||||
updateNotifications = async ({ teamId, monitorIds, notificationIds, action }: { teamId: string; monitorIds: string[]; notificationIds: string[]; action: "add" | "remove" | "set" }): Promise<number> => {
|
||||
updateNotifications = async ({
|
||||
teamId,
|
||||
monitorIds,
|
||||
notificationIds,
|
||||
action,
|
||||
}: {
|
||||
teamId: string;
|
||||
monitorIds: string[];
|
||||
notificationIds: string[];
|
||||
action: "add" | "remove" | "set";
|
||||
}): Promise<number> => {
|
||||
const modifiedCount = await this.monitorsRepository.updateNotifications(monitorIds, notificationIds, action, teamId);
|
||||
|
||||
|
||||
// If notifications were updated, we should update the jobs in the queue
|
||||
if (modifiedCount > 0) {
|
||||
const monitors = await this.monitorsRepository.findByIds(monitorIds);
|
||||
await Promise.all(monitors.map(monitor => this.jobQueue.updateJob(monitor)));
|
||||
await Promise.all(monitors.map((monitor) => this.jobQueue.updateJob(monitor)));
|
||||
}
|
||||
|
||||
|
||||
return modifiedCount;
|
||||
};
|
||||
|
||||
|
||||
Reference in new issue
Block a user