GitHub/Spring
1
0
Fork 0
mirror of https://github.com/OtusTeam/Spring.git synced 2026-06-20 11:14:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Spring-2019-08 - 18 - Solution from the class

Browse Source
This commit is contained in:
ydvorzhetskiy
2019-10-30 21:36:30 +03:00
parent 0b743cc75f
commit 32cefe19b1
1 changed files with 13 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2019-08/spring-18/spring-18-solution/src/main/java/ru/otus/spring/Main.java
+13 -22
View File
@@ -1,5 +1,6 @@
package ru.otus.spring;
import org.apache.commons.lang3.StringUtils;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
@@ -16,7 +17,9 @@ import java.util.Arrays;
import static org.springframework.http.MediaType.APPLICATION_JSON;
import static org.springframework.web.reactive.function.BodyInserters.fromObject;
import static org.springframework.web.reactive.function.server.RequestPredicates.accept;
import static org.springframework.web.reactive.function.server.RequestPredicates.queryParam;
import static org.springframework.web.reactive.function.server.RouterFunctions.route;
import static org.springframework.web.reactive.function.server.ServerResponse.notFound;
import static org.springframework.web.reactive.function.server.ServerResponse.ok;
@SpringBootApplication
@@ -36,31 +39,19 @@ public class Main {
@Bean
public RouterFunction<ServerResponse> composedRoutes(PersonRepository repository) {
PersonHandler handler = new PersonHandler(repository);
RouterFunction<ServerResponse> route = route()
.GET("/func/person", accept(APPLICATION_JSON), handler::list)
return route()
.GET("/func/person", queryParam("name", StringUtils::isNotEmpty),
request -> request.queryParam("name")
.map(repository::findAllByLastName)
.map(persons -> ok().body(persons, Person.class))
.orElse(notFound().build())
)
.GET("/func/person", accept(APPLICATION_JSON),
request -> ok().contentType(APPLICATION_JSON).body(repository.findAll(), Person.class))
.GET("/func/person/{id}", accept(APPLICATION_JSON),
request -> repository.findById(request.pathVariable("id"))
.flatMap(person -> ok().contentType(APPLICATION_JSON).body(fromObject(person)))
)
.build();
return route;
}
static class PersonHandler {
private PersonRepository repository;
PersonHandler(PersonRepository repository) {
this.repository = repository;
}
Mono<ServerResponse> list(ServerRequest request) {
return ok().contentType(APPLICATION_JSON).body(repository.findAll(), Person.class);
}
).build();
}
}