X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=pwreset%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fdemos%2Fpwreset%2Fadapters%2Fout%2FRemoteUsersServiceConsumer.java;h=78c5548cf9b6f7b839f73f45e20a5814ab62cfb1;hb=fd8887be198e30aa19e149ea601d90c809f5de93;hp=eb1492fb6107324d23356bf8c002cddb0b1fd757;hpb=5316cb48d040cad4e84ee6057acee61772fd7df2;p=demos%2Fpact diff --git a/pwreset/src/main/java/de/juplo/demos/pwreset/adapters/out/RemoteUsersServiceConsumer.java b/pwreset/src/main/java/de/juplo/demos/pwreset/adapters/out/RemoteUsersServiceConsumer.java index eb1492f..78c5548 100644 --- a/pwreset/src/main/java/de/juplo/demos/pwreset/adapters/out/RemoteUsersServiceConsumer.java +++ b/pwreset/src/main/java/de/juplo/demos/pwreset/adapters/out/RemoteUsersServiceConsumer.java @@ -1,13 +1,13 @@ package de.juplo.demos.pwreset.adapters.out; -import de.juplo.demos.pwreset.domain.api.User; -import de.juplo.demos.pwreset.domain.api.UsersService; +import de.juplo.demos.pwreset.api.out.UsersService; import lombok.RequiredArgsConstructor; import org.springframework.http.HttpStatus; import org.springframework.http.ResponseEntity; import org.springframework.web.client.RestTemplate; import java.util.Optional; +import java.util.UUID; @RequiredArgsConstructor @@ -18,23 +18,31 @@ public class RemoteUsersServiceConsumer implements UsersService @Override - public Optional getUserByEmail(String email) { + public Optional getUserByEmail(String email) + { ResponseEntity response = restTemplate.getForEntity(uriTemplate, UserDTO.class, email); + HttpStatus status = response.getStatusCode(); UserDTO dto = response.getBody(); - switch (response.getStatusCode()) { + + switch (response.getStatusCode()) + { case OK: return - Optional.of( - User.builder() - .id(dto.id) - .email(dto.email) - .build()); + Optional.of(dto.id); + case NOT_FOUND: return Optional.empty(); + default: throw new RuntimeException(status.toString()); } } + + @Override + public void setPassword(UUID userId, String password) + { + + } }