Upload 2 files

.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -1,21 +0,0 @@
-__pycache_/
-backup/
-database/
-.env
-backup_graph.py
-graph.py
-langgraph_test.ipynb
-received.webm
-response_audio.mp3
-test_output.wav
-test.ipynb
-test.py
-tools.py
-.venv/
-__pycache__/
-*.py[cod]
-testing_audio_files/
-*.wav
-*.mp3
-.venv/
-whatsapp_api.py

README.md

@@ -1,8 +1,10 @@
 ---
 title: Xipper
-emoji: 🏢
-colorFrom: red
-colorTo: yellow
+emoji: 🤖
+colorFrom: blue
+colorTo: purple
 sdk: docker
-pinned: false
----
+app_port: 7860
+---
+
+Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference

agents/inventory_agent.py

@@ -1,194 +0,0 @@
-from hotel_api import update_inventory,fetch_inventory_availability
-from agents.llm import llm
-import json
-
-
-async def inventory_manager(state):
-    if state.get("pending_manager") == "inventory":
-        user_reply = str(state.get("query","")).lower()
-        prompt = f"""User said: "{user_reply}"
-        If this is a positive confirmation for a booking, return "yes"
-        otherwise return "no". Nothing extra."""
-
-        response = llm.invoke(prompt)
-        confirmation = response.content.strip().lower()
-        if hasattr(response, 'usage_metadata') and response.usage_metadata:
-            print(f"Tokens used: {response.usage_metadata}")
-
-        if confirmation == "yes":
-            pa = state.get("pending_action")
-            if not pa:
-                return {"response": "I seem to have lost the room details. Could you please repeat your inventory request?", "pending_manager": None, "pending_action": None}
-
-            from datetime import datetime, timedelta
-            today = datetime.now()
-            start_date = today.strftime("%Y-%m-%d")
-            end_date = (today + timedelta(days=1)).strftime("%Y-%m-%d")
-
-            success, data = await update_inventory(
-                category=pa["category"],
-                operation=pa["action"],
-                count=pa["count"],
-                start_date=start_date,
-                end_date=end_date
-            )
-
-            action_words = {"block": "blocked", "unblock": "unblocked", "release": "released", "unrelease": "unreleased"}
-            past_action = action_words.get(pa["action"], pa["action"])
-
-            if success:
-                status = f"Got it. I have successfully {past_action} {pa['count']} {pa['category']} room(s) for tonight."
-            else:
-                error_msg = data.get("error","an unknown API error")
-                status = f"I tried to {pa['action']} those {pa['category']} rooms, but the system returned an error: {error_msg}."
-            return {"response": status,"pending_action": None,"pending_manager": None}
-        else:
-            return {"response": "Okay, I have cancelled the inventory change.", "pending_manager": "", "pending_action": {}}
-
-
-    from hotel_api import get_room_map
-    room_map = await get_room_map()
-    real_categories = list(room_map.keys())
-
-    prompt = f"""Extract inventory details from the request.
-    Request: {state['query']}
-    AVAILABLE_ROOM_CATEGORIES: {real_categories}
-    Return ONLY a JSON object: {{"action": "check|block|unblock|release|unrelease", "category": "category_name_from_list|all", "count": number}}
-    
-    IMPORTANT HINGLISH NUMBER RULES:
-    - "ek" = 1, "do" = 2, "teen" = 3, "char" = 4. 
-    - Example: "do double room block kar do" means count=2, category="double", action="block".
-    - Example: "teen stanndard room book kar do" means count=2, category="standard", action="book".
-    RULES:
-    1. For 'category', you MUST pick the exact closest match strictly from the AVAILABLE ROOM CATEGORIES list. Do not guess or use standard names if they aren't in the list. If they do not specify a category, use "all".
-    2. If count is missing, use 1.
-    If category is missing, use "all". If count is missing, use 1.
-    Return ONLY JSON, no extra text."""
-
-    response = llm.invoke(prompt)
-    if hasattr(response, 'usage_metadata') and response.usage_metadata:
-        print(f"Tokens used: {response.usage_metadata}")
-    try:
-        data = json.loads(response.content.strip())
-        print(f"EXTRACTED: {data}")
-    except:
-        return {"response": "I couldn't quite understand your inventory"}
-
-    action = data.get("action","check")
-    category = data.get("category","all")
-    try:
-        count = int(data.get("count",1))
-    except:
-        count = 1
-
-    if action == "check":
-        from datetime import datetime,timedelta
-        today = datetime.now()
-        start_date = today.strftime("%Y-%m-%d")
-        end_date = (today + timedelta(days=1)).strftime("%Y-%m-%d")
-        success, data = await fetch_inventory_availability(start_date, end_date)
-        print(f"API SUCCESS: {success}, DATA KEYS: {data.keys()}")
-
-        if success:
-            categories = data.get("categories",[])
-            
-            if category == "all":
-                today_str = today.strftime("%d-%m-%Y")
-                total_physical = 0
-                total_avail = 0
-                total_booked = 0
-                total_blocked = 0
-                total_ooo = 0
-
-                for cat in categories:
-                    total_physical += int(cat.get("totalRooms", 0))
-
-                    exact_daily_data = {}
-                    for dd in cat.get("dateWiseData", []):
-                        if dd.get("date") == today_str:
-                            exact_daily_data = dd
-                            break
-
-                    summary = cat.get("summary") or {}
-                    
-                    # 2. Extract values. If daily data is missing/null, fallback to summary.
-                    avail = exact_daily_data.get("availableRooms")
-                    if avail is None: avail = summary.get("totalAvailableRooms", 0)
-                    
-                    booked = exact_daily_data.get("bookedRooms")
-                    if booked is None: booked = summary.get("totalBookedRooms", 0)
-                    
-                    blocked = exact_daily_data.get("blockedRooms")
-                    if blocked is None: blocked = summary.get("totalBlockedRooms", 0)
-                    
-                    ooo = exact_daily_data.get("outOfOrderRooms")
-                    if ooo is None: ooo = summary.get("totalOutOfOrderRooms", 0)
-
-                    # 3. Ensure they are integers to prevent math crashes
-                    total_avail += int(avail or 0)
-                    total_booked += int(booked or 0)
-                    total_blocked += int(blocked or 0)
-                    total_ooo += int(ooo or 0)
-
-
-                accounted_rooms = total_avail + total_booked + total_blocked + total_ooo
-                syncing_rooms = total_physical - accounted_rooms
-
-                if syncing_rooms > 0:
-                    status = f"Out of {total_physical} total rooms, {total_avail} are available today. ध्यान दें: {syncing_rooms} room(s) are currently updating their blocked or booked status in the system."
-                else:
-                    status = f"Out of {total_physical} total rooms today, {total_avail} are available, {total_booked} are booked, {total_blocked} are blocked, and {total_ooo} are out of order."
-
-
-            else:
-                status = f"I checked the system, but I couldn't find any inventory data for the {category} category."
-                for cat in categories:
-                    if category in cat.get("categoryName", "").lower():
-                        today_str = today.strftime("%d-%m-%Y")
-                        exact_daily_data = {}
-
-                        for dd in cat.get("dateWiseData",[]):
-                            if dd.get("date") == today_str:
-                                exact_daily_data = dd
-                                break
-                        summary = cat.get("summary") or {}
-                        
-                        avail = exact_daily_data.get("availableRooms")
-                        if avail is None: avail = summary.get("totalAvailableRooms", 0)
-                        
-                        booked = exact_daily_data.get("bookedRooms")
-                        if booked is None: booked = summary.get("totalBookedRooms", 0)
-                        
-                        blocked = exact_daily_data.get("blockedRooms")
-                        if blocked is None: blocked = summary.get("totalBlockedRooms", 0)
-                        
-                        ooo = exact_daily_data.get("outOfOrderRooms")
-                        if ooo is None: ooo = summary.get("totalOutOfOrderRooms", 0)
-
-                        avail = int(avail or 0)
-                        booked = int(booked or 0)
-                        blocked = int(blocked or 0)
-                        ooo = int(ooo or 0)
-                        
-                        # Catch the Ghost Rooms for this specific category!
-                        total_physical = int(cat.get("totalRooms", 0))
-                        accounted_rooms = avail + booked + blocked + ooo
-                        syncing_rooms = total_physical - accounted_rooms
-                        
-                        if syncing_rooms > 0:
-                            status = f"For {cat['categoryName']}, {avail} are available right now. ध्यान दें: {syncing_rooms} room(s) are currently syncing their blocked or booked status."
-                        else:
-                            status = f"{cat['categoryName']}: {avail} available, {booked} booked, {blocked} blocked, and {ooo} out of order."
-                        break
-        else:
-            status = "I couldn't connect to the hotel system. Please try again."
-        return {"response":status}
-
-    else:
-        pending_data = {
-            "action": action,
-            "category": category,
-            "count": count
-        }
-        status = f"I am ready to {action} {count} {category} room(s). Should I proceed?"
-        return {"response": status,"pending_manager":"inventory","pending_action":pending_data}

agents/llm.py

@@ -1,17 +0,0 @@
-from langchain_groq import ChatGroq
-# from langchain_openai import ChatOpenAI
-import os
-from dotenv import load_dotenv
-load_dotenv()
-
-
-llm = ChatGroq(
-    model="llama-3.3-70b-versatile",
-    api_key=os.getenv("GROQ_API_KEY"),
-    temperature=0.0
-)
-
-# llm = ChatOpenAI(
-#     model="gpt-4.1-nano",
-#     api_key=os.getenv("OPENAI_API_KEY")
-# )

agents/rate_agent.py

@@ -1,225 +0,0 @@
-from agents.llm import llm
-from hotel_api import update_rates,fetch_room_availability
-import json
-import os
-
-
-
-async def rate_manager(state):
-    if state.get("pending_manager") == "rates":
-        user_reply = str(state.get("query","")).lower()
-
-        prompt = f"""User said: "{user_reply}"
-        If this is a positive confirmation for a booking, return "yes"
-        otherwise return "no". Nothing extra."""
-        response = llm.invoke(prompt)
-        confirmation = response.content.strip().lower()
-        if hasattr(response, 'usage_metadata') and response.usage_metadata:
-            print(f"Tokens used: {response.usage_metadata}")
-
-        if confirmation == "yes":
-            pa = state["pending_action"]
-
-            room_info = pa.get("room_info", {})
-
-            from datetime import datetime
-            today = datetime.now()
-            date_str = today.strftime("%Y-%m-%d")
-
-            success, data = await update_rates(
-                category=pa["category"],
-                new_price=pa["new_price"],
-                start_date=date_str,
-                end_date=date_str,
-                room_code=room_info.get("roomCode")
-            )
-
-            if success:
-                status = f"Done! The rate for {pa['category']} rooms has been successfully updated to {pa['new_price']} rupees."
-            else:
-                status = f"Sorry, I failed to update the rate for {pa['category']} rooms."
-            return {"response": status, "pending_manager": None, "pending_action": None}
-        else:
-            return {"response": "No problem, I have cancelled the rate change.", "pending_manager": None, "pending_action": None}
-
-    prompt = f"""Extract rate details from the request.
-    Request: {state['query']}
-    Return ONLY a JSON object: {{"action": "check|change", "category": "standard|deluxe|suite|presidential", "new_price": 0, "date":"today"}}
-    - If it's just checking the price, leave new_price as 0.
-    - If they don't mention a specific date, default to "today".
-    Return ONLY JSON, no extra text."""
-
-    response = llm.invoke(prompt)
-    if hasattr(response, 'usage_metadata') and response.usage_metadata:
-        print(f"Tokens used: {response.usage_metadata}")
-
-    try:
-        data = json.loads(response.content.strip())
-    except:
-        return {"response": "sorry i couldn't quite catch your rates"}
-
-    # action = data.get("action","check")
-    # category = data.get("category","single")
-
-    # if action == "check":
-    #     # check_in = data.get("check_in")
-    #     # check_out = data.get("check_out")
-    #     from datetime import datetime,timedelta
-
-    #     today = datetime.now()
-    #     check_in = today.strftime("%Y-%m-%d")
-    #     check_out = (today + timedelta(days=1)).strftime("%Y-%m-%d")
-    #     adults = int(data.get("adults",1))
-
-    #     rooms_payload = [{"roomNumber": 1, "guests": {"adults":adults,"children":0}}]
-
-    #     success, api_response = await fetch_room_availability(
-    #         phone_number_id=os.getenv("PHONE_NUMBER_ID"),
-    #         check_in=check_in,
-    #         check_out=check_out,
-    #         rooms=rooms_payload
-    #     )
-    #     # print(f"Success: {success}")
-    #     # print(f"API RESPONSE KEY: {api_response.keys()}")
-    #     # print(f"RAW reservationPrice: {api_response.get('reservationPrice', 'KEY NOT FOUND')}")
-    #     # print(f"RAW data key: {api_response.get('data', 'KEY NOT FOUND')}")
-
-
-    #     if success:
-    #         print("--- LIVE RATE DATA ---")
-    #         print(json.dumps(api_response.get("data", {}).get("reservationPrice",[]), indent=2))
-
-    #         prices_list = api_response.get("data", {}).get("reservationPrice", [])
-    #         found_price = None
-    #         print(f"PRICES LIST LENGTH: {len(prices_list)}")
-    #         if prices_list:
-    #             print(f"FIRST ITEM KEY: {prices_list[0].keys()}")
-    #             print(f"FIRST ITEM roomType: {prices_list[0].get("roomType")}")
-
-
-
-    #         from hotel_api import get_room_map
-    #         from tools.category_matcher import match_category
-
-    #         room_map = await get_room_map()
-    #         matched_category = await match_category(category, room_map)
-
-    #         if matched_category and matched_category in room_map:
-    #             category = matched_category
-
-    #         room_info = room_map.get(category)
-    #         print(f"LOOKING FOR: {category.lower()}, FOUND: {room_info}")
-
-    #         print(f"ALL ROOM TYPES: {[r.get('roomType') for r in prices_list]}")
-
-    #         for room in prices_list:
-    #             if category in room.get("roomType", "").lower():
-    #                 # Attempt to grab the price. We might need to change 'price' to the exact key!
-    #                 cats = room.get("categories",[])
-    #                 if cats:
-    #                     found_price = cats[0].get("totalPrice") 
-    #                 break
-
-    #         if found_price is not None:
-    #             status = f"The current rate for a {category} room today is {found_price} rupees."
-    #         else:
-    #             status = f"I checked the system, but I couldn't find the rate for the {category} category."
-    #     else:
-    #         status = "I tried to check the live rates, but the system returned an error."
-            
-    #     return {"response": status}
-    # else:
-    #     # User wants to CHANGE the rate
-    #     price = data.get("new_price", 0)
-    #     if price == 0:
-    #         return {"response": "I didn't catch the new price. Please tell me the amount you want to change it to."}
-        
-    #     pending_data = {
-    #         "category": category,
-    #         "new_price": price
-    #     }
-    #     status = f"I am ready to change the rate of {category} rooms to {price} rupees. Should I confirm this change?"
-    #     return {"response": status, "pending_manager": "rates", "pending_action": pending_data}
-
-
-    action = data.get("action", "check")
-    raw_category = data.get("category", "single")
-
-    # ==========================================
-    # 1. MAP CATEGORY FOR BOTH CHECK AND CHANGE
-    # ==========================================
-    from hotel_api import get_room_map
-    from tools.category_matcher import match_category
-
-    room_map = await get_room_map()
-    matched_category = await match_category(raw_category, room_map)
-
-    # Resolve to the exact key in your room map
-    if matched_category and matched_category in room_map:
-        category = matched_category
-    else:
-        category = raw_category
-
-    # Grab the exact official name for the Channex API
-    room_info = room_map.get(category, {})
-    exact_api_name = room_info.get("categoryName", category)
-    # ==========================================
-
-    print("\n" + "🔥"*20)
-    print(f"DEBUGGING CHANNEX FOR: {category}")
-    print(json.dumps(room_info, indent=2))
-    print("🔥"*20 + "\n")
-
-    if action == "check":
-        from datetime import datetime, timedelta
-
-        today = datetime.now()
-        check_in = today.strftime("%Y-%m-%d")
-        check_out = (today + timedelta(days=1)).strftime("%Y-%m-%d")
-        adults = int(data.get("adults", 1))
-
-        rooms_payload = [{"roomNumber": 1, "guests": {"adults": adults, "children": 0}}]
-
-        success, api_response = await fetch_room_availability(
-            phone_number_id=os.getenv("PHONE_NUMBER_ID"),
-            check_in=check_in,
-            check_out=check_out,
-            rooms=rooms_payload
-        )
-
-        if success:
-            prices_list = api_response.get("data", {}).get("reservationPrice", [])
-            found_price = None
-
-            for room in prices_list:
-                # Use exact_api_name to match against the API's response
-                if exact_api_name.lower() in room.get("roomType", "").lower():
-                    cats = room.get("categories", [])
-                    if cats:
-                        found_price = cats[0].get("totalPrice") 
-                    break
-
-            if found_price is not None:
-                status = f"The current rate for a {exact_api_name} room today is {found_price} rupees."
-            else:
-                status = f"I checked the system, but I couldn't find the rate for the {exact_api_name} category."
-        else:
-            status = "I tried to check the live rates, but the system returned an error."
-            
-        return {"response": status}
-
-    else:
-        # User wants to CHANGE the rate
-        price = data.get("new_price", 0)
-        if price == 0:
-            return {"response": "I didn't catch the new price. Please tell me the amount you want to change it to."}
-        
-        # 2. SAVE THE EXACT API NAME TO PENDING ACTION
-        pending_data = {
-            "category": exact_api_name, 
-            "new_price": price,
-            "room_info": room_info
-        }
-        status = f"I am ready to change the rate of {exact_api_name} rooms to {price} rupees. Should I confirm this change?"
-        return {"response": status, "pending_manager": "rates", "pending_action": pending_data}
-    

