5 changed files with 141 additions and 5 deletions
@ -0,0 +1,102 @@
@@ -0,0 +1,102 @@
|
||||
/* |
||||
* Copyright 2002-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.security.web.server.ui; |
||||
|
||||
import org.springframework.core.io.buffer.DataBuffer; |
||||
import org.springframework.core.io.buffer.DataBufferFactory; |
||||
import org.springframework.http.HttpMethod; |
||||
import org.springframework.http.HttpStatus; |
||||
import org.springframework.http.MediaType; |
||||
import org.springframework.http.server.reactive.ServerHttpResponse; |
||||
import org.springframework.security.web.server.csrf.CsrfToken; |
||||
import org.springframework.security.web.server.util.matcher.ServerWebExchangeMatcher; |
||||
import org.springframework.security.web.server.util.matcher.ServerWebExchangeMatchers; |
||||
import org.springframework.util.MultiValueMap; |
||||
import org.springframework.web.server.ServerWebExchange; |
||||
import org.springframework.web.server.WebFilter; |
||||
import org.springframework.web.server.WebFilterChain; |
||||
import reactor.core.publisher.Mono; |
||||
|
||||
import java.nio.charset.Charset; |
||||
|
||||
/** |
||||
* @author Rob Winch |
||||
* @since 5.0 |
||||
*/ |
||||
public class LogoutPageGeneratingWebFilter implements WebFilter { |
||||
private ServerWebExchangeMatcher matcher = ServerWebExchangeMatchers |
||||
.pathMatchers(HttpMethod.GET, "/logout"); |
||||
|
||||
@Override |
||||
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) { |
||||
return this.matcher.matches(exchange) |
||||
.filter(ServerWebExchangeMatcher.MatchResult::isMatch) |
||||
.switchIfEmpty(chain.filter(exchange).then(Mono.empty())) |
||||
.flatMap(matchResult -> render(exchange)); |
||||
} |
||||
|
||||
private Mono<Void> render(ServerWebExchange exchange) { |
||||
ServerHttpResponse result = exchange.getResponse(); |
||||
result.setStatusCode(HttpStatus.OK); |
||||
result.getHeaders().setContentType(MediaType.TEXT_HTML); |
||||
return result.writeWith(createBuffer(exchange)); |
||||
// .doOnError( error -> DataBufferUtils.release(buffer));
|
||||
} |
||||
|
||||
private Mono<DataBuffer> createBuffer(ServerWebExchange exchange) { |
||||
Mono<CsrfToken> token = (Mono<CsrfToken>) exchange.getAttributes() |
||||
.getOrDefault(CsrfToken.class.getName(), Mono.<CsrfToken>empty()); |
||||
return token |
||||
.map(LogoutPageGeneratingWebFilter::csrfToken) |
||||
.defaultIfEmpty("") |
||||
.map(csrfTokenHtmlInput -> { |
||||
byte[] bytes = createPage(csrfTokenHtmlInput); |
||||
DataBufferFactory bufferFactory = exchange.getResponse().bufferFactory(); |
||||
return bufferFactory.wrap(bytes); |
||||
}); |
||||
} |
||||
|
||||
private static byte[] createPage(String csrfTokenHtmlInput) { |
||||
String page = "<!DOCTYPE html>\n" |
||||
+ "<html lang=\"en\">\n" |
||||
+ " <head>\n" |
||||
+ " <meta charset=\"utf-8\">\n" |
||||
+ " <meta name=\"viewport\" content=\"width=device-width, initial-scale=1, shrink-to-fit=no\">\n" |
||||
+ " <meta name=\"description\" content=\"\">\n" |
||||
+ " <meta name=\"author\" content=\"\">\n" |
||||
+ " <title>Confirm Log Out?</title>\n" |
||||
+ " <link href=\"https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0-beta/css/bootstrap.min.css\" rel=\"stylesheet\" integrity=\"sha384-/Y6pD6FV/Vv2HJnA6t+vslU6fwYXjCFtcEpHbNJ0lyAFsXTsjBbfaDjzALeQsN6M\" crossorigin=\"anonymous\">\n" |
||||
+ " <link href=\"http://getbootstrap.com/docs/4.0/examples/signin/signin.css\" rel=\"stylesheet\" crossorigin=\"anonymous\"/>\n" |
||||
+ " </head>\n" |
||||
+ " <body>\n" |
||||
+ " <div class=\"container\">\n" |
||||
+ " <form class=\"form-signin\" method=\"post\" action=\"/logout\">\n" |
||||
+ " <h2 class=\"form-signin-heading\">Are you sure you want to log out?</h2>\n" |
||||
+ csrfTokenHtmlInput |
||||
+ " <button class=\"btn btn-lg btn-primary btn-block\" type=\"submit\">Log Out</button>\n" |
||||
+ " </form>\n" |
||||
+ " </div>\n" |
||||
+ " </body>\n" |
||||
+ "</html>"; |
||||
|
||||
return page.getBytes(Charset.defaultCharset()); |
||||
} |
||||
|
||||
private static String csrfToken(CsrfToken token) { |
||||
return " <input type=\"hidden\" name=\"" + token.getParameterName() + "\" value=\"" + token.getToken() + "\">\n"; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue