add driver name search for passengers

app/ai/tool_schemas.py

@@ -33,7 +33,7 @@ _SEARCH_TRIPS = {
     "function": {
         "name": "search_trips",
         "description": (
-            "Search active trips by departure/destination (either can be omitted). "
+            "Search active trips by departure/destination/driver name (any can be omitted). "
             "Results sent as WhatsApp cards automatically. "
             "Times Asia/Aden. Buckets: صباح before 12, ظهر 12-17:59, ليل 18+."
         ),
@@ -74,6 +74,10 @@ _SEARCH_TRIPS = {
                     "type": "string",
                     "description": "Optional car type in Arabic, for example سيارة or باص.",
                 },
+                "driver_name": {
+                    "type": "string",
+                    "description": "Optional driver name to filter trips by driver.",
+                },
                 "vector_query_text": {
                     "type": "string",
                     "description": "Optional semantic text; auto-built from other fields.",

app/database/supabase.py

@@ -354,6 +354,7 @@ class SupabaseRepository:
         *,
         departure: str | None = None,
         destination: str | None = None,
+        driver_name: str | None = None,
         seats: int | None = None,
         vehicle_type: str | None = None,
         departure_request: DepartureRequest | None = None,
@@ -370,6 +371,11 @@ class SupabaseRepository:
             query = query.ilike("departure", f"%{departure}%")
         if destination:
             query = query.ilike("destination", f"%{destination}%")
+        if driver_name:
+            driver_ids = await self._resolve_driver_ids_by_name(driver_name)
+            if not driver_ids:
+                return []
+            query = query.in_("driver_id", driver_ids)
         if seats:
             query = query.gte("available_seats", seats)
         if vehicle_type:
@@ -407,6 +413,7 @@ class SupabaseRepository:
         query_embedding: list[float],
         departure: str | None = None,
         destination: str | None = None,
+        driver_name: str | None = None,
         departure_date: date | None = None,
         departure_time: str | None = None,
         requested_time: time | None = None,
@@ -423,6 +430,7 @@ class SupabaseRepository:
                     "match_threshold": 0.0,
                     "filter_departure": departure,
                     "filter_destination": destination,
+                    "filter_driver_name": driver_name,
                     "filter_departure_date": (
                         departure_date.isoformat() if departure_date else None
                     ),
@@ -468,6 +476,24 @@ class SupabaseRepository:
             .execute()
         )
 
+    async def _resolve_driver_ids_by_name(self, driver_name: str) -> list[str]:
+        customers_resp = (
+            await self.client.table("customers")
+            .select("id")
+            .ilike("name", f"%{driver_name}%")
+            .execute()
+        )
+        customer_ids = [c["id"] for c in (_response_data(customers_resp) or [])]
+        if not customer_ids:
+            return []
+        drivers_resp = (
+            await self.client.table("drivers")
+            .select("id")
+            .in_("customer_id", customer_ids)
+            .execute()
+        )
+        return [d["id"] for d in (_response_data(drivers_resp) or [])]
+
     def _apply_departure_request_filter(
         self,
         query: Any,

app/tools/handlers.py

@@ -96,6 +96,7 @@ class FalsaToolHandlers:
     async def search_trips(self, arguments: dict[str, Any]) -> ToolResult:
         departure = _optional_string(arguments.get("departure"))
         destination = _optional_string(arguments.get("destination"))
+        driver_name = _optional_string(arguments.get("driver_name"))
         travel_date = _optional_string(arguments.get("travel_date"))
         travel_time = _optional_string(arguments.get("travel_time"))
         travel_time_exact = _optional_string(arguments.get("travel_time_exact"))
@@ -114,16 +115,20 @@ class FalsaToolHandlers:
             exact_time=travel_time_exact,
         )
 
-        if not departure and not destination:
+        if not departure and not destination and not driver_name:
             return ToolResult(
                 ok=False,
                 data={},
-                error="At least departure or destination is required before searching trips",
+                error=(
+                    "At least departure, destination, or driver name"
+                    " is required before searching trips"
+                ),
             )
 
         query = vector_query_text or _trip_vector_query_text(
             departure=departure,
             destination=destination,
+            driver_name=driver_name,
             travel_date=travel_date,
             travel_time=travel_time,
             travel_time_exact=travel_time_exact,
@@ -136,6 +141,7 @@ class FalsaToolHandlers:
             query_embedding=query_embedding,
             departure=departure,
             destination=destination,
+            driver_name=driver_name,
             departure_date=departure_request.departure_date,
             departure_time=departure_request.departure_time,
             requested_time=requested_time,
@@ -147,6 +153,7 @@ class FalsaToolHandlers:
             trips = await self.repository.search_active_trips(
                 departure=departure,
                 destination=destination,
+                driver_name=driver_name,
                 seats=seats,
                 vehicle_type=vehicle_type,
                 departure_request=departure_request,
@@ -160,6 +167,7 @@ class FalsaToolHandlers:
                 trip,
                 departure=departure,
                 destination=destination,
+                driver_name=driver_name,
                 seats=seats,
                 vehicle_type=vehicle_type,
                 departure_request=departure_request,
@@ -911,6 +919,7 @@ def _trip_vector_query_text(
     *,
     departure: str | None,
     destination: str | None,
+    driver_name: str | None,
     travel_date: str | None,
     travel_time: str | None,
     travel_time_exact: str | None,
@@ -923,6 +932,7 @@ def _trip_vector_query_text(
         for part in [
             departure,
             destination,
+            driver_name,
             travel_date,
             travel_time_exact,
             travel_time,
@@ -939,6 +949,7 @@ def _is_trip_match(
     *,
     departure: str | None,
     destination: str | None,
+    driver_name: str | None,
     seats: int,
     vehicle_type: str | None,
     departure_request: Any,
@@ -951,6 +962,10 @@ def _is_trip_match(
         return False
     if destination and destination.lower() not in str(trip.get("destination") or "").lower():
         return False
+    if driver_name:
+        trip_driver_name = str(trip.get("driver_name") or "").lower()
+        if driver_name.lower() not in trip_driver_name:
+            return False
     if vehicle_type:
         car = _first_or_dict(trip.get("driver_cars")) or {}
         car_type = car.get("car_type") or trip.get("car_type")

prompts/falsa_info.md

@@ -15,7 +15,7 @@
 المستخدم الجديد: يسأله النظام هل يريد السفر (مسافر) أو العمل كسائق. المسافر: يبحث عن رحلات ويختار ويتواصل مع السائق. السائق: ينشر رحلات ويدير جدوله ويسجل مركباته ويستلم إشعارات الاهتمام بالرحلات.
 
 ## البحث عن الرحلات
-تقدر تبحث برسالة بسيطة حتى لو كانت المعلومات ناقصة. مثال: "من صنعاء إلى تعز بكرة". البحث ذكي — يفهم المعنى وليس الكلمات المطابقة فقط. إذا ما لقى نتائج بالضبط، يبحث في كل الرحلات النشطة. أوقات الرحلات تصنف إلى ثلاث فترات: صباح (قبل 12 ظهراً)، ظهر (من 12 ظهراً إلى 6 مساءً)، ليل (بعد 6 مساءً). أنواع المركبات: سيارة، باص، أو أي نوع يسجله السائق.
+تقدر تبحث برسالة بسيطة حتى لو كانت المعلومات ناقصة. مثال: "من صنعاء إلى تعز بكرة". تقدر أيضاً تبحث باسم السائق، مثال: "أبي رحلات السائق أحمد". البحث ذكي — يفهم المعنى وليس الكلمات المطابقة فقط. إذا ما لقى نتائج بالضبط، يبحث في كل الرحلات النشطة. أوقات الرحلات تصنف إلى ثلاث فترات: صباح (قبل 12 ظهراً)، ظهر (من 12 ظهراً إلى 6 مساءً)، ليل (بعد 6 مساءً). أنواع المركبات: سيارة، باص، أو أي نوع يسجله السائق.
 
 ## اختيار الرحلة والتواصل مع السائق
 عندما تختار رحلة بالرد على بطاقة الرحلة: يتم تسجيل اهتمامك (ليس حجزاً مؤكداً)، السائق يستلم إشعار فيه اسمك ورقمك وعدد المقاعد المطلوبة، أنت تستلم رقم السائق، تتواصلون مباشرة للاتفاق على الحجز والسعر. المقاعد لا تحجز. قد يتواصل معك أكثر من شخص مهتم بنفس الرحلة.
@@ -41,6 +41,7 @@
 س: وش معنى المقاعد المتاحة؟ ج: عدد المقاعد الفارغة في الرحلة. تقدر تطلب أي عدد لكن لا تحجز — السائق يؤكد بعد التواصل.
 س: هل أقدر ألغي اختياري؟ ج: اختيار الرحلة هو إرسال اهتمام فقط ولا يوجد إلغاء من النظام. إذا تغير رأيك، تواصل مع السائق مباشرة.
 س: كيف أسجل كسائق؟ ج: قول "أبي أسجل كسائق" أو اختر وضع السائق. يحتاج الاسم الكامل.
+س: كيف أبحث عن رحلة لسائق معين؟ ج: قول "أبي رحلات السائق أحمد" أو "دور رحلة مع السائق". فلزا تبحث في الرحلات المتاحة لهالسائق وترسل لك النتائج.
 س: كيف أضيف رحلة كسائق؟ ج: قول "أبي أضيف رحلة من عدن إلى الحديدة الجمعة الصباح". فلزا تطلب التفاصيل الناقصة.
 س: كيف أعدل أو ألغي رحلة؟ ج: قول "أبي أعدل رحلة" أو "أبي ألغي رحلة". فلزا ترسل لك قائمة رحلاتك — ترد على اللي تبيه.
 س: هل فيه رحلات بين كل المدن؟ ج: فلزا تعرض الرحلات اللي ينشرها السائقين. إذا ما لقيت رحلتك، اسأل مرة ثانية أو تواصل مع الدعم.

prompts/system_passenger.md

@@ -1,4 +1,4 @@
-- search_trips as soon as the user mentions a departure or destination. You do not need all details — the tool accepts partial info. Only ask a follow-up if neither departure nor destination was mentioned.
+- search_trips as soon as the user mentions a departure, destination, or driver name. You do not need all details — the tool accepts partial info. Only ask a follow-up if neither departure, destination, nor driver name was mentioned.
 - When search_trips finds matches, trip cards are sent to the user automatically along with a prompt to choose one. Do NOT add any text after calling search_trips — the tool will handle the response.
 - When the user replies to a trip card, immediately call select_trip — trip_id is auto-detected and seats default to 1. Do not ask for seat count or other details.
 - Selections are not reservations — seats are not held.

supabase/migrations/202607130001_driver_name_search.sql

@@ -0,0 +1,123 @@
+-- Add driver name filtering to match_active_trips RPC
+
+DROP FUNCTION IF EXISTS public.match_active_trips(
+  extensions.vector(1024), float, int, text, text, date, text, time, int, text
+);
+
+CREATE OR REPLACE FUNCTION public.match_active_trips(
+  query_embedding extensions.vector(1024),
+  match_threshold float DEFAULT 0.0,
+  match_count int DEFAULT 10,
+  filter_departure text DEFAULT NULL,
+  filter_destination text DEFAULT NULL,
+  filter_driver_name text DEFAULT NULL,
+  filter_departure_date date DEFAULT NULL,
+  filter_departure_time text DEFAULT NULL,
+  filter_requested_time time DEFAULT NULL,
+  filter_seats int DEFAULT 1,
+  filter_vehicle_type text DEFAULT NULL
+)
+RETURNS TABLE (
+  trip_id uuid,
+  departure text,
+  destination text,
+  departure_date date,
+  departure_time text,
+  available_seats integer,
+  total_seats integer,
+  price numeric,
+  status text,
+  driver_name text,
+  driver_phone_number text,
+  car_type text,
+  chunk_text text,
+  similarity float,
+  time_difference_minutes integer,
+  registered boolean
+)
+LANGUAGE sql STABLE
+AS $$
+  WITH ranked AS (
+    SELECT
+      driver_trips.id AS trip_id,
+      driver_trips.departure,
+      driver_trips.destination,
+      driver_trips.departure_date,
+      driver_trips.departure_time,
+      driver_trips.available_seats,
+      driver_trips.total_seats,
+      driver_trips.price,
+      driver_trips.status,
+      customers.name AS driver_name,
+      customers."remoteJid" AS driver_phone_number,
+      driver_cars.car_type,
+      driver_trip_embeddings.chunk_text,
+      COALESCE(customers.registered, false) AS registered,
+      1 - (driver_trip_embeddings.embedding <=> query_embedding) AS similarity,
+      driver_trip_embeddings.embedding <=> query_embedding AS vector_distance,
+      CASE
+        WHEN filter_requested_time IS NULL THEN NULL
+        ELSE abs(
+          extract(epoch FROM (
+            public.departure_bucket_clock_time(driver_trips.departure_time)
+            - filter_requested_time
+          )) / 60
+        )::integer
+      END AS time_difference_minutes
+    FROM public.driver_trip_embeddings
+    JOIN public.driver_trips ON driver_trips.id = driver_trip_embeddings.trip_id
+    LEFT JOIN public.drivers ON drivers.id = driver_trips.driver_id
+    LEFT JOIN public.customers ON customers.id = drivers.customer_id
+    LEFT JOIN public.driver_cars ON driver_cars.id = driver_trips.car_id
+    WHERE driver_trips.status = 'active'
+      AND driver_trips.available_seats >= COALESCE(filter_seats, 1)
+      AND (filter_departure IS NULL OR driver_trips.departure ILIKE '%' || filter_departure || '%')
+      AND (filter_destination IS NULL OR driver_trips.destination ILIKE '%' || filter_destination || '%')
+      AND (filter_driver_name IS NULL OR customers.name ILIKE '%' || filter_driver_name || '%')
+      AND (filter_departure_date IS NULL OR driver_trips.departure_date = filter_departure_date)
+      AND (filter_departure_time IS NULL OR driver_trips.departure_time = filter_departure_time)
+      AND (filter_vehicle_type IS NULL OR driver_cars.car_type ILIKE '%' || filter_vehicle_type || '%')
+      AND (
+        driver_trips.departure_date > (NOW() AT TIME ZONE 'Asia/Aden')::date
+        OR (
+          driver_trips.departure_date = (NOW() AT TIME ZONE 'Asia/Aden')::date
+          AND (
+            (NOW() AT TIME ZONE 'Asia/Aden')::time < TIME '12:00'
+            OR (
+              (NOW() AT TIME ZONE 'Asia/Aden')::time < TIME '18:00'
+              AND driver_trips.departure_time IN ('noon', 'night')
+            )
+            OR (
+              (NOW() AT TIME ZONE 'Asia/Aden')::time >= TIME '18:00'
+              AND driver_trips.departure_time = 'night'
+            )
+          )
+        )
+      )
+  )
+  SELECT
+    ranked.trip_id,
+    ranked.departure,
+    ranked.destination,
+    ranked.departure_date,
+    ranked.departure_time,
+    ranked.available_seats,
+    ranked.total_seats,
+    ranked.price,
+    ranked.status,
+    ranked.driver_name,
+    ranked.driver_phone_number,
+    ranked.car_type,
+    ranked.chunk_text,
+    ranked.similarity,
+    ranked.time_difference_minutes,
+    ranked.registered
+  FROM ranked
+  WHERE ranked.similarity >= match_threshold
+  ORDER BY
+    ranked.registered DESC,
+    ranked.time_difference_minutes NULLS LAST,
+    ranked.departure_date,
+    ranked.vector_distance
+  LIMIT match_count;
+$$;

tests/test_tools.py

@@ -145,7 +145,8 @@ async def test_search_trips_requires_at_least_departure_or_destination():
     result = await handlers.search_trips({"seats": 2})
 
     assert result.ok is False
-    assert "departure or destination" in (result.error or "")
+    assert "departure" in (result.error or "")
+    assert "driver name" in (result.error or "")
 
 
 @pytest.mark.asyncio