Update app.py

app.py

@@ -24,6 +24,7 @@ from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
 from sqlalchemy.orm import sessionmaker, declarative_base
 from sqlalchemy import Column, Integer, String, DateTime, Text, Float
 
+# Environment keys remain, but you can adjust them if needed.
 SPOONACULAR_API_KEY = os.getenv("SPOONACULAR_API_KEY", "default_fallback_value")
 PAYSTACK_SECRET_KEY = os.getenv("PAYSTACK_SECRET_KEY", "default_fallback_value")
 DATABASE_URL = os.getenv("DATABASE_URL", "default_fallback_value")
@@ -35,13 +36,13 @@ WHATSAPP_PHONE_NUMBER_ID = os.getenv("WHATSAPP_PHONE_NUMBER_ID", "default_value"
 WHATSAPP_ACCESS_TOKEN = os.getenv("WHATSAPP_ACCESS_TOKEN", "default_value")
 MANAGEMENT_WHATSAPP_NUMBER = os.getenv("MANAGEMENT_WHATSAPP_NUMBER", "default_value")
 
+# Updated shipping costs for popular Los Angeles neighborhoods (in dollars)
 TOWN_SHIPPING_COSTS = {
-    "lasu gate": 1000,
-    "ojo": 800,
-    "ajangbadi": 1200,
-    "iba": 900,
-    "okokomaiko": 1500,
-    "default": 1000
+    "downtown los angeles": 5,
+    "hollywood": 6,
+    "santa monica": 7,
+    "pasadena": 5,
+    "default": 8
 }
 
 Base = declarative_base()
@@ -99,7 +100,7 @@ class MenuItem(Base):
     id = Column(Integer, primary_key=True, index=True)
     name = Column(String, unique=True, index=True)
     description = Column(Text)
-    price = Column(Integer)  # Price as an integer (in Naira)
+    price = Column(Integer)  # Price in dollars
     nutrition = Column(Text)
 
 class TownShippingCost(Base):
@@ -108,7 +109,6 @@ class TownShippingCost(Base):
     town = Column(String, unique=True, index=True)
     cost = Column(Integer)
 
-
 engine = create_async_engine(DATABASE_URL, echo=True)
 async_session = sessionmaker(engine, class_=AsyncSession, expire_on_commit=False)
 
@@ -120,65 +120,28 @@ user_state = {}
 conversation_context = {}
 proactive_timer = {}
 
+# --- Updated Menu for Creole Kings ---
 menu_items = [
-    {"name": "Jollof Rice", "description": "A spicy and flavorful rice dish", "price": 1500, "nutrition": "Calories: 300 kcal, Carbs: 50g, Protein: 10g, Fat: 5g"},
-    {"name": "Fried Rice", "description": "A savory rice dish with vegetables and meat", "price": 1200, "nutrition": "Calories: 350 kcal, Carbs: 55g, Protein: 12g, Fat: 8g"},
-    {"name": "Chicken Wings", "description": "Crispy fried chicken wings", "price": 2000, "nutrition": "Calories: 400 kcal, Carbs: 20g, Protein: 25g, Fat: 15g"},
-    {"name": "Egusi Soup", "description": "A rich and hearty soup made with melon seeds", "price": 1000, "nutrition": "Calories: 250 kcal, Carbs: 15g, Protein: 8g, Fat: 10g"},
-    {"name": "Native Rice", "description": "Traditional native-style rice", "price": 1500, "nutrition": "Calories: 350 kcal, Carbs: 60g, Protein: 10g, Fat: 7g"},
-    {"name": "Spaghetti Jollof", "description": "Jollof-style spaghetti dish", "price": 1200, "nutrition": "Calories: 400 kcal, Carbs: 65g, Protein: 10g, Fat: 8g"},
-    {"name": "Macaroni", "description": "Jollof-style macaroni dish", "price": 1200, "nutrition": "Calories: 380 kcal, Carbs: 60g, Protein: 9g, Fat: 7g"},
-    {"name": "White Rice with Vegetable Sauce", "description": "White rice served with vegetable sauce and chicken", "price": 3700, "nutrition": "Calories: 450 kcal, Carbs: 60g, Protein: 15g, Fat: 10g"},
-    {"name": "Vegetable Sauce with Chicken", "description": "Vegetable sauce with chicken, no rice", "price": 2500, "nutrition": "Calories: 300 kcal, Carbs: 20g, Protein: 15g, Fat: 10g"},
-    {"name": "Chicken Drumstick", "description": "Fried or grilled chicken drumstick", "price": 2500, "nutrition": "Calories: 350 kcal, Carbs: 5g, Protein: 30g, Fat: 15g"},
-    {"name": "Chicken Wings", "description": "Crispy fried chicken wings", "price": 3960, "nutrition": "Calories: 450 kcal, Carbs: 20g, Protein: 30g, Fat: 20g"},
-    {"name": "Fried Chicken", "description": "Crispy deep-fried chicken", "price": 4140, "nutrition": "Calories: 500 kcal, Carbs: 15g, Protein: 35g, Fat: 25g"},
-    {"name": "Turkey", "description": "Crispy deep-fried turkey", "price": 4000, "nutrition": "Calories: 480 kcal, Carbs: 10g, Protein: 40g, Fat: 20g"},
-    {"name": "Gizzard", "description": "Fried or grilled gizzard", "price": 3000, "nutrition": "Calories: 200 kcal, Carbs: 5g, Protein: 20g, Fat: 8g"},
-    {"name": "Fish", "description": "Fried or grilled fish", "price": 2500, "nutrition": "Calories: 250 kcal, Carbs: 5g, Protein: 25g, Fat: 10g"},
-    {"name": "Beef", "description": "Spicy fried or grilled beef", "price": 1200, "nutrition": "Calories: 300 kcal, Carbs: 2g, Protein: 28g, Fat: 15g"},
-    {"name": "Pepper Chicken", "description": "Spicy peppered chicken", "price": 1500, "nutrition": "Calories: 400 kcal, Carbs: 10g, Protein: 35g, Fat: 18g"},
-    {"name": "Pepper Chicken Big", "description": "Larger portion of spicy peppered chicken", "price": 2500, "nutrition": "Calories: 600 kcal, Carbs: 15g, Protein: 50g, Fat: 25g"},
-    {"name": "Salad", "description": "Fresh vegetable salad", "price": 800, "nutrition": "Calories: 100 kcal, Carbs: 15g, Protein: 3g, Fat: 5g"},
-    {"name": "Egg and Yam", "description": "Boiled yam served with eggs", "price": 1000, "nutrition": "Calories: 300 kcal, Carbs: 50g, Protein: 10g, Fat: 5g"},
-    {"name": "Moi Moi", "description": "Steamed bean pudding", "price": 1000, "nutrition": "Calories: 250 kcal, Carbs: 30g, Protein: 12g, Fat: 8g"},
-    {"name": "Plantain", "description": "Fried or boiled ripe plantain", "price": 1000, "nutrition": "Calories: 200 kcal, Carbs: 50g, Protein: 2g, Fat: 1g"},
-    {"name": "Soup with Goat Meat and Semo", "description": "Rich soup with goat meat served with semo", "price": 4600, "nutrition": "Calories: 500 kcal, Carbs: 60g, Protein: 30g, Fat: 15g"},
-    {"name": "Soup with Chicken and Semo", "description": "Soup served with chicken and semo", "price": 500, "nutrition": "Calories: 450 kcal, Carbs: 55g, Protein: 28g, Fat: 12g"},
-    {"name": "Extra Semo", "description": "Additional portion of semo", "price": 500, "nutrition": "Calories: 200 kcal, Carbs: 45g, Protein: 5g, Fat: 1g"},
-    {"name": "Banga Soup", "description": "Traditional dish with catfish", "price": 5000, "nutrition": "Calories: 600 kcal, Carbs: 50g, Protein: 35g, Fat: 15g"}
+    {"name": "Jambalaya", "description": "A classic Creole dish with rice, chicken, sausage, and shrimp", "price": 15, "nutrition": "Approximately 500 kcal"},
+    {"name": "Gumbo", "description": "A hearty stew with chicken, sausage, okra, and spices", "price": 18, "nutrition": "Approximately 600 kcal"},
+    {"name": "Crawfish Étouffée", "description": "A rich, flavorful dish with crawfish simmered in a spiced roux", "price": 20, "nutrition": "Approximately 550 kcal"},
+    {"name": "Red Beans & Rice", "description": "Slow-cooked red beans served over rice with Creole spices", "price": 12, "nutrition": "Approximately 450 kcal"},
+    {"name": "Shrimp Po' Boy", "description": "Crispy fried shrimp served on a French roll with lettuce and tomato", "price": 16, "nutrition": "Approximately 500 kcal"},
+    {"name": "Muffuletta Sandwich", "description": "A hearty sandwich with layered meats, cheeses, and olive salad", "price": 14, "nutrition": "Approximately 650 kcal"},
+    {"name": "Blackened Fish", "description": "Fish fillet seasoned with Cajun spices and seared", "price": 17, "nutrition": "Approximately 400 kcal"},
+    {"name": "Creole Salad", "description": "Fresh mixed greens with a Creole vinaigrette", "price": 10, "nutrition": "Approximately 300 kcal"},
+    {"name": "Beignets", "description": "Light and fluffy deep-fried pastries dusted with powdered sugar", "price": 8, "nutrition": "Approximately 350 kcal"},
+    {"name": "Bananas Foster", "description": "Sautéed bananas in a rich butter and brown sugar sauce, flambéed with rum", "price": 9, "nutrition": "Approximately 400 kcal"}
 ]
 
-nigerian_drinks = [
-    {"name": "Chapman", "description": "Popular Nigerian cocktail with a fruity, fizzy taste", "price": 1500, "nutrition": "Calories: 180 kcal, Carbs: 40g, Protein: 1g, Fat: 0g"},
-    {"name": "VitaMilk", "description": "Healthy, protein-rich plant-based milk", "price": 1000, "nutrition": "Calories: 180 kcal, Carbs: 20g, Protein: 8g, Fat: 6g"},
-    {"name": "Malt Drink", "description": "Non-alcoholic malt-based drink", "price": 1000, "nutrition": "Calories: 200 kcal, Carbs: 50g, Protein: 2g, Fat: 0g"},
-    {"name": "Soft Drinks", "description": "Carbonated sodas like Coke, Fanta, and Sprite", "price": 800, "nutrition": "Calories: 150 kcal, Carbs: 39g, Protein: 0g, Fat: 0g"},
-    {"name": "Bottled Water", "description": "Pure, refreshing drinking water", "price": 500, "nutrition": "Calories: 0 kcal, Carbs: 0g, Protein: 0g, Fat: 0g"},
-    {"name": "Energy Drink", "description": "Boost of energy with caffeine and vitamins", "price": 1500, "nutrition": "Calories: 200 kcal, Carbs: 50g, Protein: 1g, Fat: 0g"}
+creole_drinks = [
+    {"name": "Hurricane Cocktail", "description": "A sweet and tangy cocktail with rum and passion fruit", "price": 12, "nutrition": "Approximately 250 kcal"},
+    {"name": "Cajun Spice Margarita", "description": "A margarita with a hint of Cajun spice", "price": 11, "nutrition": "Approximately 200 kcal"},
+    {"name": "Iced Tea", "description": "Refreshing iced tea, unsweetened or sweetened", "price": 5, "nutrition": "Approximately 100 kcal"},
+    {"name": "Lemonade", "description": "Freshly squeezed lemonade", "price": 6, "nutrition": "Approximately 120 kcal"}
 ]
 
-menu_items.extend(nigerian_drinks)
-
-
-class ConversationState:
-    def __init__(self):
-        self.flow = None
-        self.step = 0
-        self.data = {}
-        self.last_active = datetime.utcnow()
-
-    def update_last_active(self):
-        self.last_active = datetime.utcnow()
-
-    def is_expired(self):
-        return datetime.utcnow() - self.last_active > SESSION_TIMEOUT
-
-    def reset(self):
-        self.flow = None
-        self.step = 0
-        self.data = {}
-        self.last_active = datetime.utcnow()
+menu_items.extend(creole_drinks)
 
 SESSION_TIMEOUT = timedelta(minutes=5)
 
@@ -212,7 +175,6 @@ async def populate_shipping_costs():
                 session.add(new_cost)
         await session.commit()
 
-
 async def log_chat_to_db(user_id: str, direction: str, message: str):
     async with async_session() as session:
         entry = ChatHistory(user_id=user_id, direction=direction, message=message)
@@ -255,7 +217,7 @@ def create_paystack_payment_link(email: str, amount: int, reference: str) -> dic
         "email": email,
         "amount": amount,
         "reference": reference,
-        "callback_url": "https://fred808-botpy-808.hf.space/payment_callback"
+        "callback_url": "https://creolekings.com/payment_callback"  # Updated callback URL example
     }
     try:
         response = requests.post(url, json=data, headers=headers, timeout=10)
@@ -346,8 +308,8 @@ def calculate_shipping_cost(address: str) -> int:
 def calculate_eta(destination: str) -> str:
     if not GOOGLE_MAPS_API_KEY:
         return "ETA unavailable (Google Maps API key missing)."
-
-    origin = "Plot 13 Isashi Road, Iyana Isashi, Off Lagos - Badagry Expy, Lagos"
+    # Updated origin address for Creole Kings in Los Angeles
+    origin = "123 Main Street, Los Angeles, CA"
     url = f"https://maps.googleapis.com/maps/api/directions/json?origin={origin}&destination={destination}&key={GOOGLE_MAPS_API_KEY}"
     
     try:
@@ -398,7 +360,6 @@ async def get_menu_items():
             for item in items
         ]
 
