97 lines
2.7 KiB
Python
97 lines
2.7 KiB
Python
import logging
|
|
from fastapi import FastAPI
|
|
from fastapi.openapi.utils import get_openapi
|
|
|
|
from webapi.providers import common
|
|
from webapi.providers.logger import register_logger
|
|
from webapi.providers import router
|
|
from webapi.providers import database
|
|
from webapi.providers import scheduler
|
|
from webapi.providers import exception_handler
|
|
from webapi.providers import probes
|
|
from webapi.providers import metrics
|
|
from .freeleaps_app import FreeleapsApp
|
|
from common.config.app_settings import app_settings
|
|
from common.log.module_logger import ModuleLogger
|
|
|
|
|
|
def create_app() -> FastAPI:
|
|
logging.info("App initializing")
|
|
|
|
app = FreeleapsApp()
|
|
|
|
register_logger()
|
|
|
|
# Create application logger for startup logging
|
|
app_logger = ModuleLogger(sender_id="ApplicationBootstrap")
|
|
|
|
register(app, exception_handler)
|
|
register(app, database)
|
|
register(app, router)
|
|
register(app, scheduler)
|
|
register(app, common)
|
|
|
|
# Call the custom_openapi function to change the OpenAPI version
|
|
customize_openapi_security(app)
|
|
|
|
# Register probe APIs if enabled
|
|
if app_settings.PROBES_ENABLED:
|
|
register(app, probes)
|
|
|
|
# Register metrics APIs if enabled
|
|
if app_settings.METRICS_ENABLED:
|
|
register(app, metrics)
|
|
|
|
# Log application startup completion
|
|
import asyncio
|
|
async def log_startup():
|
|
await app_logger.log_info("Central Storage application initialized successfully")
|
|
|
|
# Run the async logging
|
|
asyncio.create_task(log_startup())
|
|
|
|
return app
|
|
|
|
|
|
# This function overrides the OpenAPI schema version to 3.0.0
|
|
def customize_openapi_security(app: FastAPI) -> None:
|
|
|
|
def custom_openapi():
|
|
if app.openapi_schema:
|
|
return app.openapi_schema
|
|
|
|
# Generate OpenAPI schema
|
|
openapi_schema = get_openapi(
|
|
title="FreeLeaps API",
|
|
version="3.1.0",
|
|
description="FreeLeaps API Documentation",
|
|
routes=app.routes,
|
|
)
|
|
|
|
# Ensure the components section exists in the OpenAPI schema
|
|
if "components" not in openapi_schema:
|
|
openapi_schema["components"] = {}
|
|
|
|
# Add security scheme to components
|
|
openapi_schema["components"]["securitySchemes"] = {
|
|
"bearerAuth": {"type": "http", "scheme": "bearer", "bearerFormat": "JWT"}
|
|
}
|
|
|
|
# Add security requirement globally
|
|
openapi_schema["security"] = [{"bearerAuth": []}]
|
|
|
|
app.openapi_schema = openapi_schema
|
|
return app.openapi_schema
|
|
|
|
app.openapi = custom_openapi
|
|
|
|
|
|
def register(app, provider):
|
|
logging.info(provider.__name__ + " registering")
|
|
provider.register(app)
|
|
|
|
|
|
def boot(app, provider):
|
|
logging.info(provider.__name__ + " booting")
|
|
provider.boot(app)
|