X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/e490a30a4a926a55543fe3222e808233069b869e..7d911f9ffbdf63b2b2a45c3a3ee7063d006a5779:/nominatim/server/starlette/server.py diff --git a/nominatim/server/starlette/server.py b/nominatim/server/starlette/server.py index dfbdc502..f81b122f 100644 --- a/nominatim/server/starlette/server.py +++ b/nominatim/server/starlette/server.py @@ -18,9 +18,9 @@ from starlette.requests import Request from starlette.middleware import Middleware from starlette.middleware.cors import CORSMiddleware -from nominatim.config import Configuration from nominatim.api import NominatimAPIAsync import nominatim.api.v1 as api_impl +from nominatim.config import Configuration class ParamWrapper(api_impl.ASGIAdaptor): """ Adaptor class for server glue to Starlette framework. @@ -38,12 +38,17 @@ class ParamWrapper(api_impl.ASGIAdaptor): return self.request.headers.get(name, default) - def error(self, msg: str) -> HTTPException: - return HTTPException(400, detail=msg) + def error(self, msg: str, status: int = 400) -> HTTPException: + return HTTPException(status, detail=msg, + headers={'content-type': self.content_type}) + + + def create_response(self, status: int, output: str) -> Response: + return Response(output, status_code=status, media_type=self.content_type) - def create_response(self, status: int, output: str, content_type: str) -> Response: - return Response(output, status_code=status, media_type=content_type) + def config(self) -> Configuration: + return cast(Configuration, self.request.app.state.API.config) def _wrap_endpoint(func: api_impl.EndpointFunc)\ @@ -55,21 +60,36 @@ def _wrap_endpoint(func: api_impl.EndpointFunc)\ def get_application(project_dir: Path, - environ: Optional[Mapping[str, str]] = None) -> Starlette: + environ: Optional[Mapping[str, str]] = None, + debug: bool = True) -> Starlette: """ Create a Nominatim falcon ASGI application. """ config = Configuration(project_dir, environ) routes = [] + legacy_urls = config.get_bool('SERVE_LEGACY_URLS') for name, func in api_impl.ROUTES: - routes.append(Route(f"/{name}", endpoint=_wrap_endpoint(func))) + endpoint = _wrap_endpoint(func) + routes.append(Route(f"/{name}", endpoint=endpoint)) + if legacy_urls: + routes.append(Route(f"/{name}.php", endpoint=endpoint)) middleware = [] if config.get_bool('CORS_NOACCESSCONTROL'): middleware.append(Middleware(CORSMiddleware, allow_origins=['*'])) - app = Starlette(debug=True, routes=routes, middleware=middleware) + async def _shutdown() -> None: + await app.state.API.close() + + app = Starlette(debug=debug, routes=routes, middleware=middleware, + on_shutdown=[_shutdown]) app.state.API = NominatimAPIAsync(project_dir, environ) return app + + +def run_wsgi() -> Starlette: + """ Entry point for uvicorn. + """ + return get_application(Path('.'), debug=False)