Rename reset to seed and seed products from CSV

Rename products/reset.py to products/seed.py and update API to seed the product table from an in-package CSV. Change endpoint from POST /products/reset to GET /products/seed, move CSV to app/api/products/start_data.csv and resolve its absolute path. Map CSV 'desc' field to DB 'title' on insert, update SQL to use title, and guard against empty query results (handle cur.description None). Update imports and router includes to use products_router/seed_router names. Remove legacy product-list root logic and clean up tests by deleting obsolete echo tests.

Author: goldlabelapps

app/api/products/__init__.py

@@ -1,2 +1,2 @@
-from .products import router
-from .reset import router as reset_router
+from .products import router as products_router
+from .seed import router as seed_router

app/api/products/reset.py app/api/products/seed.pyapp/api/products/reset.py renamed to app/api/products/seed.py

@@ -1,14 +1,16 @@
-import os
+from app import __version__
+import os, time
 import csv
 from fastapi import APIRouter, status
 from app.api.db import get_db_connection
 
 router = APIRouter()
 
-CSV_PATH = os.path.join(os.path.dirname(os.path.dirname(os.path.dirname(__file__))), 'tests', 'csv', 'small.csv')
+CSV_PATH = os.path.join(os.path.dirname(__file__), 'start_data.csv')
+CSV_PATH = os.path.abspath(CSV_PATH)
 
-@router.post("/products/reset", status_code=status.HTTP_200_OK)
-def reset_products() -> dict:
+@router.get("/products/seed", status_code=status.HTTP_200_OK)
+def seed_products() -> dict:
     """Delete and recreate the product table, then seed with CSV data."""
     conn_gen = get_db_connection()
     conn = next(conn_gen)
@@ -20,7 +22,7 @@ def reset_products() -> dict:
             id SERIAL PRIMARY KEY,
             Params TEXT,
             item INTEGER,
-            desc TEXT,
+            title TEXT,
             UOS TEXT,
             Pack_Description TEXT,
             Hierarchy1 TEXT,
@@ -45,65 +47,35 @@ def reset_products() -> dict:
         reader = csv.DictReader(csvfile)
         rows = [row for row in reader]
         for row in rows:
+            # Map 'desc' from CSV to 'title' for DB
+            row['title'] = row.pop('desc')
             cur.execute(
                 """
                 INSERT INTO product (
-                    Params, item, desc, UOS, Pack_Description, Hierarchy1, Hierarchy2, Hierarchy3, UOP,
+                    Params, item, title, UOS, Pack_Description, Hierarchy1, Hierarchy2, Hierarchy3, UOP,
                     sSell1, sSell2, sSell3, sSell4, sSell5, pack1, pack2, pack3, pack4, pack5, EAN
                 ) VALUES (
-                    %(Params)s, %(item)s, %(desc)s, %(UOS)s, %(Pack_Description)s, %(Hierarchy1)s, %(Hierarchy2)s, %(Hierarchy3)s, %(UOP)s,
+                    %(Params)s, %(item)s, %(title)s, %(UOS)s, %(Pack_Description)s, %(Hierarchy1)s, %(Hierarchy2)s, %(Hierarchy3)s, %(UOP)s,
                     %(sSell1)s, %(sSell2)s, %(sSell3)s, %(sSell4)s, %(sSell5)s, %(pack1)s, %(pack2)s, %(pack3)s, %(pack4)s, %(pack5)s, %(EAN)s
                 )
                 """,
                 row
             )
     conn.commit()
     cur.execute('SELECT * FROM product;')
-    products = [dict(zip([desc[0] for desc in cur.description], row)) for row in cur.fetchall()]
+    if cur.description is None:
+        products = []
+    else:
+        columns = [desc[0] for desc in cur.description]
+        products = [dict(zip(columns, row)) for row in cur.fetchall()]
     cur.close()
     conn.close()
-    return {"message": "Product table reset and seeded from CSV.", "data": products}
-import os, time
-import psycopg2
-from dotenv import load_dotenv
-from app import __version__
-
-router = APIRouter()
 
-@router.get("/products")
-def root() -> dict:
-    """Return a structured welcome message for the API root, including product data."""
-    load_dotenv()
-    conn = psycopg2.connect(
-        host=os.getenv('DB_HOST'),
-        port=os.getenv('DB_PORT', '5432'),
-        dbname=os.getenv('DB_NAME'),
-        user=os.getenv('DB_USER'),
-        password=os.getenv('DB_PASSWORD')
-    )
-    cur = conn.cursor()
-    cur.execute('SELECT id, name, description, price, in_stock, created_at FROM product;')
-    products = [
-        {
-            "id": row[0],
-            "name": row[1],
-            "description": row[2],
-            "price": float(row[3]),
-            "in_stock": row[4],
-            "created_at": row[5].isoformat() if row[5] else None
-        }
-        for row in cur.fetchall()
-    ]
-    cur.close()
-    conn.close()
-
-    load_dotenv()
     base_url = os.getenv("BASE_URL", "http://localhost:8000")
-
     epoch = int(time.time() * 1000)
     meta = {
         "severity": "success",
-        "title": "Product List",
+        "title": "Product table seeded",
         "version": __version__,
         "base_url": base_url,
         "time": epoch,

tests/csv/small.csv app/api/products/start_data.csvtests/csv/small.csv renamed to app/api/products/start_data.csv

@@ -13,9 +13,9 @@
 from app.api.root import router as root_router
 from app.api.health import router as health_router
 from app.api.products.products import router as products_router
-from app.api.products.reset import router as reset_router
+from app.api.products.seed import router as seed_router
 
 router.include_router(root_router)
 router.include_router(health_router)
 router.include_router(products_router)
-router.include_router(reset_router)
+router.include_router(seed_router)

app/api/routes.py

@@ -25,22 +25,3 @@ def test_health_returns_ok() -> None:
     assert response.status_code == 200
     assert response.json() == {"status": "ok"}
 
-
-def test_echo_returns_message() -> None:
-    """POST /echo should return the provided message."""
-    response = client.post("/echo", json={"message": "hello"})
-    assert response.status_code == 200
-    assert response.json() == {"echo": "hello"}
-
-
-def test_echo_empty_string() -> None:
-    """POST /echo with an empty string should echo back an empty string."""
-    response = client.post("/echo", json={"message": ""})
-    assert response.status_code == 200
-    assert response.json() == {"echo": ""}
-
-
-def test_echo_missing_body_returns_422() -> None:
-    """POST /echo without a body should return 422 Unprocessable Entity."""
-    response = client.post("/echo", json={})
-    assert response.status_code == 422