danak/dsc-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update: force

Browse Source
This commit is contained in:
mahyargdz
2025-05-04 09:12:19 +03:30
parent 2e2154d745
commit 4da14a09cf
2 changed files with 23 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/app.module.ts
+3 -3
View File
@@ -7,13 +7,13 @@ import { ConfigModule } from "@nestjs/config";
import { ThrottlerModule } from "@nestjs/throttler"; import { ThrottlerModule } from "@nestjs/throttler";
import { TypeOrmModule } from "@nestjs/typeorm"; import { TypeOrmModule } from "@nestjs/typeorm";
import { MailerModule } from "@nestjs-modules/mailer"; import { MailerModule } from "@nestjs-modules/mailer";
import { TelegrafModule } from "nestjs-telegraf"; // import { TelegrafModule } from "nestjs-telegraf";
import { bullMqConfig } from "./configs/bullmq.config"; import { bullMqConfig } from "./configs/bullmq.config";
import { cacheConfig } from "./configs/cache.config"; import { cacheConfig } from "./configs/cache.config";
import { mailerConfig } from "./configs/mailer.config"; import { mailerConfig } from "./configs/mailer.config";
import { rateLimitConfig } from "./configs/rateLimit.config"; import { rateLimitConfig } from "./configs/rateLimit.config";
import { telegrafConfig } from "./configs/telegraf.config"; // import { telegrafConfig } from "./configs/telegraf.config";
import { databaseConfigs } from "./configs/typeorm.config"; import { databaseConfigs } from "./configs/typeorm.config";
import { HTTPLogger } from "./core/middlewares/logger.middleware"; import { HTTPLogger } from "./core/middlewares/logger.middleware";
import { AddressModule } from "./modules/address/address.module"; import { AddressModule } from "./modules/address/address.module";
@@ -43,7 +43,7 @@ import { MonitoringModule } from "./monitoring/monitoring.module";
@Module({ @Module({
imports: [ imports: [
TelegrafModule.forRootAsync(telegrafConfig()), // TelegrafModule.forRootAsync(telegrafConfig()),
MailerModule.forRootAsync(mailerConfig()), MailerModule.forRootAsync(mailerConfig()),
BullModule.forRootAsync(bullMqConfig()), BullModule.forRootAsync(bullMqConfig()),
ThrottlerModule.forRootAsync(rateLimitConfig()), ThrottlerModule.forRootAsync(rateLimitConfig()),
src/modules/notifications/providers/notifications.service.ts
+20 -5
View File
@@ -169,7 +169,10 @@ export class NotificationsService {
await this.smsService.sendAnnouncementSms(data.userPhone, data.title, data.description, dateFormat(data.date)); await this.smsService.sendAnnouncementSms(data.userPhone, data.title, data.description, dateFormat(data.date));
if (data.userEmail) await this.emailService.sendAnnouncementEmail(data); if (data.userEmail) await this.emailService.sendAnnouncementEmail(data);
} }
return this.createNotification({ title: NotificationMessage.ANNOUNCEMENT, type: NotifType.ANNOUNCEMENT, message, recipientId }); return this.createNotification(
{ title: NotificationMessage.ANNOUNCEMENT, type: NotifType.ANNOUNCEMENT, message, recipientId },
queryRunner,
);
} }
//************************ */ //************************ */
@@ -191,7 +194,10 @@ export class NotificationsService {
); );
if (data.userEmail) await this.emailService.sendWalletEmail(data); if (data.userEmail) await this.emailService.sendWalletEmail(data);
} }
return this.createNotification({ title: NotificationMessage.WALLET_CHARGE, type: NotifType.WALLET_CHARGE, message, recipientId }); return this.createNotification(
{ title: NotificationMessage.WALLET_CHARGE, type: NotifType.WALLET_CHARGE, message, recipientId },
queryRunner,
);
} }
//************************ */ //************************ */
@@ -214,7 +220,10 @@ export class NotificationsService {
); );
if (data.userEmail) await this.emailService.sendWalletEmail(data); if (data.userEmail) await this.emailService.sendWalletEmail(data);
} }
return this.createNotification({ title: NotificationMessage.WALLET_DEDUCTION, type: NotifType.WALLET_DEDUCTION, message, recipientId }); return this.createNotification(
{ title: NotificationMessage.WALLET_DEDUCTION, type: NotifType.WALLET_DEDUCTION, message, recipientId },
queryRunner,
);
} }
// //************************ */ // //************************ */
@@ -231,7 +240,10 @@ export class NotificationsService {
await this.smsService.sendAnswerTicketSms(data.userPhone, data.ticketId, data.subject); await this.smsService.sendAnswerTicketSms(data.userPhone, data.ticketId, data.subject);
if (data.userEmail) await this.emailService.sendTicketEmail(data); if (data.userEmail) await this.emailService.sendTicketEmail(data);
} }
return this.createNotification({ title: NotificationMessage.ANSWER_TICKET, type: NotifType.ANSWER_TICKET, message, recipientId }); return this.createNotification(
{ title: NotificationMessage.ANSWER_TICKET, type: NotifType.ANSWER_TICKET, message, recipientId },
queryRunner,
);
} }
// //************************ */ // //************************ */
@@ -248,7 +260,10 @@ export class NotificationsService {
await this.smsService.sendCreateTicketSms(data.userPhone, data.ticketId, data.subject, dateFormat(data.date)); await this.smsService.sendCreateTicketSms(data.userPhone, data.ticketId, data.subject, dateFormat(data.date));
if (data.userEmail) await this.emailService.sendTicketEmail(data); if (data.userEmail) await this.emailService.sendTicketEmail(data);
} }
return this.createNotification({ title: NotificationMessage.CREATE_TICKET, type: NotifType.CREATE_TICKET, message, recipientId }); return this.createNotification(
{ title: NotificationMessage.CREATE_TICKET, type: NotifType.CREATE_TICKET, message, recipientId },
queryRunner,
);
} }
//************************ */ //************************ */
async createAssignTicketNotificationForAdmin(recipientId: string, data: ITicketNotificationData, queryRunner: QueryRunner) { async createAssignTicketNotificationForAdmin(recipientId: string, data: ITicketNotificationData, queryRunner: QueryRunner) {