-
 async def track_order(user_id: str, order_id: str) -> str:
     async with async_session() as session:
         order_result = await session.execute(
@@ -475,24 +436,18 @@ def match_dishes(user_input: str, threshold: int = 70) -> list:
     Then, try an exact whole-word match using a regex with word boundaries.
     If no exact match is found, fall back to fuzzy matching.
     """
-    # Normalize input: lowercase, strip, and collapse spaces
     normalized_input = re.sub(r'\s+', ' ', user_input.lower().strip())
     matched_dishes = []
     
-    # Try exact matching with word boundaries.
     for item in menu_items:
         dish_name = item["name"]
-        # Create a pattern with word boundaries; e.g., for "fried rice":
-        # pattern becomes: r'\bfried rice\b'
         pattern = r'\b' + re.escape(dish_name.lower()) + r'\b'
         if re.search(pattern, normalized_input):
             matched_dishes.append(dish_name)
     
-    # If we found any exact matches, return them.
     if matched_dishes:
         return list(set(matched_dishes))
     
-    # If no exact match, fall back to fuzzy matching.
     for item in menu_items:
         dish_name = item["name"]
         score = fuzz.token_sort_ratio(normalized_input, dish_name.lower())
@@ -501,61 +456,48 @@ def match_dishes(user_input: str, threshold: int = 70) -> list:
     
     return list(set(matched_dishes))
 
-# def get_dish_price(dish: str) -> int:
-#     for item in menu_items:
-#         if item["name"].lower() == dish.lower():
-#             return item["price"]
-#     return 0  # or raise an error if dish not found
-
-# Fetch dish price from the MenuItem table
+# Use the asynchronous get_dish_price from the database
 async def get_dish_price(dish: str) -> int:
     async with async_session() as session:
-        # Using ilike() for case-insensitive matching
         result = await session.execute(select(MenuItem).where(MenuItem.name.ilike(dish)))
         menu_item = result.scalars().first()
         return menu_item.price if menu_item else 0
 
-# Fetch shipping cost from the TownShippingCost table based on the address.
 async def get_shipping_cost(address: str) -> int:
     async with async_session() as session:
         result = await session.execute(select(TownShippingCost))
         costs = result.scalars().all()
         address_lower = address.lower()
-        # Look for a matching town in the address.
         for cost in costs:
             if cost.town in address_lower:
                 return cost.cost
-        # Fallback: return the default cost.
         default_cost = next((c for c in costs if c.town == "default"), None)
-        return default_cost.cost if default_cost else 1000
-
+        return default_cost.cost if default_cost else 8
 
 def send_email_notification(order_details):
-    # Construct the email payload. Adjust values as needed.
+    # Updated email notification for Creole Kings
     payload = {
-        "from": "yungdml31@gmail.com",
-        "to": "samyung05@gmail.com, angelofoodcourt@gmail.com",  # You can also use a comma-separated list for multiple recipients.
+        "from": "orders@creolekings.com",
+        "to": "manager@creolekings.com",
         "subject": f"New Order Received: {order_details['order_id']}",
         "body": (
             f"New Order Received:\n"
             f"Order ID: {order_details['order_id']}\n"
             f"Dish: {order_details['dish']}\n"
             f"Quantity: {order_details['quantity']}\n"
-            f"Total Price: N{order_details['price']}\n"
+            f"Total Price: ${order_details['price']}\n"
             f"Phone: {order_details.get('phone_number', 'Not Provided')}\n"
             f"Delivery Address: {order_details.get('address', 'Not Provided')}\n"
             f"Extras: {order_details.get('extras', 'None')}\n"
             f"Status: Pending Payment"
         ),
-        # Even though your endpoint is set up to receive these fields, if they're fixed you can omit them or keep them here:
-        "smtpHost": "smtp.gmail.com",   # or your SMTP host
-        "smtpPort": 587,                # or your SMTP port
-        "smtpSecure": "false",          # boolean as string if needed
-        "smtpUser": "yungdml31@gmail.com",      
-        "smtpPassword": "uddvxabxotlvfewk",
+        "smtpHost": "smtp.gmail.com",
+        "smtpPort": 587,
+        "smtpSecure": "false",
+        "smtpUser": "orders@creolekings.com",
+        "smtpPassword": "creolekings_smtp_password",
     }
     
-    # Replace the URL with the URL of your SMTP API endpoint.
     url = "https://smtp-server-ten.vercel.app/smtp"
     try:
         response = requests.post(url, json=payload, timeout=10)
@@ -565,29 +507,6 @@ def send_email_notification(order_details):
         print(f"Error sending email: {e}")
         return None
 
-
-
-def match_dishes(user_input: str, threshold: int = 70) -> list:
-    matched_dishes = []
-    user_input_lower = user_input.lower()
-    for item in menu_items:
-        dish_name = item["name"]
-        # Direct substring check
-        if dish_name.lower() in user_input_lower:
-            matched_dishes.append(dish_name)
-        else:
-            score = fuzz.token_sort_ratio(user_input_lower, dish_name.lower())
-            if score >= threshold:
-                matched_dishes.append(dish_name)
-    return list(set(matched_dishes))
-
-def get_dish_price(dish: str) -> int:
-    for item in menu_items:
-        if item["name"].lower() == dish.lower():
-            return item["price"]
-    return 0
-
-
 async def process_order_flow(user_id: str, message: str) -> str:
     """
     Processes order flow allowing an unlimited number of dishes.
@@ -598,16 +517,14 @@ async def process_order_flow(user_id: str, message: str) -> str:
         del user_state[user_id]
         state = None
 
-    # 1) If user says "order" or "menu", initialize the order flow.
+    # 1) Initialize order flow with a welcome message for Creole Kings.
     if message.lower() in ["order", "menu"]:
         state = ConversationState()
         state.flow = "order"
         state.step = 1
         state.update_last_active()
         user_state[user_id] = state
-        if message.lower() == "order":
-            return "Sure! What dish would you like to order?"
-        return ""
+        return "Welcome to Creole Kings! What dish would you like to order today?"
 
     if not state and "order" in message.lower():
         state = ConversationState()
@@ -615,14 +532,13 @@ async def process_order_flow(user_id: str, message: str) -> str:
         state.step = 1
         state.update_last_active()
         user_state[user_id] = state
-        return "Sure! What dish would you like to order?"
+        return "Welcome to Creole Kings! What dish would you like to order today?"
 
-    # 2) If we aren't in the order flow yet, try to detect dish(es)
+    # 2) Detect dish(es)
     if not state or state.flow != "order":
         matched = match_dishes(message)
         if matched:
             if len(matched) == 1:
-                # Single dish order
                 found_dish = matched[0]
                 state = ConversationState()
                 state.flow = "order"
@@ -648,13 +564,12 @@ async def process_order_flow(user_id: str, message: str) -> str:
                         state.step = 5
                         return (f"Thanks! Your phone number is recorded as: {state.data['phone_number']}.\n"
                                 f"Your delivery address is: {state.data['address']}.\n"
-                                f"Your delivery cost is N{shipping_cost}. Would you like extras (yes/no)?")
+                                f"Delivery fee: ${shipping_cost}. Would you like extras (yes/no)?")
                     elif state.data.get("phone_number") and not state.data.get("address"):
