Resolve addresses by three word addresses

Author: Sandra Thieme

src/main/java/net/contargo/iris/address/api/AddressApiController.java

@@ -32,9 +32,12 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 import javax.servlet.http.HttpServletRequest;
 
+import static net.contargo.iris.address.w3w.ThreeWordMatcher.isThreeWordAddress;
+
 import static org.slf4j.LoggerFactory.getLogger;
 
 import static org.springframework.hateoas.mvc.ControllerLinkBuilder.linkTo;
@@ -139,6 +142,15 @@ public ListOfAddressListsResponse addressesByAddressDetails(@RequestParam(requir
             }
         }
 
+        if (isThreeWordAddress(street)) {
+            Optional<AddressDto> addressDto = addressDtoService.getAddressesByThreeWords(street.trim());
+
+            if (addressDto.isPresent()) {
+                addressListDtos = singletonList(new AddressListDto("Result for three words " + street,
+                            singletonList(addressDto.get())));
+            }
+        }
+
         Map<String, String> addressDetails = NominatimUtil.parameterMap(street, postalCode, city, country, name);
 
         if (addressListDtos.isEmpty()) {

src/main/java/net/contargo/iris/address/dto/AddressDtoService.java

@@ -4,6 +4,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 
 /**
@@ -96,4 +97,14 @@ public interface AddressDtoService {
      * @return  a list of matching addresses
      */
     List<AddressDto> getAddressesByQuery(String query);
+
+
+    /**
+     * Returns an optional {@link AddressDto} matching the given three word address.
+     *
+     * @param  threeWords  a three word address
+     *
+     * @return  an optional address
+     */
+    Optional<AddressDto> getAddressesByThreeWords(String threeWords);
 }

src/main/java/net/contargo/iris/address/dto/AddressDtoServiceImpl.java

@@ -8,6 +8,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 import static java.util.Collections.singletonList;
 import static java.util.stream.Collectors.toList;
@@ -101,4 +102,13 @@ public List<AddressDto> getAddressesByQuery(String query) {
 
         return addressServiceWrapper.getAddressesByQuery(query).stream().map(AddressDto::new).collect(toList());
     }
+
+
+    @Override
+    public Optional<AddressDto> getAddressesByThreeWords(String threeWords) {
+
+        Optional<Address> optionalAddress = addressServiceWrapper.getAddressByThreeWords(threeWords);
+
+        return optionalAddress.map(AddressDto::new);
+    }
 }

src/main/java/net/contargo/iris/address/service/AddressServiceWrapper.java

@@ -7,6 +7,8 @@
 import net.contargo.iris.address.staticsearch.StaticAddress;
 import net.contargo.iris.address.staticsearch.service.StaticAddressNotFoundException;
 import net.contargo.iris.address.staticsearch.service.StaticAddressService;
+import net.contargo.iris.address.w3w.ThreeWordClient;
+import net.contargo.iris.address.w3w.ThreeWordClientException;
 import net.contargo.iris.normalizer.NormalizerService;
 
 import org.apache.commons.lang.StringUtils;
@@ -19,6 +21,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.regex.Pattern;
 
 import static net.contargo.iris.address.nominatim.service.AddressDetailKey.CITY;
