package de.gedoplan.seminar.sbt.sbtrestexercise;
|
|
import de.gedoplan.seminar.sbt.sbtrestexercise.domain.Person;
|
import org.junit.jupiter.api.BeforeEach;
|
import org.junit.jupiter.api.Test;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.springframework.boot.test.web.server.LocalServerPort;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.web.reactive.function.client.WebClient;
|
|
import java.util.List;
|
|
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
public class PersonenResourceTest {
|
|
@LocalServerPort
|
private int port;
|
private WebClient client;
|
|
@BeforeEach
|
public void init() {
|
client = WebClient.create("http://localhost:"+port+"/personen");
|
}
|
|
@Test
|
public void testGetPersonen() {
|
List<Person> personen = client.get()
|
.retrieve().bodyToFlux(Person.class)
|
.collectList().block();
|
System.out.printf("Found %d talks:\n", personen.size());
|
personen.forEach(talk -> System.out.println(" "+talk));
|
}
|
|
@Test
|
public void testGetPersonById() {
|
Person person = client.get()
|
.uri(ub -> ub.path("/{id}").build(1))
|
.retrieve().bodyToMono(Person.class)
|
.block();
|
System.out.println(person);
|
}
|
|
@Test
|
public void testCreateTalk() {
|
Person person = new Person("Duck","Donald");
|
|
ResponseEntity<String> response = client.post()
|
.contentType(MediaType.APPLICATION_JSON)
|
.bodyValue(person)
|
.retrieve()
|
.toEntity(String.class)
|
.block();
|
|
HttpStatus httpStatus = HttpStatus.resolve(response.getStatusCode().value());
|
System.out.printf("Response status: %03d %s\n", httpStatus.value(), httpStatus.getReasonPhrase());
|
String message = switch (httpStatus) {
|
case CREATED -> "URI: %s\n".formatted(response.getHeaders().getLocation());
|
case INTERNAL_SERVER_ERROR -> response.getBody();
|
default -> "";
|
};
|
System.out.println(message);
|
|
}
|
|
}
|