-                        return "Thank you. Please provide your delivery address."
+                        return "Thank you. Please provide your delivery address (e.g., '3105551234, 123 Main St, Los Angeles, CA')."
                     else:
-                        return "Please provide your phone number and address."
+                        return "Please provide your phone number and address (e.g., '3105551234, 123 Main St, Los Angeles, CA')."
             else:
-                # Multiple dishes detected – store all in candidate_dishes.
                 state = ConversationState()
                 state.flow = "order"
                 state.update_last_active()
@@ -667,7 +582,6 @@ async def process_order_flow(user_id: str, message: str) -> str:
         else:
             return "I couldn't identify the dish. Please type the dish name from our menu."
     
-    # --- Candidate Dishes Clarification Branch ---
     if state and state.flow == "order" and "candidate_dishes" in state.data:
         normalized = message.strip().lower()
         if normalized in ["both", "all"]:
@@ -676,7 +590,7 @@ async def process_order_flow(user_id: str, message: str) -> str:
             state.step = 2
             dishes_str = ", ".join(state.data["dishes"])
             return (f"You have selected: {dishes_str}. How many servings of each would you like? "
-                    "(For example, '2 for Jollof Rice, 3 for Chicken Wings, 1 for Fish')")
+                    "(For example, '2 for Jambalaya, 3 for Gumbo')")
         else:
             for dish in state.data["candidate_dishes"]:
                 if dish.lower() in normalized:
