fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: if no aggregate resource, should direct response client

Browse Source
This commit is contained in:
hongqiaowei
2020-12-08 15:50:44 +08:00
parent 10d1b4c3c1
commit 9a5ad1e2e0
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/we/filter/FizzGatewayFilter.java
View File

@@ -34,6 +34,7 @@ import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils; import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.core.io.buffer.NettyDataBufferFactory; import org.springframework.core.io.buffer.NettyDataBufferFactory;
import org.springframework.http.HttpMethod; import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse; import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@@ -93,7 +94,7 @@ public class FizzGatewayFilter implements WebFilter {
String method = request.getMethodValue(); String method = request.getMethodValue();
AggregateResource aggregateResource = configLoader.matchAggregateResource(method, path); AggregateResource aggregateResource = configLoader.matchAggregateResource(method, path);
if (aggregateResource == null) { if (aggregateResource == null) {
return chain.filter(exchange); return WebUtils.responseError(exchange, HttpStatus.INTERNAL_SERVER_ERROR.value(), "no aggregate resource: " + path);
} }
Pipeline pipeline = aggregateResource.getPipeline(); Pipeline pipeline = aggregateResource.getPipeline();