"Added webhook support to bot, allowing it to receive updates via HTTP requests; refactored start method to handle both webhook and long-polling modes"

Author: m-mdy-m

src/bot/index.ts

@@ -25,15 +25,69 @@ export class CopBot {
     return CopBot.instance;
   }
   async start() {
-    try {
+    const port = Config.port || 3000;
+    const isProduction = Config.environment === 'production';
+    if (isProduction) {
+      const server = http.createServer(async (req, res) => {
+        console.log('method', req.method);
+        console.log('url', req.url);
+
+        if (req.method === 'POST' && req.url === '/webhook') {
+          let body = '';
+          req.on('data', (chunk) => {
+            body += chunk;
+          });
+          req.on('end', async () => {
+            try {
+              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);
+              if (!update || !update.id) {
+                throw new Error('Missing required field: id');
+              }
+              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;
+              res.end('Internal Server Error');
+            }
+          });
+
+          req.on('error', (err) => {
+            console.error('Request error:', err);
+            res.statusCode = 400;
+            res.end('Bad Request');
+          });
+        } else {
+          res.statusCode = 404;
+          res.end();
+        }
+      });
+      server.listen(port, '0.0.0.0', () => {
+        console.log(`Bot started on port ${port}`);
+      });
       await this._bot.start({
         onStart: (botInfo) => {
-          console.log(`Bot started in long-polling mode! Username: ${botInfo.username}`);
+          console.log(`Bot started in web-hook mode! Username: ${botInfo.username}`);
         },
       });
-    } catch (error) {
-      console.error('Error starting bot in long-polling mode:', error);
-      process.exit(1);
+    } else {
+      try {
+        await this._bot.start({
+          onStart: (botInfo) => {
+            console.log(`Bot started in long-polling mode! Username: ${botInfo.username}`);
+          },
+        });
+      } catch (error) {
+        console.error('Error starting bot in long-polling mode:', error);
+        process.exit(1);
+      }
     }
   }
   @Catch()