@@ -688,16 +602,13 @@ async def process_order_flow(user_id: str, message: str) -> str:
             return (f"Please specify which one you'd like to order from: {dish_options} "
                     "(or type 'both' if you'd like to order all).")
 
-
-
-    # 3) If state exists and we're at step 2: parse quantity details.
+    # 3) Step 2: Parse quantity details.
     if state and state.flow == "order" and state.step == 2:
-        # For multi-dish orders, expect input like "2 for Jollof Rice, 3 for Chicken Wings, 1 for Fish"
         if "dishes" in state.data and len(state.data["dishes"]) > 1:
             pairs = re.findall(r'(\d+)\s*for\s*([a-zA-Z\s]+)', message, flags=re.IGNORECASE)
             if not pairs:
                 return ("I'm sorry, I didn't understand the quantity details. "
-                        "Please specify like '2 for Jollof Rice, 3 for Chicken Wings, 1 for Fish'.")
+                        "Please specify like '2 for Jambalaya, 3 for Gumbo'.")
             order_quantities = {}
             for quantity, dish_text in pairs:
                 dish_text = dish_text.strip().lower()
@@ -709,11 +620,10 @@ async def process_order_flow(user_id: str, message: str) -> str:
                 state.step = 3
                 summary = "\n".join([f"{q} serving(s) of {d}" for d, q in order_quantities.items()])
                 return (f"Got it. You have ordered:\n{summary}\n"
-                        "Please provide your phone number and delivery address.")
+                        "Please provide your phone number and delivery address (e.g., '3105551234, 123 Main St, Los Angeles, CA').")
             else:
                 return ("I'm sorry, I couldn't match those dishes. "
-                        "Please try something like '2 for Jollof Rice, 3 for Chicken Wings, 1 for Fish'.")
-        # For single-dish order at step 2: user types just a quantity.
+                        "Please try something like '2 for Jambalaya, 3 for Gumbo'.")
         numbers = re.findall(r'\d+', message)
         if not numbers:
             return "Please enter a valid number for the quantity (e.g., 1, 2, 3)."
