Add queue delete endpoint and improve APIs

Add a new DELETE /queue/delete route to remove queue records by id and register it in the queue router. Change the GET queue summary to return a random example record (ORDER BY RANDOM() LIMIT 1) instead of the most recently updated records. Update the LinkedIn import to point to linkedin.csv instead of the sample file. Add a global RequestValidationError handler in app.main that returns errors using the existing make_meta format, and add required imports for that handler.

Author: goldlabelapps

app/api/queue/__init__.py

@@ -7,6 +7,7 @@
 from .routes.get import router as get_router
 
 from .routes.create import router as create_router
+from .routes.delete import router as delete_router
 
 from .routes.import_linkedin import router as import_linkedin_router
 
@@ -18,6 +19,7 @@
 router.include_router(empty_router)
 router.include_router(get_router)
 router.include_router(create_router)
+router.include_router(delete_router)
 router.include_router(import_linkedin_router)
 router.include_router(alter_router)
 router.include_router(rename_router)

app/api/queue/routes/delete.py

@@ -0,0 +1,24 @@
+import os
+from fastapi import APIRouter, HTTPException
+from app.utils.make_meta import make_meta
+from app.utils.db import get_db_connection_direct
+
+router = APIRouter()
+
+@router.delete("/queue/delete")
+def delete_queue_record(id: int) -> dict:
+    """DELETE /queue/delete: Delete a record from the queue table by id."""
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        cursor.execute("DELETE FROM queue WHERE id = %s RETURNING id;", (id,))
+        deleted = cursor.fetchone()
+        conn.commit()
+        conn.close()
+        if deleted:
+            return {"meta": make_meta("success", f"Record with id {id} deleted.")}
+        else:
+            return {"meta": make_meta("error", f"No record found with id {id}.")}
+    except Exception as e:
+        msg = str(e)
+        return {"meta": make_meta("error", msg)}

app/api/queue/routes/get.py

@@ -27,11 +27,11 @@ def read_queue() -> dict:
             for row in cursor.fetchall()
         ]
 
-        # 3. Get the 10 most recently updated records
-        cursor.execute("SELECT * FROM queue ORDER BY updated DESC LIMIT 10;")
+        # 3. Get a random record
+        cursor.execute("SELECT * FROM queue ORDER BY RANDOM() LIMIT 1;")
         columns = [desc[0] for desc in cursor.description] if cursor.description else []
         rows = cursor.fetchall()
-        most_recent = [dict(zip(columns, row)) for row in rows] if rows and columns else []
+        random_record = [dict(zip(columns, row)) for row in rows] if rows and columns else []
 
         # 4. Get unique values from collection and group columns
         cursor.execute("SELECT DISTINCT collection FROM queue WHERE collection IS NOT NULL;")
@@ -47,7 +47,7 @@ def read_queue() -> dict:
                 "in_queue": record_count,
                 "collections": collections,
                 "groups": groups,
-                "example": most_recent[:1],
+                "example": random_record,
                 # "queue_schema": schema
             }
         }

app/api/queue/routes/import_linkedin.py

@@ -10,7 +10,7 @@
 @router.post("/queue/import/linkedin")
 def import_linkedin_csv() -> dict:
     """POST /queue/import/linkedin: Import data from linkedin.csv into the queue table, robust for large files."""
-    csv_path = os.path.join(os.path.dirname(__file__), "../csv/linkedin/linkedin_sample.csv")
+    csv_path = os.path.join(os.path.dirname(__file__), "../csv/linkedin/linkedin.csv")
     if not os.path.exists(csv_path):
         raise HTTPException(status_code=404, detail="linkedin.csv not found")
     try:

app/main.py

@@ -1,5 +1,8 @@
 from app import __version__
-from fastapi import FastAPI
+from fastapi import FastAPI, Request
+from fastapi.responses import JSONResponse
+from fastapi.exceptions import RequestValidationError
+from app.utils.make_meta import make_meta
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.staticfiles import StaticFiles
 from fastapi.responses import FileResponse
@@ -26,6 +29,13 @@
     allow_headers=["*"]
 )
 
+
+# Global validation error handler for make_meta pattern
+@app.exception_handler(RequestValidationError)
+async def validation_exception_handler(request: Request, exc: RequestValidationError):
+    msg = exc.errors()[0]['msg'] if exc.errors() else str(exc)
+    return JSONResponse(status_code=422, content={"meta": make_meta("error", msg)})
+
 app.include_router(router)
 
 # Mount static directory