Update app.py

app.py

@@ -242,6 +242,38 @@ async def get_order_details(order_id: str) -> Optional[Order]:
         )
         return result.scalar_one_or_none()
 
+def send_email_notification(order_details):
+    # Build the email payload based on the delivery request details.
+    payload = {
+        "from": "[email protected]",
+        "to": "[email protected], [email protected]",
+        "subject": f"New Delivery Request Received: {order_details['order_id']}",
+        "body": (
+            f"New Delivery Request Received:\n"
+            f"Order ID: {order_details['order_id']}\n"
+            f"Package Description: {order_details.get('package_description', 'Not Provided')}\n"
+            f"Pickup Address: {order_details.get('pickup_address', 'Not Provided')}\n"
+            f"Delivery Address: {order_details.get('delivery_address', 'Not Provided')}\n"
+            f"Contact Number: {order_details.get('contact_number', 'Not Provided')}\n"
+            f"Status: Pending Payment"
+        ),
+        "smtpHost": "smtp.gmail.com",
+        "smtpPort": 587,
+        "smtpSecure": "false",
+        "smtpUser": "[email protected]",      
+        "smtpPassword": "uddvxabxotlvfewk",
+    }
+    
+    url = "https://smtp-server-ten.vercel.app/smtp"  # Adjust to your SMTP API endpoint.
+    try:
+        response = requests.post(url, json=payload, timeout=10)
+        response.raise_for_status()
+        return response.json()
+    except Exception as e:
+        print(f"Error sending email: {e}")
+        return None
+
+
 def calculate_eta(last_location: dict) -> str:
     # Implement actual ETA calculation logic here.
     return "30 minutes"
@@ -269,7 +301,7 @@ async def on_startup():
 logger = logging.getLogger(__name__)
 
 @app.post("/delivery")
-async def create_delivery_order(order_req: DeliveryOrderRequest):
+async def create_delivery_order(order_req: DeliveryOrderRequest, bg: BackgroundTasks):
     try:
         logger.info(f"Received order request: {order_req}")
 
@@ -277,7 +309,7 @@ async def create_delivery_order(order_req: DeliveryOrderRequest):
         order_id = f"DEL-{random.randint(100000000, 999999999)}"
         logger.info(f"Generated order ID: {order_id}")
 
-        # Extract delivery location
+        # Extract delivery location and calculate shipping cost.
         delivery_address = order_req.delivery_address.lower()
         shipping_cost = TOWN_SHIPPING_COSTS.get("default", 1000)
         for town, cost in TOWN_SHIPPING_COSTS.items():
@@ -286,7 +318,7 @@ async def create_delivery_order(order_req: DeliveryOrderRequest):
                 break
         logger.info(f"Calculated shipping cost: ₦{shipping_cost}")
 
-        # Set item price (adjustable as needed)
+        # Set item price (adjustable as needed) and calculate total.
         item_price = 5000
         total_amount = item_price + shipping_cost
         total_amount_kobo = total_amount * 100  # Convert to kobo
@@ -299,6 +331,16 @@ async def create_delivery_order(order_req: DeliveryOrderRequest):
         payment_data = create_paystack_payment_link(email, total_amount_kobo, order_id)
         logger.info(f"Generated payment data: {payment_data}")
 
+        # Notify admin via email in the background
+        email_details = {
+            "order_id": order_id,
+            "package_description": order_req.package_description,
+            "pickup_address": order_req.pickup_address,
+            "delivery_address": order_req.delivery_address,
+            "contact_number": order_req.contact_number,
+        }
+        bg.add_task(send_email_notification, email_details)
+
         if payment_data.get("status"):
             payment_link = payment_data["data"]["authorization_url"]
             return {
@@ -306,7 +348,7 @@ async def create_delivery_order(order_req: DeliveryOrderRequest):
                 "total_amount": f"₦{total_amount}",
                 "shipping_cost": f"₦{shipping_cost}",
                 "payment_link": payment_link,
-                "message": "Order created successfully. Please complete payment using the link provided."
+                "message": "Delivery request created successfully. Please complete payment using the link provided."
             }
         else:
             logger.error(f"Failed to generate payment link for order {order_id}")
@@ -314,13 +356,14 @@ async def create_delivery_order(order_req: DeliveryOrderRequest):
                 "order_id": order_id,
                 "total_amount": f"₦{total_amount}",
                 "shipping_cost": f"₦{shipping_cost}",
-                "message": "Order created, but payment initialization failed. Please try again later."
+                "message": "Delivery request created, but payment initialization failed. Please try again later."
             }
 
     except Exception as e:
         logger.error(f"Error creating delivery order: {e}", exc_info=True)
         raise HTTPException(status_code=500, detail=f"Error: {str(e)}")
 
+
 @app.post("/chatbot")
 async def enhanced_chatbot_handler(request: Request, bg: BackgroundTasks):
     data = await request.json()