@@ -724,10 +634,9 @@ async def process_order_flow(user_id: str, message: str) -> str:
         state.step = 3
         dish = state.data.get("dish", "")
         return (f"Got it. {quantity} serving(s) of {dish}.\n"
-                "Please provide your phone number and delivery address.")
+                "Please provide your phone number and delivery address (e.g., '3105551234, 123 Main St, Los Angeles, CA').")
 
-    # Step 4: Parse phone & address (for single or multi-dish orders), then skip extras.
-    # --- Step 4: Parse phone & address, compute shipping cost, and jump to confirmation ---
+    # 4) Step 3: Parse phone & address.
     if state and state.flow == "order" and state.step == 3:
         phone_pattern = r'(\+?\d{10,15})'
         phone_match = re.search(phone_pattern, message)
@@ -744,67 +653,57 @@ async def process_order_flow(user_id: str, message: str) -> str:
                 state.data["address"] = message.strip()
             else:
                 return ("Please provide both your phone number and address. "
-                        "For example: '09162409591, 1, Iyana Isashi, Isashi, Lagos'.")
+                        "For example: '3105551234, 123 Main St, Los Angeles, CA'.")
         if not state.data.get("address"):
             return "Thank you. Please provide your delivery address."
-        # Get shipping cost from the database
         shipping_cost = await get_shipping_cost(state.data["address"])
         state.data["shipping_cost"] = shipping_cost
