Add LinkedIn import, alter route, and sample CSV

Add endpoints and sample data to support importing LinkedIn CSVs and altering the queue schema.

- Add app/api/queue/routes/import_linkedin.py: POST /queue/import/linkedin reads a linkedin_sample.csv, skips lines starting with 'Notes:', and inserts rows into the queue table (sets created/updated, hidden=false, collection='prospects').
- Add app/api/queue/routes/alter.py: POST /queue/alter/add-column runs an ALTER TABLE to add a column and returns an appropriate meta response; handles 'already exists' errors.
- Add sample CSV at app/api/queue/csv/linkedin/linkedin_sample.csv for testing/import.
- Update app/api/queue/__init__.py to include the new routers (import_linkedin and alter).
- Small change in app/api/queue/routes/get.py: rename response key record_count -> queued and reorder schema/most_recent keys.

These changes make it easier to seed the queue from LinkedIn exports and modify the queue schema dynamically.

Author: goldlabelapps

app/api/queue/__init__.py

@@ -5,10 +5,16 @@
 from .routes.drop import router as drop_router
 from .routes.empty import router as empty_router
 from .routes.get import router as get_router
+
 from .routes.create import router as create_router
 
+from .routes.import_linkedin import router as import_linkedin_router
+from .routes.alter import router as alter_router
+
 router = APIRouter()
 router.include_router(drop_router)
 router.include_router(empty_router)
 router.include_router(get_router)
-router.include_router(create_router)
+router.include_router(create_router)
+router.include_router(import_linkedin_router)
+router.include_router(alter_router)

app/api/queue/csv/linkedin/linkedin_sample.csv

@@ -0,0 +1,11 @@
+First Name,Last Name,URL,Email Address,Company,Position,Connected On
+Manny,Okene,https://www.linkedin.com/in/manny-o-462924138,,Premier Group Recruitment,Associate Director,29 Mar 2026
+Mark Keers -,Pulse IT Recruitment Ltd,https://www.linkedin.com/in/markkeers,,Pulse IT Recruitment Ltd,IT Recruiter & Managing Director  - 07500 734616,26 Mar 2026
+Shaun,O'Donnell,https://www.linkedin.com/in/shaunodonnell,,Erin Associates Ltd,Director,12 Mar 2026
+Kai,Kemp,https://www.linkedin.com/in/kaikemp97,,Technify Talent,Principal Consultant,04 Mar 2026
+James,Ward,https://www.linkedin.com/in/james-ward-echopay,,EchoPay Technology Ltd,Managing Director,04 Mar 2026
+Graham,Feegan,https://www.linkedin.com/in/grahamfeegan,,Charles Jenson Recruitment,Recruitment Director,18 Feb 2026
+Nabil,Cook,https://www.linkedin.com/in/nabilcook,,OMEGA Solutions,Co-Founder & Technical Director,11 Feb 2026
+Oliver,Ward,https://www.linkedin.com/in/oliver-ward-6057a1262,,EchoPay,Customer Success Manager,11 Feb 2026
+🟢 Brad,Leaman,https://www.linkedin.com/in/bradleaman,,F5 Consultants,Principal Recruitment Consultant & Co-Founder,08 Feb 2026
+Rupal,Gupta,https://www.linkedin.com/in/rupal-gupta-a66975214,,PRACYVA ,Senior IT Recruiter (UK/EU),04 Feb 2026

app/api/queue/routes/alter.py

@@ -0,0 +1,25 @@
+from fastapi import APIRouter, HTTPException, Body
+from app.utils.make_meta import make_meta
+from app.utils.db import get_db_connection_direct
+
+router = APIRouter()
+
+@router.post("/queue/alter/add-column")
+def add_column_to_queue(
+    column_name: str = Body(..., embed=True),
+    column_type: str = Body(..., embed=True)
+) -> dict:
+    """POST /queue/alter/add-column: Add a new column to the queue table."""
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        sql = f'ALTER TABLE queue ADD COLUMN "{column_name}" {column_type};'
+        cursor.execute(sql)
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", f"Column '{column_name}' added as {column_type}")}
+    except Exception as e:
+        msg = str(e)
+        if 'already exists' in msg:
+            return {"meta": make_meta("error", f"Column '{column_name}' exists")}
+        raise HTTPException(status_code=500, detail=msg)

app/api/queue/routes/get.py

@@ -38,9 +38,9 @@ def read_queue() -> dict:
         return {
             "meta": make_meta("success", "Queue table info"),
             "data": {
-                "record_count": record_count,
-                "schema": schema,
-                "most_recent": most_recent
+                "queued": record_count,
+                "most_recent": most_recent,
+                "schema": schema
             }
         }
     except Exception as e:

app/api/queue/routes/import_linkedin.py

@@ -0,0 +1,46 @@
+import os
+import csv
+import time
+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.post("/queue/import/linkedin")
+def import_linkedin_csv() -> dict:
+    """POST /queue/import/linkedin: Import data from linkedin_sample.csv into the queue table."""
+    csv_path = os.path.join(os.path.dirname(__file__), "../csv/linkedin/linkedin_sample.csv")
+    if not os.path.exists(csv_path):
+        raise HTTPException(status_code=404, detail="linkedin_sample.csv not found")
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        with open(csv_path, newline='', encoding='utf-8') as csvfile:
+            reader = csv.DictReader(row for row in csvfile if not row.startswith('Notes:'))
+            now = int(time.time())
+            for row in reader:
+                cursor.execute(
+                    """
+                    INSERT INTO queue (first_name, last_name, url, email_address, company, position, connected_on, created, updated, hidden, collection)
+                    VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
+                    """,
+                    [
+                        row.get('First Name'),
+                        row.get('Last Name'),
+                        row.get('URL'),
+                        row.get('Email Address'),
+                        row.get('Company'),
+                        row.get('Position'),
+                        row.get('Connected On'),
+                        now,
+                        now,
+                        False,
+                        'prospects'
+                    ]
+                )
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", "LinkedIn CSV imported")}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))