Add prospects search endpoint and bump version

Bump __version__ to 1.2.1 and add a new /prospects/search endpoint. The search route accepts query, page and limit parameters, performs full-text search against the search_vector column using plainto_tsquery('english'), returns paginated results with total/pages metadata, and includes basic error handling and DB resource cleanup. Also update the prospects root links to expose the new search URL.

Author: goldlabelapps

app/__init__.py

@@ -1,4 +1,4 @@
 """NX AI - FastAPI/Python/Postgres/tsvector"""
 
 # Current Version
-__version__ = "1.2.0"
+__version__ = "1.2.1"

app/api/prospects/prospects.py

@@ -14,12 +14,10 @@ def root() -> dict:
     meta = make_meta("success", "Prospects start")
     data = [
         {"init": f"{base_url}/prospects/init"},
-        {"single": f"{base_url}/prospects/101"},
-        {"read": f"{base_url}/prospects/read"},
+        {"search": f"{base_url}/prospects/search/?query=example"},
     ]
     return {"meta": meta, "data": data}
 
-
 # endpoint: /prospects/read
 @router.get("/prospects/read")
 def prospects_read(
@@ -61,6 +59,55 @@ def prospects_read(
         "data": data,
     }
 
+from typing import Optional
+
+# endpoint: /prospects/search
+@router.get("/prospects/search")
+def prospects_search(query: Optional[str] = Query(None, description="Search query string"),
+                    page: int = Query(1, ge=1, description="Page number (1-based)"),
+                    limit: int = Query(50, ge=1, le=500, description="Records per page (default 50, max 500)")) -> dict:
+    """Search prospects using full-text search on search_vector column."""
+    meta = make_meta("success", f"Search prospects for query: {query}")
+    data = []
+    total = 0
+    if not query or not query.strip():
+        meta = make_meta("error", "Query parameter is required for search.")
+        return {"meta": meta, "data": [], "pagination": {"page": page, "limit": limit, "total": 0, "pages": 0}}
+    conn_gen = get_db_connection()
+    conn = next(conn_gen)
+    cur = conn.cursor()
+    offset = (page - 1) * limit
+    try:
+        # Count total matches
+        cur.execute("SELECT COUNT(*) FROM prospects WHERE search_vector @@ plainto_tsquery('english', %s);", (query,))
+        count_row = cur.fetchone() if cur.description is not None else None
+        total = count_row[0] if count_row is not None else 0
+        # Fetch paginated results
+        cur.execute("SELECT * FROM prospects WHERE search_vector @@ plainto_tsquery('english', %s) OFFSET %s LIMIT %s;", (query, offset, limit))
+        if cur.description is not None:
+            columns = [desc[0] for desc in cur.description]
+            rows = cur.fetchall()
+            data = [dict(zip(columns, row)) for row in rows]
+        else:
+            data = []
+    except Exception as e:
+        meta = make_meta("error", f"Search failed: {str(e)}")
+        data = []
+        total = 0
+    finally:
+        cur.close()
+        conn.close()
+    return {
+        "meta": meta,
+        "pagination": {
+            "page": page,
+            "limit": limit,
+            "total": total,
+            "pages": (total // limit) + (1 if total % limit else 0)
+        },
+        "data": data,
+    }
+
 # endpoint: /prospects/init
 @router.get("/prospects/init")
 def prospects_init() -> dict: