Add dependency injection library

Author: AndreuCodina

.github/workflows/pull_request.yaml

@@ -23,13 +23,13 @@ jobs:
         uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
 
       - name: Install uv
-        uses: astral-sh/setup-uv@ed21f2f24f8dd64503750218de024bcf64c7250a # v7.1.5
+        uses: astral-sh/setup-uv@681c641aba71e4a1c380be3ab5e12ad51f415867 # v7.1.6
         with:
           version-file: pyproject.toml
           resolution-strategy: lowest
 
       - name: Install Python
-        uses: actions/setup-python@83679a892e2d95755f2dac6acb0bfd1e9ac5d548 # v6.0.1
+        uses: actions/setup-python@83679a892e2d95755f2dac6acb0bfd1e9ac5d548 # v6.1.0
         with:
           python-version-file: .python-version
 

notebooks/notebook.ipynb

@@ -5,7 +5,29 @@
    "execution_count": null,
    "metadata": {},
    "outputs": [],
-   "source": []
+   "source": [
+    "from python_template.api.main import configure_services\n",
+    "from python_template.api.services.email_service import EmailService"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "service_provider = await configure_services().build_service_provider().__aenter__()"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "email_service = await service_provider.get_required_service(EmailService)\n",
+    "await email_service.send_email()"
+   ]
   }
  ],
  "metadata": {
@@ -24,7 +46,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.13.7"
+   "version": "3.14.0"
   }
  },
  "nbformat": 4,

pyproject.toml

@@ -3,10 +3,11 @@ name = "python-template"
 version = "0.1.0"
 requires-python = ">=3.14"
 dependencies = [
-    "aiohttp>=3.13.2",
+    "aiohttp>=3.13.3",
+    "aspy-dependency-injection>=0.4.1",
     "azure-cosmos>=4.14.3",
     "azure-monitor-opentelemetry>=1.8.3",
-    "fastapi[standard-no-fastapi-cloud-cli]>=0.127.0",
+    "fastapi[standard-no-fastapi-cloud-cli]>=0.128.0",
     "pydantic>=2.12.5",
     "pydantic-settings[azure-key-vault]>=2.12.0",
 ]
@@ -19,7 +20,7 @@ dev = [
     "pytest-cov>=7.0.0",
     "pytest-mock>=3.15.1",
     "ruff>=0.14.10",
-    "ty>=0.0.5",
+    "ty>=0.0.8",
 ]
 
 [build-system]
@@ -29,6 +30,9 @@ build-backend = "uv_build"
 [tool.uv]
 required-version = ">=0.9.16,<0.10.0"
 
