all

src/bots/botManager.ts

@@ -75,7 +75,15 @@ export const initializeBot = async (botToken: string, botData?: BotData) => {
     setupCallbackHandlers(bot);
     
     // Set bot commands
-    // await bot.telegram.setMyCommands(BotCommands);
+    try {
+      await bot.telegram.setMyCommands(BotCommands, {
+        scope: { type: 'default' }
+      });
+      logger.info('Bot commands set successfully');
+    } catch (error: any) {
+      logger.error(`Failed to set bot commands: ${error.message}`);
+      // Continue initialization even if setting commands fails
+    }
     
     return { 
       success: true, 
@@ -88,6 +96,26 @@ export const initializeBot = async (botToken: string, botData?: BotData) => {
   }
 };
 
+// Utility function to update bot status in database
+const updateBotStatus = async (botId: string, isActive: boolean, error?: string) => {
+  try {
+    await supabase
+      .from('bots')
+      .update({
+        is_active: isActive,
+        last_activity: new Date().toISOString(),
+        state: {
+          status: isActive ? 'running' : 'error',
+          startedAt: isActive ? new Date().toISOString() : undefined,
+          error: error
+        }
+      })
+      .eq('id', botId);
+  } catch (error: any) {
+    logger.error(`Error updating bot status: ${error.message}`);
+  }
+};
+
 export const stopBot = async (botId: string) => {
   try {
     // Get bot token from database
@@ -98,6 +126,7 @@ export const stopBot = async (botId: string) => {
       .single();
       
     if (error || !botData) {
+      await updateBotStatus(botId, false, "Bot not found in database");
       return { success: false, message: "Bot not found in database" };
     }
     
@@ -109,22 +138,17 @@ export const stopBot = async (botId: string) => {
       telegrafBots.delete(botToken);
       
       // Update database
-      await supabase
-        .from('bots')
-        .update({
-          is_active: false,
-          state: {
-            status: 'stopped',
-            stoppedAt: new Date().toISOString()
-          }
-        })
-        .eq('id', botId);
-        
+      await updateBotStatus(botId, false);
       return { success: true, message: "Bot stopped successfully" };
     }
+    
+    // Bot instance not found
+    await updateBotStatus(botId, false, "Bot instance not found");
+  
     return { success: false, message: "Bot instance not found" };
   } catch (error: any) {
     logger.error(`Error stopping bot: ${error.message}`);
+    await updateBotStatus(botId, false, error.message);
     return { success: false, message: `Failed to stop bot: ${error.message}` };
   }
 };

src/bots/index.ts

@@ -6,6 +6,26 @@ import { setupPaymentWebhookHandlers } from './handlers/paymentWebhookHandlers';
 
 const logger = createLogger('BotManager');
 
+// Utility function to update bot status in database
+const updateBotStatus = async (botId: string, isActive: boolean, error?: string) => {
+  try {
+    await supabase
+      .from('bots')
+      .update({
+        is_active: isActive,
+        last_activity: new Date().toISOString(),
+        state: {
+          status: isActive ? 'running' : 'error',
+          startedAt: isActive ? new Date().toISOString() : undefined,
+          error: error
+        }
+      })
+      .eq('id', botId);
+  } catch (error: any) {
+    logger.error(`Error updating bot status: ${error.message}`);
+  }
+};
+
 export const handleAddTelegrafBot = async (botId: string) => {
   if (!botId) {
     return { status: 400, data: { error: "Bot ID is required" } };
@@ -50,22 +70,9 @@ export const handleAddTelegrafBot = async (botId: string) => {
         telegrafBots.set(botData.bot_token, result.bot);
         
         try {
-          // Launch the bot
-          // await result.bot.launch();
+          // Update bot status to active
+          await updateBotStatus(botId, true);
           
-          // Update last_activity and is_active in database
-          await supabase
-            .from('bots')
-            .update({
-              is_active: true,
-              last_activity: new Date().toISOString(),
-              state: {
-                status: 'running',
-                startedAt: new Date().toISOString()
-              }
-            })
-            .eq('id', botId);
-            
           logger.info(`Bot ${botData.name} (${botId}) launched successfully`);
 
           await result.bot.launch();
@@ -84,18 +91,22 @@ export const handleAddTelegrafBot = async (botId: string) => {
 
         } catch (error: any) {
           logger.error(`Error launching bot: ${error.message}`);
+          await updateBotStatus(botId, false, error.message);
           return { status: 500, data: { error: `Error launching bot: ${error.message}` } };
         }
       } else {
         logger.error(`Error initializing bot: ${result.message}`);
+        await updateBotStatus(botId, false, result.message);
         return { status: 500, data: { error: result.message } };
       }
     } catch (error: any) {
       logger.error(`Bot initialization error: ${error.message}`);
+      await updateBotStatus(botId, false, error.message);
       return { status: 500, data: { error: `Bot initialization error: ${error.message}` } };
     }
   } catch (error: any) {
     logger.error(`Unexpected error: ${error.message}`);
+    await updateBotStatus(botId, false, error.message);
     return { status: 500, data: { error: `Unexpected error: ${error.message}` } };
   }
 };