X-Git-Url: https://git.openstreetmap.org./nominatim.git/blobdiff_plain/d5b6042118504e6419a557c99685381914161732..38369ca3cfe6e52bb6f7589c714a04294497520e:/nominatim/server/falcon/server.py

diff --git a/nominatim/server/falcon/server.py b/nominatim/server/falcon/server.py
index f1030f5c..5ec418a6 100644
--- a/nominatim/server/falcon/server.py
+++ b/nominatim/server/falcon/server.py
@@ -7,7 +7,7 @@
 """
 Server implementation using the falcon webserver framework.
 """
-from typing import Optional, Mapping, cast, Any
+from typing import Optional, Mapping, cast, Any, List
 from pathlib import Path
 import datetime as dt
 
@@ -122,7 +122,7 @@ class FileLoggingMiddleware:
             writes logs for sucessful requests for search, reverse and lookup.
         """
         if not req_succeeded or resource is None or resp.status != 200\
-            or resource.name not in ('reverse', 'search', 'lookup'):
+            or resource.name not in ('reverse', 'search', 'lookup', 'details'):
             return
 
         finish = dt.datetime.now(tz=dt.timezone.utc)
@@ -136,16 +136,29 @@ class FileLoggingMiddleware:
                       f'{resource.name} "{params}"\n')
 
 
+class APIShutdown:
+    """ Middleware that closes any open database connections.
+    """
+
+    def __init__(self, api: NominatimAPIAsync) -> None:
+        self.api = api
+
+    async def process_shutdown(self, *_: Any) -> None:
+        """Process the ASGI lifespan shutdown event.
+        """
+        await self.api.close()
+
+
 def get_application(project_dir: Path,
                     environ: Optional[Mapping[str, str]] = None) -> App:
     """ Create a Nominatim Falcon ASGI application.
     """
     api = NominatimAPIAsync(project_dir, environ)
 
-    middleware: Optional[object] = None
+    middleware: List[object] = [APIShutdown(api)]
     log_file = api.config.LOG_FILE
     if log_file:
-        middleware = FileLoggingMiddleware(log_file)
+        middleware.append(FileLoggingMiddleware(log_file))
 
     app = App(cors_enable=api.config.get_bool('CORS_NOACCESSCONTROL'),
               middleware=middleware)