all

src/bots/handlers/serviceHandlers.ts

@@ -14,7 +14,9 @@ import {
   getNoSearchResultsMessage,
   getInvalidSearchInputMessage,
   getSearchCountryPromptMessage,
-  getNoCountrySearchResultsMessage
+  getNoCountrySearchResultsMessage,
+  getNoAffordableProductsMessage,
+  getAffordableProductsMessage
 } from "../utils/messageUtils";
 import { 
   getLoggedInMenuKeyboard, 
@@ -202,6 +204,122 @@ export const setupServiceHandlers = (bot: any) => {
     }
   });
 
+  // Add handler for 'buy_with_balance' button
+  bot.action('buy_with_balance', async (ctx: BotContext) => {
+    await ctx.answerCbQuery();
+    const telegramId = ctx.from?.id;
+    if (!telegramId || !authService.isUserLoggedIn(telegramId, ctx)) {
+      try {
+        await ctx.editMessageText(getAuthRequiredMessage(), { reply_markup: getMainMenuKeyboard().reply_markup });
+      } catch (editError: any) {
+        if (editError.message && editError.message.includes('message is not modified')) {
+          logger.info(`Auth required message not modified (buy_with_balance). No action needed.`);
+        } else {
+          logger.error(`Error editing auth required message (buy_with_balance): ${editError.message}`);
+        }
+      }
+      return;
+    }
+
+    try {
+      const user = await authService.getUserByTelegramId(telegramId, ctx);
+      if (!user) {
+        try {
+          await ctx.editMessageText(getAuthRequiredMessage(), { reply_markup: getMainMenuKeyboard().reply_markup });
+        } catch (editError: any) {
+          if (editError.message && editError.message.includes('message is not modified')) {
+            logger.info(`Auth required message not modified (buy_with_balance - user not found). No action needed.`);
+          } else {
+            logger.error(`Error editing auth required message (buy_with_balance - user not found): ${editError.message}`);
+          }
+        }
+        return;
+      }
+
+      const userBalance = user.balance;
+      const maxPrices = await virtualNumberService.getMaxPrices();
+
+      const affordableProducts = maxPrices.filter(product => {
+        // Convert product price to bot's currency (USD, assuming max-prices are in USD)
+        // And then apply profit calculation
+        const productPriceInBotCurrency = product.price;
+        const finalPrice = calculatePriceWithProfit(ctx, productPriceInBotCurrency, 'USD');
+        return userBalance >= finalPrice;
+      }).sort((a, b) => a.product.localeCompare(b.product)); // Sort alphabetically
+
+      if (affordableProducts.length === 0) {
+        try {
+          await ctx.editMessageText(getNoAffordableProductsMessage(userBalance, ctx), {
+            parse_mode: 'HTML',
+            reply_markup: getLoggedInMenuKeyboard().reply_markup
+          });
+        } catch (editError: any) {
+          if (editError.message && editError.message.includes('message is not modified')) {
+            logger.info(`No affordable products message not modified. No action needed.`);
+          } else {
+            logger.error(`Error editing no affordable products message: ${editError.message}`);
+          }
+        }
+        return;
+      }
+
+      const buttons = [];
+      const rowSize = 2;
+
+      for (let i = 0; i < affordableProducts.length; i += rowSize) {
+        const row = [];
+        for (let j = 0; j < rowSize && i + j < affordableProducts.length; j++) {
+          const product = affordableProducts[i + j];
+          const serviceData = fiveSimProducts[product.product];
+          if (serviceData) {
+            // Apply profit to the price for display
+            const displayPrice = calculatePriceWithProfit(ctx, product.price, 'USD');
+            row.push(
+              Markup.button.callback(
+                `${serviceData.icon} ${serviceData.label_en} (${formatPrice(ctx, displayPrice)})`,
+                `service_${product.product}`
+              )
+            );
+          } else {
+            logger.warn(`Service data not found for product: ${product.product}`);
+          }
+        }
+        if (row.length > 0) {
+          buttons.push(row);
+        }
+      }
+
+      buttons.push([Markup.button.callback('🔙 Back to Menu', 'logged_in_menu')]);
+
+      try {
+        await ctx.editMessageText(getAffordableProductsMessage(userBalance, ctx), {
+          parse_mode: 'HTML',
+          reply_markup: Markup.inlineKeyboard(buttons).reply_markup
+        });
+      } catch (editError: any) {
+        if (editError.message && editError.message.includes('message is not modified')) {
+          logger.info(`Affordable products message not modified. No action needed.`);
+        } else {
+          logger.error(`Error editing affordable products message: ${editError.message}`);
+        }
+      }
+
+    } catch (error: any) {
+      logger.error(`Error handling buy_with_balance: ${error.message}`);
+      try {
+        await ctx.editMessageText('⚠️ An error occurred while fetching affordable products. Please try again later.', {
+          reply_markup: getLoggedInMenuKeyboard().reply_markup
+        });
+      } catch (editError: any) {
+        if (editError.message && editError.message.includes('message is not modified')) {
+          logger.info(`Error message for affordable products not modified. No action needed.`);
+        } else {
+          logger.error(`Error editing error message for affordable products: ${editError.message}`);
+        }
+      }
+    }
+  });
+
   // Text handler for product/country search input
   bot.on('text', async (ctx: BotContext) => {
     try {

src/bots/services/VirtualNumberService.ts

@@ -29,6 +29,13 @@ export interface ProductPrices {
     };
 }
 
+export interface MaxPrice {
+    id: number;
+    product: string;
+    price: number;
+    CreatedAt: string; // date string
+}
+
 export class VirtualNumberService {
     private static instance: VirtualNumberService;
     private apiKey: string;
@@ -147,4 +154,23 @@ export class VirtualNumberService {
             throw new Error(`Failed to check SMS: ${error.message}`);
         }
     }
+
+    /**
+     * Get a list of established price limits.
+     */
+    async getMaxPrices(): Promise<MaxPrice[]> {
+        try {
+            const response = await axios.get(`${this.baseUrl}/user/max-prices`, {
+                headers: {
+                    'Authorization': `Bearer ${this.apiKey}`,
+                    'Accept': 'application/json',
+                }
+            });
+            
+            return response.data;
+        } catch (error: any) {
+            logger.error(`Error fetching max prices: ${error.message}`);
+            throw new Error(`Failed to fetch max prices: ${error.message}`);
+        }
+    }
 } 

src/bots/utils/keyboardUtils.ts

@@ -30,6 +30,7 @@ export const getLoggedInMenuKeyboard = () => {
       Markup.button.callback(messageManager.getMessage('btn_top_up'), 'top_up_balance'),
       Markup.button.callback(messageManager.getMessage('btn_history'), 'history')
     ],
+    [Markup.button.callback('💰 Buy with Balance', 'buy_with_balance')],
     [
       Markup.button.callback(messageManager.getMessage('btn_back'), 'main_menu')
     ],

src/bots/utils/messageManager.ts

@@ -90,6 +90,14 @@ class MessageManager {
       'no_country_search_results': {
         ar_value: 'عذراً، لم يتم العثور على دول مطابقة لبحثك.',
         en_value: 'Sorry, no matching countries found for your search.'
+      },
+      'affordable_products_list': {
+        ar_value: 'المنتجات التي يمكنك شراؤها برصيدك الحالي ({balance}):',
+        en_value: 'Products you can buy with your current balance ({balance}):'
+      },
+      'no_affordable_products': {
+        ar_value: 'عذراً، لا توجد منتجات يمكنك شراؤها برصيدك الحالي ({balance}).',
+        en_value: 'Sorry, no products can be bought with your current balance ({balance}).'
       }
     };
 

src/bots/utils/messageUtils.ts

@@ -177,4 +177,14 @@ export const getSearchCountryPromptMessage = () => {
 
 export const getNoCountrySearchResultsMessage = () => {
   return messageManager.getMessage('no_country_search_results');
+};
+
+export const getAffordableProductsMessage = (balance: number, ctx: BotContext) => {
+  return messageManager.getMessage('affordable_products_list')
+    .replace('{balance}', formatPrice(ctx, balance));
+};
+
+export const getNoAffordableProductsMessage = (balance: number, ctx: BotContext) => {
+  return messageManager.getMessage('no_affordable_products')
+    .replace('{balance}', formatPrice(ctx, balance));
 };