fix(cop): Removed CopBot context management and rate limit notification functionality

Author: m-mdy-m

src/bot/index.ts

@@ -17,7 +17,6 @@ export class CopBot {
   private webhookPath = `/bot/${Config.token}`;
   private webhookURL = `${Config.web_hook}${this.webhookPath}`;
   private mode = this.isProduction ? 'webhook' : 'long-polling';
-  private static latestContext: Context | null = null;
   private constructor() {
     this._bot = new Bot<Context>(Config.token);
   }
@@ -28,19 +27,6 @@ export class CopBot {
     }
     return CopBot.instance;
   }
-  public static setContext(ctx: Context): void {
-    logger.info(`Setting new context: at ${new Date().toISOString()}`);
-    this.latestContext = ctx;
-  }
-
-  public static getContext(): Context | null {
-    if (this.latestContext) {
-      logger.info(`Retrieved latest context: at ${new Date().toISOString()}`);
-    } else {
-      logger.warn('Attempted to retrieve context, but no context is set.');
-    }
-    return this.latestContext;
-  }
   // Stop the bot
   async stop(): Promise<void> {
     if (this.healthCheckInterval) {
@@ -131,10 +117,7 @@ export class CopBot {
       })
     );
     this._bot.on('my_chat_member', (ctx) => this.handleJoinNewChat(ctx));
-    this._bot.on('message', (ctx) => {
-      CopBot.setContext(ctx);
-      this.handleMessage(ctx);
-    });
+    this._bot.on('message', (ctx) => this.handleMessage(ctx));
     this._bot.catch(async (error: BotError<Context>) => {
       if (error.message.includes('timeout')) {
         await error.ctx.reply('The request took too long to process. Please try again later.');

src/database/service/Database.ts

@@ -14,8 +14,6 @@ export class DatabaseService {
     } catch (error: any) {
       console.error(`Error executing query: ${sql}`, error);
       throw new Error(`Database query failed: ${error.message}`);
-    } finally {
-      this._client.release();
     }
   }
   async insert<T extends QueryResultRow>(tableName: string, data: Record<string, any>, returning: string[] = ['*']): Promise<T> {

src/service/database/ServiceProvider.ts

@@ -32,22 +32,12 @@ export class ServiceProvider {
     return ServiceProvider.instance;
   }
   private async enforceRateLimit(): Promise<void> {
-    const ctx = CopBot.getContext();
     const now = Date.now();
     if (this.lastRequestTime) {
       const elapsed = now - this.lastRequestTime;
       if (elapsed < this.requestInterval) {
         const waitTime = this.requestInterval - elapsed;
-
-        if (ctx) {
-          try {
-            await ctx.reply(`⚠️ Rate limit exceeded. Please wait for ${waitTime} ms before making another request.`);
-          } catch (error: any) {
-            logger.error(`Failed to notify user about rate limit: ${error.message}`);
-          }
-        } else {
-          logger.warn('No active context to send a rate limit message.');
-        }
+        logger.error(`⚠️ Rate limit exceeded. Please wait for ${waitTime} ms before making another request.`);
         await new Promise((resolve) => setTimeout(resolve, waitTime));
       }
     }