rename booking leads to trip selections

- create_booking_lead -> select_trip across tools, schemas, handlers, prompts
- booking_leads table -> trip_selections (with migration)
- update Arabic notifications and prompts to reflect 'interest' not 'booking'
- add selection_count to trip cards and summaries
- update README and falsa_info.md to reflect new coordination model

README.md

@@ -1,6 +1,6 @@
 # FALSA
 
-> **AI-powered travel booking assistant — on WhatsApp.**
+> **AI-powered travel service — on WhatsApp.**
 
 > **🚧 Work in progress — not yet published. Coming soon.**
 
@@ -8,7 +8,7 @@
   <img src="assets/Falsa.png" alt="FALSA logo" width="100%">
 </p>
 
-FALSA lets passengers search trips and book seats, and lets drivers publish, update, and manage their trips — all through a natural conversation on WhatsApp. No app to install, no complex UI to learn. Just type what you want.
+FALSA lets passengers search trips and connect with drivers, and lets drivers publish, update, and manage their trips — all through a natural conversation on WhatsApp. No app to install, no complex UI to learn. Just type what you want.
 
 ---
 
@@ -25,8 +25,8 @@ Travel booking platforms in my country are poorly adopted. Not because people do
 
 FALSA removes all of that. The entire interface is a single chat conversation. **You say where you're going and when — FALSA handles the rest.**
 
-- **Passengers** describe their trip in natural language; FALSA searches available trips, shows options, and helps book.
-- **Drivers** publish trips, manage schedules, and receive booking leads — all by chatting.
+- **Passengers** describe their trip in natural language; FALSA searches available trips, shows options, and connects them with drivers.
+- **Drivers** publish trips, manage schedules, and receive trip interest notifications — all by chatting.
 - No app install, no account creation flow, no confusing dashboard.
 
 ---
@@ -35,8 +35,8 @@ FALSA removes all of that. The entire interface is a single chat conversation. *
 
 - **Natural-language trip search** — "I want to go from Sana'a to Taiz tomorrow morning"
 - **WhatsApp-native interaction** — interactive lists, text replies, no extra UI
-- **Driver tools** — publish trips, add cars, modify/delete trips, receive booking notifications
-- **Passenger tools** — search trips, create booking leads, get FALSA information
+- **Driver tools** — publish trips, add cars, modify/delete trips, receive trip interest notifications
+- **Passenger tools** — search trips, select trips, get driver contact, get FALSA information
 - **AI-powered orchestration** — tool-calling LLM (Groq primary, Hugging Face fallback) routes intent to the right action
 - **RAG knowledge base** — company info, pricing, policies embedded via Jina AI and retrieved on demand
 - **Trip vector search** — semantic search over driver trips for flexible departure matching

app/ai/tool_schemas.py

@@ -85,12 +85,13 @@ _SEARCH_TRIPS = {
     },
 }
 