@@ -46,14 +49,16 @@ public class AddressServiceWrapper {
     private final StaticAddressService staticAddressService;
     private final AddressCache addressCache;
     private final NormalizerService normalizerService;
+    private final ThreeWordClient threeWordClient;
 
     public AddressServiceWrapper(AddressService addressService, StaticAddressService staticAddressService,
-        AddressCache cache, NormalizerService normalizerService) {
+        AddressCache cache, NormalizerService normalizerService, ThreeWordClient threeWordClient) {
 
         this.addressService = addressService;
         this.staticAddressService = staticAddressService;
         this.addressCache = cache;
         this.normalizerService = normalizerService;
+        this.threeWordClient = threeWordClient;
     }
 
     /**
@@ -225,4 +230,19 @@ public List<Address> getAddressesByQuery(String query) {
 
         return addresses;
     }
+
+
+    @SuppressWarnings("squid:S1166")
+    public Optional<Address> getAddressByThreeWords(String threeWords) {
+
+        try {
+            GeoLocation resolvedLocation = threeWordClient.resolve(threeWords);
+
+            return Optional.of(getAddressForGeoLocation(resolvedLocation));
+        } catch (ThreeWordClientException e) {
+            LOG.info("Cannot resolve three word address {}: {}", threeWords, e.getMessage());
+
+            return Optional.empty();
+        }
+    }
 }

src/main/java/net/contargo/iris/address/w3w/ForwardW3wResponse.java

@@ -0,0 +1,77 @@
+package net.contargo.iris.address.w3w;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import net.contargo.iris.GeoLocation;
+
+import java.math.BigDecimal;
+
+
+/**
+ * @author  Sandra Thieme - [email protected]
+ */
+class ForwardW3wResponse {
+
+    private final W3wResponseGeometry geometry;
+    private final W3wResponseStatus status;
+
+    @JsonCreator
+    ForwardW3wResponse(@JsonProperty("geometry") W3wResponseGeometry geometry,
+        @JsonProperty("status") W3wResponseStatus status) {
+
+        this.geometry = geometry;
+        this.status = status;
+    }
+
+    GeoLocation toGeolocation() {
+
+        return new GeoLocation(geometry.lat, geometry.lon);
+    }
+
+
+    boolean error() {
+
+        return status.code != null;
+    }
+
+
+    Integer errorCode() {
+
+        return status.code;
+    }
+
+
+    String errorMessage() {
+
+        return status.message;
+    }
+
+    private static class W3wResponseGeometry {
+
+        private final BigDecimal lat;
+        private final BigDecimal lon;
+
+        @JsonCreator
+        private W3wResponseGeometry(@JsonProperty("lat") BigDecimal lat,
+            @JsonProperty("lng") BigDecimal lon) {
+
+            this.lat = lat;
+            this.lon = lon;
+        }
+    }
+
+    private static class W3wResponseStatus {
+
+        private final Integer code;
+        private final String message;
+
+        @JsonCreator
+        private W3wResponseStatus(@JsonProperty("code") Integer code,
+            @JsonProperty("message") String message) {
+
+            this.code = code;
+            this.message = message;
+        }
+    }
+}

src/main/java/net/contargo/iris/address/w3w/ThreeWordClient.java

@@ -0,0 +1,47 @@
+package net.contargo.iris.address.w3w;
+
+import net.contargo.iris.GeoLocation;
+
+import org.springframework.http.ResponseEntity;
+
+import org.springframework.web.client.RestTemplate;
+
+
+/**
+ * @author  Sandra Thieme - [email protected]
+ */
+public class ThreeWordClient {
+
+    private static final String FORWARD_URL =
+        "https://api.what3words.com/v2/forward?addr={w3wAddress}&key={apiKey}&lang=de";
+
+    private final RestTemplate restTemplate;
+    private final String apiKey;
+
+    public ThreeWordClient(RestTemplate restTemplate, String apiKey) {
+
+        this.restTemplate = restTemplate;
+        this.apiKey = apiKey;
+    }
+
+    public GeoLocation resolve(String threeWords) {
+
+        ResponseEntity<ForwardW3wResponse> response = restTemplate.getForEntity(FORWARD_URL, ForwardW3wResponse.class,
+                threeWords, apiKey);
+
+        checkErrorStatus(response.getBody(), threeWords);
+
+        return response.getBody().toGeolocation();
+    }
+
+
+    private static void checkErrorStatus(ForwardW3wResponse response, String threeWords) {
+
+        if (response.error()) {
+            Integer code = response.errorCode();
+            String message = response.errorMessage();
+
+            throw new ThreeWordClientException(code, message, threeWords);
+        }
+    }
+}

src/main/java/net/contargo/iris/address/w3w/ThreeWordClientException.java

@@ -0,0 +1,13 @@
+package net.contargo.iris.address.w3w;
+
+/**
+ * @author  Sandra Thieme - [email protected]
+ */
+public class ThreeWordClientException extends RuntimeException {
+
+    ThreeWordClientException(Integer code, String message, String threeWords) {
+
+        super("API of w3w returned error code " + code + " with message '" + message
+            + "' for three word address '" + threeWords + "'");
+    }
+}

src/main/java/net/contargo/iris/address/w3w/ThreeWordMatcher.java

@@ -0,0 +1,17 @@
+package net.contargo.iris.address.w3w;
+
+import java.util.regex.Pattern;
+
+
+/**
+ * @author  Sandra Thieme - [email protected]
+ */
+public class ThreeWordMatcher {
+
+    private static final Pattern THREE_WORD_PATTERN = Pattern.compile("^\\p{L}+\\.\\p{L}+\\.\\p{L}+$");
+
+    public static boolean isThreeWordAddress(String input) {
+
+        return input != null && THREE_WORD_PATTERN.matcher(input.trim()).matches();
+    }
+}

src/main/resources/application-context.xml

@@ -120,8 +120,16 @@
             </bean>
         </constructor-arg>
         <constructor-arg name="normalizerService" ref="normalizerService"/>
+        <constructor-arg name="threeWordClient" ref="threeWordClient"/>
     </bean>
-    
+
+    <bean id="threeWordClient" class="net.contargo.iris.address.w3w.ThreeWordClient">
+        <constructor-arg>
+            <bean class="org.springframework.web.client.RestTemplate"/>
+        </constructor-arg>
+        <constructor-arg name="apiKey" value="${w3w.apikey}"/>
+    </bean>
+
     <bean id="addressListFilter" class="net.contargo.iris.address.service.AddressListFilterImpl"/>
 
     <bean id="addressDtoService" class="net.contargo.iris.address.dto.AddressDtoServiceImpl">
@@ -401,7 +409,7 @@
             </bean>
         </constructor-arg>
     </bean>
-    
+
     <bean id="postcodeCitySuburbStaticAddressMappingProcessor" class="net.contargo.iris.address.staticsearch.service.PostcodeCitySuburbStaticAddressMappingProcessor">
         <constructor-arg name="next" ref="postcodeCityStaticAddressMappingProcessor"/>
         <constructor-arg name="normalizerService" ref="normalizerService"/>

src/main/resources/application.properties

@@ -45,4 +45,6 @@ [email protected]
 addresses.csvdir=csv/
 addresses.cron=0 * * * * ?
 
-feature.dtruck=false
+feature.dtruck=false
+
+w3w.apikey=

src/test/java/net/contargo/iris/address/api/AddressApiControllerMvcUnitTest.java

@@ -30,6 +30,7 @@
 
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Optional;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 
@@ -169,6 +170,32 @@ public void addressesByAddressDetailsWithHashKey() throws Exception {
     }
 
 
+    @Test
+    public void addressesByAddressDetailsWithThreeWords() throws Exception {
+
+        AddressDto addressDto = new AddressDto(new Address("Resolved address"));
+        when(addressDtoServiceMock.getAddressesByThreeWords("one.two.three")).thenReturn(Optional.of(addressDto));
+
+        ResultActions resultActions = mockMvc.perform(get("/geocodes/?street=one.two.three").accept(APPLICATION_JSON));
+        resultActions.andExpect(status().isOk());
+        resultActions.andExpect(content().contentType("application/json"));
+        resultActions.andExpect(jsonPath("$.geoCodeResponse.addresses[0].addresses[0].displayName").value(
+                "Resolved address"));
+    }
+
+
+    @Test
+    public void addressesByAddressDetailsWithFailure() throws Exception {
+
+        when(addressDtoServiceMock.getAddressesByThreeWords("one.two.three")).thenReturn(Optional.empty());
+
+        ResultActions resultActions = mockMvc.perform(get("/geocodes/?street=one.two.three").accept(APPLICATION_JSON));
+        resultActions.andExpect(status().isOk());
+        resultActions.andExpect(content().contentType("application/json"));
+        resultActions.andExpect(jsonPath("$.geoCodeResponse.addresses").isEmpty());
+    }
+
+
     @Test
     public void addressesByAddressDetailsWithHashKeyAndException() throws Exception {
 

src/test/java/net/contargo/iris/address/dto/AddressDtoServiceImplUnitTest.java

@@ -14,6 +14,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 
 import static net.contargo.iris.address.nominatim.service.AddressDetailKey.CITY;
 import static net.contargo.iris.address.nominatim.service.AddressDetailKey.COUNTRY;
@@ -192,4 +193,16 @@ public void getAddressesByQuery() {
         assertThat(addresses, hasSize(1));
         assertThat(addresses.get(0).getDisplayName(), is("Gartenstr. 67, Karlsruhe (Südweststadt)"));
     }
+
+
+    @Test
+    public void getAddressesByThreeWords() {
+
+        when(addressServiceWrapperMock.getAddressByThreeWords("riches.lofts.guessing")).thenReturn(Optional.of(
+                new Address("German Chancellery")));
+
+        Optional<AddressDto> dto = sut.getAddressesByThreeWords("riches.lofts.guessing");
+
+        assertThat(dto.get().getDisplayName(), is("German Chancellery"));
+    }
 }