Update app.py

app.py

@@ -1,5 +1,5 @@
 import torch
-from flask import Flask, render_template, request, jsonify, session
+from flask import Flask, render_template, request, jsonify
 import json
 import os
 from transformers import pipeline
@@ -13,7 +13,6 @@ from simple_salesforce import Salesforce
 import requests  # Import requests for exception handling
 
 app = Flask(__name__)
-app.secret_key = 'your_secret_key'  # Use a secure secret key for sessions
 
 # Use whisper-small for faster processing and better speed
 device = "cuda" if torch.cuda.is_available() else "cpu"
@@ -22,23 +21,27 @@ device = "cuda" if torch.cuda.is_available() else "cpu"
 config = AutoConfig.from_pretrained("openai/whisper-small")
 config.update({"timeout": 60})  # Set timeout to 60 seconds
 
-# Salesforce connection setup
+# Salesforce credentials (Replace with actual values)
 try:
     print("Attempting to connect to Salesforce...")
     sf = Salesforce(username='[email protected]', password='Sati@1020', security_token='sSSjyhInIsUohKpG8sHzty2q')
     print("Connected to Salesforce successfully!")
+    print("User Info:", sf.UserInfo)  # Log the user info to verify the connection
 except Exception as e:
     print(f"Failed to connect to Salesforce: {str(e)}")
 
 # Function for Salesforce operations
 def create_salesforce_record(name, email, phone_number):
     try:
+        # Create a new record in Salesforce's Customer_Login__c object
         customer_login = sf.Customer_Login__c.create({
             'Name': name,
             'Email__c': email,
             'Phone_Number__c': phone_number
         })
         return customer_login
+    except SalesforceResourceNotFound as e:
+        raise Exception(f"Salesforce resource not found: {str(e)}")
     except Exception as e:
         raise Exception(f"Failed to create record: {str(e)}")
 
@@ -47,17 +50,6 @@ def get_menu_items():
     result = sf.query(query)
     return result['records']
 
-def create_salesforce_order(cart_items, total_price, customer_id):
-    try:
-        order = sf.Order__c.create({
-            'Total_Price__c': total_price,
-            'Cart_Items__c': json.dumps(cart_items),  # Storing cart items as JSON
-            'Customer__c': customer_id  # Linking to the customer record
-        })
-        return order
-    except Exception as e:
-        raise Exception(f"Failed to create order: {str(e)}")
-
 # Voice-related functions
 def generate_audio_prompt(text, filename):
     try:
@@ -97,101 +89,175 @@ def dashboard():
 @app.route('/submit', methods=['POST'])
 def submit():
     try:
+        # Ensure JSON is being received
         data = request.get_json()
         print("Received Data:", data)  # Debugging line
 
         if not data:
             return jsonify({"success": False, "message": "Invalid or empty JSON received"}), 400
 
+        # Get the values from the JSON data
         name = data.get("name")
         email = data.get("email")
         phone = data.get("phone")
 
+        # Validate if all fields are present
         if not name or not email or not phone:
             return jsonify({"success": False, "message": "Missing required fields"}), 400
 
+        # Prepare data for Salesforce submission
         salesforce_data = {
             "Name": name,
             "Email__c": email,  # Ensure this is the correct field API name in Salesforce
             "Phone_Number__c": phone  # Ensure this is the correct field API name in Salesforce
         }
 
+        # Insert data into Salesforce using simple_salesforce
         try:
             result = sf.Customer_Login__c.create(salesforce_data)  # Replace `Customer_Login__c` with your Salesforce object API name
             print(f"Salesforce Response: {result}")  # Debugging line
+
             return jsonify({"success": True, "message": "Data submitted successfully"})
+        
         except Exception as e:
             if "STORAGE_LIMIT_EXCEEDED" in str(e):
                 return jsonify({"success": False, "message": "Salesforce storage limit exceeded. Please clean up or contact support."}), 500
             else:
                 print(f"Salesforce Insertion Error: {str(e)}")  # Log Salesforce errors
                 return jsonify({"success": False, "message": "Salesforce submission failed", "error": str(e)}), 500
+
     except Exception as e:
         print(f"Server Error: {str(e)}")  # Log general errors
         return jsonify({"success": False, "message": "Internal server error", "error": str(e)}), 500
 
+
 @app.route('/validate-login', methods=['POST'])
 def validate_login():
     try:
+        # Ensure JSON is being received
         data = request.get_json()
         login_email = data.get("email")
         login_mobile = data.get("mobile")
 
+        # Validate if email and mobile are present
         if not login_email or not login_mobile:
             return jsonify({"success": False, "message": "Missing email or mobile number"}), 400
 
+        # Query Salesforce to check if the record exists
         query = f"SELECT Id, Name, Email__c, Phone_Number__c FROM Customer_Login__c WHERE Email__c = '{login_email}' AND Phone_Number__c = '{login_mobile}'"
         result = sf.query(query)
 
         if result['records']:
-            user_name = result['records'][0]['Name']
+            # If a matching record is found, return success and the name
+            user_name = result['records'][0]['Name']  # Assuming the 'Name' field is present in the Salesforce object
             return jsonify({"success": True, "message": "Login successful", "name": user_name})
         else:
+            # If no matching record is found
             return jsonify({"success": False, "message": "Invalid email or mobile number"}), 401
+
     except Exception as e:
         print(f"Error validating login: {str(e)}")
         return jsonify({"success": False, "message": "Internal server error", "error": str(e)}), 500
 