-    
-        # Automatically set extras to empty (since we're not using extras)
         state.data["extras"] = ""
-        
-        # Jump directly to order confirmation (Step 7)
         state.step = 7
-    
-        # For order summary, determine dish summary and quantity:
         if "orders" in state.data:
             dish_summary = ", ".join(state.data["orders"].keys())
             quantity_total = sum(state.data["orders"].values())
             total_price = 0
             for dish, qty in state.data["orders"].items():
-                total_price += (get_dish_price(dish)) * qty
+                dish_price = await get_dish_price(dish)
+                total_price += dish_price * qty
             total_price += shipping_cost
         else:
             dish_summary = state.data.get("dish", "")
             quantity_total = state.data.get("quantity", 1)
-            dish_price = get_dish_price(dish_summary)
+            dish_price = await get_dish_price(dish_summary)
             total_price = (quantity_total * dish_price) + shipping_cost
-    
         return (f"Order Summary:\n"
                 f"Dish(es): {dish_summary}\n"
                 f"Quantity: {quantity_total}\n"
                 f"Phone: {state.data.get('phone_number', '')}\n"
                 f"Address: {state.data.get('address', '')}\n"
-                f"Shipping Cost: N{shipping_cost}\n"
-                f"Total Price: N{total_price}\n"
+                f"Delivery Fee: ${shipping_cost}\n"
+                f"Total Price: ${total_price}\n"
                 "Confirm order? (yes/no)")
 
