Merge pull request #3796 from anqixxx/locale-refactor

Localize() + Results refactor

Author: lonvia

src/nominatim_api/localization.py

@@ -9,6 +9,7 @@
 """
 from typing import Mapping, List, Optional
 from .config import Configuration
+from .results import AddressLines, BaseResultT
 
 import re
 
@@ -96,3 +97,24 @@ def from_accept_languages(langstr: str) -> 'Locales':
                 languages.append(parts[0])
 
         return Locales(languages)
+
+    def localize(self, lines: AddressLines) -> None:
+        """ Sets the local name of address parts according to the chosen
+            locale.
+
+            Only address parts that are marked as isaddress are localized.
+
+            AddressLines should be modified in place.
+        """
+        for line in lines:
+            if line.isaddress and line.names:
+                line.local_name = self.display_name(line.names)
+
+    def localize_results(self, results: List[BaseResultT]) -> None:
+        """ Set the local name of results according to the chosen
+            locale.
+        """
+        for result in results:
+            result.locale_name = self.display_name(result.names)
+            if result.address_rows:
+                self.localize(result.address_rows)

src/nominatim_api/results.py

@@ -11,7 +11,10 @@
 internal use only. That's why they are implemented as free-standing functions
 instead of member functions.
 """
-from typing import Optional, Tuple, Dict, Sequence, TypeVar, Type, List, cast, Callable
+from typing import (
+    Optional, Tuple, Dict, Sequence, TypeVar, Type, List,
+    cast, Callable
+)
 import enum
 import dataclasses
 import datetime as dt
@@ -23,7 +26,6 @@
 from .types import Point, Bbox, LookupDetails
 from .connection import SearchConnection
 from .logging import log
-from .localization import Locales
 
 # This file defines complex result data classes.
 