+
 @app.route("/menu", methods=["GET"])
 def menu_page():
     menu_items = get_menu_items()
     menu_data = [{"name": item['Name'], "price": item['Price__c'], "ingredients": item['Ingredients__c'], "category": item['Category__c']} for item in menu_items]
     return render_template("menu_page.html", menu_items=menu_data)
 
-@app.route("/add_to_cart", methods=["POST"])
-def add_to_cart():
-    cart_items = session.get('cart_items', [])
+# Route for handling order
+@app.route("/order", methods=["POST"])
+def place_order():
     item_name = request.json.get('item_name')
     quantity = request.json.get('quantity')
-    
-    cart_items.append({"name": item_name, "quantity": quantity})
-    session['cart_items'] = cart_items  # Update session with new cart items
-    
-    return jsonify({"success": True, "message": f"Added {item_name} to your cart."})
-
-@app.route("/view_cart", methods=["GET"])
-def view_cart():
-    cart_items = session.get('cart_items', [])
+    order_data = {"Item__c": item_name, "Quantity__c": quantity}
+    sf.Order__c.create(order_data)
+    return jsonify({"success": True, "message": f"Order for {item_name} placed successfully."})
+
+# Route to handle the cart
+@app.route("/cart", methods=["GET"])
+def cart():
+    cart_items = []  # Placeholder for cart items
     return render_template("cart_page.html", cart_items=cart_items)
 
-@app.route("/place_order", methods=["POST"])
-def place_order():
-    cart_items = session.get('cart_items', [])
-    total_price = sum([item['quantity'] * 100 for item in cart_items])  # Placeholder price calculation
-    customer_id = session.get('customer_id')
+# Route for the order summary page
+@app.route("/order-summary", methods=["GET"])
+def order_summary():
+    order_details = []  # Placeholder for order details
+    return render_template("order_summary.html", order_details=order_details)
+
+@app.route("/transcribe", methods=["POST"])
+def transcribe():
+    if "audio" not in request.files:
+        print("No audio file provided")
+        return jsonify({"error": "No audio file provided"}), 400
 
-    if not customer_id:
-        return jsonify({"message": "User not logged in"}), 400
+    audio_file = request.files["audio"]
+    input_audio_path = os.path.join("static", "temp_input.wav")
+    output_audio_path = os.path.join("static", "temp.wav")
+    audio_file.save(input_audio_path)
 
     try:
-        order_data = {"Total_Price__c": total_price, "Cart_Items__c": json.dumps(cart_items), "Customer__c": customer_id}
-        order = sf.Order__c.create(order_data)
-        session.pop('cart_items', None)  # Clear the cart after placing the order
-        return jsonify({"message": "Order placed successfully!", "order": order})
+        # Convert to WAV
+        convert_to_wav(input_audio_path, output_audio_path)
+
+        # Check for silence
+        if is_silent_audio(output_audio_path):
+            return jsonify({"error": "No speech detected. Please try again."}), 400
+        else:
+            print("Audio contains speech, proceeding with transcription.")
+
+        # Use Whisper ASR model for transcription
+        result = None
+        retry_attempts = 3
+        for attempt in range(retry_attempts):
+            try:
+                result = pipeline("automatic-speech-recognition", model="openai/whisper-small", device=0 if torch.cuda.is_available() else -1, config=config)
+                print(f"Transcribed text: {result['text']}")
+                break
+            except requests.exceptions.ReadTimeout:
+                print(f"Timeout occurred, retrying attempt {attempt + 1}/{retry_attempts}...")
+                time.sleep(5)
+
+        if result is None:
+            return jsonify({"error": "Unable to transcribe audio after retries."}), 500
+
+        transcribed_text = result["text"].strip().capitalize()
+        print(f"Transcribed text: {transcribed_text}")
+
+        # Extract name, email, and phone number from the transcribed text
+        parts = transcribed_text.split()
+        name = parts[0] if len(parts) > 0 else "Unknown Name"
+        email = parts[1] if '@' in parts[1] else "[email protected]"
+        phone_number = parts[2] if len(parts) > 2 else "0000000000"
+        print(f"Parsed data - Name: {name}, Email: {email}, Phone Number: {phone_number}")
+
+        # Confirm details before submission
+        confirmation = f"Is this correct? Name: {name}, Email: {email}, Phone: {phone_number}"
+        generate_audio_prompt(confirmation, "confirmation.mp3")
+
+        # Simulate confirmation via user action
+        user_confirms = True  # Assuming the user confirms, you can replace this with actual user input logic
+
+        if user_confirms:
+            # Create record in Salesforce
+            salesforce_response = create_salesforce_record(name, email, phone_number)
+
+            # Log the Salesforce response
+            print(f"Salesforce record creation response: {salesforce_response}")
+
+            # Check if the response contains an error
+            if "error" in salesforce_response:
+                print(f"Error creating record in Salesforce: {salesforce_response['error']}")
+                return jsonify(salesforce_response), 500
+
+            return jsonify({"text": transcribed_text, "salesforce_record": salesforce_response})
 
     except Exception as e:
-        return jsonify({"message": f"Failed to create order: {str(e)}"}), 500
+        print(f"Error in transcribing or processing: {str(e)}")
+        return jsonify({"error": f"Speech recognition error: {str(e)}"}), 500
 
-# Run the app
+# Start Production Server
 if __name__ == "__main__":
-    app.run(debug=True)
+    serve(app, host="0.0.0.0", port=7860)