rework api configuration

stac_api/api/__init__.py

@@ -1,4 +1,2 @@
 """api module"""
-from .app import create_app
-from .routers import create_core_router, create_tiles_router, create_transactions_router
 from .routes import create_endpoint_from_model, create_endpoint_with_depends

stac_api/api/app.py

@@ -1,108 +1,189 @@
 """fastapi app creation"""
+from dataclasses import dataclass, field
+from typing import Dict, List, Optional, Type
 
 from fastapi import APIRouter, FastAPI
-from sqlalchemy import create_engine
-from sqlalchemy.orm import sessionmaker
-from starlette.requests import Request
-
-from stac_api.api.models import ItemUri
-from stac_api.api.routers import (
-    create_core_router,
-    create_tiles_router,
-    create_transactions_router,
+from fastapi.openapi.utils import get_openapi
+
+from stac_api.api.extensions import FieldsExtension
+from stac_api.api.extensions.extension import ApiExtension
+from stac_api.api.models import (
+    CollectionUri,
+    EmptyRequest,
+    ItemCollectionUri,
+    ItemUri,
+    SearchGetRequest,
+    _create_request_model,
 )
-from stac_api.api.routes import create_endpoint_with_depends
-from stac_api.clients.postgres.core import CoreCrudClient
-from stac_api.clients.postgres.tokens import PaginationTokenClient
-from stac_api.clients.postgres.transactions import TransactionsClient
-from stac_api.clients.tiles.ogc import TilesClient
-from stac_api.config import AddOns, ApiExtensions, ApiSettings, inject_settings
+from stac_api.api.routes import create_endpoint_from_model, create_endpoint_with_depends
+from stac_api.clients.base import BaseCoreClient
+from stac_api.config import ApiSettings, inject_settings
 from stac_api.errors import DEFAULT_STATUS_CODES, add_exception_handlers
-from stac_api.models.ogc import TileSetResource
-from stac_api.openapi import config_openapi
-from stac_api.utils.dependencies import READER, WRITER
+from stac_api.models import schemas
+from stac_pydantic import ItemCollection
+from stac_pydantic.api import ConformanceClasses, LandingPage
 
 
-def create_app(settings: ApiSettings) -> FastAPI:
-    """Create a FastAPI app"""
-    paging_client = PaginationTokenClient()
-    core_client = CoreCrudClient(pagination_client=paging_client)
+@dataclass
+class StacApi:
+    """StacApi"""
 
-    app = FastAPI()
-    inject_settings(settings)
-
-    app.debug = settings.debug
-    app.include_router(
-        create_core_router(core_client, settings), tags=["Core Endpoints"]
+    settings: ApiSettings
+    client: BaseCoreClient
+    extensions: Optional[List[ApiExtension]] = field(  # type:ignore
+        default_factory=list
     )
-    add_exception_handlers(app, DEFAULT_STATUS_CODES)
-
-    if settings.api_extension_is_enabled(ApiExtensions.transaction):
-        transaction_client = TransactionsClient()
-        app.include_router(
-            create_transactions_router(transaction_client, settings),
-            tags=["Transaction Extension"],
+    exceptions: Dict[Type[Exception], int] = field(
+        default_factory=lambda: DEFAULT_STATUS_CODES
+    )
+    app: FastAPI = FastAPI()
+
+    def get_extension(self, extension: Type[ApiExtension]) -> Optional[ApiExtension]:
+        """check if an api extension is enabled"""
+        for ext in self.extensions:
+            if isinstance(ext, extension):
+                return ext
+        return None
+
+    def register_core(self):
+        """register stac core endpoints"""
+        search_request_model = _create_request_model(schemas.STACSearch)
+        fields_ext = self.get_extension(FieldsExtension)
+        router = APIRouter()
+        router.add_api_route(
+            name="Landing Page",
+            path="/",
+            response_model=LandingPage,
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(
+                self.client.landing_page, EmptyRequest
+            ),
         )
-
-    if settings.add_on_is_enabled(AddOns.tiles):
-        tiles_client = TilesClient()
-        app.add_api_route(
-            name="Get OGC Tiles Resource",
-            path="/collections/{collectionId}/items/{itemId}/tiles",
-            response_model=TileSetResource,
+        router.add_api_route(
+            name="Conformance Classes",
+            path="/conformance",
+            response_model=ConformanceClasses,
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(
+                self.client.conformance, EmptyRequest
+            ),
+        )
+        router.add_api_route(
+            name="Get Item",
+            path="/collections/{collectionId}/items/{itemId}",
+            response_model=schemas.Item,
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(self.client.get_item, ItemUri),
+        )
+        router.add_api_route(
+            name="Search",
+            path="/search",
+            response_model=ItemCollection if not fields_ext else None,
+            response_model_exclude_unset=True,
             response_model_exclude_none=True,
+            methods=["POST"],
+            endpoint=create_endpoint_from_model(
+                self.client.post_search, search_request_model
+            ),
+        ),
+        router.add_api_route(
+            name="Search",
+            path="/search",
+            response_model=ItemCollection if not fields_ext else None,
             response_model_exclude_unset=True,
+            response_model_exclude_none=True,
             methods=["GET"],
-            endpoint=create_endpoint_with_depends(tiles_client.get_item_tiles, ItemUri),
-            tags=["OGC Tiles"],
+            endpoint=create_endpoint_with_depends(
+                self.client.get_search, SearchGetRequest
+            ),
         )
-        app.include_router(create_tiles_router(), prefix="/titiler", tags=["Titiler"])
-
-    config_openapi(app, settings)
-
-    @app.on_event("startup")
-    async def on_startup():
-        """Create database engines and sessions on startup"""
-        app.state.ENGINE_READER = create_engine(
-            settings.reader_connection_string, echo=settings.debug
+        router.add_api_route(
+            name="Get Collections",
+            path="/collections",
+            response_model=List[schemas.Collection],
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(
+                self.client.all_collections, EmptyRequest
+            ),
         )
-        app.state.ENGINE_WRITER = create_engine(
-            settings.writer_connection_string, echo=settings.debug
+        router.add_api_route(
+            name="Get Collection",
+            path="/collections/{collectionId}",
+            response_model=schemas.Collection,
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(
+                self.client.get_collection, CollectionUri
+            ),
         )
-        app.state.DB_READER = sessionmaker(
-            autocommit=False, autoflush=False, bind=app.state.ENGINE_READER
+        router.add_api_route(
+            name="Get ItemCollection",
+            path="/collections/{collectionId}/items",
+            response_model=ItemCollection,
+            response_model_exclude_unset=True,
+            response_model_exclude_none=True,
+            methods=["GET"],
+            endpoint=create_endpoint_with_depends(
+                self.client.item_collection, ItemCollectionUri
+            ),
         )
-        app.state.DB_WRITER = sessionmaker(
-            autocommit=False, autoflush=False, bind=app.state.ENGINE_WRITER
+        self.app.include_router(router)
+
+    def customize_openapi(self):
+        """customize openapi schema"""
+        if self.app.openapi_schema:
+            return self.app.openapi_schema
+
+        # TODO: parametrize
+        openapi_schema = get_openapi(
+            title="Arturo STAC API", version="0.1", routes=self.app.routes
         )
 
-    @app.on_event("shutdown")
-    async def on_shutdown():
-        """Dispose of database engines and sessions on app shutdown"""
-        app.state.ENGINE_READER.dispose()
-        app.state.ENGINE_WRITER.dispose()
-
-    @app.middleware("http")
-    async def create_db_connection(request: Request, call_next):
-        """Create a new database connection for each request"""
-        if "titiler" in str(request.url):
-            return await call_next(request)
-        reader = request.app.state.DB_READER()
-        writer = request.app.state.DB_WRITER()
-        READER.set(reader)
-        WRITER.set(writer)
-        resp = await call_next(request)
-        reader.close()
-        writer.close()
-        return resp
-
-    mgmt_router = APIRouter()
-
-    @mgmt_router.get("/_mgmt/ping")
-    async def ping():
-        """Liveliness/readiness probe"""
-        return {"message": "PONG"}
-
-    app.include_router(mgmt_router, tags=["Liveliness/Readiness"])
-
-    return app
+        self.app.openapi_schema = openapi_schema
+        return self.app.openapi_schema
+
+    def add_health_check(self):
+        """add a health check"""
+        mgmt_router = APIRouter()
+
+        @mgmt_router.get("/_mgmt/ping")
+        async def ping():
+            """Liveliness/readiness probe"""
+            return {"message": "PONG"}
+
+        self.app.include_router(mgmt_router, tags=["Liveliness/Readiness"])
+
+    def __post_init__(self):
+        """post-init hook"""
+        # inject settings
+        self.app.debug = self.settings.debug
+        self.client.extensions = self.extensions
+
+        fields_ext = self.get_extension(FieldsExtension)
+        if fields_ext:
+            self.settings.default_includes = fields_ext.default_includes
+
+        inject_settings(self.settings)
+
+        self.register_core()
+        # register extensions
+        for ext in self.extensions:
+            ext.register(self.app)
+
+        # add health check
+        self.add_health_check()
+
+        # register exception handlers
+        add_exception_handlers(self.app, status_codes=self.exceptions)
+
+        # customize openapi
+        self.app.openapi = self.customize_openapi

stac_api/api/extensions/__init__.py

@@ -0,0 +1,9 @@
+"""stac_api.api.extensions"""
+from .context import ContextExtension  # noqa
+
+# from .extension import ApiExtension  # noqa
+from .fields import FieldsExtension  # noqa
+from .query import QueryExtension  # noqa
+from .sort import SortExtension  # noqa
+from .tiles import TilesExtension  # noqa
+from .transaction import TransactionExtension  # noqa

stac_api/api/extensions/context.py

@@ -0,0 +1,18 @@
+"""context extension"""
+from dataclasses import dataclass
+
+from fastapi import FastAPI
+
+from stac_api.api.extensions.extension import ApiExtension
+
+
+@dataclass
+class ContextExtension(ApiExtension):
+    """
+    stac-api context extension
+    (https://github.com/radiantearth/stac-api-spec/tree/master/extensions/context)
+    """
+
+    def register(self, app: FastAPI) -> None:
+        """register extension with the application"""
+        pass

stac_api/api/extensions/extension.py

@@ -0,0 +1,15 @@
+"""base api extension"""
+import abc
+from dataclasses import dataclass
+
+from fastapi import FastAPI
+
+
+@dataclass  # type:ignore
+class ApiExtension(abc.ABC):
+    """orchestration for API extensions"""
+
+    @abc.abstractmethod
+    def register(self, app: FastAPI) -> None:
+        """register extension with the application"""
+        ...

stac_api/api/extensions/fields.py

@@ -0,0 +1,31 @@
+"""fields extension"""
+from dataclasses import dataclass, field
+from typing import Set
+
+from fastapi import FastAPI
+
+from stac_api.api.extensions.extension import ApiExtension
+
+
+@dataclass
+class FieldsExtension(ApiExtension):
+    """
+    stac-api fields extension
+    (https://github.com/radiantearth/stac-api-spec/tree/master/extensions/fields)
+    """
+
+    default_includes: Set[str] = field(
+        default_factory=lambda: {
+            "id",
+            "type",
+            "geometry",
+            "bbox",
+            "links",
+            "assets",
+            "properties.datetime",
+        }
+    )
+
+    def register(self, app: FastAPI) -> None:
+        """register extension with the application"""
+        pass

stac_api/api/extensions/query.py

@@ -0,0 +1,18 @@
+"""query extension"""
+from dataclasses import dataclass
+
+from fastapi import FastAPI
+
+from stac_api.api.extensions.extension import ApiExtension
+
+
+@dataclass
+class QueryExtension(ApiExtension):
+    """
+    stac-api query extension
+    (https://github.com/radiantearth/stac-api-spec/tree/master/extensions/query)
+    """
+
+    def register(self, app: FastAPI) -> None:
+        """register extension with the application"""
+        pass

stac_api/api/extensions/sort.py

@@ -0,0 +1,18 @@
+"""sort extension"""
+from dataclasses import dataclass
+
+from fastapi import FastAPI
+
+from stac_api.api.extensions.extension import ApiExtension
+
+
+@dataclass
+class SortExtension(ApiExtension):
+    """
+    stac-api query extension
+    (https://github.com/radiantearth/stac-api-spec/tree/master/extensions/sort)
+    """
+
+    def register(self, app: FastAPI) -> None:
+        """register extension with the application"""
+        pass