agents/reservation_agent.py

@@ -1,651 +0,0 @@
-from hotel_api import fetch_room_availability,create_reservation
-from datetime import datetime,timedelta
-from agents.llm import llm
-import re
-import json
-import os
-from dotenv import load_dotenv
-load_dotenv()
-
-
-async def reservation_manager(state):
-    pb = state.get("pending_action") or {}
-    user_reply = str(state.get("query", "")).strip().lower()
-    extracted = state.get("extracted_data", {})
-    booking_step = state.get("booking_step","")
-    current_manager = state.get("pending_manager")
-
-    if current_manager == "reservations" or not current_manager:
-
-        # cancel_words = ["cancel","stop","no","don't","abort","quit"]
-        cancel_pattern = r'\b(cancel|stop|don\'t|abort|quit)\b'
-        # if any(word in user_reply for word in cancel_words):
-        if re.search(cancel_pattern, user_reply):
-            return {
-                "response": "No problem, I have canceled the current process. How else can I help you?",
-                "pending_manager": "",
-                "pending_action": {},
-                "booking_step": ""
-            }
-
-        if booking_step == "":
-            from hotel_api import get_room_map
-            room_map = await get_room_map()
-            real_categories = list(room_map.keys())
-            today_str = datetime.now().strftime("%Y-%m-%d")
-            today_day = datetime.now().strftime("%A")
-            prompt = f"""Extract booking details from the hotel owner's request.
-            Request: {state['query']}
-            CRITICAL CONTEXT:
-            - Today is {today_day}, {today_str}. Use this to calculate "tomorrow", "next Friday", etc.
-            - AVAILABLE ROOM CATEGORIES: {real_categories}
-            Return ONLY a JSON object:
-            {{
-                "action": "book|cancel|modify|check_availability",
-                "category": "category_name_from_list_or_null",
-                "guest_name": "The person's name. Could be the first word, or after 'name:', 'guest:', 'for'. Example: 'Kabilan', 'Mr. Sharma', 'John'. Look carefully — it's often the very first word in the message.",
-                "check_in": "YYYY-MM-DD_or_null",
-                "check_out": "YYYY-MM-DD_or_null",
-                "adults": 1,
-                "room_count": 1,
-                "meal_plan": "EP|CP|MAP|AP|null",
-                "phone_number": "string_or_null",
-                "custom_price": "integer_or_null",
-                "advance_payment": "integer_or_null",
-                "payment_method": "Online Payment or Credit Card or Bank Transfer or Pay at Hotel. Return null if not mentioned."            }}
-            Rules:
-            - CRITICAL CALENDAR CONTEXT: Today is {today_day}, {today_str}. 
-            - Use today's day and date to perfectly calculate relative words like "tomorrow", "Wednesday", "this week", etc.
-            - If check-out is missing, default to 1 day after check-in.
-            - If adults are not mentioned, default to 1.
-            - meal_plan: If they mention EP, CP, MAP, AP, "room only", "with breakfast", etc., extract the acronym. Else null.
-            - phone_number: Extract the full phone number string if provided. Else null.
-            - custom_price: If the owner states a specific total price for the room (e.g., "price is 5000"), extract as integer. Else null.
-            - advance_payment: If they state an advance payment amount, extract as integer. Else null.
-            Return ONLY valid JSON."""
-
-            response = llm.invoke(prompt)
-            raw_content = response.content.strip()
-            if hasattr(response, 'usage_metadata') and response.usage_metadata:
-                print(f"Tokens used: {response.usage_metadata}")
-
-            # print(f"--- RAW LLM RESPONSE ---\n{raw_content}\n------------------------")
-            clean_content = raw_content.replace("```json","").replace("```","").strip()
-            try:
-                data = json.loads(clean_content)
-                print(f"--- DEBUG JSON FROM LLM: {data} ---")
-            except Exception as e:
-                print(f"JSON Parsing error: {e}")
-                return {"response": "sorry i couldn't understand your reservation details"}
-    
-        
-            if data.get("guest_name"): pb["guest_name"] = data["guest_name"]
-            if data.get("category"):   pb["category"] = data["category"]
-            if data.get("check_in"):   pb["check_in"] = data["check_in"]
-            if data.get("check_out"):  pb["check_out"] = data["check_out"]
-            if data.get("meal_plan"): pb["meal_plan"] = data["meal_plan"]
-            if data.get("phone_number"): pb["phone_number"] = data["phone_number"]
-            if data.get("custom_price"): pb["custom_price"] = data["custom_price"]
-            if data.get("advance_payment") is not None:
-                pb["advance_payment"] = data["advance_payment"]
-            if data.get("payment_method"): pb["payment_method"] = data["payment_method"]
-            if data.get("room_count"): pb["room_count"] = data["room_count"]
-
-        category = pb.get("category")
-        check_in = pb.get("check_in")
-        check_out = pb.get("check_out")
-        adults = int(extracted.get("adults", pb.get("adults", 1)))
-        guest_name = pb.get("guest_name")
-
-        if booking_step == "collect_name" and not pb.get("guest_name"):
-            pb["guest_name"] = state.get("query", "").strip()
-            print(f"Collected name: {pb['guest_name']}")
-
-        elif booking_step == "collect_category" and not pb.get("category"):
-            pb["category"] = state.get("query", "").strip()
-
-        elif booking_step == "collect_checkin" and not pb.get("check_in"):
-            pb["check_in"] = state.get("query", "").strip()
-            check_in = pb["check_in"]
-
-        elif booking_step == "collect_checkout" and not pb.get("check_out"):
-            pb["check_out"] = state.get("query", "").strip()
-            check_out = pb["check_out"]
-
-            #collecting meal plan
-        elif booking_step == "meal_plan":
-            user_reply = state.get("query","")
-
-            meal_prompt = f"""
-            The user is choosing a hotel meal plan.
-            User's reply: "{user_reply}"
-            
-            Available Plans:
-            - "EP": European Plan (Room Only, no meals, just the room)
-            - "CP": Continental Plan (Room + Breakfast)
-            - "MAP": Modified American Plan (Half Board, two meals)
-            - "AP": American Plan (Full Board, all meals)
-            
-            Analyze the user's reply. Account for STT phonetic typos (e.g., "ee pee" -> EP, "see pee" -> CP) and conversational phrases. 
-            Return ONLY a valid JSON object. If you cannot confidently map their reply to a plan, return null.
-            
-            OUTPUT FORMAT:
-            {{"meal_plan": "EP" | "CP" | "MAP" | "AP" | null}}
-            """
-            try:
-                response = await llm.ainvoke(meal_prompt)
-                cleaned_response = response.content.replace("```json", "").replace("```", "").strip()
-                if hasattr(response, 'usage_metadata') and response.usage_metadata:
-                    print(f"Tokens used: {response.usage_metadata}")
-                extracted = json.loads(cleaned_response)
-                selected_meal = extracted.get("meal_plan")
-
-            except Exception as e:
-                print(f"Meal extraction error: {e}")
-                selected_meal = None
-
-            if not selected_meal:
-                return {
-                    "response": "I didn't catch that. Please say EP (room only), CP (with breakfast), MAP (half board), or AP (all meals).", 
-                    "pending_manager": "reservations", 
-                    "pending_action": pb, 
-                    "booking_step": "meal_plan"
-                }
-
-            pb["meal_plan"] = selected_meal
-                    
-            meal_categories = pb.get("meal_categories", [])
-    
-            # Map the EP/CP/MAP/AP choice to the words the Xipper API actually uses
-            search_key = {
-                "EP": "only",
-                "CP": "breakfast",
-                "MAP": "lunch",  # Matches 'Room With Breakfast + Lunch/Dinner'
-                "AP": "all"      # Matches 'Room With All Meals'
-            }.get(selected_meal, "only")
-
-            room_count = int(pb.get("room_count", 1))
-
-            for plan in meal_categories:
-                api_plan_name = plan.get("category", "").lower()
-                
-                # If we find the matching meal plan in the API list...
-                if search_key in api_plan_name:
-                    single_new_base = plan.get("basePrice", 4000)
-                    single_new_tax = plan.get("totalTax", single_new_base * 0.12)
-                    single_new_total = plan.get("totalPrice", single_new_base + single_new_tax)
-
-                    if "pricing" not in pb:
-                        pb["pricing"] = {}
-                    
-                    # Overwrite the memory with the new, accurate prices!
-                    pb["pricing"]["basePrice"] = single_new_base   #* room_count
-                    pb["pricing"]["totalTax"] = single_new_tax #* room_count
-                    pb["pricing"]["totalPrice"] = single_new_total #* room_count
-                    pb["pricing"]["pricePerNight"] = plan.get("pricePerNight", single_new_total)
-
-                    if pb.get("custom_price"):
-                        custom_total = int(pb.get("custom_price"))
-                        pb["pricing"]["totalPrice"] = custom_total
-                    break
-
-            # return {"response": "Got it. What is the guest's phone number?", "pending_manager": "reservations", "pending_action": pb, "booking_step": "phone"}
-
-        #collecting phone number
-        elif booking_step == "phone":
-            phone = "".join(filter(str.isdigit, user_reply))
-            if len(phone) < 10:
-                return {"response": "Please say a valid 10 digit phone number.", "pending_manager": "reservations", "pending_action": pb, "booking_step": "phone"}
-            pb["phone_number"] = phone
-            # return {
-            #     "response": "How much customer paid in advance?", 
-            #     "pending_manager": "reservations", 
-            #     "pending_action": pb, 
-            #     "booking_step": "advance_payment"
-            # }
-
-        elif booking_step == "advance_payment":
-            user_reply = state.get("query","")
-            total_price = pb.get("pricing", {}).get("totalPrice", 0)
-
-            payment_prompt = f"""
-            The user is stating how much advance payment was collected for a hotel booking.
-            The total price of the booking is {total_price}.
-            User's reply: "{user_reply}"
-            
-            Extract the exact numerical amount paid in advance. Account for conversational phrases:
-            - If they say "nothing", "zero", or "pay at hotel", return 0.
-            - If they say "half", return exactly half of the total price.
-            - If they say "full" or "all of it", return the total price.
-            
-            Return ONLY a valid JSON object.
-            
-            OUTPUT FORMAT:
-            {{"advance_amount": integer_number_here}}
-            """
-            try:
-                response = await llm.ainvoke(payment_prompt)
-                cleaned_response = response.content.replace("```json", "").replace("```", "").strip()
-                if hasattr(response, 'usage_metadata') and response.usage_metadata:
-                    print(f"Tokens used: {response.usage_metadata}")
-                extracted = json.loads(cleaned_response)
-                advance_amount = extracted.get("advance_amount", 0)
-            except Exception as e:
-                print(f"Advance payment extraction error: {e}")
-                advance_amount = 0
-
-            pb["advance_payment"] = advance_amount
-
-            # guest_name = pb.get("guest_name", "Guest")
-            # room_type = pb.get("category", "room")
-            # meal_plan = pb.get("meal_plan", "EP")
-
-            # return {
-            #     "response": "What is the payment method? Online payment, Credit card, Bank transfer, or Pay at hotel?",
-            #     "pending_manager": "reservations",
-            #     "booking_step": "payment",
-            #     "pending_action": pb
-            # }
-
-        #cpllecting payment method
-        elif booking_step == "payment":
-            try:
-                payment_map = {
-                    "online": "Online Payment",
-                    "credit": "Credit Card",
-                    "card": "Credit Card",
-                    "bank": "Bank Transfer",
-                    "transfer": "Bank Transfer",
-                    "hotel": "Pay at Hotel",
-                    "cash": "Pay at Hotel",
-                    "upi": "Online Payment"
-                }
-                payment_method = None
-                for key,val in payment_map.items():
-                    if key in user_reply.lower():
-                        payment_method = val
-                        break
-                if not payment_method:
-                    return {"response": "Please say Online payment, Credit card, Bank transfer, or Pay at hotel.", "pending_manager": "reservations", "pending_action": pb, "booking_step": "payment"}
-
-                pb["payment_method"] = payment_method
-                pricing_data = pb.get("pricing") or {} 
-                total_price = pricing_data.get("totalPrice", 0)
-                total_price = pb.get("pricing", {}).get("totalPrice", 0)
-
-                # status = f"Confirming: {pb['category']} room for {pb['guest_name']}, phone {pb['phone_number']}, {pb['meal_plan']} meal plan, {payment_method} payment. Total {total_price} rupees. Shall I book?"
-                # return {
-                #     "response": status, 
-                #     "pending_manager": "reservations", 
-                #     "pending_action": pb, 
-                #     "booking_step": "confirm"
-                # }
-            
-            except Exception as e:
-                # IF IT CRASHES, CATCH IT AND PRINT THE EXACT CAUSE!
-                print("\n" + "="*50)
-                print(f"🔥 CRASH IN PAYMENT STEP: {e}")
-                import traceback
-                traceback.print_exc()
-                print("="*50 + "\n")
-                
-                # Return safely so the server doesn't throw a 503
-                safe_pb = state.get("pending_action") or {}
-                return {"response": "Sorry, I encountered an internal glitch while processing the payment type. Could you repeat that?", "pending_manager": "reservations", "pending_action": safe_pb, "booking_step": "payment"}
-
-        
-        from tools.date_utiles import sanitize_date
-        # from agents.llm import llm
-
-        check_in = await sanitize_date(check_in,llm)
-        check_out = await sanitize_date(check_out,llm)
-
-        pb["check_in"] = check_in
-        pb["check_out"] = check_out
-
-
-        if not pb.get("availability_checked") and category and check_in and check_out:
-            room_count = int(pb.get("room_count",1))
-
-            adults_per_room = max(1, adults//room_count)
-            rooms_payload = []
-            for i in range(room_count):
-                rooms_payload.append({
-                    "roomNumber": i + 1, 
-                    "guests": {"adults": adults_per_room, "children": 0}
-                })
-            # rooms_payload = [{"roomNumber": 1, "guests": {"adults":adults,"children":0}}]
-            # safe_phone_id = state.get("phone_number_id")
-            # if not safe_phone_id: 
-            safe_phone_id = os.getenv("PHONE_NUMBER_ID")
-
-            success,avail_data = await fetch_room_availability(
-                phone_number_id=safe_phone_id,
-                check_in=check_in,
-                check_out=check_out,
-                rooms=rooms_payload
-            )
-
-            # print(f"PRICES LIST: {avail_data.get('reservationPrice', [])}")
-
-
-            if not success:
-                return {"response": "I tried to check availability for those dates, but the system returned an error."}
-
-            prices_list = avail_data.get("data", {}).get("reservationPrice",[])
-            found_room = None
-
-            # from hotel_api import get_room_map
-            # room_map = await get_room_map()
-            # print(f"ROOM MAP KEYS: {list(room_map.keys())}")
-            # room_info = None
-            # for key,value in room_map.items():
-            #     if key in category.lower():
-            #         room_info = value
-            #         category = key
-            #         pb["category"] = key
-            #         break
-            # # room_info = room_map.get(category.lower())
-            # # print(f"LOOKING FOR: {category.lower()}, FOUND: {room_info}")
-
-            # if not room_info:   
-            #     pb["category"] = None  #-> wipe bad data
-            #     return {
-            #         "response": f"Sorry, I don't recognize {category} category",
-            #         "pending_manager":"reservations",
-            #         "booking_step":"collect_category",
-            #         "pending_action": pb
-            #     }
-
-            from hotel_api import get_room_map
-            from tools.category_matcher import match_category
-            
-            room_map = await get_room_map()
-            print(f"ROOM MAP KEYS: {list(room_map.keys())}")
-
-            matched_category = await match_category(category, room_map)
-
-
-            room_info = None
-            if matched_category and matched_category in room_map:
-                room_info = room_map[matched_category]
-                category = matched_category
-                pb["category"] = matched_category
-
-            if not room_info:
-                pb["category"] = None
-                return {
-                    "response": f"I couldn't find a matching room category for '{category}'. Available categories are: {', '.join(room_map.keys())}. Which one would you like?",
-                    "pending_manager": "reservations",
-                    "booking_step": "collect_category",
-                    "pending_action": pb
-                }
-
-            target_name = room_info["categoryName"].lower()
-
-            for room in prices_list:
-                if target_name == room.get("roomType", "").lower():
-                    found_room = room
-                    break
-
-            if not found_room:
-                pb["category"] = None
-                return {
-                    "response": f"I checked the inventory, but the {category} category is either sold out or has no pricing set for those dates.",
-                    "pending_manager":"reservations",
-                    "pending_action":pb,
-                    "booking_step": "collect_category"
-                    }
-
-            print("\n" + "="*50)
-            print(f"API DATA FOR {category.upper()}: {found_room}")
-            print("="*50 + "\n")
-
-            exact_room_name = found_room.get("roomType", category.title() + " room")
-
-            meal_categories = found_room.get("categories", [])
-
-            room_count = int(pb.get("room_count",1))
-
-            if meal_categories:
-                # Default to the first one in the list (usually 'Room Only') for the initial quote
-                default_plan = meal_categories[0]
-                single_base = default_plan.get("basePrice", 4000)
-                single_tax = default_plan.get("totalTax", single_base * 0.12)
-                single_total = default_plan.get("totalPrice", single_base + single_tax)
-
-                #multiply by number of rooms
-                base_price = single_base * room_count
-                total_tax = single_tax * room_count
-                total_price = single_total * room_count
-            else:
-                # Fallback if the categories array is empty
-                base_price = 4000 * room_count
-                total_tax = 480 * room_count
-                total_price = 4480 * room_count
-
-            if pb.get("custom_price"):
-                total_price = int(pb["custom_price"])
-                base_price = total_price / 1.12 
-                total_tax = total_price - base_price
-
-            pb["category"] = category
-            pb["roomType"] = exact_room_name
-            pb["guest_name"] = guest_name
-            pb["check_in"] = check_in
-            pb["check_out"] = check_out
-            pb["adults"] = adults
-            pb["children"] = 0
-            pb["meal_categories"] = meal_categories
-            pb["availability_checked"] = True  # Flag to show we found the room
-            
-            pb["pricing"] = {
-                "basePrice": base_price,
-                "totalTax": total_tax,
-                "totalPrice": total_price,
-                "pricePerNight": meal_categories[0].get("pricePerNight", total_price) if meal_categories else total_price,
-                "numberOfNights": meal_categories[0].get("numberOfNights", 1) if meal_categories else 1,
-                "dateWisePricing": [],
-                "meal_categories": meal_categories
-            }
-#-------------------------------------------------------------------------------------------------
-        current_price = pb.get("pricing", {}).get("totalPrice", 0)
-
-        if not pb.get("guest_name"):
-            return {
-                "response": "I can definitely help you check availability. Could you please tell me the guest's name for the reservation?",
-                "pending_manager":"reservations",
-                "booking_step":"collect_name",
-                "pending_action": pb
-            }
-
-        if not pb.get("category"): #or pb.get("category").lower() == None:
-            return {
-                "response": f"Got it, booking for {pb['guest_name']}. What category of room would you like?",
-                "pending_manager":"reservations",
-                "booking_step": "collect_category",
-                "pending_action": pb
-            }
-
-        if not pb.get("check_in"):
-            return {
-                "response": f"Perfect. What is your check-in date for the {pb['category']} room?",
-                "pending_manager":"reservations",
-                "booking_step":"collect_checkin",
-                "pending_action": pb
-            }
-
-        if not pb.get("check_out"):
-            return {
-                "response": "And what will be your check-out date?",
-                "pending_manager": "reservations",
-                "booking_step":"collect_checkout",
-                "pending_action": pb
-            }
-
-        if not pb.get("meal_plan"):
-            return {
-                "response": "what meal plan would you like?",
-                "pending_manager": "reservations",
-                "booking_step": "meal_plan",
-                "pending_action": pb
-            }
-
-        if not pb.get("phone_number"):
-            return {
-                "response": "what is guest phone number",
-                "pending_manager": "reservations",
-                "booking_step": "phone", #_______________________________________________
-                "pending_action": pb
-            }
-
-        if pb.get("advance_payment") is None:
-            return {
-                "response": "How much advance payment made?",
-                "pending_manager": "reservations",
-                "booking_step": "advance_payment",
-                "pending_action": pb
-            }
-
-        if not pb.get("payment_method"):
-            if pb.get("advance_payment") is not None and pb.get("advance_payment") > 0:
-                pb["payment_method"] = "Pay at Hotel"
-            else:
-                return {
-                    "response": "What is the payment method? Online, Credit card, Bank transfer, or Pay at hotel?",
-                    "pending_manager": "reservations",
-                    "booking_step": "payment",
-                    "pending_action": pb
-                }
-
-        print("🎉 All slots filled successfully:", pb)
-
-        if booking_step != "confirm":
-            guest = pb.get("guest_name", "Guest")
-            method = pb.get("payment_method", "Pay at Hotel")
-            return {
-                "response": f"Got everything. Shall I confirm the {pb.get('meal_plan')} booking for {guest} using {method} at {current_price} rupees?",
-                "pending_manager": "reservations",
-                "booking_step": "confirm",
-                "pending_action": pb
-            }
-
-        if booking_step == "confirm":
-            try:
-                prompt = f"""User said: "{user_reply}"
-                If this is a positive confirmation for a booking, return "yes"
-                otherwise return "no". Nothing extra."""
-                response = await llm.ainvoke(prompt)
-                if hasattr(response, 'usage_metadata') and response.usage_metadata:
-                    print(f"Tokens used: {response.usage_metadata}")
-                confirmation = response.content.strip().lower()
-                
-
-                if confirmation == "yes":
-
-                    cin_str = pb.get("check_in")
-                    nights = pb.get("pricing", {}).get("numberOfNights", 1)
-                    from tools.pricing_utils import build_date_wise_pricing,get_meal_name
-                    correct_meal_name = get_meal_name(pb.get("meal_plan", "EP"))
-
-                    pricing_dict = pb.get("pricing", {})
-
-                    # base_price = pb.get("pricing", {}).get("basePrice", 0)
-                    # total_tax = pb.get("pricing", {}).get("totalTax", 0)
-
-
-
-                    # Update the pricing dictionary with our new array
-                    # pricing_dict["dateWisePricing"] = date_wise_pricing
-
-#----------------------------------------------------------------------------
-                    room_count = int(pb.get("room_count",1))
-                    adults_per_room = max(1,pb["adults"]//room_count)
-
-                    per_room_base = pricing_dict.get("basePrice", 0) / room_count
-                    per_room_tax = pricing_dict.get("totalTax", 0) / room_count
-                    per_room_total = pricing_dict.get("totalPrice", 0) / room_count
-
-                    date_wise_pricing = build_date_wise_pricing(cin_str, nights, per_room_base, per_room_tax)
-                    
-                    room_details = []
-                    for i in range(room_count):
-                        room_pricing = {
-                            "basePrice": per_room_base,
-                            "totalTax": per_room_tax,
-                            "totalPrice": per_room_total,
-                            "pricePerNight": per_room_total,
-                            "numberOfNights": pricing_dict.get("numberOfNights", 1),
-                            "dateWisePricing": date_wise_pricing
-                        }
-                        room_details.append({
-                            "roomName": f"Room {i+1}",
-                            "roomType": pb["roomType"],
-                            "mealPlan": correct_meal_name,
-                            "adults": adults_per_room,
-                            "children": pb["children"],
-                            "pets": "No",
-                            "pricing": room_pricing
-                        })
-                    
-                    guest_details = [{
-                        "title": "Mr",
-                        "firstName": pb["guest_name"].split()[0],
-                        "lastName": pb["guest_name"].split()[-1] if len(pb["guest_name"].split()) > 1 else "",
-                        "phoneNumber": pb["phone_number"],
-                        "email": "",
-                        "xipperId": "",
-                        "cXipperId": ""
-                    }]
-
-
-                    success,data = await create_reservation(
-                        hotel_id=os.getenv("HOTEL_ID"),
-                        check_in=pb["check_in"],
-                        check_out=pb["check_out"],
-                        user_id=os.getenv("USER_ID"),
-                        room_details=room_details,
-                        guest_details=guest_details,
-                        payment_method=pb["payment_method"],
-                        total_amount=pb.get("pricing", {}).get("totalPrice", 0.0),
-                        advance_payment=pb.get("advance_payment", 0)
-                    )
-                    
-
-                    if success:
-                        status = f"Done! Booking for {pb['guest_name']} successfully completed."
-
-                        # from whatsapp_api import send_booking_confirmation
-                        # await send_booking_confirmation(
-                        #     guest_phone="9911943475",
-                        #     guest_name=pb["guest_name"],
-                        #     room_type=pb["category"],
-                        #     check_in=pb["check_in"],
-                        #     check_out=pb["check_out"],
-                        #     total_price=pricing_dict["totalPrice"]
-                        # )
-
-                        return {"response": status, "pending_manager": "", "pending_action": {}, "booking_step": ""}
-                    else:
-                        error_msg = data.get("data", {}).get("message", data.get("message", "an unknown API error"))
-                        status = f"Sorry, the booking failed. The server said: {error_msg}."
-                        return {"response": status, "pending_manager": "", "pending_action": {}, "booking_step": ""}
-                                            
-                else:
-                    return {
-                        "response": "No problem, I have cancelled the reservation process.", 
-                        "pending_manager": "", 
-                        "pending_action": {},
-                        "booking_step": "",
-                        "conversation_language": None
-                    }
-                
-            except Exception as e:
-                print("\n" + "="*50)
-                print(f"🔥 CRASH IN CONFIRM STEP: {e}")
-                import traceback
-                traceback.print_exc()
-                print("="*50 + "\n")
-                
-                safe_pb = state.get("pending_action") or {}
-                return {"response": "Sorry, an internal error occurred while finalizing the booking. Should I try to submit it again?", "pending_manager": "reservations", "pending_action": safe_pb, "booking_step": "confirm"}

agents/unknown_agent.py

@@ -1,4 +0,0 @@
-
-async def unknown_handler(state):
-    response = "Sorry but i can't help with you this query because i am here to help with your hotel management"
-    return {"response": response}

frontend/index2.html

@@ -1,477 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>Voice Agent · Xipper</title>
-    <style>
-        * { box-sizing: border-box; margin: 0; padding: 0; }
-
-        body {
-            background: linear-gradient(145deg, #1b2a3a 0%, #0f1a26 100%);
-            min-height: 100vh;
-            display: flex;
-            justify-content: center;
-            align-items: center;
-            font-family: 'Segoe UI', system-ui, -apple-system, sans-serif;
-            padding: 1.5rem;
-        }
-
-        .card {
-            background: rgba(30, 44, 58, 0.7);
-            backdrop-filter: blur(8px);
-            border-radius: 4rem 4rem 3rem 3rem;
-            box-shadow: 0 25px 50px -8px rgba(0,0,0,0.8), inset 0 2px 4px rgba(255,255,255,0.06);
-            padding: 3rem 2.5rem 3.5rem;
-            max-width: 600px;
-            width: 100%;
-            text-align: center;
-            border: 1px solid rgba(255,255,255,0.04);
-        }
-
-        h1 {
-            font-weight: 300;
-            font-size: 1.8rem;
-            letter-spacing: 2px;
-            color: #d6e6f5;
-            text-shadow: 0 2px 3px rgba(0,0,0,0.4);
-            margin-bottom: 0.25rem;
-        }
-
-        .sub {
-            color: #8aa9c9;
-            font-weight: 300;
-            font-size: 0.95rem;
-            border-bottom: 1px dashed #3a556b;
-            padding-bottom: 1.2rem;
-            margin-bottom: 2.2rem;
-        }
-
-        .mic-wrapper {
-            position: relative;
-            display: inline-block;
-            margin: 0.5rem 0 1.8rem;
-        }
-
-        .mic-btn {
-            background: #2b445a;
-            border: none;
-            border-radius: 50%;
-            width: 150px;
-            height: 150px;
-            box-shadow: 0 12px 28px rgba(0,0,0,0.7), 0 0 0 2px #4b6d89 inset, 0 0 0 4px #1a2e3f inset;
-            cursor: pointer;
-            transition: all 0.15s ease;
-            display: flex;
-            align-items: center;
-            justify-content: center;
-            color: #d9edff;
-            fill: currentColor;
-        }
-
-        .mic-btn:hover { background: #365a77; transform: scale(1.02); }
-        .mic-btn svg {
-            width: 70px; height: 70px;
-            filter: drop-shadow(0 4px 6px rgba(0,0,0,0.3));
-            transition: transform 0.1s;
-        }
-
-        .mic-btn.idle     { background: #2b445a; }
-        .mic-btn.listening {
-            background: #6f3a4a;
-            box-shadow: 0 0 0 4px #b34a5a inset, 0 0 0 6px #3f1f2b inset, 0 12px 28px #250f16;
-        }
-        .mic-btn.listening svg {
-            animation: pulse 1.2s infinite ease-in-out;
-            filter: drop-shadow(0 0 12px #ff7b7b);
-        }
-        .mic-btn.processing {
-            background: #1e3a6f;
-            box-shadow: 0 0 0 4px #2a5ab3 inset, 0 0 0 6px #0f1f3f inset, 0 12px 28px #0a1428;
-        }
-        .mic-btn.processing svg {
-            animation: pulse 0.8s infinite ease-in-out;
-            filter: drop-shadow(0 0 12px #4a9eff);
-        }
-
-        @keyframes pulse {
-            0%   { transform: scale(1); }
-            50%  { transform: scale(1.08); }
-            100% { transform: scale(1); }
-        }
-
-        .status-box {
-            background: #0e1a24cc;
-            border-radius: 60px;
-            padding: 0.9rem 1.8rem;
-            margin: 1.2rem 0 0.6rem;
-            display: inline-block;
-            border: 1px solid #3e5c74;
-            color: #c2d9ef;
-            font-size: 1rem;
-            min-width: 180px;
-            box-shadow: inset 0 2px 6px rgba(0,0,0,0.4);
-        }
-
-        /* Live transcript display */
-        .live-transcript {
-            background: #0e1a2488;
-            border-radius: 12px;
-            padding: 0.6rem 1.2rem;
-            margin: 0.4rem 0 1rem;
-            color: #7ab8e8;
-            font-size: 0.88rem;
-            font-style: italic;
-            min-height: 2rem;
-            border: 1px dashed #2a4a62;
-        }
-
-        .log-area {
-            background: #0f1923cc;
-            border-radius: 28px;
-            padding: 1rem 1.6rem;
-            margin: 1rem 0 0.8rem;
-            font-size: 0.9rem;
-            color: #b3ceea;
-            border-left: 3px solid #3d779b;
-            text-align: left;
-            min-height: 100px;
-            max-height: 200px;
-            overflow-y: auto;
-            word-break: break-word;
-            line-height: 1.6;
-            box-shadow: inset 0 4px 8px rgba(0,0,0,0.3);
-        }
-
-        .log-entry { margin-bottom: 0.4rem; }
-        .log-user  { color: #aac2dd; }
-        .log-agent { color: #a6e0b0; }
-        .log-info  { color: #d6ecff; opacity: 0.6; font-style: italic; }
-        .log-error { color: #ffa79e; }
-
-        .footnote {
-            margin-top: 1.5rem;
-            color: #5a7d99;
-            font-size: 0.75rem;
-            opacity: 0.7;
-            border-top: 1px solid #2f4b61;
-            padding-top: 1.2rem;
-        }
-
-        .btn-reset {
-            background: transparent;
-            border: 1px solid #3d6079;
-            color: #b3ceea;
-            border-radius: 40px;
-            padding: 0.4rem 1.2rem;
-            font-size: 0.8rem;
-            margin-top: 0.4rem;
-            cursor: pointer;
-            transition: 0.2s;
-            opacity: 0.6;
-        }
-        .btn-reset:hover { background: #2f4b61; opacity: 1; }
-
-        #chat-container { margin-top: 20px; }
-        #chatInput {
-            width: 300px; padding: 10px;
-            background: #1a2e3f;
-            border: 1px solid #3a5a75;
-            border-radius: 8px;
-            color: #d6ecff;
-            font-size: 0.9rem;
-        }
-        #btn-send-chat {
-            padding: 10px 16px;
-            background: #2b445a;
-            border: 1px solid #4b6d89;
-            border-radius: 8px;
-            color: #d9edff;
-            cursor: pointer;
-            margin-left: 6px;
-        }
-        #btn-send-chat:hover { background: #365a77; }
-    </style>
-</head>
-<body>
-<div class="card">
-    <h1>🎙️ VOICE AGENT</h1>
-    <div class="sub">click mic · speak · pause naturally · agent responds</div>
-
-    <div class="mic-wrapper">
-        <button class="mic-btn idle" id="micButton" aria-label="Start voice conversation">
-            <svg viewBox="0 0 24 24" width="70" height="70">
-                <path d="M12 16c-2.206 0-4-1.794-4-4V6c0-2.206 1.794-4 4-4s4 1.794 4 4v6c0 2.206-1.794 4-4 4zm8-4h-2c0 2.607-2.126 4.5-4 4.5S10 14.607 10 12H8c0 3.157 2.416 5.5 5 5.944V20h-2v2h6v-2h-2v-2.056c2.584-.444 5-2.787 5-5.944z"/>
-            </svg>
-        </button>
-    </div>
-
-    <div class="status-box">
-        <span id="statusText">🔴 idle · click mic to start</span>
-    </div>
-
-    <!-- Live transcript shown while user is speaking -->
-    <div class="live-transcript" id="liveTranscript"></div>
-
-    <div id="chat-container">
-        <input type="text" id="chatInput" placeholder="Or type your message...">
-        <button id="btn-send-chat">Send</button>
-    </div>
-
-    <div class="log-area" id="logArea">
-        <div class="log-entry log-info">📋 ready · click mic to start conversation</div>
-    </div>
-
-    <button class="btn-reset" id="resetLogBtn">↻ clear log</button>
-    <div class="footnote">Server-side VAD · WebSocket streaming · Deepgram nova-2 · Sarvam TTS</div>
-</div>
-
-<script>
-(function () {
-    "use strict";
-
-    const API_BASE  = 'https://kanhaiyaml-xipper.hf.space';
-    const CHAT_URL  = `${API_BASE}/chat`;
-    const WS_URL    = `https://kanhaiyaml-xipper.hf.space/ws/voice`;
-    const SAMPLE_RATE = 16000;
-
-    const micBtn        = document.getElementById('micButton');
-    const statusText    = document.getElementById('statusText');
-    const logArea       = document.getElementById('logArea');
-    const liveTranscript = document.getElementById('liveTranscript');
-    const chatInput     = document.getElementById('chatInput');
-    const sendChatBtn   = document.getElementById('btn-send-chat');
-
-    let isActive        = false;
-    let audioContext    = null;
-    let micSource       = null;
-    let scriptProcessor = null;
-    let stream          = null;
-    let socket          = null;
-
-    function setStatus(text) { statusText.textContent = text; }
-    function setMicState(state) { micBtn.className = `mic-btn ${state}`; }
-    function addLog(msg, type = 'info') {
-        const div = document.createElement('div');
-        div.className = `log-entry log-${type}`;
-        div.textContent = msg;
-        logArea.appendChild(div);
-        logArea.scrollTop = logArea.scrollHeight;
-    }
-
-    function float32ToInt16Buffer(float32Array) {
-        const int16 = new Int16Array(float32Array.length);
-        for (let i = 0; i < float32Array.length; i++) {
-            const c = Math.max(-1, Math.min(1, float32Array[i]));
-            int16[i] = c < 0 ? c * 32768 : c * 32767;
-        }
-        return int16.buffer;
-    }
-
-    function playAudioAndContinue(audioBase64) {
-        let b64 = audioBase64;
-        if (b64.startsWith('data:audio/')) b64 = b64.substring(b64.indexOf(',') + 1);
-        const binary = window.atob(b64);
-        const bytes  = new Uint8Array(binary.length);
-        for (let i = 0; i < binary.length; i++) bytes[i] = binary.charCodeAt(i);
-
-        const blob  = new Blob([bytes], { type: 'audio/wav' });
-        const url   = URL.createObjectURL(blob);
-        const audio = new Audio(url);
-
-        setMicState('processing');
-        setStatus('🔊 speaking...');
-
-        audio.onended = () => {
-            // Agent done speaking — go back to listening (socket still open)
-            if (isActive) {
-                setMicState('listening');
-                setStatus('🎤 listening...');
-            }
-        };
-
-        audio.play().catch(err => {
-            console.warn('Autoplay blocked:', err);
-            addLog('🔊 Autoplay blocked — click mic to continue', 'error');
-            setMicState('idle');
-            setStatus('🔴 autoplay blocked · click mic');
-        });
-    }
-
-    function openWebSocket() {
-        socket = new WebSocket(WS_URL);
-        socket.binaryType = 'arraybuffer';
-
-        socket.onopen = () => {
-            setMicState('listening');
-            setStatus('🎤 listening...');
-            addLog('🟢 Connected · speak now', 'info');
-            startStreamingAudio();
-        };
-
-        socket.onmessage = (event) => {
-            try {
-                const data = JSON.parse(event.data);
-
-                // Live transcript while user is speaking
-                if (data.interim_transcript !== undefined) {
-                    liveTranscript.textContent = '👂 ' + data.interim_transcript;
-                    return;
-                }
-                if (data.live_transcript !== undefined) {
-                    liveTranscript.textContent = '✅ ' + data.live_transcript;
-                    return;
-                }
-
-                // Server detected end of utterance, now processing
-                if (data.status === 'processing') {
-                    setMicState('processing');
-                    setStatus('⏳ thinking...');
-                    if (data.transcript) addLog(`👤 You: ${data.transcript}`, 'user');
-                    liveTranscript.textContent = '';
-                    return;
-                }
-
-                if (data.error) {
-                    addLog(`❌ ${data.error}`, 'error');
-                    return;
-                }
-
-                // Final response with audio
-                const { transcript, response: agentReply, audio } = data;
-                if (transcript) addLog(`👤 You: ${transcript}`, 'user');
-                if (agentReply) addLog(`🤖 Agent: ${agentReply}`, 'agent');
-                liveTranscript.textContent = '';
-
-                if (audio) {
-                    playAudioAndContinue(audio);
-                } else {
-                    setMicState('listening');
-                    setStatus('🎤 listening...');
-                }
-
-            } catch (e) {
-                console.error('Parse error:', e);
-            }
-        };
-
-        socket.onerror = (e) => {
-            console.error('WebSocket error:', e);
-            addLog('❌ Connection error', 'error');
-            setMicState('idle');
-            setStatus('⚠️ error');
-        };
-
-        socket.onclose = () => {
-            console.log('WebSocket closed');
-            if (isActive) {
-                // Unexpected close — try to reconnect after a short delay
-                setStatus('🔄 reconnecting...');
-                setTimeout(() => { if (isActive) openWebSocket(); }, 1000);
-            }
-        };
-    }
-
-    function startStreamingAudio() {
-        // Just pipe raw PCM to the WebSocket continuously.
-        // No VAD here — server decides when speech ends.
-        scriptProcessor.onaudioprocess = (event) => {
-            if (!socket || socket.readyState !== WebSocket.OPEN) return;
-            const float32 = event.inputBuffer.getChannelData(0);
-            socket.send(float32ToInt16Buffer(float32));
-        };
-    }
-
-    async function startConversation() {
-        if (isActive) {
-            stopConversation();
-            return;
-        }
-
-        try {
-            stream = await navigator.mediaDevices.getUserMedia({
-                audio: {
-                    echoCancellation: true,
-                    noiseSuppression: true,
-                    autoGainControl:  true,
-                    sampleRate:       SAMPLE_RATE,
-                    channelCount:     1,
-                }
-            });
-
-            audioContext    = new AudioContext({ sampleRate: SAMPLE_RATE });
-            micSource       = audioContext.createMediaStreamSource(stream);
-            scriptProcessor = audioContext.createScriptProcessor(4096, 1, 1);
-            micSource.connect(scriptProcessor);
-            scriptProcessor.connect(audioContext.destination);
-
-            isActive = true;
-            openWebSocket();
-
-        } catch (err) {
-            console.error('Mic error:', err);
-            let msg = '❌ Mic error: ';
-            if (err.name === 'NotAllowedError') msg += 'Permission denied.';
-            else msg += err.message;
-            addLog(msg, 'error');
-            setMicState('idle');
-            setStatus('⛔ mic error');
-        }
-    }
-
-    function stopConversation() {
-        isActive = false;
-
-        if (scriptProcessor) { scriptProcessor.disconnect(); scriptProcessor = null; }
-        if (micSource)       { micSource.disconnect();       micSource = null; }
-        if (audioContext)    { audioContext.close();          audioContext = null; }
-        if (stream)          { stream.getTracks().forEach(t => t.stop()); stream = null; }
-
-        if (socket && socket.readyState === WebSocket.OPEN) {
-            socket.send("STOP");   // tell server we're done
-            socket.close();
-        }
-
-        liveTranscript.textContent = '';
-        setMicState('idle');
-        setStatus('🔴 idle · click mic to start');
-        addLog('🔴 Conversation ended', 'info');
-    }
-
-    micBtn.addEventListener('click', startConversation);
-
-    // Text chat
-    sendChatBtn.onclick = async function () {
-        const message = chatInput.value.trim();
-        if (!message) return;
-        chatInput.value = '';
-        addLog(`👤 You: ${message}`, 'user');
-        setStatus('⏳ thinking...');
-        try {
-            const res  = await fetch(CHAT_URL, {
-                method: 'POST',
-                headers: { 'Content-Type': 'application/json' },
-                body: JSON.stringify({ message })
-            });
-            const data = await res.json();
-            addLog(`🤖 Agent: ${data.response}`, 'agent');
-            setStatus('🟢 ready');
-            if (data.audio) playAudioAndContinue(data.audio);
-        } catch (err) {
-            addLog('❌ Failed to send message.', 'error');
-            setStatus('🔴 error');
-        }
-    };
-
-    chatInput.addEventListener('keypress', e => { if (e.key === 'Enter') sendChatBtn.click(); });
-    document.getElementById('resetLogBtn').addEventListener('click', () => {
-        logArea.innerHTML = '<div class="log-entry log-info">📋 log cleared</div>';
-    });
-    window.addEventListener('beforeunload', () => { if (isActive) stopConversation(); });
-
-    setMicState('idle');
-    setStatus('🔴 idle · click mic to start');
-})();
-</script>
-</body>
-</html>

functions.py

@@ -1,17 +0,0 @@
-from datetime import datetime, timedelta
-
-
-def sanitize_date(date_str):
-    if not date_str:
-        return None
-    d = str(date_str).strip().lower()
-    today_dt = datetime.now()
-    
-    if d in ["today", "आज"]: 
-        return today_dt.strftime("%Y-%m-%d")
-    if d in ["tomorrow", "कल"]: 
-        return (today_dt + timedelta(days=1)).strftime("%Y-%m-%d")
-    if d in ["day after tomorrow", "परसों"]: 
-        return (today_dt + timedelta(days=2)).strftime("%Y-%m-%d")
-        
-    return date_str

graph_main.py

@@ -1,88 +0,0 @@
-from agents.rate_agent import rate_manager
-from agents.inventory_agent import inventory_manager
-from agents.reservation_agent import reservation_manager
-from agents.unknown_agent import unknown_handler
-from agents.llm import llm
-from langgraph.graph import StateGraph,START,END
-from typing import TypedDict,Optional
-from langgraph.checkpoint.memory import MemorySaver
-from dotenv import load_dotenv
-load_dotenv()
-
-
-
-class SupportState(TypedDict):
-    query: str
-    next_agent: str
-    response: str
-    pending_manager: Optional[str]
-    pending_action: Optional[dict]
-    phone_number_id: str
-    booking_link: str
-    booking_step: str
-    conversation_language: Optional[str]
-
-    
-memory = MemorySaver()
-
-
-async def choose_agent(state: SupportState):
-    if state.get("pending_manager"):
-        return {"next_agent":state["pending_manager"]}
-    
-    prompt = f"""Classify the hotel owner's request into one of these 3 managers:
-    'inventory' - Check availability, block, unblock, release, or unrelease rooms.
-    'rates' - Check room prices or change room rates.
-    'reservations' - Make a new booking, modify existing, or cancel.
-    'unknown' - Any request not related to hotel management (coding, general knowledge, etc.)    
-    Request: {state['query']}
-
-    IMPORTANT RULES:
-    - If the user is asking "how many" (कितने) or asking for counts, it is ALWAYS "inventory", even if they use the word "booked".
-    - ONLY return "reservations" if there is a specific guest involved or an intent to create a new booking right now.
-    Return ONLY one word: inventory, rates, reservations, or unknown."""
-
-    response = llm.invoke(prompt)
-    manager = response.content.strip().lower().replace(".","").replace("'","")
-
-    if hasattr(response, 'usage_metadata') and response.usage_metadata:
-        print(f"Tokens used: {response.usage_metadata}")
-
-    if manager not in ["inventory","rates","reservations"]:
-        manager = "unknown"
-    print(f"LLM returned: '{response.content.strip().lower()}'")
-
-    return {"next_agent": manager}
-
-
-def agent_router(state: SupportState):
-    return state["next_agent"]
-
-
-
-graph = StateGraph(SupportState)
-graph.add_node("choose_agent",choose_agent)
-graph.add_node("inventory_manager",inventory_manager)
-graph.add_node("rate_manager",rate_manager)
-graph.add_node("reservation_manager",reservation_manager)
-graph.add_node("unknown_handler",unknown_handler)
-
-
-graph.add_edge(START,"choose_agent")
-graph.add_conditional_edges(
-    "choose_agent",
-    agent_router,
-    {
-        "inventory": "inventory_manager",
-        "rates": "rate_manager",
-        "reservations": "reservation_manager",
-        "unknown": "unknown_handler"
-    }
-)
-
-graph.add_edge("inventory_manager", END)
-graph.add_edge("rate_manager", END)
-graph.add_edge("reservation_manager", END)
-graph.add_edge("unknown_handler",END)
-
-graph = graph.compile(checkpointer=memory)

graph_test.py

@@ -310,7 +310,7 @@ async def rate_manager(state: SupportState):
         rooms_payload = [{"roomNumber": 1, "guests": {"adults":adults,"children":0}}]
 
         success, api_response = await fetch_room_availability(
-            phone_number_id=os.getenv("PHONE_NUMBER_ID"),
+            phone_number_id="1220503234474080",
             check_in=check_in,
             check_out=check_out,
             rooms=rooms_payload
@@ -336,23 +336,7 @@ async def rate_manager(state: SupportState):
 
             from hotel_api import get_room_map
             room_map = await get_room_map()
-            # room_info = room_map.get(category.lower())
-
-            category_prompt = f"""
-            The user wants to check rates for "{category}" room.
-            Available room categories: {list(room_map.keys())}
-            Match to the closest category. Return ONLY JSON:
-            {{"matched_category": "exact_key_from_list_or_null"}}
-            """
-            cat_response = await llm.ainvoke(category_prompt)
-            cat_clean = cat_response.content.replace("```json","").replace("```","").strip()
-            cat_data = json.loads(cat_clean)
-            matched_category = cat_data.get("matched_category")
-
-            if matched_category and matched_category in room_map:
-                category = matched_category
-
-            room_info = room_map.get(category)
+            room_info = room_map.get(category.lower())
             print(f"LOOKING FOR: {category.lower()}, FOUND: {room_info}")
 
 
@@ -481,11 +465,9 @@ async def reservation_manager(state: SupportState):
 
         elif booking_step == "collect_checkin" and not pb.get("check_in"):
             pb["check_in"] = state.get("query", "").strip()
-            check_in = pb["check_in"]
 
         elif booking_step == "collect_checkout" and not pb.get("check_out"):
             pb["check_out"] = state.get("query", "").strip()
-            check_out = pb["check_out"]
 
             #collecting meal plan
         elif booking_step == "meal_plan":
@@ -661,19 +643,11 @@ async def reservation_manager(state: SupportState):
                 safe_pb = state.get("pending_action") or {}
                 return {"response": "Sorry, I encountered an internal glitch while processing the payment type. Could you repeat that?", "pending_manager": "reservations", "pending_action": safe_pb, "booking_step": "payment"}
 
-        
-        from functions import sanitize_date
-        check_in = sanitize_date(check_in)
-        check_out = sanitize_date(check_out)
-
-        pb["check_in"] = check_in
-        pb["check_out"] = check_out
-
-
         if not pb.get("availability_checked") and category and check_in and check_out:
             rooms_payload = [{"roomNumber": 1, "guests": {"adults":adults,"children":0}}]
             # safe_phone_id = state.get("phone_number_id")
             # if not safe_phone_id: 
+            #     safe_phone_id = "1098093760057955"
             safe_phone_id = "1220503234474080"
 
             success,avail_data = await fetch_room_availability(
@@ -692,63 +666,25 @@ async def reservation_manager(state: SupportState):
             prices_list = avail_data.get("data", {}).get("reservationPrice",[])
             found_room = None
 
-            # from hotel_api import get_room_map
-            # room_map = await get_room_map()
-            # print(f"ROOM MAP KEYS: {list(room_map.keys())}")
-            # room_info = None
-            # for key,value in room_map.items():
-            #     if key in category.lower():
-            #         room_info = value
-            #         category = key
-            #         pb["category"] = key
-            #         break
-            # # room_info = room_map.get(category.lower())
-            # # print(f"LOOKING FOR: {category.lower()}, FOUND: {room_info}")
-
-            # if not room_info:   
-            #     pb["category"] = None  #-> wipe bad data
-            #     return {
-            #         "response": f"Sorry, I don't recognize {category} category",
-            #         "pending_manager":"reservations",
-            #         "booking_step":"collect_category",
-            #         "pending_action": pb
-            #     }
-
             from hotel_api import get_room_map
             room_map = await get_room_map()
             print(f"ROOM MAP KEYS: {list(room_map.keys())}")
-
-            category_prompt = f"""
-            The hotel owner said they want to book a "{category}" room.
-            Available room categories: {list(room_map.keys())}
-
-            Match the owner's input to the closest category from the list.
-            If there is no reasonable match, return null.
-
-            Return ONLY a JSON object:
-            {{"matched_category": "exact_key_from_list_or_null"}}
-            """
-            try:
-                cat_response = await llm.ainvoke(category_prompt)
-                cat_clean = cat_response.content.replace("```json","").replace("```","").strip()
-                cat_data = json.loads(cat_clean)
-                matched_category = cat_data.get("matched_category")
-            except Exception as e:
-                print(f"Category match error: {e}")
-                matched_category = None
-
             room_info = None
-            if matched_category and matched_category in room_map:
-                room_info = room_map[matched_category]
-                category = matched_category
-                pb["category"] = matched_category
+            for key,value in room_map.items():
+                if key in category.lower():
+                    room_info = value
+                    category = key
+                    pb["category"] = key
+                    break
+            # room_info = room_map.get(category.lower())
+            # print(f"LOOKING FOR: {category.lower()}, FOUND: {room_info}")
 
-            if not room_info:
-                pb["category"] = None
+            if not room_info:   
+                pb["category"] = None  #-> wipe bad data
                 return {
-                    "response": f"I couldn't find a matching room category for '{category}'. Available categories are: {', '.join(room_map.keys())}. Which one would you like?",
-                    "pending_manager": "reservations",
-                    "booking_step": "collect_category",
+                    "response": f"Sorry, I don't recognize {category} category",
+                    "pending_manager":"reservations",
+                    "booking_step":"collect_category",
                     "pending_action": pb
                 }
 
@@ -976,7 +912,7 @@ async def reservation_manager(state: SupportState):
                     
 
                     if success:
-                        status = f"Done! Booking for {pb['guest_name']} successfully completed."
+                        status = f"Done! I have initiated the booking for {pb['guest_name']}. Please complete the form to confirm."
                         return {"response": status, "pending_manager": "", "pending_action": {}, "booking_step": ""}
                     else:
                         error_msg = data.get("data", {}).get("message", data.get("message", "an unknown API error"))

hotel_api.py

@@ -1,12 +1,10 @@
 import httpx
 from datetime import datetime, timedelta
-import os
-from dotenv import load_dotenv
-load_dotenv()
 
-BASE_URL = os.getenv("BASE_URL")
-HOTEL_ID = os.getenv("HOTEL_ID")
-PHONE_NUMBER_ID = os.getenv("PHONE_NUMBER_ID")
+
+BASE_URL = "https://dev-api.xipper.in/api/v1.0.0"
+HOTEL_ID = "XH33228365"
+PHONE_NUMBER_ID = "1220503234474080"
 
 async def fetch_inventory_availability(start_date: str, end_date: str):
     url = f"{BASE_URL}/inventory/room/availability"
@@ -46,13 +44,11 @@ async def get_room_map():
     if success:
         for cat in data.get("categories",[]):
             name = cat.get("categoryName", "").lower()
-            print(f"LOADED CATEGORY: {name}")
             _room_map_cache[name] = {
                 "categoryName": cat.get("categoryName"),
                 "roomCode": cat.get("roomCode"),
                 "roomCategoryId": cat.get("roomCategoryId")
             }
-    # print(f"FINAL ROOM MAP: {list(_room_map_cache.keys())}")
     return _room_map_cache
 
 
@@ -210,8 +206,7 @@ async def update_rates(
     category: str, 
     new_price: int, 
     start_date: str, 
-    end_date: str,
-    room_code=None
+    end_date: str
 ) -> tuple[bool, dict]:
     """
     Updates the daily price of a room category on both Xipper and OTAs.
@@ -227,13 +222,12 @@ async def update_rates(
     # 2. Format the string to match the strict payload rules
     # If LLM gives "twin room":
     room_type_name = category.title() # Becomes "Twin Room"
-    if not room_code:
-        room_code = category.lower().replace(" ", "-") # Becomes "twin-room"
+    room_code = category.lower().replace(" ", "-") # Becomes "twin-room"
     
     # In your payload, there are two rate plans: EP (Room Only) and CP (With Breakfast).
     # We will assume EP gets the exact new price, and CP costs slightly more.
-    ep_code = "EP"
-    cp_code = "CP"
+    ep_code = f"{room_code}-s-ep"
+    cp_code = f"{room_code}-s-cp"
     breakfast_addon = 20 # Just matching the +20 difference from your example payload
 
     # 3. Build the exact payload you provided!
@@ -271,7 +265,6 @@ async def update_rates(
             response = await client.post(url, json=payload)
             response.raise_for_status() 
             data = response.json()
-            print(f"DATA: {data}")
             
             # NEW: Check if the business logic inside the JSON failed!
             if data.get("status") == "Fail":

index.html

@@ -0,0 +1,654 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <script src="https://cdnjs.cloudflare.com/ajax/libs/RecordRTC/5.6.2/RecordRTC.min.js"></script>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Voice recorder · FastAPI /voice</title>
+    <style>
+        * {
+            box-sizing: border-box;
+            margin: 0;
+            padding: 0;
+        }
+
+        body {
+            background: linear-gradient(145deg, #1b2a3a 0%, #0f1a26 100%);
+            min-height: 100vh;
+            display: flex;
+            justify-content: center;
+            align-items: center;
+            font-family: 'Segoe UI', system-ui, -apple-system, sans-serif;
+            padding: 1.5rem;
+            margin: 0;
+        }
+
+        .card {
+            background: rgba(30, 44, 58, 0.7);
+            backdrop-filter: blur(8px);
+            -webkit-backdrop-filter: blur(8px);
+            border-radius: 4rem 4rem 3rem 3rem;
+            box-shadow: 0 25px 50px -8px rgba(0,0,0,0.8), inset 0 2px 4px rgba(255,255,255,0.06);
+            padding: 3rem 2.5rem 3.5rem;
+            max-width: 600px;
+            width: 100%;
+            text-align: center;
+            border: 1px solid rgba(255,255,255,0.04);
+            transition: box-shadow 0.2s;
+        }
+
+        h1 {
+            font-weight: 300;
+            font-size: 1.8rem;
+            letter-spacing: 2px;
+            color: #d6e6f5;
+            text-shadow: 0 2px 3px rgba(0,0,0,0.4);
+            margin-bottom: 0.25rem;
+        }
+
+        .sub {
+            color: #8aa9c9;
+            font-weight: 300;
+            font-size: 0.95rem;
+            border-bottom: 1px dashed #3a556b;
+            padding-bottom: 1.2rem;
+            margin-bottom: 2.2rem;
+            letter-spacing: 0.3px;
+        }
+
+        .sub code {
+            background: #1f3345;
+            padding: 0.2rem 0.8rem;
+            border-radius: 30px;
+            color: #aac2dd;
+        }
+
+        .mic-wrapper {
+            position: relative;
+            display: inline-block;
+            margin: 0.5rem 0 1.8rem;
+        }
+
+        .mic-btn {
+            background: #2b445a;
+            border: none;
+            border-radius: 50%;
+            width: 150px;
+            height: 150px;
+            box-shadow: 0 12px 28px rgba(0,0,0,0.7), 0 0 0 2px #4b6d89 inset, 0 0 0 4px #1a2e3f inset;
+            cursor: pointer;
+            transition: all 0.15s ease;
+            display: flex;
+            align-items: center;
+            justify-content: center;
+            color: #d9edff;
+            fill: currentColor;
+            position: relative;
+        }
+
+        .mic-btn:hover {
+            background: #365a77;
+            transform: scale(1.02);
+            box-shadow: 0 16px 36px rgba(0,0,0,0.8), 0 0 0 2px #6b93b5 inset, 0 0 0 4px #1a2e3f inset;
+        }
+
+        .mic-btn:active {
+            transform: scale(0.94);
+            background: #1e3a52;
+        }
+
+        .mic-btn svg {
+            width: 70px;
+            height: 70px;
+            filter: drop-shadow(0 4px 6px rgba(0,0,0,0.3));
+            transition: transform 0.1s;
+        }
+
+        .mic-btn.recording svg {
+            animation: pulse 1.2s infinite ease-in-out;
+            filter: drop-shadow(0 0 12px #ff7b7b);
+        }
+
+        .mic-btn.recording {
+            background: #6f3a4a;
+            box-shadow: 0 0 0 4px #b34a5a inset, 0 0 0 6px #3f1f2b inset, 0 12px 28px #250f16;
+        }
+
+        @keyframes pulse {
+            0% { transform: scale(1); }
+            50% { transform: scale(1.08); }
+            100% { transform: scale(1); }
+        }
+
+        .status-box {
+            background: #0e1a24cc;
+            backdrop-filter: blur(4px);
+            -webkit-backdrop-filter: blur(4px);
+            border-radius: 60px;
+            padding: 0.9rem 1.8rem;
+            margin: 1.2rem 0 1.8rem;
+            display: inline-block;
+            border: 1px solid #3e5c74;
+            color: #c2d9ef;
+            font-weight: 400;
+            font-size: 1rem;
+            letter-spacing: 0.5px;
+            min-width: 180px;
+            box-shadow: inset 0 2px 6px rgba(0,0,0,0.4);
+        }
+
+        .status-box span {
+            font-weight: 300;
+            color: #aac2dd;
+        }
+
+        .log-area {
+            background: #0f1923cc;
+            border-radius: 28px;
+            padding: 1rem 1.6rem;
+            margin: 1.8rem 0 0.8rem;
+            font-size: 0.9rem;
+            color: #b3ceea;
+            border-left: 3px solid #3d779b;
+            text-align: left;
+            min-height: 72px;
+            backdrop-filter: blur(2px);
+            word-break: break-word;
+            line-height: 1.5;
+            box-shadow: inset 0 4px 8px rgba(0,0,0,0.3);
+            display: flex;
+            align-items: center;
+        }
+
+        .log-area .log-placeholder {
+            opacity: 0.5;
+            font-style: italic;
+            font-weight: 300;
+        }
+
+        .log-area .log-message {
+            color: #d6ecff;
+        }
+
+        .log-area .log-error {
+            color: #ffa79e;
+        }
+
+        .log-area .log-success {
+            color: #a6e0b0;
+        }
+
+        .footnote {
+            margin-top: 1.5rem;
+            color: #5a7d99;
+            font-size: 0.75rem;
+            letter-spacing: 0.3px;
+            opacity: 0.7;
+            border-top: 1px solid #2f4b61;
+            padding-top: 1.2rem;
+        }
+
+        .btn-reset {
+            background: transparent;
+            border: 1px solid #3d6079;
+            color: #b3ceea;
+            border-radius: 40px;
+            padding: 0.4rem 1.2rem;
+            font-size: 0.8rem;
+            margin-top: 0.4rem;
+            cursor: pointer;
+            transition: 0.2s;
+            opacity: 0.6;
+        }
+
+        .btn-reset:hover {
+            background: #2f4b61;
+            opacity: 1;
+            border-color: #6c93b0;
+        }
+
+        .endpoint-badge {
+            display: inline-block;
+            background: #1a2e3f;
+            padding: 0.3rem 1rem;
+            border-radius: 30px;
+            font-size: 0.8rem;
+            color: #8bb3d4;
+            margin-top: 0.5rem;
+            border: 1px solid #3a5a75;
+        }
+
+        .endpoint-badge code {
+            background: #0d1a26;
+            padding: 0.1rem 0.5rem;
+            border-radius: 12px;
+            color: #7fb7e0;
+        }
+    </style>
+</head>
+<body>
+    <div class="card">
+        <h1>🎙️ VOICE RECORDER</h1>
+        <div class="sub">click mic → speak → send to <code>/voice</code> (FastAPI)</div>
+
+        <div class="mic-wrapper">
+            <button class="mic-btn" id="micButton" aria-label="Record voice">
+                <svg viewBox="0 0 24 24" width="70" height="70">
+                    <path d="M12 16c-2.206 0-4-1.794-4-4V6c0-2.206 1.794-4 4-4s4 1.794 4 4v6c0 2.206-1.794 4-4 4zm8-4h-2c0 2.607-2.126 4.5-4 4.5S10 14.607 10 12H8c0 3.157 2.416 5.5 5 5.944V20h-2v2h6v-2h-2v-2.056c2.584-.444 5-2.787 5-5.944z"/>
+                </svg>
+            </button>
+        </div>
+
+        <div id="chat-container" style="margin-top: 20px;">
+            <input type="text" id="chatInput" placeholder="Type your message here..." style="width: 300px; padding: 10px;">
+            <button id="btn-send-chat" style="padding: 10px;">Send</button>
+        </div>
+
+        <div class="status-box" id="statusDisplay">
+            <span id="statusText">🔴 idle</span>
+        </div>
+
+        <div class="endpoint-badge">⬇️ POST to <code>http://localhost:8000/voice</code></div>
+
+        <div class="log-area" id="logArea">
+            <span class="log-placeholder" id="logPlaceholder">📋 ready · click mic to start recording</span>
+            <span class="log-message" id="logMessage" style="display: none;"></span>
+        </div>
+
+        <button class="btn-reset" id="resetLogBtn">↻ clear log</button>
+        <div class="footnote">audio: WebM (Opus) · sent as multipart/form-data</div>
+    </div>
+
+    <script>
+        (function() {
+            "use strict";
+
+            // DOM refs
+            const micBtn = document.getElementById('micButton');
+            const statusText = document.getElementById('statusText');
+            const logPlaceholder = document.getElementById('logPlaceholder');
+            const logMessage = document.getElementById('logMessage');
+
+            const chatInput = document.getElementById('chatInput');
+            const sendChatBtn = document.getElementById('btn-send-chat');
+
+            sendChatBtn.onclick = async function() {
+                const message = chatInput.value.trim();
+                if (!message) return;
+
+                // Clear the input box immediately
+                chatInput.value = '';
+                
+                // Show the user's message in your log/UI
+                setLogMessage(`👤 You (Typed): ${message}`, 'info');
+                setStatus('⏳ Agent typing...', false);
+
+                try {
+                    // We use the EXACT SAME user ID (phoneNumberId) as the voice endpoint
+                    const response = await fetch('https://dingy-unsaddle-casualty.ngrok-free.dev/chat', {
+                        method: 'POST',
+                        headers: { 'Content-Type': 'application/json' },
+                        body: JSON.stringify({
+                            message: message,
+                            // phoneNumberId: '1220503234474080' // Ensure this matches your voice ID!
+                        })
+                    });
+
+                    const data = await response.json();
+                    
+                    // Show the bot's reply in your log/UI
+                    setLogMessage(`🤖 Agent: ${data.response}`, 'success');
+                    setStatus('🟢 ready', false);
+
+                    if (data.audio) {
+                        let base64String = data.audio;
+                        const base64Prefix = 'data:audio/';
+                        if (base64String.startsWith(base64Prefix)) {
+                            const commaIndex = base64String.indexOf(',');
+                            if (commaIndex !== -1) {
+                                base64String = base64String.substring(commaIndex + 1);
+                            }
+                        }
+
+                        // Decode Base64 to binary
+                        const binaryString = window.atob(base64String);
+                        const bytes = new Uint8Array(binaryString.length);
+                        for (let i = 0; i < binaryString.length; i++) {
+                            bytes[i] = binaryString.charCodeAt(i);
+                        }
+
+                        // Determine MIME type (default to mp3 or wav depending on your TTS)
+                        let mimeType = 'audio/wav'; 
+                        if (data.audio.startsWith('data:audio/')) {
+                            const mimeMatch = data.audio.match(/^data:(audio\/[^;]+);/);
+                            if (mimeMatch) {
+                                mimeType = mimeMatch[1];
+                            }
+                        }
+
+                        const audioBlobResponse = new Blob([bytes], { type: mimeType });
+                        const audioUrl = URL.createObjectURL(audioBlobResponse);
+
+                        // Play it!
+                        const audio = new Audio(audioUrl);
+                        audio.play().catch(err => {
+                            console.warn('Autoplay blocked by browser:', err);
+                        });
+                    }
+                    
+                } catch (error) {
+                    console.error("Chat error:", error);
+                    setLogMessage('❌ Failed to send message.', 'error');
+                    setStatus('🔴 error', false);
+                }
+            };
+
+            // Allow pressing "Enter" to send
+            chatInput.addEventListener('keypress', function (e) {
+                if (e.key === 'Enter') sendChatBtn.click();
+            });
+
+            // state
+            let mediaRecorder = null;
+            let audioChunks = [];
+            let isRecording = false;
+            let stream = null;
+
+            // FastAPI endpoint URL - CHANGE THIS IF YOUR API RUNS ON A DIFFERENT PORT
+            const API_BASE_URL = 'https://dingy-unsaddle-casualty.ngrok-free.dev';
+            const API_ENDPOINT = `${API_BASE_URL}/voice`;
+
+            // helpers
+            function setStatus(text, isRecordingState = false) {
+                statusText.textContent = text;
+                if (isRecordingState) {
+                    micBtn.classList.add('recording');
+                } else {
+                    micBtn.classList.remove('recording');
+                }
+            }
+
+            function setLogMessage(msg, type = 'info') {
+                logPlaceholder.style.display = 'none';
+                logMessage.style.display = 'inline';
+                logMessage.className = 'log-message';
+                if (type === 'error') logMessage.className = 'log-error';
+                else if (type === 'success') logMessage.className = 'log-success';
+                logMessage.textContent = msg;
+            }
+
+            function resetLogToPlaceholder() {
+                logMessage.style.display = 'none';
+                logPlaceholder.style.display = 'inline';
+                logPlaceholder.textContent = '📋 ready · click mic to start recording';
+            }
+
+            // clear log button
+            document.getElementById('resetLogBtn').addEventListener('click', function() {
+                resetLogToPlaceholder();
+            });
+
+            async function sendAudioToEndpoint(audioBlob) {
+                try {
+                    setStatus('⏳ sending to FastAPI...', false);
+
+                    const formData = new FormData();
+                    formData.append('audio', audioBlob, `voice-${Date.now()}.webm`);
+
+                    const response = await fetch(API_ENDPOINT, {
+                        method: 'POST',
+                        body: formData,
+                        headers: {
+                            'ngrok-skip-browser-warning': 'true'
+                        },
+                    });
+
+                    // First, read the response as JSON (as your backend returns JSON)
+                    let data;
+                    const contentType = response.headers.get('content-type') || '';
+                    if (contentType.includes('application/json')) {
+                        data = await response.json();
+                    } else {
+                        // Fallback: if not JSON, treat as text (error or plain response)
+                        const text = await response.text();
+                        throw new Error(`Unexpected response (not JSON): ${text.substring(0, 100)}`);
+                    }
+
+                    // Handle HTTP errors (if response.ok is false, but we still got JSON)
+                    if (!response.ok) {
+                        const errorMsg = data.detail || data.message || JSON.stringify(data);
+                        throw new Error(`Server error ${response.status}: ${errorMsg}`);
+                    }
+
+                    // ---- Now process the successful response ----
+                    const { transcript, detected_language, response: agentReply, audio: audioBase64, booking_link } = data;
+
+                    // 1. Display the transcript and agent reply in the log area
+                    let logText = `📝 "${transcript}" (${detected_language || 'unknown'})\n`;
+                    logText += `🤖 ${agentReply || ''}`;
+                    if (booking_link) {
+                        logText += `\n🔗 Booking: ${booking_link}`;
+                    }
+                    setLogMessage(logText, 'success');
+
+                    // 2. Handle the audio (Base64 -> Blob -> play)
+                    if (audioBase64) {
+                        // Remove data URI prefix if present (e.g., "data:audio/wav;base64,")
+                        let base64String = audioBase64;
+                        const base64Prefix = 'data:audio/';
+                        if (base64String.startsWith(base64Prefix)) {
+                            // Extract the part after the comma
+                            const commaIndex = base64String.indexOf(',');
+                            if (commaIndex !== -1) {
+                                base64String = base64String.substring(commaIndex + 1);
+                            }
+                        }
+
+                        // Decode Base64 to binary
+                        const binaryString = window.atob(base64String);
+                        const bytes = new Uint8Array(binaryString.length);
+                        for (let i = 0; i < binaryString.length; i++) {
+                            bytes[i] = binaryString.charCodeAt(i);
+                        }
+
+                        // Determine MIME type from the response (or guess from the base64 prefix)
+                        let mimeType = 'audio/wav'; // default
+                        if (audioBase64.startsWith('data:audio/')) {
+                            const mimeMatch = audioBase64.match(/^data:(audio\/[^;]+);/);
+                            if (mimeMatch) {
+                                mimeType = mimeMatch[1];
+                            }
+                        }
+
+                        const audioBlobResponse = new Blob([bytes], { type: mimeType });
+                        const audioUrl = URL.createObjectURL(audioBlobResponse);
+
+                        // Play the audio
+                        const audio = new Audio(audioUrl);
+                        const playPromise = audio.play();
+                        if (playPromise !== undefined) {
+                            playPromise.catch(err => {
+                                console.warn('Autoplay blocked:', err);
+                                setLogMessage(
+                                    `🔊 Audio ready but autoplay blocked. Click the mic again or tap the play button (if shown).\n${logText}`,
+                                    'info'
+                                );
+                                // You could optionally show a manual "Play" button here.
+                            });
+                        }
+
+                        const sizeKB = (audioBlobResponse.size / 1024).toFixed(1);
+                        setStatus(`✔️ audio playing (${sizeKB} KB)`, false);
+                    } else {
+                        // No audio returned – just show text
+                        setStatus('✔️ done (no audio)', false);
+                    }
+
+                } catch (err) {
+                    console.error('Upload error:', err);
+                    let errorMsg = err.message;
+                    if (err.message.includes('Failed to fetch')) {
+                        errorMsg = 'Cannot connect to FastAPI server. Make sure it\'s running on http://localhost:8000';
+                    }
+                    setLogMessage(`❌ Error: ${errorMsg}`, 'error');
+                    setStatus('⚠️ error', false);
+                }
+            }
+
+            // ----- finish recording & send -----
+            function finishRecordingAndSend() {
+                if (mediaRecorder && mediaRecorder.state === 'recording') {
+                    mediaRecorder.stop();
+                } else {
+                    resetRecordingState();
+                }
+            }
+
+            // reset media recorder & stream
+            function resetRecordingState() {
+                if (mediaRecorder) {
+                    if (mediaRecorder.state === 'recording') {
+                        try { mediaRecorder.stop(); } catch (_) {}
+                    }
+                    mediaRecorder = null;
+                }
+                if (stream) {
+                    stream.getTracks().forEach(track => track.stop());
+                    stream = null;
+                }
+                audioChunks = [];
+                isRecording = false;
+                micBtn.classList.remove('recording');
+                setStatus('🔴 idle', false);
+            }
+
+            // ----- start recording -----
+            async function startRecording() {
+                // If already recording, stop and send
+                if (isRecording) {
+                    finishRecordingAndSend();
+                    return;
+                }
+
+                // Reset any previous state
+                resetRecordingState();
+
+                try {
+                    // Request microphone access
+                    stream = await navigator.mediaDevices.getUserMedia({
+                        audio: {
+                            echoCancellation: true,
+                            noiseSuppression: true,
+                            autoGainControl: true,
+                            sampleRate: 16000,
+                        }
+                    });
+
+                    // Use WebM format (widely supported)
+                    const options = { mimeType: 'audio/webm;codecs=opus' };
+                    if (!MediaRecorder.isTypeSupported(options.mimeType)) {
+                        console.warn('Opus not supported, using default audio/webm');
+                        mediaRecorder = new MediaRecorder(stream);
+                    } else {
+                        mediaRecorder = new MediaRecorder(stream, options);
+                    }
+
+                    audioChunks = [];
+
+                    mediaRecorder.ondataavailable = (event) => {
+                        if (event.data.size > 0) {
+                            audioChunks.push(event.data);
+                        }
+                    };
+
+                    mediaRecorder.onstop = () => {
+                        if (audioChunks.length === 0) {
+                            setLogMessage('⚠️ No audio data captured', 'error');
+                            setStatus('🔴 idle', false);
+                            micBtn.classList.remove('recording');
+                            isRecording = false;
+                            return;
+                        }
+
+                        const blob = new Blob(audioChunks, {
+                            type: mediaRecorder.mimeType || 'audio/webm'
+                        });
+
+                        audioChunks = [];
+
+                        // Send to FastAPI endpoint
+                        sendAudioToEndpoint(blob).finally(() => {
+                            if (stream) {
+                                stream.getTracks().forEach(track => track.stop());
+                                stream = null;
+                            }
+                            isRecording = false;
+                            micBtn.classList.remove('recording');
+                        });
+                    };
+
+                    // Start recording (collect data in 1-second chunks)
+                    mediaRecorder.start(1000);
+                    isRecording = true;
+                    micBtn.classList.add('recording');
+                    setStatus('🔴 recording...', true);
+                    setLogMessage('🎤 Speak now · click mic to stop and send to FastAPI', 'info');
+
+                } catch (err) {
+                    console.error('Microphone error:', err);
+                    let msg = '❌ Cannot access microphone: ';
+                    if (err.name === 'NotAllowedError' || err.name === 'PermissionDeniedError') {
+                        msg += 'Permission denied. Please allow microphone access.';
+                    } else if (err.name === 'NotFoundError' || err.name === 'DevicesNotFoundError') {
+                        msg += 'No microphone found. Please connect a microphone.';
+                    } else {
+                        msg += err.message;
+                    }
+                    setLogMessage(msg, 'error');
+                    setStatus('⛔ mic error', false);
+                    resetRecordingState();
+                }
+            }
+
+            // ----- mic click handler -----
+            micBtn.addEventListener('click', startRecording);
+
+            // Clean up on page unload
+            window.addEventListener('beforeunload', function() {
+                if (stream) {
+                    stream.getTracks().forEach(track => track.stop());
+                }
+                if (mediaRecorder && mediaRecorder.state === 'recording') {
+                    mediaRecorder.stop();
+                }
+            });
+
+            // Initial status
+            setStatus('🔴 idle', false);
+            resetLogToPlaceholder();
+
+            // Check if FastAPI endpoint is reachable
+            async function checkEndpoint() {
+                try {
+                    console.log(`Checking FastAPI endpoint: ${API_ENDPOINT}`);
+                    const response = await fetch(API_ENDPOINT, { 
+                        method: 'POST',
+                        mode: 'cors'
+                    });
+                    if (response.ok) {
+                        console.log('✅ FastAPI /voice endpoint is reachable');
+                        setLogMessage('✅ Connected to FastAPI server at localhost:8000', 'success');
+                    }
+                } catch (e) {
+                    console.warn('⚠️ Cannot reach /voice endpoint. Make sure FastAPI server is running on localhost:8000');
+                    setLogMessage('⚠️ Cannot reach FastAPI server. Make sure it\'s running on localhost:8000', 'error');
+                }
+            }
+            
+            // Check connection after a short delay
+            setTimeout(checkEndpoint, 1000);
+
+        })();
+    </script>
+</body>
+</html>

main.py

@@ -1,20 +1,20 @@
 from fastapi.middleware.cors import CORSMiddleware
-from fastapi import FastAPI, UploadFile, File, HTTPException
+from fastapi import FastAPI,UploadFile,File,HTTPException
 from pydantic import BaseModel
 from fastapi.responses import FileResponse
-from translate import translate_to_target_language, translate_input_to_english
-from graph_main import graph
+from translate import translate_to_target_language,translate_input_to_english
+from graph_test import graph
 from sarvamai import SarvamAI
 import tempfile
-from pydub import AudioSegment
-import io
 from groq import Groq
-from deepgram import DeepgramClient, FileSource, PrerecordedOptions, LiveOptions, LiveTranscriptionEvents
+# from elevenlabs.client import ElevenLabs
+from deepgram import DeepgramClient,FileSource,PrerecordedOptions
 import base64
+from pydub import AudioSegment
+import io
 import os
 import time
 import string
-import asyncio
 from dotenv import load_dotenv
 load_dotenv()
 
@@ -32,7 +32,9 @@ print("CORS middleware added")
 
 class ChatRequest(BaseModel):
     message: str
+    # phoneNumberId: str
 
+# elevenlabs_client = ElevenLabs(api_key=os.getenv("ELEVENLABS_API_KEY"))
 groq_client = Groq(api_key=os.getenv("GROQ_API_KEY"))
 sarvam_client = SarvamAI(api_subscription_key=os.getenv("SARVAM_API_KEY"))
 deepgram_client = DeepgramClient(os.getenv("DEEPGRAM_API_KEY"))
@@ -53,350 +55,214 @@ SARVAM_LANG_MAP = {
 async def chat(request: ChatRequest):
     try:
         user_text = request.message
+
         config = {"configurable": {"thread_id": "hotel_owner_1"}}
-        result = await graph.ainvoke({"query": user_text}, config=config)
-        response = result.get("response", "sorry, i couldn't process that request")
 
-        lang_prompt = f"""Detect the language of this text: "{user_text}"
-        Return ONLY one of these codes: hi, en, ta, mr, bn, te, gu, kn
-        Return ONLY the code, nothing else."""
+        result = await graph.ainvoke({"query": user_text},config=config)
+        # print(f"Full result: {result}")
 
-        from agents.llm import llm
-        lang_response = llm.invoke(lang_prompt)
-        detected_language = lang_response.content.strip().lower()
-        print(f"Detected language: {detected_language}")
+        response = result.get("response","sorry, i couldn't process that request")
+        # print("reached here 1")
+        # detected_language = response.get("language", "hi")  
+        sarvam_lang = "hi-IN"
 
-        final_response = translate_to_target_language(response, detected_language)
-        sarvam_lang = SARVAM_LANG_MAP.get(detected_language, "hi-IN")
+
+        # final_response = translate_to_target_language(response,detected_language)
+        # print(f"final response: {final_response}")
+
+        # sarvam_lang = SARVAM_LANG_MAP.get(detected_language.lower(),"hi-IN")
 
         for attempt in range(3):
             try:
+                tts_start = time.time()
                 tts_response = sarvam_client.text_to_speech.convert(
-                    text=final_response,
+                    text=response,
                     target_language_code=sarvam_lang,
                     speaker="abhilash",
                     model="bulbul:v2"
                 )
+                print(f"TTS Latency: {time.time() - tts_start:.2f}s")
+                # print(f"TTS response: {tts_response}")
+                # print(f"Audio list: {tts_response.audios}")
                 break
             except Exception as e:
+                # print(f"❌ TTS attempt {attempt} failed: {e}")  # ← add this
                 if attempt == 2:
                     raise HTTPException(status_code=503, detail=f"TTS unavailable: {e}")
 
         audio_bytes = base64.b64decode(tts_response.audios[0])
         audio_base64 = base64.b64encode(audio_bytes).decode("utf-8")
 
-        return {"response": response, "audio": audio_base64}
+
+        return {
+            "response": response,
+            "audio": audio_base64
+        }
     except Exception as e:
-        import traceback
         print(f"Chat endpoint error: {e}")
-        traceback.print_exc()
         return {"response": "Sorry, I encountered an error."}
 
 
 @app.get("/")
 def root():
-    return FileResponse("frontend/index2.html")
-
+    return FileResponse("index.html")
 
 @app.post("/voice")
 async def voice(audio: UploadFile = File(...)):
-    temp_file = None
+    # temp_file = "temp_audio.wav"
     try:
         audio_bytes = await audio.read()
 
-        if len(audio_bytes) > 5 * 1024 * 1024:
-            return HTTPException(status_code=400, detail="Audio file is too large. Max 5 MB file is allowed")
+        with open("received.webm", "wb") as f:
+            f.write(audio_bytes)
+
+        if len(audio_bytes) > 5*1024*1024:
+            return HTTPException(status_code=400,detail="Audio file is too large. Max 5 MB file is allowed")
 
         try:
             raw_audio = AudioSegment.from_file(io.BytesIO(audio_bytes))
+
             clean_audio = raw_audio.set_frame_rate(16000).set_channels(1)
         except Exception as e:
-            raise HTTPException(status_code=400, detail=f"failed to process audio format: {e}")
-
-        f = tempfile.NamedTemporaryFile(delete=False, suffix=".wav")
+            raise HTTPException(status_code=400,detail=f"failed to process audio format: {e}")
+        
+        f = tempfile.NamedTemporaryFile(delete=False,suffix=".wav")
         temp_file = f.name
-        f.close()
+        # f.write(audio_bytes)
         clean_audio.export(temp_file, format="wav")
-
+        f.close()
+        
         total_start = time.time()
 
-        with open(temp_file, "rb") as f:
+        #this is one of the most wrost way never use this way to make stt better
+        # hotel_vocab = "Kanhaiya, Aman, Maharani, Deluxe, Standard, Suite, Presidential, EP, CP, MAP, AP, room only, breakfast, booking, check-in, check-out, advance"
+
+        with open(temp_file,"rb") as f:
             for attempt in range(3):
                 try:
                     stt_start = time.time()
-                    payload = {"buffer": f.read()}
+
+                    payload: FileSource = {
+                        "buffer": f.read(),
+                    }
+                    # The Magic Parameters
                     options = PrerecordedOptions(
-                        model="nova-2",
-                        language="hi-en",
-                        smart_format=True,
-                        punctuate=True
+                        model="nova-2",      # The fastest, most accurate model
+                        language="hi",       # Deepgram's Hindi model flawlessly handles Hinglish
+                        smart_format=True,   # Forces dates, times, and phone numbers into digits!
+                        punctuate=True       # Adds periods and commas so LangGraph reads it easily
                     )
+
                     response = deepgram_client.listen.rest.v("1").transcribe_file(payload, options)
+
+                    # Extract the text from the JSON response
                     transcript_data = response["results"]["channels"][0]["alternatives"][0]
                     raw_transcript = transcript_data["transcript"]
                     print(f"Deepgram Heard: {raw_transcript}")
+                    # transcript = elevenlabs_client.speech_to_text.convert(
+                    #     file=f,
+                    #     model_id="scribe_v2"
+                    # )
+                    # transcript = groq_client.audio.transcriptions.create(
+                    #     model="whisper-large-v3",
+                    #     file=f,
+                    #     response_format="verbose_json",
+                        # prompt=hotel_vocab,
+                        # temperature=0.0
+                    # )
+                    
                     print(f"STT Latency: {time.time() - stt_start:.2f}s")
                     break
                 except Exception as e:
                     if attempt == 2:
-                        raise HTTPException(status_code=503, detail="STT service unavailable")
+                        raise HTTPException(status_code=503,detail="STT service unavailable")
+        # raw_transcript = transcript.text.strip()
 
         try:
+            trans_start = time.time()
             clean_english_query = translate_input_to_english(raw_transcript)
+            print(f"Translation Latency: {time.time() - trans_start:.2f}s")
         except Exception as e:
-            raise HTTPException(status_code=503, detail="Translation not possible")
+            raise HTTPException(status_code=503,detail="Translation not possible")
+        
+        detected_language = clean_english_query.get("language", "hi")  
 
-        detected_language = clean_english_query.get("language", "hi")
-        english_text = clean_english_query.get("english_text", "")
+        print(f"Original: {raw_transcript} | Translated: {clean_english_query} | Language: {detected_language}")
+        # if detected_language in ["ur", "urdu"]:
+        #     detected_language = "hi"
+
+        english_text = clean_english_query.get("english_text","")
         clean_english_query = english_text.translate(str.maketrans('', '', string.punctuation)).strip()
 
         if not clean_english_query:
-            return {"transcript": "", "response": "Sorry, I couldn't hear you. Please try again.", "audio_base64": None}
+            return {"transcript":"","response": "Sorry, I couldn't here you. Please try again.","audio_base64": None}
 
-        config = {"configurable": {"thread_id": "hotel_owner_1"}}
+        # detected_language = transcript.language
+        # hinglish_query = translate_to_hinglish(clean_english_query)
+        # print(f"Hinglish Query: {hinglish_query}")
+        # print(f"Detected language: {detected_language}")
+        # print(f"whisper transcript: {query}")
+
+        config = {"configurable": {"thread_id":"hotel_owner_1"}}
         try:
-            result = await graph.ainvoke({"query": clean_english_query}, config=config)
+            graph_start = time.time()
+            result = await graph.ainvoke({"query": clean_english_query},config=config)
+            print(f"Graph Latency: {time.time() - graph_start:.2f}s")
+
         except Exception as e:
+            # IF GRAPH CRASHES, CATCH IT AND PRINT THE EXACT LINE!
+            print("\n" + "🔥"*25)
+            print(f"CRASH IN LANGGRAPH: {e}")
             import traceback
             traceback.print_exc()
-            result = {"response": "I'm sorry, I encountered an internal glitch. Could you repeat that?"}
+            print("🔥"*25 + "\n")
+
+            result = {
+                "response": "I'm sorry, I encountered an internal glitch. Could you repeat that?"
+            }
 
         graph_response = result.get("response", "Sorry, I couldn't process that request")
-        final_response = translate_to_target_language(graph_response, detected_language)
-        sarvam_lang = SARVAM_LANG_MAP.get(detected_language.lower(), "hi-IN")
+        print(f"graph output: {graph_response}")
+
+
+        final_response = translate_to_target_language(graph_response,detected_language)
+        print(f"final response: {final_response}")
+
+        sarvam_lang = SARVAM_LANG_MAP.get(detected_language.lower(),"hi-IN")
 
         for attempt in range(3):
             try:
+                tts_start = time.time()
                 tts_response = sarvam_client.text_to_speech.convert(
                     text=final_response,
                     target_language_code=sarvam_lang,
                     speaker="abhilash",
                     model="bulbul:v2"
                 )
+                print(f"TTS Latency: {time.time() - tts_start:.2f}s")
                 break
             except Exception as e:
                 if attempt == 2:
-                    raise HTTPException(status_code=503, detail="TTS service unavailable")
+                    raise HTTPException(status_code=503,detail="TTS service unavailable")
 
         audio_bytes = base64.b64decode(tts_response.audios[0])
         audio_base64 = base64.b64encode(audio_bytes).decode("utf-8")
+        with open("test_output.wav", "wb") as f:
+            f.write(audio_bytes)
+
         print(f"Total Latency: {time.time() - total_start:.2f}s")
 
+        booking_link = result.get("booking_link","")
+
         return {
             "transcript": clean_english_query,
             "detected_language": detected_language,
             "response": final_response,
             "audio": audio_base64,
-            "booking_link": result.get("booking_link", "")
+            "booking_link": booking_link
         }
-
+    
     finally:
-        if temp_file and os.path.exists(temp_file):
+        if os.path.exists(temp_file):
             os.remove(temp_file)
-
-
-from fastapi import WebSocket, WebSocketDisconnect
-
-
-async def process_and_respond(websocket: WebSocket, full_transcript: str, detected_language: str):
-    """Takes the final transcript, runs LLM + TTS, sends audio back."""
-    english_text = full_transcript.strip()
-    if not english_text:
-        await websocket.send_json({"response": "Sorry, I couldn't hear anything. Please try again."})
-        return
-
-    await websocket.send_json({"status": "processing", "transcript": english_text})
-
-    config = {"configurable": {"thread_id": "hotel_owner_1"}}
-    try:
-        graph_start = time.time()
-        result = await graph.ainvoke({"query": english_text}, config=config)
-        print(f"Graph Latency: {time.time() - graph_start:.2f}s")
-    except Exception as e:
-        import traceback
-        traceback.print_exc()
-        result = {"response": "I'm sorry, I encountered an internal glitch. Could you repeat that?"}
-
-    graph_response = result.get("response", "Sorry, I couldn't process that request")
-    print(f"Graph output: {graph_response}")
-
-    final_response = await asyncio.to_thread(translate_to_target_language, graph_response, detected_language)
-    sarvam_lang = SARVAM_LANG_MAP.get(detected_language.lower(), "hi-IN")
-
-    for attempt in range(3):
-        try:
-            tts_start = time.time()
-            tts_response = await asyncio.to_thread(
-            sarvam_client.text_to_speech.convert,
-                text=final_response,
-                target_language_code=sarvam_lang,
-                speaker="abhilash",
-                model="bulbul:v2"
-            )
-            print(f"TTS Latency: {time.time() - tts_start:.2f}s")
-            break
-        except Exception as e:
-            if attempt == 2:
-                await websocket.send_json({"response": "Audio generation failed, please try again."})
-                return
-
-    audio_bytes = base64.b64decode(tts_response.audios[0])
-    audio_base64 = base64.b64encode(audio_bytes).decode("utf-8")
-
-    try:
-        await websocket.send_json({
-            "transcript": english_text,
-            "detected_language": detected_language,
-            "response": final_response,
-            "audio": audio_base64
-        })
-    except Exception:
-        print("Client disconnected before response could be sent")
-
-
-@app.websocket("/ws/voice")
-async def voice_ws(websocket: WebSocket):
-    await websocket.accept()
-
-    # Shared state between Deepgram callbacks and the main loop
-    full_transcript = ""
-    detected_language = "hi"
-    utterance_end_event = asyncio.Event()  # fires when Deepgram detects end of speech
-    is_processing = False                  # prevent overlapping pipeline runs
-
-    # ── Deepgram callbacks ────────────────────────────────────────────────────
-
-    async def on_transcript(self, result, **kwargs):
-        nonlocal full_transcript, detected_language
-        transcript = result.channel.alternatives[0].transcript
-        if not transcript:
-            return
-        # Only accumulate is_final results to avoid duplicates
-        if result.is_final:
-            full_transcript += " " + transcript
-            print(f"Deepgram [final]: {transcript}")
-
-            # Translate on the fly so detected_language is ready when utterance ends
-            try:
-                translated = await asyncio.to_thread(translate_input_to_english, full_transcript.strip())
-                detected_language = translated.get("language", "hi")
-                english = translated.get("english_text", full_transcript.strip())
-                # Replace accumulated transcript with clean english version
-                full_transcript = english
-            except Exception as e:
-                print(f"Translation error: {e}")
-
-            # Send live transcript to frontend so user sees what was heard
-            try:
-                await websocket.send_json({"live_transcript": full_transcript})
-            except Exception:
-                pass
-        else:
-            # Send interim results so frontend can show "hearing..." feedback
-            try:
-                await websocket.send_json({"interim_transcript": transcript})
-            except Exception:
-                pass
-
-    async def on_utterance_end(self, utterance_end, **kwargs):
-        """
-        Deepgram fires this after endpointing_ms of silence — means user stopped talking.
-        We set the event here; the main loop picks it up and runs the pipeline.
-        """
-        nonlocal is_processing
-        print(f"Deepgram UtteranceEnd fired — transcript so far: '{full_transcript.strip()}'")
-        if full_transcript.strip() and not is_processing:
-            utterance_end_event.set()
-
-    async def on_error(self, error, **kwargs):
-        print(f"Deepgram error: {error}")
-        try:
-            await websocket.send_json({"error": str(error)})
-        except Exception:
-            pass
-
-    # ── Connect to Deepgram ───────────────────────────────────────────────────
-
-    dg_connection = deepgram_client.listen.asyncwebsocket.v("1")
-    dg_connection.on(LiveTranscriptionEvents.Transcript, on_transcript)
-    dg_connection.on(LiveTranscriptionEvents.UtteranceEnd, on_utterance_end)
-    dg_connection.on(LiveTranscriptionEvents.Error, on_error)
-
-    options = LiveOptions(
-        model="nova-2",
-        language="hi",
-        smart_format=True,
-        punctuate=True,
-        encoding="linear16",
-        sample_rate=16000,
-        channels=1,
-        # Server-side VAD settings:
-        # endpointing_ms — how long Deepgram waits after last speech before
-        #   firing UtteranceEnd. 1200ms is a good balance for natural speech.
-        endpointing=1200,
-        # utterance_end_ms — extra buffer after endpointing before the event fires.
-        utterance_end_ms="1500",
-        # interim_results — send partial transcripts so we can show live feedback.
-        interim_results=True,
-        # vad_events — enables SpeechStarted event (optional, good for UI feedback).
-        vad_events=True,
-    )
-
-    started = await dg_connection.start(options)
-    print(f"Deepgram started: {started}")
-    if not started:
-        print("ERROR: Deepgram WebSocket failed to start")
-        await websocket.send_json({"error": "Speech service unavailable. Please try again."})
-        await websocket.close()
-        return
-
-    # ── Main loop: receive audio from browser, forward to Deepgram ───────────
-    # Browser now just streams raw PCM continuously — no END message needed.
-    # Server-side VAD (via utterance_end_event) drives the pipeline.
-
-    async def receive_audio():
-        """Reads audio chunks from browser and forwards to Deepgram."""
-        try:
-            while True:
-                message = await websocket.receive()
-                if "bytes" in message and message["bytes"]:
-                    await dg_connection.send(message["bytes"])
-                elif "text" in message and message["text"] == "STOP":
-                    # Browser sends STOP only when user clicks mic off
-                    break
-        except WebSocketDisconnect:
-            pass
-
-    try:
-        # Run audio receiver in background so utterance_end_event can be
-        # awaited at the same time in the foreground
-        audio_task = asyncio.create_task(receive_audio())
-
-        while not audio_task.done():
-            # Wait for either Deepgram to detect end of utterance, or audio to stop
-            try:
-                await asyncio.wait_for(utterance_end_event.wait(), timeout=0.5)
-            except asyncio.TimeoutError:
-                continue
-
-            if utterance_end_event.is_set():
-                utterance_end_event.clear()
-                is_processing = True
-
-                # Snapshot and reset transcript for next turn
-                turn_transcript = full_transcript.strip()
-                turn_language = detected_language
-                full_transcript = ""
-
-                if turn_transcript:
-                    await process_and_respond(websocket, turn_transcript, turn_language)
-
-                is_processing = False
-
-        audio_task.cancel()
-
-    except WebSocketDisconnect:
-        print("Client disconnected")
-    finally:
-        await dg_connection.finish()
-        print("Deepgram connection closed")
+    

packages.txt

@@ -1 +0,0 @@
-ffmpeg

tools/category_matcher.py

@@ -1,23 +0,0 @@
-from agents.llm import llm
-import json
-
-async def match_category(category: str, room_map: dict) -> str | None:
-    prompt = f"""
-    The user said they want "{category}" room.
-    Available room categories: {list(room_map.keys())}
-    Match to the closest category. Return ONLY JSON:
-    {{"matched_category": "exact_key_from_list_or_null"}}
-    """
-    try:
-        response = await llm.ainvoke(prompt)
-        clean = response.content.replace("```json","").replace("```","").strip()
-        if hasattr(response, 'usage_metadata') and response.usage_metadata:
-            print(f"Tokens used: {response.usage_metadata}")
-        data = json.loads(clean)
-        matched = data.get("matched_category")
-        if matched and matched in room_map:
-            return matched
-        return None
-    except Exception as e:
-        print(f"Category match error: {e}")
-        return None

tools/date_utiles.py

@@ -1,39 +0,0 @@
-from datetime import datetime, timedelta
-import json
-
-async def sanitize_date(date_str, llm):
-    if not date_str:
-        return None
-    
-    d = str(date_str).strip()
-    today_dt = datetime.now()
-    today_str = today_dt.strftime("%Y-%m-%d")
-    today_day = today_dt.strftime("%A")
-    
-    # quick check if already in correct format
-    try:
-        datetime.strptime(d, "%Y-%m-%d")
-        return d
-    except:
-        pass
-    
-    prompt = f"""Today is {today_day}, {today_str}.
-    Convert this date expression to YYYY-MM-DD format: "{d}"
-    
-    This could be in any language (Hindi, Hinglish, Tamil, English, etc).
-    Examples: "aaj"/"today"/"आज" = today, "kal"/"tomorrow"/"कல்" = tomorrow,
-    "parso" = day after tomorrow, "agle Friday" = next Friday.
-    
-    Return ONLY a JSON object: {{"date": "YYYY-MM-DD"}}
-    If you cannot determine the date, return: {{"date": null}}"""
-    
-    try:
-        response = await llm.ainvoke(prompt)
-        clean = response.content.replace("```json", "").replace("```", "").strip()
-        if hasattr(response, 'usage_metadata') and response.usage_metadata:
-            print(f"Tokens used: {response.usage_metadata}")
-        data = json.loads(clean)
-        return data.get("date")
-    except Exception as e:
-        print(f"Date sanitize error: {e}")
-        return None

tools/pricing_utils.py

@@ -1,39 +0,0 @@
-from datetime import datetime, timedelta
-
-def build_date_wise_pricing(check_in: str, nights: int, base_price: float, total_tax: float) -> list:
-    nightly_base = round(base_price / nights, 2) if nights > 0 else base_price
-    nightly_tax = round(total_tax / nights, 2) if nights > 0 else total_tax
-    
-    date_wise = []
-    try:
-        cin_date = datetime.strptime(check_in, "%Y-%m-%d")
-        for i in range(nights):
-            current_date = cin_date + timedelta(days=i)
-            date_wise.append({
-                "date": current_date.strftime("%d-%m-%Y"),
-                "price": nightly_base,
-                "tax": nightly_tax
-            })
-    except Exception as e:
-        print(f"Date generation error: {e}")
-    
-    return date_wise
-
-def apply_custom_price(pb: dict) -> dict:
-    if pb.get("custom_price"):
-        custom_total = int(pb["custom_price"])
-        if "pricing" not in pb:
-            pb["pricing"] = {}
-        pb["pricing"]["totalPrice"] = custom_total
-    return pb
-
-
-MEAL_PLAN_MAP = {
-    "EP": "Room Only",
-    "CP": "Room With Breakfast",
-    "MAP": "Room With Breakfast + Lunch/Dinner",
-    "AP": "Room With All Meals"
-}
-
-def get_meal_name(meal_abbreviation: str) -> str:
-    return MEAL_PLAN_MAP.get(meal_abbreviation, "Room Only")

translate.py

@@ -1,5 +1,4 @@
 from groq import Groq
-from openai import OpenAI
 from langsmith import traceable
 import os
 import json
@@ -7,7 +6,6 @@ from dotenv import load_dotenv
 load_dotenv()
 
 client = Groq(api_key=os.getenv("GROQ_API_KEY"))
-# client = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
 
 @traceable(name="translate_input_to_english")
 def translate_input_to_english(raw_transcript):
@@ -30,13 +28,8 @@ def translate_input_to_english(raw_transcript):
         messages=[{"role": "user", "content": prompt}],
         temperature=0.1
     )
-    # response = client.chat.completions.create(
-    #     model="gpt-4.1-nano",
-    #     messages=[{"role": "user", "content": prompt}],
-    #     temperature=0.1
-    # )
 
-    print(f"[translate] Tokens: input={response.usage.prompt_tokens}, output={response.usage.completion_tokens}, total={response.usage.total_tokens}")
+    print(response.usage)
     raw_response = response.choices[0].message.content.strip()
     
     raw_response = raw_response.replace('json', '').replace('```', '').strip()
@@ -50,14 +43,6 @@ def translate_input_to_english(raw_transcript):
 @traceable(name="translate_to_target_language")
 def translate_to_target_language(text, target_lang):
 
-    lang_map = {
-        "hi": "hindi", "ta": "tamil", "mr": "marathi",
-        "bn": "bengali", "te": "telugu", "gu": "gujarati",
-        "en": "english", "kn": "kannada"
-    }
-    target_lang = lang_map.get(target_lang.lower().strip(), target_lang.lower().strip())
-
-
     supported_langs = ["hindi", "tamil", "marathi", "bengali", "telugu", "gujarati", "english","kannada"]
     if target_lang.lower().strip() not in supported_langs:
         target_lang = "hindi"
@@ -85,13 +70,8 @@ def translate_to_target_language(text, target_lang):
         messages=[{"role": "user", "content": prompt}],
         temperature=0.3 
     )
-    # response = client.chat.completions.create(
-    #     model="gpt-4.1-nano",
-    #     messages=[{"role": "user", "content": prompt}],
-    #     temperature=0.1
-    # )
 
-    print(f"Token Usages - {response.usage}")
+    print(response.usage)
     translated_text = response.choices[0].message.content.strip()
 
     native_to_eng = {