Update app.py

app.py

@@ -46,7 +46,7 @@ def get_menu_items():
 
     dietary_preference = request.json.get('dietary_preference', 'both').lower()
     try:
-        soql = "SELECT Name, Image_URL__c, Category__c FROM Sector_Detail__c"
+        soql = "SELECT Name, Image_URL__c, Category__c FROM Ingredient_Object__c"
         if dietary_preference == 'vegetarian':
             soql += " WHERE Category__c = 'Veg'"
         elif dietary_preference == 'non-vegetarian':
@@ -83,7 +83,7 @@ def suggest_items():
         return jsonify({"error": "Search term is required"}), 400
 
     try:
-        soql = f"SELECT Name, Image_URL__c FROM Sector_Detail__c WHERE Name LIKE '%{search_term}%' OR Ingredients__c LIKE '%{search_term}%' LIMIT 10"
+        soql = f"SELECT Name, Image_URL__c FROM Ingredient_Object__c WHERE Name LIKE '%{search_term}%' OR Ingredients__c LIKE '%{search_term}%' LIMIT 10"
         logger.info(f"Executing SOQL query: {soql}")
         result = sf.query(soql)
         suggestions = [
@@ -96,7 +96,7 @@ def suggest_items():
         logger.error(f"Failed to fetch suggestions: {str(e)}")
         return jsonify({"error": "Failed to fetch suggestions from Salesforce"}), 500
 
-# Fetch item details with fallback to menu items
+# Fetch item details
 @app.route('/get_item_details', methods=['POST'])
 def get_item_details():
     global sf
@@ -110,14 +110,12 @@ def get_item_details():
         return jsonify({"error": "Item name is required"}), 400
 
     try:
-        # Case-insensitive search for exact or partial match
-        soql = f"SELECT Name, Description__c, Ingredients__c, Image_URL__c FROM Sector_Detail__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
+        soql = f"SELECT Name, Description__c, Ingredients__c, Image_URL__c FROM Ingredient_Object__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
         logger.info(f"Executing SOQL query: {soql}")
         result = sf.query(soql)
 
         if result['totalSize'] == 0:
-            # Fallback: Check if it exists in menu items
-            soql_fallback = f"SELECT Name, Image_URL__c FROM Sector_Detail__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
+            soql_fallback = f"SELECT Name, Image_URL__c FROM Ingredient_Object__c WHERE Name LIKE '%{item_name}%' LIMIT 1"
             result_fallback = sf.query(soql_fallback)
             if result_fallback['totalSize'] > 0:
                 record = result_fallback['records'][0]
@@ -144,5 +142,31 @@ def get_item_details():
         logger.error(f"Failed to fetch item details: {str(e)}")
         return jsonify({"error": "Failed to fetch item details from Salesforce"}), 500
 
+# Submit selected items to Salesforce
+@app.route('/submit_ingredients', methods=['POST'])
+def submit_ingredients():
+    global sf
+    if not sf:
+        sf = get_salesforce_connection()
+        if not sf:
+            return jsonify({"error": "Unable to connect to Salesforce"}), 500
+
+    ingredients = request.json.get('ingredients', [])
+    if not ingredients:
+        return jsonify({"error": "No ingredients provided"}), 400
+
+    try:
+        # Create a new record in Ingredient_Object__c with the selected ingredients
+        ingredient_names = ", ".join(ingredients)
+        sf.Ingredient_Object__c.create({
+            'Name': f"User Selection {ingredient_names[:50]}",  # Truncate if too long
+            'Ingredients__c': ingredient_names
+        })
+        logger.info(f"Submitted ingredients to Salesforce: {ingredient_names}")
+        return jsonify({"success": "Ingredients submitted successfully"})
+    except Exception as e:
+        logger.error(f"Failed to submit ingredients: {str(e)}")
+        return jsonify({"error": "Failed to submit ingredients to Salesforce"}), 500
+
 if __name__ == '__main__':
     app.run(debug=True, host='0.0.0.0', port=7860)