Add queue API routes and sample data

Introduce a Queue API surface: add individual route modules (create, drop, empty, get) and register them via app/api/queue/__init__.py (APIRouter includes). Add supporting artifacts: a sample linkedin.csv and SQL schema (create_queue_table.sql). Also update queue implementation and top-level app/api/routes.py to wire the new queue endpoints.

Author: goldlabelapps

app/api/queue/__init__.py

@@ -1,3 +1,14 @@
 """Queue Routes"""
 
-from .queue import router as queue_router
+
+from fastapi import APIRouter
+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
+
+router = APIRouter()
+router.include_router(drop_router)
+router.include_router(empty_router)
+router.include_router(get_router)
+router.include_router(create_router)

app/api/queue/linkedin.csv

@@ -1,15 +1,8 @@
-import os
-from fastapi import APIRouter, HTTPException, Query, Request, Depends
-from app.utils.make_meta import make_meta
-from app.utils.db import get_db_connection_direct
-from app.utils.api_key_auth import get_api_key
 
-router = APIRouter()
 
-
-@router.get("/queue")
-def read_queue() -> dict:
-    """GET /queue: """
-    return {"meta": make_meta("success", "Hello from queue"), "data": {"do": "it"}}
+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
 
 

app/api/queue/queue.py

@@ -0,0 +1,25 @@
+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.post("/queue/create")
+def create_queue_table() -> dict:
+    """POST /queue/create: Create the queue table from SQL script."""
+    try:
+        sql_path = os.path.join(os.path.dirname(__file__), "../sql/create_queue_table.sql")
+        with open(sql_path, "r") as f:
+            sql = f.read()
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        # Split SQL script into individual statements for PostgreSQL
+        statements = [s.strip() for s in sql.split(';') if s.strip()]
+        for statement in statements:
+            cursor.execute(statement)
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", "Queue table created")}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))

app/api/queue/routes/create.py

@@ -0,0 +1,19 @@
+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.post("/queue/drop")
+def drop_queue_table() -> dict:
+    """POST /queue/drop: Drop the queue table."""
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        cursor.execute("DROP TABLE IF EXISTS queue;")
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", "Queue table dropped")}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))

app/api/queue/routes/drop.py

@@ -0,0 +1,19 @@
+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.post("/queue/empty")
+def empty_queue_table() -> dict:
+    """POST /queue/empty: Remove all records from the queue table."""
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        cursor.execute("DELETE FROM queue;")
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", "Queue table emptied")}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))

app/api/queue/routes/empty.py

@@ -0,0 +1,47 @@
+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.get("/queue")
+def read_queue() -> dict:
+    """GET /queue: Return queue table info, schema, and most recent record."""
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+
+        # 1. Count records
+        cursor.execute("SELECT COUNT(*) FROM queue;")
+        count_row = cursor.fetchone()
+        record_count = count_row[0] if count_row else 0
+
+        # 2. Get table schema
+        cursor.execute("SELECT column_name, data_type, is_nullable FROM information_schema.columns WHERE table_name = 'queue';")
+        schema = [
+            {
+                "name": row[0],
+                "type": row[1]
+            }
+            for row in cursor.fetchall()
+        ]
+
+        # 3. Get most recently updated record
+        cursor.execute("SELECT * FROM queue ORDER BY updated DESC LIMIT 1;")
+        columns = [desc[0] for desc in cursor.description] if cursor.description else []
+        row = cursor.fetchone()
+        most_recent = dict(zip(columns, row)) if row and columns else None
+
+        conn.close()
+
+        return {
+            "meta": make_meta("success", "Queue table info"),
+            "data": {
+                "record_count": record_count,
+                "schema": schema,
+                "most_recent": most_recent
+            }
+        }
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))

app/api/queue/routes/get.py

@@ -0,0 +1,14 @@
+CREATE TABLE IF NOT EXISTS queue (
+    id SERIAL PRIMARY KEY,
+    first_name TEXT,
+    last_name TEXT,
+    url TEXT,
+    email_address TEXT,
+    company TEXT,
+    position TEXT,
+    connected_on TEXT,
+    created INTEGER,
+    updated INTEGER,
+    hidden BOOLEAN DEFAULT FALSE,
+    collection TEXT
+);

app/api/queue/sql/create_queue_table.sql

@@ -13,7 +13,7 @@
 from app.api.prompt.drop import router as drop_router
 from app.api.prospects.prospects import router as prospects_router
 from app.api.orders.orders import router as orders_router
-from app.api.queue.queue import router as queue_router
+from app.api.queue import router as queue_router
 
 router.include_router(root_router)
 router.include_router(resend_router)