Update app.py

app.py

@@ -109,29 +109,17 @@ def submit():
             "Phone__c": phone
         }
 
-        headers = {
-            "Authorization": f"Bearer {SALESFORCE_ACCESS_TOKEN}",
-            "Content-Type": "application/json"
-        }
-
-        # Send data to Salesforce
-        response = requests.post(
-            f"{SALESFORCE_INSTANCE_URL}/services/data/v52.0/sobjects/{SALESFORCE_OBJECT}/",
-            headers=headers,
-            data=json.dumps(salesforce_data)
-        )
+        # Insert data into Salesforce using simple_salesforce
+        try:
+            result = sf.Customer__c.create(salesforce_data)  # Replace `Customer__c` with your Salesforce object API name
+            print(f"Salesforce Response: {result}")  # Debugging line
 
-        # Debugging Salesforce response
-        print("Salesforce Response:", response.status_code, response.text)
-
-        if response.status_code == 201:
             return jsonify({"success": True, "message": "Data submitted successfully"})
-        else:
-            return jsonify({"success": False, "message": "Salesforce submission failed", "error": response.text}), 500
+        
+        except Exception as e:
+            print(f"Salesforce Insertion Error: {str(e)}")  # Log Salesforce errors
+            return jsonify({"success": False, "message": "Salesforce submission failed", "error": str(e)}), 500
 
-    except requests.exceptions.RequestException as e:
-        print(f"Request Error: {str(e)}")  # Log request-related errors
-        return jsonify({"success": False, "message": "Request error with Salesforce", "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