feat: update

Author: hi02102002

server/src/queues/mail.queue.ts

@@ -13,27 +13,37 @@ export class SendMailQueue extends Queue {
     })
   }
 
-  async addJob(data: Parameters<typeof sendMail>[0]) {
-    const lastSubmissionTime = await redis.get(`send-email:${data.to}`)
-    const currentTime = new Date().getTime()
-    if (
-      lastSubmissionTime &&
-      currentTime - parseInt(lastSubmissionTime) < 60 * 1000
-    ) {
-      throw new HttpException(429, 'You can only send email once per minute')
+  async addJob({
+    isPreventSpam = true,
+    ...data
+  }: Parameters<typeof sendMail>[0] & {
+    isPreventSpam?: boolean
+  }) {
+    if (isPreventSpam) {
+      const lastSubmissionTime = await redis.get(`send-email:${data.to}`)
+      const currentTime = new Date().getTime()
+      if (
+        lastSubmissionTime &&
+        currentTime - parseInt(lastSubmissionTime) < 60 * 1000
+      ) {
+        throw new HttpException(429, 'You can only send email once per minute')
+      }
     }
 
     const job = await this.add('send-mail', data, {
-      attempts: 3,
+      attempts: 1,
       backoff: {
         type: 'exponential',
         delay: 1000,
       },
-      removeOnComplete: true,
-      removeOnFail: true,
     })
 
-    await redis.set(`send-email:${data.to}`, currentTime.toString(), 'EX', 60)
+    await redis.set(
+      `send-email:${data.to}`,
+      new Date().getTime().toString(),
+      'EX',
+      60,
+    )
 
     return job
   }

server/src/services/bot-mail.service.ts

@@ -41,6 +41,7 @@ export class BotMailService {
       template: template as any,
       pass: password,
       user: email,
+      isPreventSpam: false,
     })
   }
 }