Update app.py

app.py

@@ -35,7 +35,7 @@ sf = get_salesforce_connection()
 def index():
     return render_template('index.html')
 
-# Fetch items from Sector_Detail__c for dietary preferences
+# Fetch items from Sector_Detail__c with search support
 @app.route('/get_menu_items', methods=['POST'])
 def get_menu_items():
     global sf
@@ -45,13 +45,19 @@ def get_menu_items():
             logger.error("Salesforce connection failed after retry")
             return jsonify({"error": "Unable to connect to Salesforce"}), 500
 
-    dietary_preference = request.json.get('dietary_preference', 'both').lower()
+    data = request.json
+    dietary_preference = data.get('dietary_preference', 'both').lower()
+    search_term = data.get('search_term', '').strip()
+
     try:
         soql = "SELECT Name, Image_URL__c, Category__c, Description__c FROM Sector_Detail__c"
-        if dietary_preference == 'vegetarian':
-            soql += " WHERE Category__c = 'Veg'"
-        elif dietary_preference == 'non-vegetarian':
-            soql += " WHERE Category__c = 'Non-Veg'"
+        conditions = []
+        if search_term:
+            conditions.append(f"Name LIKE '%{search_term}%'")
+        if dietary_preference in ['vegetarian', 'non-vegetarian']:
+            conditions.append(f"Category__c = '{dietary_preference.capitalize()}'")
+        if conditions:
+            soql += " WHERE " + " AND ".join(conditions)
         soql += " LIMIT 200"
         
         logger.info(f"Executing SOQL query: {soql}")
@@ -65,10 +71,10 @@ def get_menu_items():
             }
             for record in result['records'] if 'Name' in record
         ]
-        logger.info(f"Fetched {len(items)} items from Sector_Detail__c for {dietary_preference}")
+        logger.info(f"Fetched {len(items)} items from Sector_Detail__c for {dietary_preference} with search '{search_term}'")
         return jsonify({"menu_items": items})
     except Exception as e:
-        logger.error(f"Failed to fetch items from Sector_Detail__c: {str(e)}")
+        logger.error(f"Failed to fetch items from Sector_Detail__c: {e}")
         return jsonify({"error": f"Failed to fetch items from Salesforce: {str(e)}"}), 500
 
 # Fetch suggestions from Ingredient_Object__c
@@ -163,7 +169,7 @@ def get_item_details_by_name():
         logger.error(f"Failed to fetch item details from Sector_Detail__c: {str(e)}")
         return jsonify({"error": f"Failed to fetch item details from Salesforce: {str(e)}"}), 500
 
-# Fetch item details (Name and Image_URL) from Sector_Detail__c by name
+# Fetch item details (Name, Image_URL, Category, Description) from Sector_Detail__c by name
 @app.route('/get_sector_item_details', methods=['POST'])
 def get_sector_item_details():
     global sf
@@ -177,7 +183,7 @@ def get_sector_item_details():
         return jsonify({"error": "Item name is required"}), 400
 
     try:
-        soql = f"SELECT Name, Image_URL__c FROM Sector_Detail__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
+        soql = f"SELECT Name, Image_URL__c, Category__c, Description__c FROM Sector_Detail__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
         logger.info(f"Executing SOQL query: {soql}")
         result = sf.query(soql)
 
@@ -187,9 +193,11 @@ def get_sector_item_details():
         record = result['records'][0]
         item_details = {
             "name": record.get('Name', ''),
-            "image_url": record.get('Image_URL__c', 'https://via.placeholder.com/30')
+            "image_url": record.get('Image_URL__c', 'https://via.placeholder.com/30'),
+            "category": record.get('Category__c', 'Unknown'),
+            "description": record.get('Description__c', 'No description available')
         }
-        logger.info(f"Fetched details for '{item_name}' from Sector_Detail__c")
+        logger.info(f"Fetched details for '{item_name}' from Sector_Detail__c: {item_details}")
         return jsonify({"item_details": item_details})
     except Exception as e:
         logger.error(f"Failed to fetch item details from Sector_Detail__c: {str(e)}")
@@ -210,9 +218,10 @@ def submit_items():
 
     try:
         for item in items:
-            logger.info(f"Submitting item: {item}")
+            logger.info(f"Submitting item to Ingredient_Object__c: {item}")
             sf.Ingredient_Object__c.create({
                 'Ingredient_Name__c': item['name'],
+                'Category__c': item.get('category', 'Unknown'),  # Explicitly set Category__c
                 'Description__c': item.get('description', 'No description available')
             })
             logger.info(f"Successfully submitted item to Ingredient_Object__c: {item['name']}")