all

src/bots/handlers/purchaseHandlers.ts

@@ -217,25 +217,25 @@ export const executePurchase = async (
     logger.error(`Error purchasing number for ${service} in ${countryId}: ${error.message}`);
     
     // Create purchase record with FAILED state if we have user info
-    try {
-      const user = await authService.getUserByTelegramId(telegramId!,ctx);
-      if (user) {
-        // Return the cost to user's balance on error
-        await authService.updateUserBalance(telegramId!,ctx, user.balance + costWithProfit);
+    // try {
+    //   const user = await authService.getUserByTelegramId(telegramId!,ctx);
+    //   if (user) {
+    //     // Return the cost to user's balance on error
+    //     await authService.updateUserBalance(telegramId!,ctx, user.balance + costWithProfit);
         
-        await purchaseTrackingService.createPurchase({
-          userId: user.id,
-          telegramId: telegramId!,
-          service: service,
-          countryId: countryId,
-          operator: operator,
-          cost: costWithProfit,
-          state: PurchaseState.FAILED
-        });
-      }
-    } catch (dbError) {
-      logger.error(`Error creating failed purchase record: ${dbError}`);
-    }
+    //     await purchaseTrackingService.createPurchase({
+    //       userId: user.id,
+    //       telegramId: telegramId!,
+    //       service: service,
+    //       countryId: countryId,
+    //       operator: operator,
+    //       cost: costWithProfit,
+    //       state: PurchaseState.FAILED
+    //     });
+    //   }
+    // } catch (dbError) {
+    //   logger.error(`Error creating failed purchase record: ${dbError}`);
+    // }
     
     await ctx.deleteMessage(loadingMsgId);
     await ctx.reply(getPurchaseErrorMessage(error.message), getLoggedInMenuKeyboard());

src/bots/index.ts

@@ -78,7 +78,7 @@ export const handleAddTelegrafBot = async (botId: string) => {
           await result.bot.launch();
           
           // Setup payment webhook handlers
-          setupPaymentWebhookHandlers(result.bot);
+          // setupPaymentWebhookHandlers(result.bot);
           
           return { status: 200, data: { 
             message: result.message,

src/bots/services/BalanceUpdateService.ts

@@ -15,7 +15,7 @@ export class BalanceUpdateService {
   private constructor() {
     // Delay the initial subscription setup to ensure bot is ready
     setTimeout(() => {
-      this.setupRealtimeSubscription();
+      //this.setupRealtimeSubscription();
       //this.setupBotsSubscription();
     }, 1000);
   }

src/bots/utils/handlerUtils.ts

@@ -59,6 +59,7 @@ export const callbackReplyHandler = (
     // Answer the callback query first
     await ctx.answerCbQuery();
     
+    
     // Execute the reply function to get message content and options
     const result = await Promise.resolve(replyFunction(ctx));
     

src/db/supabase.ts

@@ -7,11 +7,11 @@ export const supabaseAnonKey = process.env.SUPABASE_ANON_KEY
 export const service_role_key = process.env.SUPABASE_SERVICE_ROLE_KEY
 // Create Supabase client with real-time enabled
 export const supabase = createClient(supabaseUrl!, supabaseAnonKey!, {
-  realtime: {
-    params: {
-      eventsPerSecond: 10
-    }
-  }
+  // realtime: {
+  //   params: {
+  //     eventsPerSecond: 10
+  //   }
+  // }
 })
 
 // Create admin client with service role key
@@ -20,11 +20,11 @@ export const supabaseAdmin = createClient(supabaseUrl!, service_role_key!, {
     autoRefreshToken: false,
     persistSession: false
   },
-  realtime: {
-    params: {
-      eventsPerSecond: 10
-    }
-  }
+  // realtime: {
+  //   params: {
+  //     eventsPerSecond: 10
+  //   }
+  // }
 })
 
 // Access auth admin api