feat(data-models): init data models for e2e user flow handling

pyproject.toml

@@ -9,6 +9,7 @@ dependencies = [
     "asyncpg>=0.31.0",
     "authlib>=1.6.5",
     "cryptography>=46.0.3",
+    "email-validator>=2.2.0",
     "fastapi>=0.124.0",
     "pydantic-settings>=2.12.0",
     "pydantic>=2.12.5",

src/app/chore/lifespan.py

@@ -9,6 +9,7 @@
 
 from fastapi import FastAPI
 
+import app.db_models  # noqa: F401 — registers all ORM models with Base.metadata
 from app.shared.database.base import Base
 from app.shared.database.engine import close_database, get_engine, init_database
 

src/app/db_models.py

@@ -0,0 +1,37 @@
+"""
+Database Model Registry
+
+Imports ALL SQLAlchemy ORM models so that Base.metadata knows about every
+table. This module must be imported before calling Base.metadata.create_all().
+
+Why this file exists:
+    SQLAlchemy's Base.metadata only knows about a table after its ORM class
+    has been imported. If a model is never imported, its table is never created.
+    Centralising all imports here means you only need to import this one module
+    to guarantee that create_all() sees the full schema.
+
+Usage:
+    import app.db_models  # noqa: F401  — side-effect import
+    async with engine.begin() as conn:
+        await conn.run_sync(Base.metadata.create_all)
+"""
+
+# Item store (partner service)
+from app.services.crud_item_store.models.item_db_models import ItemDB  # noqa: F401
+
+# Customers
+from app.services.customers.models.customers_db_models import AddressDB, CustomerDB  # noqa: F401
+
+# Inventory
+
+# Orders
+from app.services.orders.models.orders_db_models import OrderDB, OrderItemDB  # noqa: F401
+
+# Payments
+from app.services.payments.models.payments_db_models import PaymentDB  # noqa: F401
+
+# Webhooks
+from app.services.webhooks.models.webhooks_db_models import WebhookEventDB  # noqa: F401
+
+# Shipments
+from app.services.shipments.models.shipments_db_models import ShipmentDB  # noqa: F401

src/app/services/crud_item_store/crud_item_store.py

@@ -19,7 +19,7 @@
 from fastapi import APIRouter
 
 # Import routers
-from .routers import items
+from .routers import items_router
 
 # Create the main router for this service
 router = APIRouter(
@@ -28,6 +28,6 @@
 )
 
 # Include sub-routers
-router.include_router(items.router)
+router.include_router(items_router.router)
 
 __all__ = ["router"]

src/app/services/crud_item_store/functions/__init__.py

@@ -4,8 +4,8 @@
 Business logic and transformation functions for items.
 """
 
-from .transformations import db_to_response, prepare_item_update_data
-from .validation import check_duplicate_field, validate_update_conflicts
+from .item_transformations import db_to_response, prepare_item_update_data
+from .item_validation import check_duplicate_field, validate_update_conflicts
 
 __all__ = [
     "db_to_response",

src/app/services/crud_item_store/functions/validation.py → src/app/services/crud_item_store/functions/item_validation.py

@@ -8,9 +8,12 @@
 from uuid import UUID
 
 from app.shared.exceptions import duplicate_entry
+from app.shared.logger import get_logger
 from ..models import ItemDB
 from ..services import ItemRepository
 
+logger = get_logger(__name__)
+
 
 async def check_duplicate_field(
     repo: ItemRepository,
@@ -44,6 +47,13 @@ async def check_duplicate_field(
         >>> # Can check any field on the model
         >>> await check_duplicate_field(repo, "name", "Test Product")
     """
+    logger.debug(
+        "Checking for duplicate field value",
+        extra={
+            "field_name": field_name,
+            "exclude_uuid": str(exclude_uuid) if exclude_uuid else None,
+        },
+    )
     # Use the repository's generic field_exists method
     # This will raise ValueError if field doesn't exist on the model
     exists = await repo.field_exists(field_name, field_value, exclude_uuid=exclude_uuid)

src/app/services/crud_item_store/models/__init__.py

@@ -5,8 +5,8 @@
 Response models are in the responses/ directory.
 """
 
-from .database import ItemDB
-from .item import (
+from .item_db_models import ItemDB
+from .item_models import (
     DimensionUnit,
     DimensionsModel,
     IdentifiersModel,

src/app/services/crud_item_store/responses/__init__.py

@@ -5,7 +5,7 @@
 Combines shared response structures with feature-specific models.
 """
 
-from .items import ItemResponse
+from .items_response_models import ItemResponse
 
 __all__ = [
     "ItemResponse",