From 689b6a0f28a773a7925dcff94add76ec57bb1850 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 13 Mar 2021 15:06:42 +0100 Subject: [PATCH] WIP --- pom.xml | 1 + pwreset/pom.xml | 9 +++ .../adapter/RemoteUsersServiceConsumer.java | 40 ++++++++++++ .../juplo/demos/consumer/adapter/UserDTO.java | 13 ++++ .../de/juplo/demos/consumer/domain/User.java | 15 +++++ .../demos/consumer/domain/UsersService.java | 9 +++ .../adapter/RemoteUsersServiceConsumerIT.java | 64 +++++++++++++++++++ 7 files changed, 151 insertions(+) create mode 100644 pwreset/src/main/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumer.java create mode 100644 pwreset/src/main/java/de/juplo/demos/consumer/adapter/UserDTO.java create mode 100644 pwreset/src/main/java/de/juplo/demos/consumer/domain/User.java create mode 100644 pwreset/src/main/java/de/juplo/demos/consumer/domain/UsersService.java create mode 100644 pwreset/src/test/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumerIT.java diff --git a/pom.xml b/pom.xml index 97f526e..9bee286 100644 --- a/pom.xml +++ b/pom.xml @@ -16,6 +16,7 @@ Pact-Demo based on Spring Boot 11 + 4.2.2 pwreset diff --git a/pwreset/pom.xml b/pwreset/pom.xml index e63871b..954f451 100644 --- a/pwreset/pom.xml +++ b/pwreset/pom.xml @@ -28,6 +28,12 @@ spring-boot-starter-test test + + au.com.dius.pact.consumer + junit5 + ${pact.version} + test + @@ -44,6 +50,9 @@ + + maven-failsafe-plugin + diff --git a/pwreset/src/main/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumer.java b/pwreset/src/main/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumer.java new file mode 100644 index 0000000..8cbc3eb --- /dev/null +++ b/pwreset/src/main/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumer.java @@ -0,0 +1,40 @@ +package de.juplo.demos.consumer.adapter; + +import de.juplo.demos.consumer.domain.User; +import de.juplo.demos.consumer.domain.UsersService; +import lombok.RequiredArgsConstructor; +import org.springframework.http.HttpStatus; +import org.springframework.http.ResponseEntity; +import org.springframework.web.client.RestTemplate; + +import java.util.Optional; + + +@RequiredArgsConstructor +public class RemoteUsersServiceConsumer implements UsersService +{ + private final String uriTemplate; + private final RestTemplate restTemplate; + + + @Override + public Optional getUserByEmail(String email) { + ResponseEntity response = + restTemplate.getForEntity(uriTemplate, UserDTO.class, email); + HttpStatus status = response.getStatusCode(); + UserDTO dto = response.getBody(); + switch (response.getStatusCode()) { + case OK: + return + Optional.of( + User.builder() + .id(dto.id) + .email(dto.email) + .build()); + case NOT_FOUND: + return Optional.empty(); + default: + throw new RuntimeException(status.toString()); + } + } +} diff --git a/pwreset/src/main/java/de/juplo/demos/consumer/adapter/UserDTO.java b/pwreset/src/main/java/de/juplo/demos/consumer/adapter/UserDTO.java new file mode 100644 index 0000000..bcf2692 --- /dev/null +++ b/pwreset/src/main/java/de/juplo/demos/consumer/adapter/UserDTO.java @@ -0,0 +1,13 @@ +package de.juplo.demos.consumer.adapter; + +import lombok.Setter; + +import java.util.UUID; + + +@Setter +public class UserDTO +{ + UUID id; + String email; +} diff --git a/pwreset/src/main/java/de/juplo/demos/consumer/domain/User.java b/pwreset/src/main/java/de/juplo/demos/consumer/domain/User.java new file mode 100644 index 0000000..521ad27 --- /dev/null +++ b/pwreset/src/main/java/de/juplo/demos/consumer/domain/User.java @@ -0,0 +1,15 @@ +package de.juplo.demos.consumer.domain; + +import lombok.Builder; +import lombok.Data; + +import java.util.UUID; + + +@Data +@Builder +public class User +{ + private UUID id; + private String email; +} diff --git a/pwreset/src/main/java/de/juplo/demos/consumer/domain/UsersService.java b/pwreset/src/main/java/de/juplo/demos/consumer/domain/UsersService.java new file mode 100644 index 0000000..f6738e9 --- /dev/null +++ b/pwreset/src/main/java/de/juplo/demos/consumer/domain/UsersService.java @@ -0,0 +1,9 @@ +package de.juplo.demos.consumer.domain; + +import java.util.Optional; + + +public interface UsersService +{ + Optional getUserByEmail(String email); +} diff --git a/pwreset/src/test/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumerIT.java b/pwreset/src/test/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumerIT.java new file mode 100644 index 0000000..f3786af --- /dev/null +++ b/pwreset/src/test/java/de/juplo/demos/consumer/adapter/RemoteUsersServiceConsumerIT.java @@ -0,0 +1,64 @@ +package de.juplo.demos.consumer.adapter; + +import au.com.dius.pact.consumer.MockServer; +import au.com.dius.pact.consumer.dsl.PactDslWithProvider; +import au.com.dius.pact.consumer.junit5.PactConsumerTestExt; +import au.com.dius.pact.consumer.junit5.PactTestFor; +import au.com.dius.pact.core.model.RequestResponsePact; +import au.com.dius.pact.core.model.annotations.Pact; +import de.juplo.demos.consumer.domain.User; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.extension.ExtendWith; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.boot.web.client.RestTemplateBuilder; +import org.springframework.test.context.junit.jupiter.SpringExtension; +import org.springframework.web.client.RestTemplate; + +import java.io.IOException; +import java.util.Map; +import java.util.Optional; +import java.util.UUID; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.assertj.core.api.Assertions.fail; + + +@ExtendWith(PactConsumerTestExt.class) +@PactTestFor(providerName = "UsersProvider") +public class RemoteUsersServiceConsumerIT +{ + @Pact(consumer="EmailServicesConsumer") + public RequestResponsePact getExistingUserByEmail(PactDslWithProvider builder) { + return builder + .given("User with email pact@juplo.de exists") + .uponReceiving("Request for user with email pact@juplo.de") + .path("/get") + .query("email=pact@juplo.de") + .method("GET") + .willRespondWith() + .status(200) + .headers(Map.of("Content-Type", "application/json;charset=UTF-8")) + .body("{\"id\": \"123e4567-e89b-12d3-a456-426614174000\", \"email\": \"pact@juplo.de\"}") + .toPact(); + } + + @Test + @PactTestFor(pactMethod = "getExistingUserByEmail") + public void testGetExistingUserByEmail(MockServer mockServer) { + RestTemplate restTemplate = new RestTemplateBuilder().rootUri(mockServer.getUrl()).build(); + RemoteUsersServiceConsumer usersService = new RemoteUsersServiceConsumer("/get?email={email}", restTemplate); + try { + Optional result = usersService.getUserByEmail("pact@juplo.de"); + + assertThat(result.isPresent()).isTrue(); + User user = result.get(); + assertThat(user.getId()).isEqualTo(UUID.fromString("123e4567-e89b-12d3-a456-426614174000")); + assertThat(user.getEmail()).isEqualTo("pact@juplo.de"); + } + catch (Exception e) { + fail("Unexpected exception", e); + } + } +} -- 2.20.1