"Removed unnecessary code, simplified error handling, and refactored bot initialization and webhook setup."

Author: m-mdy-m

src/app.ts

@@ -12,15 +12,13 @@ async function main() {
     logger.info('Bot initialized');
   } catch (error: any) {
     logger.error('Error during initialization:', error);
-    process.exit(1); // Exit if initialization fails
+    process.exit(1);
   }
-
-  // Handle graceful shutdown on SIGTERM
   process.on('SIGTERM', async () => {
     logger.info('SIGTERM signal received. Closing bot...');
     try {
       const db = ServiceProvider.getInstance();
-      await db.close(); // Ensure DB is closed before exiting
+      await db.close();
       logger.info('Database closed.');
     } catch (error: any) {
       logger.error('Error during shutdown:', error);
@@ -29,24 +27,19 @@ async function main() {
       process.exit(0);
     }
   });
-
-  // Handle unhandled promise rejections
   process.on('unhandledRejection', (reason, promise) => {
     console.error('Unhandled Rejection at:', promise, 'reason:', reason);
-    // Consider gracefully shutting down the app here if necessary
   });
-
-  // Handle uncaught exceptions
   process.on('uncaughtException', async (error: any) => {
     logger.error('Uncaught Exception:', error);
     try {
       const db = ServiceProvider.getInstance();
-      await db.close(); // Close DB before exiting on uncaught exception
+      await db.close();
       logger.info('Database closed due to uncaught exception.');
     } catch (shutdownError: any) {
       logger.error('Error during shutdown:', shutdownError);
     } finally {
-      process.exit(1); // Exit the process on uncaught exception
+      process.exit(1);
     }
   });
 }

src/bot/index.ts

@@ -34,29 +34,24 @@ export class CopBot {
       const server = http.createServer(async (req, res) => {
         if (req.method === 'POST' && req.url === '/webhook') {
           let body = '';
-
-          // Collect data chunks
           req.on('data', (chunk) => {
             body += chunk;
           });
-
-          // Handle incoming request once the data is complete
           req.on('end', async () => {
             try {
-              // Parse the incoming JSON body
               const update = JSON.parse(body);
               if (!update) {
                 console.error('Received empty body or malformed JSON.');
                 return (res.statusCode = 400);
               }
 
               console.log('Received webhook body:', update);
-              await this._bot.handleUpdate(update); // Handle the update
-              res.statusCode = 200; // Success response to Telegram
+              await this._bot.handleUpdate(update);
+              res.statusCode = 200;
               res.end();
             } catch (error: any) {
               console.error('Error parsing JSON in webhook request:', error.message || error.stack);
-              res.statusCode = 500; // Internal Server Error
+              res.statusCode = 500;
               res.end('Internal Server Error');
             }
           });
@@ -67,26 +62,15 @@ export class CopBot {
             res.end('Bad Request');
           });
         } else {
-          res.statusCode = 404; // Not Found
+          res.statusCode = 404;
           res.end();
         }
       });
       server.listen(port, '0.0.0.0', () => {
         console.log(`Bot started on port ${port}`);
       });
-      try {
-        await this._bot.api.setWebhook(`${web_hook}`);
-        console.log(`Webhook set successfully to: ${web_hook}`);
-        const webhookStatus = await this._bot.api.getWebhookInfo();
-        if (webhookStatus.url) {
-          console.log(`Webhook is already set to: ${webhookStatus.url}`);
-        } else {
-          console.log('No webhook set.');
-        }
-      } catch (error: any) {
-        console.error('Error setting webhook:', error.message || error.stack);
-        process.exit(1); // Exit if critical error
-      }
+      await this._bot.api.setWebhook(`${web_hook}`);
+      console.log(`Webhook set successfully to: ${web_hook}`);
     } else {
       try {
         await this._bot.start({
@@ -96,7 +80,7 @@ export class CopBot {
         });
       } catch (error) {
         console.error('Error starting bot in long-polling mode:', error);
-        process.exit(1); // Exit if the bot fails to start
+        process.exit(1);
       }
     }
   }
@@ -179,9 +163,9 @@ export class CopBot {
   }
   @Catch()
   async initial(): Promise<void> {
+    await this.start();
     new GenerateCommand(this._bot).generate();
     await this.message();
-    await this.start();
     console.log('Bot Is Start');
   }
 }