github
/
halo
mirror of https://github.com/halo-dev/halo
1
0
Fork 0
Code Issues Releases Wiki Activity

Refactor CustomEndpoint for customizing GroupVersion (#2429) 

#### What type of PR is this?

/kind improvement
/area core
/milestone 2.0.0

#### What this PR does / why we need it:

Refactor CustomEndpoint for customizing GroupVersion.

#### Does this PR introduce a user-facing change?

```release-note
None
```
pull/2438/head
John Niang 2022-09-20 14:38:09 +08:00 committed by GitHub
parent a39cf2645e
commit 1714f8edb2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 25 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/run/halo/app/config/WebFluxConfig.java
View File

@ -65,8 +65,7 @@ public class WebFluxConfig implements WebFluxConfigurer {
@Bean
RouterFunction<ServerResponse> customEndpoints(ApplicationContext context) {
var builder = new CustomEndpointsBuilder();
context.getBeansOfType(CustomEndpoint.class).values()
.forEach(customEndpoint -> builder.add(customEndpoint.endpoint()));
context.getBeansOfType(CustomEndpoint.class).values().forEach(builder::add);
return builder.build();
}

6
src/main/java/run/halo/app/core/extension/endpoint/CustomEndpoint.java
View File

@ -2,15 +2,19 @@ package run.halo.app.core.extension.endpoint;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.ServerResponse;
import run.halo.app.extension.GroupVersion;
/**
* RouterFunction provider for custom endpoints.
*
* @author johnniang
*/
@FunctionalInterface
public interface CustomEndpoint {
RouterFunction<ServerResponse> endpoint();
default GroupVersion groupVersion() {
return GroupVersion.parseAPIVersion("api.console.halo.run/v1alpha1");
}
}

30
src/main/java/run/halo/app/core/extension/endpoint/CustomEndpointsBuilder.java
View File

@ -1,33 +1,41 @@
package run.halo.app.core.extension.endpoint;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.springdoc.webflux.core.fn.SpringdocRouteBuilder;
import org.springframework.web.reactive.function.server.RequestPredicates;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.ServerResponse;
import run.halo.app.extension.GroupVersion;
public class CustomEndpointsBuilder {
private final List<RouterFunction<ServerResponse>> routerFunctions;
private final Map<GroupVersion, List<RouterFunction<ServerResponse>>> routerFunctionsMap;
public CustomEndpointsBuilder() {
routerFunctions = new LinkedList<>();
routerFunctionsMap = new HashMap<>();
}
public CustomEndpointsBuilder add(RouterFunction<ServerResponse> routerFunction) {
routerFunctions.add(routerFunction);
public CustomEndpointsBuilder add(CustomEndpoint customEndpoint) {
routerFunctionsMap
.computeIfAbsent(customEndpoint.groupVersion(), gv -> new LinkedList<>())
.add(customEndpoint.endpoint());
return this;
}
public RouterFunction<ServerResponse> build() {
return SpringdocRouteBuilder.route()
.nest(RequestPredicates.path("/apis/api.console.halo.run/v1alpha1"),
SpringdocRouteBuilder routeBuilder = SpringdocRouteBuilder.route();
routerFunctionsMap.forEach((gv, routerFunctions) -> {
routeBuilder.nest(RequestPredicates.path("/apis/" + gv),
() -> routerFunctions.stream().reduce(RouterFunction::and).orElse(null),
builder -> builder
.operationId("CustomEndpoints")
.description("Custom endpoints")
.tag("api.console.halo.run/v1alpha1/CustomEndpoint"))
.build();
builder -> builder.operationId("CustomEndpoints")
.description("Custom Endpoint")
.tag(gv + "/CustomEndpoint")
);
});
routerFunctionsMap.clear();
return routeBuilder.build();
}
}