Add /prospects/unique endpoint; bump version

Bump package version to 1.1.3 and add a new GET endpoint /prospects/unique that accepts a list of field names (Query param) and returns unique values and counts for each specified field from the prospects table. The handler queries the DB, aggregates counts, returns a meta object, data per field, and any field-specific errors, and ensures DB cursor/connection are closed. Also add a trailing newline in routes.py for consistency.

Note: field names are interpolated into SQL for grouping; consider validating/sanitizing field names to avoid SQL issues.

Author: goldlabelapps

app/__init__.py

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

app/api/prospects/prospects.py

@@ -6,6 +6,34 @@
 
 router = APIRouter()
 
+
+# Endpoint to get unique values for specified fields
+from fastapi import Query
+
+@router.get("/prospects/unique")
+def get_unique_fields(fields: list[str] = Query(..., description="List of field names to get unique values for")) -> dict:
+    """Return lists of unique values and their counts for specified fields in the prospects table."""
+    conn_gen = get_db_connection()
+    conn = next(conn_gen)
+    cur = conn.cursor()
+    result = {}
+    errors = {}
+    try:
+        for field in fields:
+            try:
+                cur.execute(f'SELECT "{field}", COUNT(*) FROM prospects WHERE "{field}" IS NOT NULL GROUP BY "{field}" ORDER BY COUNT(*) DESC;')
+                values = [
+                    {"value": row[0], "count": row[1]} for row in cur.fetchall()
+                ]
+                result[field] = values
+            except Exception as e:
+                errors[field] = str(e)
+        meta = make_meta("success", f"Unique values and counts for fields: {fields}")
+        return {"meta": meta, "data": result, "errors": errors if errors else None}
+    finally:
+        cur.close()
+        conn.close()
+
 @router.get("/prospects")
 def root() -> dict:
     """Return all prospects table records"""

app/api/routes.py

@@ -25,4 +25,4 @@
 router.include_router(prospects_router)
 router.include_router(prospects_seed_router)
 router.include_router(prospects_empty_router)
-router.include_router(prospects_process_router)
+router.include_router(prospects_process_router)