Spencer Gibb
8 years ago
4 changed files with 54 additions and 21 deletions
@ -0,0 +1,45 @@
@@ -0,0 +1,45 @@
|
||||
/* |
||||
* Copyright 2013-2017 the original author or authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
package org.springframework.cloud.gateway.filter.route; |
||||
|
||||
import org.springframework.http.server.reactive.ServerHttpRequest; |
||||
import org.springframework.web.server.WebFilter; |
||||
|
||||
/** |
||||
* @author Spencer Gibb |
||||
*/ |
||||
public class PrefixPathRouteFilter implements RouteFilter { |
||||
|
||||
@Override |
||||
@SuppressWarnings("unchecked") |
||||
public WebFilter apply(String... args) { |
||||
validate(1, args); |
||||
final String prefix = args[0]; |
||||
|
||||
return (exchange, chain) -> { |
||||
ServerHttpRequest req = exchange.getRequest(); |
||||
String newPath = prefix + req.getURI().getPath(); |
||||
|
||||
ServerHttpRequest request = req.mutate() |
||||
.path(newPath) |
||||
.build(); |
||||
|
||||
return chain.filter(exchange.mutate().request(request).build()); |
||||
}; |
||||
} |
||||
} |
Loading…
Reference in new issue