feat(controller): Adding Rate Limit and checking the user's userId, and if it doesn't exist, the program won't run.

Author: bitsgenix

src/controller/command.ts

@@ -4,7 +4,12 @@ import { SafeExecution } from "../decorators/SafeExecution";
 import { COMMANDS } from "../helper";
 import { AdminCommand } from "../group-management/AdminCommand";
 import { Logger } from "../config/logger";
-const logger = new Logger({ file: "command.log", level: "debug" });
+import { RateLimiter } from "../helper/RateLimiter";
+const logger = new Logger({
+  file: "command.log",
+  level: "debug",
+  timestampFormat: "locale",
+});
 
 export class Command {
   @SafeExecution()
@@ -30,7 +35,13 @@ export class Command {
       },
     });
   }
-
+  @SafeExecution()
+  static async shahin(ctx: Context) {
+    await ctx.reply("دوستان.");
+    setTimeout(() => {
+      return ctx.reply("بحث تخصصی.");
+    }, 2500);
+  }
   @SafeExecution()
   static future(ctx: Context) {
     return ctx.reply("We will go to ga", {
@@ -42,8 +53,15 @@ export class Command {
 
   @SafeExecution()
   static async handleCommand(ctx: Context): Promise<void> {
+    const userId = ctx.from?.id;
+    if (!userId) return;
+    if (!RateLimiter.limit(userId)) {
+      logger.debug(`Rate limit exceeded for user: ${userId}`, "RATE_LIMIT");
+      return;
+    }
     const command = ctx.message?.text?.split("/")[1]?.split(/[\s@]/)[0];
-    logger.debug(command, "COMMAND");
+    logger.info(`Received command: ${command}`, "COMMAND");
+
     if (command && (Command as any)[command]) {
       await (Command as any)[command](ctx);
     } else {