all

src/bots/services/BalanceUpdateService.ts

@@ -39,12 +39,13 @@ export class BalanceUpdateService {
         .on(
           'postgres_changes',
           {
-            event: '*', // Listen to all events (INSERT, UPDATE, DELETE)
+            event: 'UPDATE',
             schema: 'public',
-            table: 'users_bot_telegram'
+            table: 'users_bot_telegram',
+            filter: 'balance=neq.old.balance' // Only trigger when balance column changes
           },
           async (payload: any) => {
-            logger.info('Received database change:', payload);
+            logger.info('Received balance change:', JSON.stringify(payload, null, 2));
             try {
               await this.handleBalanceUpdate(payload);
             } catch (error) {
@@ -53,7 +54,7 @@ export class BalanceUpdateService {
           }
         )
         .subscribe((status: string) => {
-          logger.info('Subscription status:', status);
+          logger.info('Balance subscription status:', status);
         });
 
       logger.info('Balance update subscription established');
@@ -63,50 +64,47 @@ export class BalanceUpdateService {
   }
 
   private async handleBalanceUpdate(payload: any) {
-    logger.info('Processing balance update payload:', payload);
+    logger.info('Processing balance update payload:', JSON.stringify(payload, null, 2));
 
     if (!this.bot) {
       logger.error('Bot instance not set in BalanceUpdateService');
       return;
     }
 
-    // Handle different event types
-    if (payload.eventType === 'UPDATE') {
-      const { old: oldRecord, new: newRecord } = payload;
-      
-      if (!oldRecord || !newRecord) {
-        logger.error('Invalid payload format:', payload);
-        return;
-      }
+    const { old: oldRecord, new: newRecord } = payload;
+    
+    if (!oldRecord || !newRecord) {
+      logger.error('Invalid payload format:', payload);
+      return;
+    }
 
-      const telegramId = newRecord.telegram_id;
-      const oldBalance = parseFloat(oldRecord.balance);
-      const newBalance = parseFloat(newRecord.balance);
-
-      logger.info(`Balance change detected for user ${telegramId}: ${oldBalance} -> ${newBalance}`);
-
-      // Only send notification if balance actually changed
-      if (oldBalance !== newBalance) {
-        try {
-          const balanceChange = newBalance - oldBalance;
-          const changeType = balanceChange > 0 ? 'increase' : 'decrease';
-          
-          const message = messageManager.getMessage('balance_update_notification')
-            .replace('{old_balance}', oldBalance.toString())
-            .replace('{new_balance}', newBalance.toString())
-            .replace('{change_type}', changeType)
-            .replace('{change_amount}', Math.abs(balanceChange).toString());
-
-          logger.info(`Sending balance update message to user ${telegramId}:`, message);
-
-          await this.bot.telegram.sendMessage(telegramId, message, { parse_mode: 'HTML' });
-          logger.info(`Balance update notification sent to user ${telegramId}`);
-        } catch (error) {
-          logger.error(`Failed to send balance update notification to user ${telegramId}:`, error);
-        }
-      } else {
-        logger.info(`No balance change detected for user ${telegramId}`);
+    const telegramId = newRecord.telegram_id;
+    const oldBalance = parseFloat(oldRecord.balance);
+    const newBalance = parseFloat(newRecord.balance);
+
+    logger.info(`Balance change detected for user ${telegramId}: ${oldBalance} -> ${newBalance}`);
+
+    // Only send notification if balance actually changed
+    if (oldBalance !== newBalance) {
+      try {
+        const balanceChange = newBalance - oldBalance;
+        const changeType = balanceChange > 0 ? 'increase' : 'decrease';
+        
+        const message = messageManager.getMessage('balance_update_notification')
+          .replace('{old_balance}', oldBalance.toString())
+          .replace('{new_balance}', newBalance.toString())
+          .replace('{change_type}', changeType)
+          .replace('{change_amount}', Math.abs(balanceChange).toString());
+
+        logger.info(`Sending balance update message to user ${telegramId}:`, message);
+
+        await this.bot.telegram.sendMessage(telegramId, message, { parse_mode: 'HTML' });
+        logger.info(`Balance update notification sent to user ${telegramId}`);
+      } catch (error) {
+        logger.error(`Failed to send balance update notification to user ${telegramId}:`, error);
       }
+    } else {
+      logger.info(`No balance change detected for user ${telegramId}`);
     }
   }