@@ -130,27 +132,21 @@ class AddressLine:
         [Localization](Result-Handling.md#localization) below.
     """
 
-
-class AddressLines(List[AddressLine]):
-    """ Sequence of address lines order in descending order by their rank.
-    """
-
-    def localize(self, locales: Locales) -> List[str]:
-        """ Set the local name of address parts according to the chosen
-            locale. Return the list of local names without duplicates.
-
-            Only address parts that are marked as isaddress are localized
-            and returned.
+    @property
+    def display_name(self) -> Optional[str]:
+        """ Dynamically compute the display name for the Address Line component
         """
-        label_parts: List[str] = []
+        if self.local_name:
+            return self.local_name
+        elif 'name' in self.names:
+            return self.names['name']
+        elif self.names:
+            return next(iter(self.names.values()), None)
+        return None
 
-        for line in self:
-            if line.isaddress and line.names:
-                line.local_name = locales.display_name(line.names)
-                if not label_parts or label_parts[-1] != line.local_name:
-                    label_parts.append(line.local_name)
 
-        return label_parts
+class AddressLines(List[AddressLine]):
+    """ A wrapper around a list of AddressLine objects."""
 
 
 @dataclasses.dataclass
@@ -189,7 +185,6 @@ class BaseResult:
     admin_level: int = 15
 
     locale_name: Optional[str] = None
-    display_name: Optional[str] = None
 
     names: Optional[Dict[str, str]] = None
     address: Optional[Dict[str, str]] = None
@@ -225,23 +220,42 @@ def lon(self) -> float:
         """
         return self.centroid[0]
 
+    @property
+    def display_name(self) -> Optional[str]:
+        """ Dynamically compute the display name for the result place
+            and, if available, its address information..
+        """
+        if self.address_rows:  # if this is true we need additional processing
+            label_parts: List[str] = []
+
+            for line in self.address_rows:  # assume locale_name is set by external formatter
+                if line.isaddress and line.names:
+                    address_name = line.display_name
+
+                    if address_name and (not label_parts or label_parts[-1] != address_name):
+                        label_parts.append(address_name)
+
+            if label_parts:
+                return ', '.join(label_parts)
+
+        # Now adding additional information for reranking
+        if self.locale_name:
+            return self.locale_name
+        elif self.names and 'name' in self.names:
+            return self.names['name']
+        elif self.names:
+            return next(iter(self.names.values()))
+        elif self.housenumber:
+            return self.housenumber
+        return None
+
     def calculated_importance(self) -> float:
         """ Get a valid importance value. This is either the stored importance
             of the value or an artificial value computed from the place's
             search rank.
         """
         return self.importance or (0.40001 - (self.rank_search/75.0))
 
-    def localize(self, locales: Locales) -> None:
-        """ Fill the locale_name and the display_name field for the
-            place and, if available, its address information.
-        """
-        self.locale_name = locales.display_name(self.names)
-        if self.address_rows:
-            self.display_name = ', '.join(self.address_rows.localize(locales))
-        else:
-            self.display_name = self.locale_name
-
 
 BaseResultT = TypeVar('BaseResultT', bound=BaseResult)
 
@@ -456,8 +470,6 @@ async def add_result_details(conn: SearchConnection, results: List[BaseResultT],
             log().comment('Query keywords')
             for result in results:
                 await complete_keywords(conn, result)
-        for result in results:
-            result.localize(details.locales)
 
 
 def _result_row_to_address_row(row: SaRow, isaddress: Optional[bool] = None) -> AddressLine:

src/nominatim_api/types.py

@@ -17,7 +17,6 @@
 from binascii import unhexlify
 
 from .errors import UsageError
-from .localization import Locales
 
 
 @dataclasses.dataclass
@@ -410,9 +409,6 @@ class LookupDetails:
         0.0 means the original geometry is kept. The higher the value, the
         more the geometry gets simplified.
     """
-    locales: Locales = Locales()
-    """ Preferred languages for localization of results.
-    """
 
     @classmethod
     def from_kwargs(cls: Type[TParam], kwargs: Dict[str, Any]) -> TParam:

src/nominatim_api/v1/server_glue.py

@@ -156,8 +156,6 @@ async def details_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
 
     debug = setup_debugging(params)
 
-    locales = Locales.from_accept_languages(get_accepted_languages(params))
-
     result = await api.details(place,
                                address_details=params.get_bool('addressdetails', False),
                                linked_places=params.get_bool('linkedplaces', True),
@@ -166,7 +164,6 @@ async def details_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
                                geometry_output=(GeometryFormat.GEOJSON
                                                 if params.get_bool('polygon_geojson', False)
                                                 else GeometryFormat.NONE),
-                               locales=locales
                                )
 
     if debug:
@@ -175,6 +172,9 @@ async def details_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     if result is None:
         params.raise_error('No place with that OSM ID found.', status=404)
 
+    locales = Locales.from_accept_languages(get_accepted_languages(params))
+    locales.localize_results([result])
+
     output = params.formatting().format_result(
         result, fmt,
         {'locales': locales,
@@ -194,7 +194,6 @@ async def reverse_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     details = parse_geometry_details(params, fmt)
     details['max_rank'] = helpers.zoom_to_rank(params.get_int('zoom', 18))
     details['layers'] = get_layers(params)
-    details['locales'] = Locales.from_accept_languages(get_accepted_languages(params))
 
     result = await api.reverse(coord, **details)
 
@@ -210,6 +209,10 @@ async def reverse_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     else:
         query = ''
 
+    if result:
+        Locales.from_accept_languages(get_accepted_languages(params)).localize_results(
+            [result])
+
     fmt_options = {'query': query,
                    'extratags': params.get_bool('extratags', False),
                    'namedetails': params.get_bool('namedetails', False),
@@ -227,7 +230,6 @@ async def lookup_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     fmt = parse_format(params, SearchResults, 'xml')
     debug = setup_debugging(params)
     details = parse_geometry_details(params, fmt)
-    details['locales'] = Locales.from_accept_languages(get_accepted_languages(params))
 
     places = []
     for oid in (params.get('osm_ids') or '').split(','):
@@ -246,6 +248,8 @@ async def lookup_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     if debug:
         return build_response(params, loglib.get_and_disable(), num_results=len(results))
 
+    Locales.from_accept_languages(get_accepted_languages(params)).localize_results(results)
+
     fmt_options = {'extratags': params.get_bool('extratags', False),
                    'namedetails': params.get_bool('namedetails', False),
                    'addressdetails': params.get_bool('addressdetails', True)}
@@ -310,8 +314,6 @@ async def search_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     else:
         details['layers'] = get_layers(params)
 
-    details['locales'] = Locales.from_accept_languages(get_accepted_languages(params))
-
     # unstructured query parameters
     query = params.get('q', None)
     # structured query parameters
@@ -336,6 +338,8 @@ async def search_endpoint(api: NominatimAPIAsync, params: ASGIAdaptor) -> Any:
     except UsageError as err:
         params.raise_error(str(err))
 
+    Locales.from_accept_languages(get_accepted_languages(params)).localize_results(results)
+
     if details['dedupe'] and len(results) > 1:
         results = helpers.deduplicate_results(results, max_results)
 

src/nominatim_db/clicmd/api.py

@@ -196,7 +196,6 @@ def run(self, args: NominatimArgs) -> int:
                                           'excluded': args.exclude_place_ids,
                                           'viewbox': args.viewbox,
                                           'bounded_viewbox': args.bounded,
-                                          'locales': _get_locales(args, api.config.DEFAULT_LANGUAGE)
                                           }
 
                 if args.query:
@@ -213,6 +212,9 @@ def run(self, args: NominatimArgs) -> int:
         except napi.UsageError as ex:
             raise UsageError(ex) from ex
 
+        locales = _get_locales(args, api.config.DEFAULT_LANGUAGE)
+        locales.localize_results(results)
+
         if args.dedupe and len(results) > 1:
             results = deduplicate_results(results, args.limit)
 
@@ -277,11 +279,14 @@ def run(self, args: NominatimArgs) -> int:
                                      layers=layers,
                                      address_details=True,  # needed for display name
                                      geometry_output=_get_geometry_output(args),
-                                     geometry_simplification=args.polygon_threshold,
-                                     locales=_get_locales(args, api.config.DEFAULT_LANGUAGE))
+                                     geometry_simplification=args.polygon_threshold)
         except napi.UsageError as ex:
             raise UsageError(ex) from ex
 
+        if result is not None:
+            locales = _get_locales(args, api.config.DEFAULT_LANGUAGE)
+            locales.localize_results([result])
+
         if args.format == 'debug':
             print(loglib.get_and_disable())
             return 0
@@ -339,11 +344,13 @@ def run(self, args: NominatimArgs) -> int:
                 results = api.lookup(places,
                                      address_details=True,  # needed for display name
                                      geometry_output=_get_geometry_output(args),
-                                     geometry_simplification=args.polygon_threshold or 0.0,
-                                     locales=_get_locales(args, api.config.DEFAULT_LANGUAGE))
+                                     geometry_simplification=args.polygon_threshold or 0.0)
         except napi.UsageError as ex:
             raise UsageError(ex) from ex
 