-
-
-    
     # 7) Step 7: Order Confirmation and Payment Link Generation
     if state and state.flow == "order" and state.step == 7:
         if message.lower() in ["yes", "y"]:
             order_id = f"ORD-{int(time.time())}"
             state.data["order_id"] = order_id
-    
-            # Calculate total price:
+
             if "orders" in state.data:
                 total_price = 0
                 for dish, qty in state.data["orders"].items():
-                    total_price += (get_dish_price(dish)) * qty
+                    dish_price = await get_dish_price(dish)
+                    total_price += dish_price * qty
                 total_price += state.data.get("shipping_cost", 0)
                 dish_summary = ", ".join(state.data["orders"].keys())
                 quantity_total = sum(state.data["orders"].values())
             else:
                 dish_summary = state.data.get("dish", "")
                 quantity_total = state.data.get("quantity", 1)
-                dish_price = get_dish_price(dish_summary)
+                dish_price = await get_dish_price(dish_summary)
                 total_price = (quantity_total * dish_price) + state.data.get("shipping_cost", 0)
             
             state.data["price"] = str(total_price)
-    
+
             async def save_order():
                 async with async_session() as session:
                     order = Order(
@@ -820,8 +719,7 @@ async def process_order_flow(user_id: str, message: str) -> str:
                     await session.commit()
             asyncio.create_task(save_order())
             asyncio.create_task(log_order_tracking(order_id, "Order Placed", "Order placed and awaiting payment."))
-    
-            # Prepare order details for email notification.
+
             order_details = {
                 "order_id": order_id,
                 "dish": dish_summary,
@@ -831,48 +729,27 @@ async def process_order_flow(user_id: str, message: str) -> str:
                 "address": state.data.get("address", "Not Provided"),
                 "extras": state.data.get("extras", "None")
             }
-            admin_emails = os.getenv("ADMIN_EMAILS", "admin@example.com").split(",")
-            email_subject = f"New Order Received: {order_id}"
-            email_body = (
-                f"New Order Received:\n"
-                f"Order ID: {order_id}\n"
-                f"Dish(es): {dish_summary}\n"
-                f"Quantity: {quantity_total}\n"
-                f"Total Price: N{total_price}\n"
-                f"Phone: {state.data.get('phone_number', '')}\n"
-                f"Delivery Address: {state.data.get('address', 'Not Provided')}\n"
-                f"Extras: {state.data.get('extras', 'None')}\n"
-                f"Status: Pending Payment"
-            )
             email_response = send_email_notification(order_details)
             if email_response:
                 print("Email notification sent successfully.")
             else:
                 print("Failed to send email notification.")
-    
-            email_for_paystack = "customer@example.com"  # Replace with user's email if available
+
+            email_for_paystack = "customer@example.com"  # Replace with customer's email if available
             payment_data = create_paystack_payment_link(email_for_paystack, total_price * 100, order_id)
             state.reset()
             if user_id in user_state:
                 del user_state[user_id]
             if payment_data.get("status"):
                 payment_link = payment_data["data"]["authorization_url"]
-                return (f"Thank you for your order of {quantity_total} serving(s) of {dish_summary}! "
+                return (f"Thank you for your order of {quantity_total} serving(s) of {dish_summary} from Creole Kings! "
                         f"Your Order ID is {order_id}.\n\n"
-                        "Please complete your payment using one of the following options:\n"
-                        f"1. Pay online via our Paystack link: {payment_link}\n"
-                        "2. Alternatively, you can make a bank transfer to the following account:\n"
-                        "   Account Number: 1433042821\n"
-                        "   Bank: Access Bank\n"
-                        "   Account Name: Angelo Food Court 2\n\n"
-                        "If you choose the bank transfer option, please send a screenshot of your payment confirmation to this chatbot.\n\n"
-                        "You can track your order status using your Order ID.\n"
-                        "Is there anything else you'd like to order?")
+                        "Please complete your payment online using the link below:\n"
+                        f"{payment_link}\n\n"
+                        "You can track your order status using your Order ID.\nWould you like to place another order?")
             else:
                 return (f"Your order has been placed with Order ID {order_id}, "
-                        "but we could not initialize online payment. Please try again later, or "
-                        "you may opt to pay via bank transfer to Account Number 1433042821, Access Bank, Angelo Food Court 2 "
-                        "and send your payment screenshot to this chatbot.")
+                        "but we could not initialize online payment. Please try again later.")
         elif message.lower() in ["no", "n"]:
             state.reset()
             if user_id in user_state:
