Update app.py

app.py

@@ -1939,23 +1939,41 @@ async def process_incoming_message(from_number: str, msg: dict):
 
         if products:
             logger.info(f"[Process] Product name detected: '{message_body}' -> Found {len(products)} products")
-            # Show ONLY the highest probability match (first product after sorting by score)
-            selected_product = products[0]  # Get the highest scored product
-            product_name = selected_product.get('Product Name', 'Unknown')
-            product_score = selected_product.get('_score', 0)
-            logger.info(f"[Process] Highest probability product: {product_name} (score: {product_score})")
             
-            context_manager.update_context(
-                from_number, 
-                current_product=selected_product, 
-                current_state='product_inquiry',
-                current_menu='product_inquiry',
-                current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
-            )
-            # Always send image+caption if possible, else text
-            logger.info(f"[DEBUG] Calling send_product_image_with_caption for: {product_name}")
-            await send_product_image_with_caption(from_number, selected_product, user_context)
-            return
+            # Check if this is a specific product name search or a category/symptom search
+            is_specific_product = False
+            
+            # Check for exact product name match (indicating specific product search)
+            normalized_input = normalize(message_body).lower().strip()
+            for product in products:
+                product_name = product.get('Product Name', '')
+                normalized_product_name = normalize(product_name).lower().strip()
+                if normalized_product_name == normalized_input:
+                    is_specific_product = True
+                    break
+            
+            # If it's a specific product name, show only that product
+            if is_specific_product and len(products) == 1:
+                selected_product = products[0]
+                product_name = selected_product.get('Product Name', 'Unknown')
+                logger.info(f"[Process] Specific product found: {product_name}")
+                
+                context_manager.update_context(
+                    from_number, 
+                    current_product=selected_product, 
+                    current_state='product_inquiry',
+                    current_menu='product_inquiry',
+                    current_menu_options=list(MENU_CONFIG['product_inquiry']['option_descriptions'].values())
+                )
+                await send_product_image_with_caption(from_number, selected_product, user_context)
+                return
+            
+            # If it's a category/symptom search with multiple products, show all products
+            else:
+                logger.info(f"[Process] Category/symptom search with {len(products)} products")
+                # Use intelligent product inquiry to show all matching products
+                await handle_intelligent_product_inquiry(from_number, message_body, user_context, reply_language)
+                return
 
         else:
             # Enhanced "not found" response with veterinary suggestions
@@ -3104,7 +3122,7 @@ async def display_all_products(from_number: str):
         chunk_size = 5
         for i in range(0, len(products), chunk_size):
             chunk = products[i:i + chunk_size]
-            message = f"📋 *Products ({i+1}-{min(i+chunk_size, len(products))} of {len(products)})*\n\n"
+            message = f"📋 *Products List ({i+1}-{min(i+chunk_size, len(products))} of {len(products)})*\n\n"
             for j, product in enumerate(chunk, i+1):
                 message += f"{format_number_with_emoji(j)} {product.get('Product Name', 'Unknown')}\n"
                 if product.get('Category'):