Move queue import handlers to import_ package

Reorganize import-related endpoints into a dedicated import_ package. Added package markers (__init__.py) and a placeholder README, moved the existing linkedin importer into app/api/queue/import_ and updated the queue router import paths accordingly. Also added a new apollo.py stub endpoint (/queue/import/apollo) that provides a template for CSV import (includes TODOs for CSV parsing and DB insertion). No functional import logic implemented yet; this change is primarily structural to group import handlers.

Author: goldlabelapps

app/api/queue/__init__.py

@@ -9,8 +9,7 @@
 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
-
+from .import_ import linkedin as linkedin_import_router
 from .routes.alter import router as alter_router
 from .routes.rename_column import router as rename_router
 
@@ -20,6 +19,6 @@
 router.include_router(get_router)
 router.include_router(create_router)
 router.include_router(delete_router)
-router.include_router(import_linkedin_router)
+router.include_router(linkedin_import_router.router)
 router.include_router(alter_router)
 router.include_router(rename_router)

app/api/queue/import/__init__.py

@@ -0,0 +1 @@
+# Makes this directory a Python package

app/api/queue/import_/README.md

@@ -0,0 +1 @@
+# Placeholder for migration

app/api/queue/import_/__init__.py

@@ -0,0 +1 @@
+# Makes this directory a Python package

app/api/queue/import_/apollo.py

@@ -0,0 +1,29 @@
+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/apollo")
+def import_apollo_csv() -> dict:
+    """POST /queue/import/apollo: Import data from apollo.csv into the queue table (template)."""
+    csv_path = os.path.join(os.path.dirname(__file__), "../csv/apollo/seed.csv")
+    if not os.path.exists(csv_path):
+        raise HTTPException(status_code=404, detail="seed.csv not found")
+    try:
+        conn = get_db_connection_direct()
+        cursor = conn.cursor()
+        # TODO: Implement CSV parsing and DB insertion logic for Apollo format
+        # Example placeholder for batch import logic:
+        # with open(csv_path, newline='', encoding='utf-8') as csvfile:
+        #     reader = csv.DictReader(csvfile)
+        #     for row in reader:
+        #         pass  # Process each row
+        conn.commit()
+        conn.close()
+        return {"meta": make_meta("success", "Apollo CSV import template executed"), "imported": 0}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))