-_CREATE_BOOKING_LEAD = {
+_SELECT_TRIP = {
     "type": "function",
     "function": {
-        "name": "create_booking_lead",
+        "name": "select_trip",
         "description": (
-            "Create pending booking (default 1 seat), notify driver. "
+            "Record customer interest in a trip (default 1 seat), notify driver, "
+            "and return driver phone number so they can coordinate directly. "
             "Call on trip-card reply. Does not reserve or confirm."
         ),
         "parameters": {
@@ -399,7 +400,7 @@ _SWITCH_TO_PASSENGER = {
 _TOOL_SCHEMAS: dict[str, dict[str, Any]] = {
     "about_falsa": _ABOUT_FALSA,
     "search_trips": _SEARCH_TRIPS,
-    "create_booking_lead": _CREATE_BOOKING_LEAD,
+    "select_trip": _SELECT_TRIP,
     "create_driver_account": _CREATE_DRIVER_ACCOUNT,
     "check_driver_info": _CHECK_DRIVER_INFO,
     "check_driver_trips": _CHECK_DRIVER_TRIPS,
@@ -435,7 +436,7 @@ _TOOLS_BY_MODE: dict[UserMode, list[str]] = {
     "passenger": [
         "about_falsa",
         "search_trips",
-        "create_booking_lead",
+        "select_trip",
         "create_driver_account",
         "switch_to_driver",
     ],

app/database/supabase.py

@@ -555,7 +555,7 @@ class SupabaseRepository:
         updated = data[0] if isinstance(data, list) else data
         return await self.get_trip_by_id(str(updated.get("id") or trip_id)) or updated
 
-    async def create_booking_lead(
+    async def create_trip_selection(
         self,
         *,
         customer_id: str,
@@ -571,14 +571,14 @@ class SupabaseRepository:
             "notes": notes,
             "driver_notification_status": "not_sent",
         }
-        response = await self.client.table("booking_leads").insert(payload).execute()
+        response = await self.client.table("trip_selections").insert(payload).execute()
         data = _response_data(response)
         return data[0] if isinstance(data, list) else data
 
-    async def update_booking_lead_notification(
+    async def update_selection_notification(
         self,
         *,
-        lead_id: str,
+        selection_id: str,
         status: str,
         metadata: dict[str, Any] | None = None,
     ) -> dict[str, Any]:
@@ -586,7 +586,17 @@ class SupabaseRepository:
         if metadata is not None:
             payload["metadata"] = metadata
         response = (
-            await self.client.table("booking_leads").update(payload).eq("id", lead_id).execute()
+            await self.client.table("trip_selections").update(payload).eq("id", selection_id).execute()
         )
         data = _response_data(response)
         return data[0] if isinstance(data, list) else data
+
+    async def count_trip_selections(self, trip_id: str) -> int:
+        response = await (
+            self.client.table("trip_selections")
+            .select("id", count="exact")
+            .eq("trip_id", trip_id)
+            .eq("status", "pending")
+            .execute()
+        )
+        return response.count if hasattr(response, "count") and response.count is not None else 0

app/services/conversation_service.py

@@ -97,18 +97,18 @@ class ConversationService:
                             embedding_model=self.settings.jina_embedding_model,
                             current_message=current_message,
                         )
-                        result = await handlers.create_booking_lead(
+                        result = await handlers.select_trip(
                             {"trip_id": trip_id, "requested_seats": 1}
                         )
                         if result.ok:
                             driver_phone = result.data.get("driver_phone")
                             reply = (
-                                f"تم تأكيد الحجز! يمكنك التواصل مع السائق على الرقم: {driver_phone}"
+                                f"تم إرسال معلوماتك إلى السائق. يمكنك التواصل معه على الرقم: {driver_phone}"
                                 if driver_phone
-                                else "تم تأكيد الحجز! سيتم إشعار السائق."
+                                else "تم إرسال معلوماتك إلى السائق. سيتم التواصل معك."
                             )
                         else:
-                            reply = f"عذراً، لم يتم تأكيد الحجز: {result.error}"
+                            reply = f"عذراً، لم يتم إرسال الطلب: {result.error}"
                         await self.whatsapp.send_text(inbound.remoteJid, reply)
                         await self.repository.create_message(
                             customer_id=str(customer["id"]),

app/tools/handlers.py

@@ -171,7 +171,10 @@ class FalsaToolHandlers:
         if top_trips:
             for trip_summary in top_trips:
                 trip_id = trip_summary["trip_id"]
+                selection_count = await self.repository.count_trip_selections(trip_id)
+                trip_summary["selection_count"] = selection_count
                 trip = next((t for t in trips if (t.get("trip_id") or t.get("id")) == trip_id), {})
+                trip["selection_count"] = selection_count
                 card = format_trip_card(trip)
                 try:
                     resp = await self.whatsapp.send_text(self.remoteJid, card)
@@ -219,7 +222,7 @@ class FalsaToolHandlers:
             },
         )
 
-    async def create_booking_lead(self, arguments: dict[str, Any]) -> ToolResult:
+    async def select_trip(self, arguments: dict[str, Any]) -> ToolResult:
         trip_id = _optional_string(arguments.get("trip_id"))
         requested_seats = _optional_int(arguments.get("requested_seats")) or 1
         notes = _optional_string(arguments.get("notes"))
@@ -243,7 +246,7 @@ class FalsaToolHandlers:
                 error="Not enough available seats",
             )
 
-        lead = await self.repository.create_booking_lead(
+        selection = await self.repository.create_trip_selection(
             customer_id=str(self.customer["id"]),
             trip_id=trip_id,
             requested_seats=requested_seats,
@@ -273,8 +276,8 @@ class FalsaToolHandlers:
             notification_status = "failed"
             notification_error = str(exc)
 
-        await self.repository.update_booking_lead_notification(
-            lead_id=str(lead["id"]),
+        await self.repository.update_selection_notification(
+            selection_id=str(selection["id"]),
             status=notification_status,
             metadata={"error": notification_error} if notification_error else None,
         )
@@ -282,12 +285,12 @@ class FalsaToolHandlers:
         return ToolResult(
             ok=True,
             data={
-                "lead_id": lead["id"],
+                "selection_id": selection["id"],
                 "status": "pending",
                 "driver_notification_status": notification_status,
                 "driver_notification_error": notification_error,
                 "driver_phone": driver_phone,
-                "message": "Booking lead created. Seats are not reserved until confirmed.",
+                "message": "Customer interest recorded. Driver has been notified — share their number so the two parties can coordinate directly.",
             },
         )
 
@@ -1019,6 +1022,7 @@ def _trip_summary(trip: dict[str, Any], *, trip_number: int | None = None) -> di
         "status": trip.get("status"),
         "similarity": trip.get("similarity"),
         "time_difference_minutes": trip.get("time_difference_minutes"),
+        "selection_count": trip.get("selection_count", 0),
     }
     if trip_number is not None:
         summary["trip_number"] = trip_number
@@ -1076,12 +1080,12 @@ def _driver_notification_text(
     notes: str | None,
 ) -> str:
     return (
-        "🔔 حجز جديد في فلسا\n"
+        "🔔 اهتمام جديد برحلة في فلسا\n"
         f"العميل: {customer.get('name') or 'عميل جديد'}\n"
         f"رقم العميل: {customer.get('phone_number') or 'غير متوفر'}\n"
         f"الرحلة: {trip.get('departure')} ← {trip.get('destination')}\n"
         f"التاريخ: {trip_departure_date(trip)} {trip_departure_bucket(trip)}\n"
         f"المقاعد المطلوبة: {requested_seats}\n"
         f"ملاحظات: {notes or 'لا يوجد'}\n"
-        "الحالة: قيد الانتظار"
+        "يرجى التواصل مع العميل للاتفاق على الحجز"
     )

app/whatsapp/trip_selection.py

@@ -92,6 +92,7 @@ def format_trip_card(trip: dict[str, Any]) -> str:
     available = trip.get("available_seats") or 0
     total = trip.get("total_seats") or 0
     price = trip.get("price") or ""
+    selection_count = trip.get("selection_count")
 
     lines = [
         "─" * 14,
@@ -101,6 +102,7 @@ def format_trip_card(trip: dict[str, Any]) -> str:
         f"السعر: {price}" if price else "",
         f"السيارة: {car_type}" if car_type else "",
         f"السائق: {driver_name}" if driver_name else "",
+        f"عدد المهتمين: {selection_count}" if selection_count is not None else "",
         "─" * 14,
     ]
     return "\n".join(line for line in lines if line)

prompts/falsa_info.md

@@ -1,23 +1,25 @@
 # FALSA Information Seed
 
 ## Company
-FALSA is an AI-powered travel booking customer service platform. Customers can ask
-about car and bus trips through WhatsApp, search available routes, and request a
-booking handoff to the driver or support team.
+FALSA is an AI-powered travel service platform on WhatsApp. Customers can ask
+about car and bus trips through WhatsApp, search available routes, and express
+interest in a trip — the driver and customer then coordinate directly.
 
 ## How The Service Works
 Customers send a message on WhatsApp. FALSA checks available active trips, shares
-matching options, and creates a pending booking lead when the customer chooses a
-trip. Seats are not reserved until the driver or support team confirms the booking.
+matching options, and records the customer's interest when they select a trip.
+Seats are not reserved. The driver is notified and the customer receives the
+driver's phone number to arrange the booking directly between themselves.
 
 ## Pricing
 Trip prices depend on route, vehicle type, seat availability, and driver pricing.
 FALSA should only share prices returned by the trip search results.
 
 ## Policies
-FALSA does not confirm a reservation or payment automatically in v1. Any booking
-lead remains pending until human or driver confirmation. Customers should provide
-accurate travel details, preferred time, number of seats, and pickup notes.
+FALSA does not handle reservations, confirmations, or payments. Customers select
+a trip, receive the driver's contact, and coordinate directly with the driver.
+Customers should provide accurate travel details, preferred time, number of seats,
+and pickup notes.
 
 ## Support
 If FALSA cannot find a suitable answer or trip, the assistant should collect the

pyproject.toml

@@ -1,7 +1,7 @@
 [project]
 name = "falsa"
 version = "0.1.0"
-description = "AI-powered WhatsApp travel booking customer service backend"
+description = "AI-powered WhatsApp travel service backend"
 requires-python = ">=3.12"
 dependencies = [
     "fastapi>=0.115.0",

tests/conftest.py

@@ -106,7 +106,7 @@ class FakeRepository:
         self.created_trips: list[dict[str, Any]] = []
         self.trip_embeddings: list[dict[str, Any]] = []
         self.messages: list[dict[str, Any]] = []
-        self.booking_leads: list[dict[str, Any]] = []
+        self.trip_selections: list[dict[str, Any]] = []
         self.notification_updates: list[dict[str, Any]] = []
         self.trips_by_id: dict[str, dict[str, Any]] = {}
         self.active_search_results: list[dict[str, Any]] = []
@@ -277,7 +277,7 @@ class FakeRepository:
         match_count = int(kwargs.get("match_count") or 10)
         return self.trip_vector_search_results[:match_count]
 
-    async def create_booking_lead(
+    async def create_trip_selection(
         self,
         *,
         customer_id: str,
@@ -285,27 +285,30 @@ class FakeRepository:
         requested_seats: int,
         notes: str | None,
     ) -> dict[str, Any]:
-        lead = {
-            "id": f"lead-{len(self.booking_leads) + 1}",
+        selection = {
+            "id": f"sel-{len(self.trip_selections) + 1}",
             "customer_id": customer_id,
             "trip_id": trip_id,
             "requested_seats": requested_seats,
             "notes": notes,
         }
-        self.booking_leads.append(lead)
-        return lead
+        self.trip_selections.append(selection)
+        return selection
 
-    async def update_booking_lead_notification(
+    async def update_selection_notification(
         self,
         *,
-        lead_id: str,
+        selection_id: str,
         status: str,
         metadata: dict[str, Any] | None = None,
     ) -> dict[str, Any]:
-        update = {"lead_id": lead_id, "status": status, "metadata": metadata}
+        update = {"selection_id": selection_id, "status": status, "metadata": metadata}
         self.notification_updates.append(update)
         return update
 
+    async def count_trip_selections(self, trip_id: str) -> int:
+        return sum(1 for s in self.trip_selections if s["trip_id"] == trip_id)
+
     async def get_driver_by_phone(self, remote_jid: str) -> dict[str, Any] | None:
         return self.drivers_by_remote_jid.get(remote_jid)
 

tests/test_conversation_service.py

@@ -117,7 +117,7 @@ async def test_conversation_uses_passenger_tools_when_user_mode_is_passenger(set
     assert tool_names == {
         "about_falsa",
         "search_trips",
-        "create_booking_lead",
+        "select_trip",
         "create_driver_account",
         "switch_to_driver",
     }

tests/test_tool_schemas.py

@@ -14,7 +14,7 @@ def test_new_user_tools_are_onboarding_only():
 def test_driver_tools_exclude_passenger_booking_tools():
     names = {schema["function"]["name"] for schema in get_tool_schemas("driver")}
     assert "search_trips" not in names
-    assert "create_booking_lead" not in names
+    assert "select_trip" not in names
     assert "initiate_trip_action" in names
     assert "update_trip_field" in names
     assert "switch_to_passenger" in names

tests/test_tools.py

@@ -222,7 +222,7 @@ async def test_search_trips_includes_alternate_alert_when_first_result_is_over_o
 
 
 @pytest.mark.asyncio
-async def test_create_booking_lead_notifies_driver():
+async def test_select_trip_notifies_driver():
     repository = FakeRepository()
     repository.trips_by_id["trip-1"] = trip()
     whatsapp = FakeWhatsApp()
@@ -232,18 +232,18 @@ async def test_create_booking_lead_notifies_driver():
         customer={"id": "cust-1", "remoteJid": "967700000001", "name": "Mona"},
     )
 
-    result = await handlers.create_booking_lead(
+    result = await handlers.select_trip(
         {"trip_id": "trip-1", "requested_seats": 2, "notes": "Window seat"}
     )
 
     assert result.ok is True
     assert result.data["driver_notification_status"] == "sent"
-    assert repository.booking_leads[0]["requested_seats"] == 2
+    assert repository.trip_selections[0]["requested_seats"] == 2
     assert whatsapp.sent[0][0] == "967700000009"
 
 
 @pytest.mark.asyncio
-async def test_create_booking_lead_uses_driver_phone_number():
+async def test_select_trip_uses_driver_phone_number():
     repository = FakeRepository()
     repository.trips_by_id["trip-1"] = trip(driver_phone_number="967700000099")
     whatsapp = FakeWhatsApp()
@@ -253,7 +253,7 @@ async def test_create_booking_lead_uses_driver_phone_number():
         customer={"id": "cust-1", "remoteJid": "967700000001", "name": "Mona"},
     )
 
-    result = await handlers.create_booking_lead(
+    result = await handlers.select_trip(
         {"trip_id": "trip-1", "requested_seats": 1}
     )
 
@@ -264,7 +264,7 @@ async def test_create_booking_lead_uses_driver_phone_number():
 
 
 @pytest.mark.asyncio
-async def test_create_booking_lead_keeps_pending_when_driver_notification_fails():
+async def test_select_trip_keeps_pending_when_driver_notification_fails():
     repository = FakeRepository()
     repository.trips_by_id["trip-1"] = trip()
     handlers = make_handlers(
@@ -272,7 +272,7 @@ async def test_create_booking_lead_keeps_pending_when_driver_notification_fails(
         whatsapp=FakeWhatsApp(fail=True),
     )
 
-    result = await handlers.create_booking_lead({"trip_id": "trip-1", "requested_seats": 1})
+    result = await handlers.select_trip({"trip_id": "trip-1", "requested_seats": 1})
 
     assert result.ok is True
     assert result.data["status"] == "pending"
@@ -281,16 +281,16 @@ async def test_create_booking_lead_keeps_pending_when_driver_notification_fails(
 
 
 @pytest.mark.asyncio
-async def test_create_booking_lead_rejects_insufficient_seats():
+async def test_select_trip_rejects_insufficient_seats():
     repository = FakeRepository()
     repository.trips_by_id["trip-1"] = trip(available_seats=1)
     handlers = make_handlers(repository=repository)
 
-    result = await handlers.create_booking_lead({"trip_id": "trip-1", "requested_seats": 2})
+    result = await handlers.select_trip({"trip_id": "trip-1", "requested_seats": 2})
 
     assert result.ok is False
     assert result.error == "Not enough available seats"
-    assert repository.booking_leads == []
+    assert repository.trip_selections == []
 
 
 @pytest.mark.asyncio