+[tool.ty.terminal]
+error-on-warning = true
+
 [tool.ruff.lint]
 select = ["ALL"]
 ignore = [

scripts/script.py

@@ -1,8 +1,13 @@
 import asyncio
 
+from python_template.api.main import configure_services
+from python_template.api.services.email_service import EmailService
+
 
 async def main() -> None:
-    pass
+    async with configure_services().build_service_provider() as service_provider:
+        email_service = await service_provider.get_required_service(EmailService)
+        await email_service.send_email()
 
 
 if __name__ == "__main__":

src/python_template/api/dependency_container.py

@@ -1,27 +1,108 @@
+import logging
 from collections.abc import AsyncGenerator
 from contextlib import asynccontextmanager
+from logging import Logger
 
+from aspy_dependency_injection.service_collection import ServiceCollection
+from azure.cosmos import PartitionKey
+from azure.cosmos.aio import CosmosClient, DatabaseProxy
+from azure.identity import DefaultAzureCredential
+from azure.monitor.opentelemetry import (
+    configure_azure_monitor,  # pyright: ignore[reportUnknownVariableType]
+)
 from fastapi import FastAPI
 
-from python_template.api.dependency_container import DependencyContainer
+from python_template.api.application_settings import ApplicationSettings
+from python_template.api.services.email_service import EmailService
+from python_template.api.workflows.products.discontinue_product.discontinue_product_workflow import (
+    DiscontinueProductWorkflow,
+)
 from python_template.api.workflows.products.product_router import product_router
+from python_template.api.workflows.products.publish_product.publish_product_workflow import (
+    PublishProductWorkflow,
+)
 from python_template.common.application_environment import ApplicationEnvironment
+from python_template.domain.entities.product import Product
 
 
-@asynccontextmanager
-async def lifespan(_: FastAPI) -> AsyncGenerator[None]:
-    await DependencyContainer.initialize()
-    yield
-    await DependencyContainer.uninitialize()
+def inject_application_settings() -> ApplicationSettings:
+    return ApplicationSettings()  # ty:ignore[missing-argument]
 
 
-openapi_url = (
-    "/openapi.json"
-    if ApplicationEnvironment.get_current() != ApplicationEnvironment.PRODUCTION
-    else None
-)
-app = FastAPI(
-    openapi_url=openapi_url,
-    lifespan=lifespan,
-)
-app.include_router(product_router)
+def inject_logging() -> Logger:
+    return logging.getLogger(__name__)
+
+
+def inject_cosmos_client(
+    application_settings: ApplicationSettings,
+) -> CosmosClient:
+    return CosmosClient(
+        url=application_settings.cosmos_db_no_sql_url,
+        credential=application_settings.cosmos_db_no_sql_key.get_secret_value(),
+    )
+
+
+def inject_cosmos_database(
+    application_settings: ApplicationSettings, cosmos_client: CosmosClient
+) -> DatabaseProxy:
+    return cosmos_client.get_database_client(
+        application_settings.cosmos_db_no_sql_database
+    )
+
+
+def configure_services() -> ServiceCollection:
+    services = ServiceCollection()
+    services.add_singleton(inject_application_settings)
+    services.add_singleton(inject_logging)
+    services.add_singleton(inject_cosmos_client)
+    services.add_transient(inject_cosmos_database)
+    services.add_transient(EmailService)
+    services.add_transient(PublishProductWorkflow)
+    services.add_transient(DiscontinueProductWorkflow)
+    return services
+
+
+def create_app() -> FastAPI:
+    @asynccontextmanager
+    async def lifespan(_: FastAPI) -> AsyncGenerator[None]:
+        async with configure_services().build_service_provider() as service_provider:
+            application_settings = await service_provider.get_required_service(
+                ApplicationSettings
+            )
+            logging.basicConfig(level=application_settings.logging_level)
+
+            if ApplicationEnvironment.get_current() != ApplicationEnvironment.LOCAL:
+                configure_azure_monitor(
+                    connection_string=application_settings.application_insights_connection_string,
+                    credential=DefaultAzureCredential(),
+                    enable_live_metrics=True,
+                )
+
+            if ApplicationEnvironment.get_current() == ApplicationEnvironment.LOCAL:
+                cosmos_client = await service_provider.get_required_service(
+                    CosmosClient
+                )
+                await cosmos_client.create_database_if_not_exists(
+                    application_settings.cosmos_db_no_sql_database
+                )
+                cosmos_database = await service_provider.get_required_service(
+                    DatabaseProxy
+                )
+                await cosmos_database.create_container_if_not_exists(
+                    id=Product.__name__, partition_key=PartitionKey("/id")
+                )
+        yield
+
+    openapi_url = (
+        "/openapi.json"
+        if ApplicationEnvironment.get_current() != ApplicationEnvironment.PRODUCTION
+        else None
+    )
+    app = FastAPI(openapi_url=openapi_url, lifespan=lifespan)
+    app.include_router(product_router)
+    return app
+
+
+app = create_app()
+services = configure_services()
+services.configure_fastapi(app)

src/python_template/api/main.py

@@ -0,0 +1,3 @@
+class EmailService:
+    async def send_email(self) -> None:
+        pass

src/python_template/api/services/email_service.py

@@ -1,15 +1,23 @@
+from typing import Annotated
+
+from aspy_dependency_injection.annotations import Inject
 from fastapi import APIRouter
 
-from python_template.api.dependency_container import DependencyContainer
 from python_template.api.workflows.products.discontinue_product.discontinue_product_request import (
     DiscontinueProductRequest,
 )
+from python_template.api.workflows.products.discontinue_product.discontinue_product_workflow import (
+    DiscontinueProductWorkflow,
+)
 from python_template.api.workflows.products.publish_product.publish_product_request import (
     PublishProductRequest,
 )
 from python_template.api.workflows.products.publish_product.publish_product_response import (
     PublishProductResponse,
 )
+from python_template.api.workflows.products.publish_product.publish_product_workflow import (
+    PublishProductWorkflow,
+)
 
 product_router = APIRouter(
     prefix="/api/v1/products",
@@ -18,12 +26,16 @@
 
 
 @product_router.post("")
-async def publish_product(request: PublishProductRequest) -> PublishProductResponse:
-    workflow = await DependencyContainer.get_publish_product_workflow()
+async def publish_product(
+    request: PublishProductRequest,
+    workflow: Annotated[PublishProductWorkflow, Inject()],
+) -> PublishProductResponse:
     return await workflow.execute(request)
 
 
 @product_router.post("/discontinue")
-async def discontinue_product(request: DiscontinueProductRequest) -> None:
-    workflow = await DependencyContainer.get_discontinue_product_workflow()
+async def discontinue_product(
+    request: DiscontinueProductRequest,
+    workflow: Annotated[DiscontinueProductWorkflow, Inject()],
+) -> None:
     await workflow.execute(request)