@@ -882,19 +759,16 @@ async def process_order_flow(user_id: str, message: str) -> str:
             return "I didn't understand that. Please type 'yes' to confirm your order or 'no' to cancel it."
 
     return ""
-        
 
 def _parse_single_dish_line(message: str, dish_name: str) -> dict:
-   
     result = {"quantity": None, "phone": None, "address": None}
 
-    # 1) Parse quantity
+    # Parse quantity
     numbers = re.findall(r'\d+', message)
     if numbers:
-        # We'll assume the first numeric is quantity if no "for" pattern is used
         result["quantity"] = int(numbers[0])
 
-    # 2) Parse phone
+    # Parse phone
     phone_pattern = r'(\+?\d{10,15})'
     phone_match = re.search(phone_pattern, message)
     address = None
@@ -937,7 +811,7 @@ async def update_user_last_interaction(user_id: str):
             await session.commit()
 
 async def send_proactive_greeting(user_id: str):
-    greeting = "Hi again! We miss you. Would you like to see our new menu items or get personalized recommendations?"
+    greeting = "Hi again! We miss you at Creole Kings. Would you like to see our new menu items or get personalized recommendations?"
     await log_chat_to_db(user_id, "outbound", greeting)
     return greeting
 
@@ -984,12 +858,12 @@ async def chatbot_response(request: Request, background_tasks: BackgroundTasks):
                 "image_url": image_url
             })
         response_payload = {
-            "response": sentiment_modifier + "Here’s our delicious menu:",
+            "response": sentiment_modifier + "Here’s our mouthwatering Creole menu:",
             "menu": menu_with_images,
             "follow_up": (
                 "To order, type the *number* or *name* of the dish you'd like. "
-                "For example, type '1' or 'Jollof Rice' to order Jollof Rice.\n\n"
-                "You can also ask for nutritional facts by typing, for example, 'Nutritional facts for Jollof Rice'."
+                "For example, type '1' or 'Jambalaya' to order.\n\n"
+                "You can also ask for nutritional facts by typing, for example, 'Nutritional facts for Gumbo'."
             )
         }
         background_tasks.add_task(log_chat_to_db, user_id, "outbound", str(response_payload))
@@ -1011,8 +885,7 @@ async def chatbot_response(request: Request, background_tasks: BackgroundTasks):
             })
             return JSONResponse(content={"response": sentiment_modifier + order_response})
 
-    # Instead of calling the LLM fallback, use a default response:
-    default_response = "I'm sorry, I didn't understand that. Please type 'menu' to see our options or 'order' to place an order."
+    default_response = "I'm sorry, I didn't understand that. Please type 'menu' to see our options or 'order' to place an order at Creole Kings."
     background_tasks.add_task(log_chat_to_db, user_id, "outbound", default_response)
     conversation_context[user_id].append({
         "timestamp": datetime.utcnow().isoformat(),
@@ -1021,7 +894,6 @@ async def chatbot_response(request: Request, background_tasks: BackgroundTasks):
     })
     return JSONResponse(content={"response": sentiment_modifier + default_response})
 
-
 @app.get("/chat_history/{user_id}")
 async def get_chat_history(user_id: str):
     async with async_session() as session:
@@ -1134,7 +1006,7 @@ async def payment_callback(request: Request):
             )
         except Exception as e:
             print(f"WhatsApp message sending failed: {e}")
-        redirect_url = "https://wa.link/es8qdg"
+        redirect_url = "https://creolekings.com/thankyou"
         return RedirectResponse(url=redirect_url)
     else:
         data = await request.json()
@@ -1163,10 +1035,8 @@ async def payment_callback(request: Request):
             else:
                 raise HTTPException(status_code=404, detail="Order not found.")
 
-
 @app.get("/track_order/{order_id}")
 async def track_order(order_id: str):
-    
     async with async_session() as session:
         result = await session.execute(
             select(OrderTracking)
@@ -1185,4 +1055,3 @@ async def track_order(order_id: str):
             return JSONResponse(content=response)
         else:
             raise HTTPException(status_code=404, detail="No tracking information found for this order.")
-