+        locales = _get_locales(args, api.config.DEFAULT_LANGUAGE)
+        locales.localize_results(results)
+
         if args.format == 'debug':
             print(loglib.get_and_disable())
             return 0
@@ -425,27 +432,28 @@ def run(self, args: NominatimArgs) -> int:
 
         try:
             with napi.NominatimAPI(args.project_dir) as api:
-                locales = _get_locales(args, api.config.DEFAULT_LANGUAGE)
                 result = api.details(place,
                                      address_details=args.addressdetails,
                                      linked_places=args.linkedplaces,
                                      parented_places=args.hierarchy,
                                      keywords=args.keywords,
                                      geometry_output=(napi.GeometryFormat.GEOJSON
                                                       if args.polygon_geojson
-                                                      else napi.GeometryFormat.NONE),
-                                     locales=locales)
+                                                      else napi.GeometryFormat.NONE))
         except napi.UsageError as ex:
             raise UsageError(ex) from ex
 
+        if result is not None:
+            locales = _get_locales(args, api.config.DEFAULT_LANGUAGE)
+            locales.localize_results([result])
+
         if args.format == 'debug':
             print(loglib.get_and_disable())
             return 0
 
         if result:
             _print_output(formatter, result, args.format or 'json',
-                          {'locales': locales,
-                           'group_hierarchy': args.group_hierarchy})
+                          {'group_hierarchy': args.group_hierarchy})
             return 0
 
         LOG.error("Object not found in database.")

src/nominatim_db/clicmd/export.py

@@ -151,9 +151,11 @@ async def dump_results(conn: napi.SearchConnection,
                        results: List[ReverseResult],
                        writer: 'csv.DictWriter[str]',
                        lang: Optional[str]) -> None:
-    locale = napi.Locales([lang] if lang else None)
     await add_result_details(conn, results,
-                             LookupDetails(address_details=True, locales=locale))
+                             LookupDetails(address_details=True))
+
+    locale = napi.Locales([lang] if lang else None)
+    locale.localize_results(results)
 
     for result in results:
         data = {'placeid': result.place_id,