from salesforce_connection import connect_to_salesforce

def place_order(email, order_items, total_price):
    sf = connect_to_salesforce()
    query = f"SELECT Id FROM Customer_Login__c WHERE Email__c = '{email}'"
    result = sf.query(query)
    if result['totalSize'] == 0:
        return {"status": "error", "message": "Invalid email"}
    
    user_id = result['records'][0]['Id']
    sf.Order__c.create({
        "Customer__c": user_id,
        "Order_Item__c": ", ".join(order_items),
        "Total_Price__c": total_price
    })
    return {"status": "success", "message": "Order placed successfully"}