From 8202f4ad051bff98862edb619564e8352e39e328 Mon Sep 17 00:00:00 2001 From: wangyu <727842003@qq.com> Date: Sat, 12 Oct 2024 17:10:48 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E6=A8=A1=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 14 +- .../cas/{filter => context}/CASContext.java | 24 +- .../{filter => context}/CASContextInit.java | 2 +- .../flyfish/boot/cas/context/CASReceipt.java | 111 +++++++++ .../SessionMappingStorage.java | 2 +- .../exception/CASAuthenticationException.java | 11 + .../flyfish/boot/cas/filter/CASFilter.java | 19 +- .../boot/cas/filter/CASLoginFilter.java | 3 + .../cas/validator/ProxyTicketValidator.java | 86 +++++++ .../flyfish/boot/cas/validator/SecureURL.java | 55 +++++ .../cas/validator/ServiceTicketValidator.java | 221 ++++++++++++++++++ .../flyfish/boot/cas/validator/XmlUtils.java | 111 +++++++++ src/main/resources/application.yml | 2 +- 13 files changed, 633 insertions(+), 28 deletions(-) rename src/main/java/dev/flyfish/boot/cas/{filter => context}/CASContext.java (85%) rename src/main/java/dev/flyfish/boot/cas/{filter => context}/CASContextInit.java (84%) create mode 100644 src/main/java/dev/flyfish/boot/cas/context/CASReceipt.java rename src/main/java/dev/flyfish/boot/cas/{filter => context}/SessionMappingStorage.java (98%) create mode 100644 src/main/java/dev/flyfish/boot/cas/exception/CASAuthenticationException.java create mode 100644 src/main/java/dev/flyfish/boot/cas/validator/ProxyTicketValidator.java create mode 100644 src/main/java/dev/flyfish/boot/cas/validator/SecureURL.java create mode 100644 src/main/java/dev/flyfish/boot/cas/validator/ServiceTicketValidator.java create mode 100644 src/main/java/dev/flyfish/boot/cas/validator/XmlUtils.java diff --git a/pom.xml b/pom.xml index 92db918..1034063 100644 --- a/pom.xml +++ b/pom.xml @@ -62,13 +62,13 @@ - - edu.yale.its - cas-client-java - 7.0.8 - system - ${project.basedir}/lib/sso-client-java-7.0.8.jar - + + + + + + + diff --git a/src/main/java/dev/flyfish/boot/cas/filter/CASContext.java b/src/main/java/dev/flyfish/boot/cas/context/CASContext.java similarity index 85% rename from src/main/java/dev/flyfish/boot/cas/filter/CASContext.java rename to src/main/java/dev/flyfish/boot/cas/context/CASContext.java index 1d2ac3a..68fd6d3 100644 --- a/src/main/java/dev/flyfish/boot/cas/filter/CASContext.java +++ b/src/main/java/dev/flyfish/boot/cas/context/CASContext.java @@ -1,4 +1,4 @@ -package dev.flyfish.boot.cas.filter; +package dev.flyfish.boot.cas.context; import lombok.AccessLevel; import lombok.Getter; @@ -42,7 +42,7 @@ public class CASContext { @Getter private String username; - static Mono create(ServerWebExchange exchange, WebFilterChain chain) { + public static Mono create(ServerWebExchange exchange, WebFilterChain chain) { return new CASContext(exchange, chain).init(); } @@ -58,48 +58,48 @@ public class CASContext { .thenReturn(this); } - boolean isTokenRequest() { + public boolean isTokenRequest() { return StringUtils.hasText(ticket); } - Mono filter() { + public Mono filter() { return chain.filter(exchange); } - Mono redirect(String url) { + public Mono redirect(String url) { ServerHttpResponse response = exchange.getResponse(); response.setRawStatusCode(HttpStatus.FOUND.value()); response.getHeaders().setLocation(URI.create(url)); return Mono.empty(); } - ServerHttpRequest getRequest() { + public ServerHttpRequest getRequest() { return exchange.getRequest(); } - ServerHttpResponse getResponse() { + public ServerHttpResponse getResponse() { return exchange.getResponse(); } - String getPath() { + public String getPath() { return exchange.getRequest().getPath().value(); } - HttpMethod getMethod() { + public HttpMethod getMethod() { return exchange.getRequest().getMethod(); } - String getQuery(String key) { + public String getQuery(String key) { ServerHttpRequest request = exchange.getRequest(); return request.getQueryParams().getFirst(key); } - Mono getFormData(String key) { + public Mono getFormData(String key) { return exchange.getFormData() .mapNotNull(formData -> formData.getFirst(key)); } - void setSessionAttribute(String key, Object value) { + public void setSessionAttribute(String key, Object value) { session.getAttributes().put(key, value); } diff --git a/src/main/java/dev/flyfish/boot/cas/filter/CASContextInit.java b/src/main/java/dev/flyfish/boot/cas/context/CASContextInit.java similarity index 84% rename from src/main/java/dev/flyfish/boot/cas/filter/CASContextInit.java rename to src/main/java/dev/flyfish/boot/cas/context/CASContextInit.java index da15b35..4260f66 100644 --- a/src/main/java/dev/flyfish/boot/cas/filter/CASContextInit.java +++ b/src/main/java/dev/flyfish/boot/cas/context/CASContextInit.java @@ -1,4 +1,4 @@ -package dev.flyfish.boot.cas.filter; +package dev.flyfish.boot.cas.context; /** * 上下文初始化逻辑 diff --git a/src/main/java/dev/flyfish/boot/cas/context/CASReceipt.java b/src/main/java/dev/flyfish/boot/cas/context/CASReceipt.java new file mode 100644 index 0000000..f500664 --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/context/CASReceipt.java @@ -0,0 +1,111 @@ +package dev.flyfish.boot.cas.context; + +import dev.flyfish.boot.cas.exception.CASAuthenticationException; +import dev.flyfish.boot.cas.validator.ProxyTicketValidator; +import lombok.Getter; +import lombok.Setter; +import lombok.ToString; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; + +@Setter +@ToString +public class CASReceipt implements Serializable { + + private static final Log log = LogFactory.getLog(CASReceipt.class); + @Getter + private String casValidateUrl; + @Getter + private String pgtIou; + @Getter + private boolean primaryAuthentication = false; + @Getter + private String proxyCallbackUrl; + + private List proxyList = new ArrayList<>(); + @Getter + private String userName; + + public static CASReceipt getReceipt(ProxyTicketValidator ptv) throws CASAuthenticationException { + if (log.isTraceEnabled()) { + log.trace("entering getReceipt(ProxyTicketValidator=[" + ptv + "])"); + } + + if (!ptv.isAuthenticationSuccesful()) { + try { + ptv.validate(); + } catch (Exception e) { + CASAuthenticationException casException = new CASAuthenticationException("Unable to validate ProxyTicketValidator [" + ptv + "]", e); + log.error(casException); + throw casException; + } + } + + if (!ptv.isAuthenticationSuccesful()) { + log.error("validation of [" + ptv + "] was not successful."); + throw new CASAuthenticationException("Unable to validate ProxyTicketValidator [" + ptv + "]"); + } else { + CASReceipt receipt = new CASReceipt(); + receipt.casValidateUrl = ptv.getCasValidateUrl(); + receipt.pgtIou = ptv.getPgtIou(); + receipt.userName = ptv.getUser(); + receipt.proxyCallbackUrl = ptv.getProxyCallbackUrl(); + receipt.proxyList = ptv.getProxyList(); + receipt.primaryAuthentication = ptv.isRenew(); + if (!receipt.validate()) { + throw new CASAuthenticationException("Validation of [" + ptv + "] did not result in an internally consistent CASReceipt."); + } else { + if (log.isTraceEnabled()) { + log.trace("returning from getReceipt() with return value [" + receipt + "]"); + } + + return receipt; + } + } + } + + public CASReceipt() { + } + + public List getProxyList() { + return Collections.unmodifiableList(this.proxyList); + } + + public boolean isProxied() { + return !this.proxyList.isEmpty(); + } + + public String getProxyingService() { + return this.proxyList.isEmpty() ? null : (String) this.proxyList.getFirst(); + } + + private boolean validate() { + boolean valid = true; + if (this.userName == null) { + log.error("Receipt was invalid because userName was null. Receipt:[" + this + "]"); + valid = false; + } + + if (this.casValidateUrl == null) { + log.error("Receipt was invalid because casValidateUrl was null. Receipt:[" + this + "]"); + valid = false; + } + + if (this.proxyList == null) { + log.error("receipt was invalid because proxyList was null. Receipt:[" + this + "]"); + valid = false; + } + + if (this.primaryAuthentication && !this.proxyList.isEmpty()) { + log.error("If authentication was by primary credentials then it could not have been proxied. Yet, primaryAuthentication is true where proxyList is not empty. Receipt:[" + this + "]"); + valid = false; + } + + return valid; + } +} diff --git a/src/main/java/dev/flyfish/boot/cas/filter/SessionMappingStorage.java b/src/main/java/dev/flyfish/boot/cas/context/SessionMappingStorage.java similarity index 98% rename from src/main/java/dev/flyfish/boot/cas/filter/SessionMappingStorage.java rename to src/main/java/dev/flyfish/boot/cas/context/SessionMappingStorage.java index f320ced..8bdd701 100644 --- a/src/main/java/dev/flyfish/boot/cas/filter/SessionMappingStorage.java +++ b/src/main/java/dev/flyfish/boot/cas/context/SessionMappingStorage.java @@ -1,4 +1,4 @@ -package dev.flyfish.boot.cas.filter; +package dev.flyfish.boot.cas.context; import lombok.extern.slf4j.Slf4j; import org.springframework.web.server.WebSession; diff --git a/src/main/java/dev/flyfish/boot/cas/exception/CASAuthenticationException.java b/src/main/java/dev/flyfish/boot/cas/exception/CASAuthenticationException.java new file mode 100644 index 0000000..b666cec --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/exception/CASAuthenticationException.java @@ -0,0 +1,11 @@ +package dev.flyfish.boot.cas.exception; + +public class CASAuthenticationException extends Exception { + public CASAuthenticationException(String string) { + super(string); + } + + public CASAuthenticationException(String message, Throwable cause) { + super(message, cause); + } +} diff --git a/src/main/java/dev/flyfish/boot/cas/filter/CASFilter.java b/src/main/java/dev/flyfish/boot/cas/filter/CASFilter.java index 8f8b1ce..f8c644d 100644 --- a/src/main/java/dev/flyfish/boot/cas/filter/CASFilter.java +++ b/src/main/java/dev/flyfish/boot/cas/filter/CASFilter.java @@ -1,9 +1,12 @@ package dev.flyfish.boot.cas.filter; -import edu.yale.its.tp.cas.client.CASAuthenticationException; -import edu.yale.its.tp.cas.client.CASReceipt; -import edu.yale.its.tp.cas.client.ProxyTicketValidator; -import edu.yale.its.tp.cas.util.XmlUtils; +import dev.flyfish.boot.cas.context.CASContext; +import dev.flyfish.boot.cas.context.CASContextInit; +import dev.flyfish.boot.cas.context.CASReceipt; +import dev.flyfish.boot.cas.context.SessionMappingStorage; +import dev.flyfish.boot.cas.exception.CASAuthenticationException; +import dev.flyfish.boot.cas.validator.ProxyTicketValidator; +import dev.flyfish.boot.cas.validator.XmlUtils; import lombok.Getter; import lombok.extern.slf4j.Slf4j; import org.springframework.http.HttpCookie; @@ -147,8 +150,12 @@ public class CASFilter implements WebFilter { URI uri = context.getRequest().getURI(); StringBuilder sb = new StringBuilder(); - - sb.append(uri.getScheme()).append("://").append(server).append(uri.getPath()); + if (server.startsWith("http")) { + sb.append(server); + } else { + sb.append(uri.getScheme()).append("://").append(server); + } + sb.append(uri.getPath()); if (uri.getQuery() != null) { String query = uri.getQuery(); diff --git a/src/main/java/dev/flyfish/boot/cas/filter/CASLoginFilter.java b/src/main/java/dev/flyfish/boot/cas/filter/CASLoginFilter.java index 7ac7d21..9523765 100644 --- a/src/main/java/dev/flyfish/boot/cas/filter/CASLoginFilter.java +++ b/src/main/java/dev/flyfish/boot/cas/filter/CASLoginFilter.java @@ -1,5 +1,8 @@ package dev.flyfish.boot.cas.filter; +import dev.flyfish.boot.cas.context.CASContext; +import dev.flyfish.boot.cas.context.CASContextInit; + /** * 登录过滤器，旨在缓存用户名 * diff --git a/src/main/java/dev/flyfish/boot/cas/validator/ProxyTicketValidator.java b/src/main/java/dev/flyfish/boot/cas/validator/ProxyTicketValidator.java new file mode 100644 index 0000000..a044a6c --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/validator/ProxyTicketValidator.java @@ -0,0 +1,86 @@ +package dev.flyfish.boot.cas.validator; + +import lombok.ToString; +import org.xml.sax.Attributes; +import org.xml.sax.SAXException; +import org.xml.sax.helpers.DefaultHandler; + +import java.util.ArrayList; +import java.util.List; + +@ToString +public class ProxyTicketValidator extends ServiceTicketValidator { + protected List proxyList; + + public ProxyTicketValidator() { + } + + public static void main(String[] args) throws Exception { + System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); + ProxyTicketValidator pv = new ProxyTicketValidator(); + pv.setCasValidateUrl("https://portal.yale.edu/cas/proxyValidate"); + pv.setService(args[0]); + pv.setServiceTicket(args[1]); + pv.validate(); + System.out.println(pv.getResponse()); + System.out.println(); + if (pv.isAuthenticationSuccesful()) { + System.out.println("user: " + pv.getUser()); + System.out.println("proxies:\n " + pv.getProxyList()); + } else { + System.out.println("error code: " + pv.getErrorCode()); + System.out.println("error message: " + pv.getErrorMessage()); + } + + } + + public List getProxyList() { + return this.proxyList; + } + + protected DefaultHandler newHandler() { + return new ProxyHandler(); + } + + protected void clear() { + super.clear(); + this.proxyList = null; + } + + protected class ProxyHandler extends ServiceTicketValidator.Handler { + protected static final String PROXIES = "cas:proxies"; + protected static final String PROXY = "cas:proxy"; + protected List proxyList = new ArrayList(); + protected boolean proxyFragment = false; + + protected ProxyHandler() { + super(); + } + + public void startElement(String ns, String ln, String qn, Attributes a) { + super.startElement(ns, ln, qn, a); + if (this.authenticationSuccess && qn.equals("cas:proxies")) { + this.proxyFragment = true; + } + + } + + public void endElement(String ns, String ln, String qn) throws SAXException { + super.endElement(ns, ln, qn); + if (qn.equals("cas:proxies")) { + this.proxyFragment = false; + } else if (this.proxyFragment && qn.equals("cas:proxy")) { + this.proxyList.add(this.currentText.toString().trim()); + } + + } + + public void endDocument() throws SAXException { + super.endDocument(); + if (this.authenticationSuccess) { + ProxyTicketValidator.this.proxyList = this.proxyList; + } + + } + } +} diff --git a/src/main/java/dev/flyfish/boot/cas/validator/SecureURL.java b/src/main/java/dev/flyfish/boot/cas/validator/SecureURL.java new file mode 100644 index 0000000..5665743 --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/validator/SecureURL.java @@ -0,0 +1,55 @@ +package dev.flyfish.boot.cas.validator; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + +import java.io.BufferedReader; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.net.URL; +import java.net.URLConnection; + +public class SecureURL { + private static final Log log = LogFactory.getLog(SecureURL.class); + + public SecureURL() { + } + + public static void main(String[] args) throws IOException { + System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); + System.out.println(retrieve(args[0])); + } + + public static String retrieve(String url) throws IOException { + if (log.isTraceEnabled()) { + log.trace("entering retrieve(" + url + ")"); + } + + BufferedReader r = null; + + try { + URL u = new URL(url); + URLConnection uc = u.openConnection(); + uc.setRequestProperty("Connection", "close"); + InputStream in = uc.getInputStream(); + + ByteArrayOutputStream output = new ByteArrayOutputStream(); + + for (int chByte = in.read(); chByte != -1; chByte = in.read()) { + output.write(chByte); + } + + String var7 = output.toString("utf-8"); + return var7; + } finally { + try { + if (r != null) { + ((BufferedReader) r).close(); + } + } catch (IOException var14) { + } + + } + } +} diff --git a/src/main/java/dev/flyfish/boot/cas/validator/ServiceTicketValidator.java b/src/main/java/dev/flyfish/boot/cas/validator/ServiceTicketValidator.java new file mode 100644 index 0000000..8dd2e08 --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/validator/ServiceTicketValidator.java @@ -0,0 +1,221 @@ +package dev.flyfish.boot.cas.validator; + +import lombok.Getter; +import lombok.ToString; +import org.xml.sax.Attributes; +import org.xml.sax.InputSource; +import org.xml.sax.SAXException; +import org.xml.sax.XMLReader; +import org.xml.sax.helpers.DefaultHandler; + +import javax.xml.parsers.ParserConfigurationException; +import javax.xml.parsers.SAXParserFactory; +import java.io.IOException; +import java.io.StringReader; + +@ToString +public class ServiceTicketValidator { + private String casValidateUrl; + private String proxyCallbackUrl; + private String st; + private String service; + private String pgtIou; + private String user; + private String errorCode; + private String errorMessage; + private String entireResponse; + private String ss; + @Getter + private boolean renew = false; + private boolean attemptedAuthentication; + private boolean successfulAuthentication; + + public ServiceTicketValidator() { + } + + public static void main(String[] args) throws Exception { + System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol"); + ServiceTicketValidator sv = new ServiceTicketValidator(); + sv.setCasValidateUrl("https://portal1.wss.yale.edu/cas/serviceValidate"); + sv.setProxyCallbackUrl("https://portal1.wss.yale.edu/casProxy/receptor"); + sv.setService(args[0]); + sv.setServiceTicket(args[1]); + sv.validate(); + System.out.println(sv.getResponse()); + System.out.println(); + if (sv.isAuthenticationSuccesful()) { + System.out.println("user: " + sv.getUser()); + System.out.println("pgtIou: " + sv.getPgtIou()); + } else { + System.out.println("error code: " + sv.getErrorCode()); + System.out.println("error message: " + sv.getErrorMessage()); + } + + } + + public void setCasValidateUrl(String x) { + this.casValidateUrl = x; + } + + public String getCasValidateUrl() { + return this.casValidateUrl; + } + + public void setProxyCallbackUrl(String x) { + this.proxyCallbackUrl = x; + } + + public void setRenew(boolean b) { + this.renew = b; + } + + public String getProxyCallbackUrl() { + return this.proxyCallbackUrl; + } + + public void setServiceTicket(String x) { + this.st = x; + } + + public void setService(String x) { + this.service = x; + } + + public String getUser() { + return this.user; + } + + public String getPgtIou() { + return this.pgtIou; + } + + public boolean isAuthenticationSuccesful() { + return this.successfulAuthentication; + } + + public String getErrorMessage() { + return this.errorMessage; + } + + public String getErrorCode() { + return this.errorCode; + } + + public String getResponse() { + return this.entireResponse; + } + + public void validate() throws IOException, SAXException, ParserConfigurationException { + if (this.casValidateUrl != null && this.st != null) { + this.clear(); + this.attemptedAuthentication = true; + StringBuffer sb = new StringBuffer(); + sb.append(this.casValidateUrl); + if (this.casValidateUrl.indexOf(63) == -1) { + sb.append('?'); + } else { + sb.append('&'); + } + + sb.append("service=" + this.service + "&ticket=" + this.st); + if (this.proxyCallbackUrl != null) { + sb.append("&pgtUrl=" + this.proxyCallbackUrl); + } + + if (this.renew) { + sb.append("&renew=true"); + } + + String url = sb.toString(); + this.ss = url; + String response = SecureURL.retrieve(url); + this.entireResponse = response; + if (response != null) { + XMLReader r = SAXParserFactory.newInstance().newSAXParser().getXMLReader(); + r.setFeature("http://xml.org/sax/features/namespaces", false); + r.setContentHandler(this.newHandler()); + r.parse(new InputSource(new StringReader(response))); + } + + } else { + throw new IllegalStateException("must set validation URL and ticket"); + } + } + + protected DefaultHandler newHandler() { + return new Handler(); + } + + protected void clear() { + this.user = this.pgtIou = this.errorMessage = null; + this.attemptedAuthentication = false; + this.successfulAuthentication = false; + } + + protected class Handler extends DefaultHandler { + protected static final String AUTHENTICATION_SUCCESS = "cas:authenticationSuccess"; + protected static final String AUTHENTICATION_FAILURE = "cas:authenticationFailure"; + protected static final String PROXY_GRANTING_TICKET = "cas:proxyGrantingTicket"; + protected static final String USER = "cas:user"; + protected StringBuffer currentText = new StringBuffer(); + protected boolean authenticationSuccess = false; + protected boolean authenticationFailure = false; + protected String netid; + protected String pgtIou; + protected String errorCode; + protected String errorMessage; + + protected Handler() { + } + + public void startElement(String ns, String ln, String qn, Attributes a) { + this.currentText = new StringBuffer(); + if (qn.equals("cas:authenticationSuccess")) { + this.authenticationSuccess = true; + } else if (qn.equals("cas:authenticationFailure")) { + this.authenticationFailure = true; + this.errorCode = a.getValue("code"); + if (this.errorCode != null) { + this.errorCode = this.errorCode.trim(); + } + } + + } + + public void characters(char[] ch, int start, int length) { + this.currentText.append(ch, start, length); + } + + public void endElement(String ns, String ln, String qn) throws SAXException { + if (this.authenticationSuccess) { + if (qn.equals("cas:user")) { + ServiceTicketValidator.this.user = this.currentText.toString().trim(); + } + + if (qn.equals("cas:proxyGrantingTicket")) { + this.pgtIou = this.currentText.toString().trim(); + } + } else if (this.authenticationFailure && qn.equals("cas:authenticationFailure")) { + this.errorMessage = this.currentText.toString().trim(); + } + + } + + public void endDocument() throws SAXException { + if (this.authenticationSuccess) { + ServiceTicketValidator.this.user = ServiceTicketValidator.this.user; + ServiceTicketValidator.this.pgtIou = this.pgtIou; + ServiceTicketValidator.this.successfulAuthentication = true; + } else { + if (!this.authenticationFailure) { + throw new SAXException("no indication of success or failure from CAS"); + } + + ServiceTicketValidator.this.errorMessage = this.errorMessage; + ServiceTicketValidator.this.errorCode = this.errorCode; + ServiceTicketValidator.this.successfulAuthentication = false; + } + + } + } +} diff --git a/src/main/java/dev/flyfish/boot/cas/validator/XmlUtils.java b/src/main/java/dev/flyfish/boot/cas/validator/XmlUtils.java new file mode 100644 index 0000000..68a0cce --- /dev/null +++ b/src/main/java/dev/flyfish/boot/cas/validator/XmlUtils.java @@ -0,0 +1,111 @@ +package dev.flyfish.boot.cas.validator; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.xml.sax.Attributes; +import org.xml.sax.InputSource; +import org.xml.sax.SAXException; +import org.xml.sax.XMLReader; +import org.xml.sax.helpers.DefaultHandler; +import org.xml.sax.helpers.XMLReaderFactory; + +import java.io.StringReader; +import java.util.ArrayList; +import java.util.List; + +public final class XmlUtils { + private static final Log LOG = LogFactory.getLog(XmlUtils.class); + + public static XMLReader getXmlReader() { + try { + return XMLReaderFactory.createXMLReader(); + } catch (SAXException var1) { + SAXException e = var1; + throw new RuntimeException("Unable to create XMLReader", e); + } + } + + public static List getTextForElements(String xmlAsString, final String element) { + final List elements = new ArrayList(2); + XMLReader reader = getXmlReader(); + DefaultHandler handler = new DefaultHandler() { + private boolean foundElement = false; + private StringBuffer buffer = new StringBuffer(); + + public void startElement(String uri, String localName, String qName, Attributes attributes) throws SAXException { + if (localName.equals(element)) { + this.foundElement = true; + } + + } + + public void endElement(String uri, String localName, String qName) throws SAXException { + if (localName.equals(element)) { + this.foundElement = false; + elements.add(this.buffer.toString()); + this.buffer = new StringBuffer(); + } + + } + + public void characters(char[] ch, int start, int length) throws SAXException { + if (this.foundElement) { + this.buffer.append(ch, start, length); + } + + } + }; + reader.setContentHandler(handler); + reader.setErrorHandler(handler); + + try { + reader.parse(new InputSource(new StringReader(xmlAsString))); + return elements; + } catch (Exception var6) { + Exception e = var6; + LOG.error(e, e); + return null; + } + } + + public static String getTextForElement(String xmlAsString, final String element) { + XMLReader reader = getXmlReader(); + final StringBuffer buffer = new StringBuffer(); + DefaultHandler handler = new DefaultHandler() { + private boolean foundElement = false; + + public void startElement(String uri, String localName, String qName, Attributes attributes) throws SAXException { + if (localName.equals(element)) { + this.foundElement = true; + } + + } + + public void endElement(String uri, String localName, String qName) throws SAXException { + if (localName.equals(element)) { + this.foundElement = false; + } + + } + + public void characters(char[] ch, int start, int length) throws SAXException { + if (this.foundElement) { + buffer.append(ch, start, length); + } + + } + }; + reader.setContentHandler(handler); + reader.setErrorHandler(handler); + + try { + reader.parse(new InputSource(new StringReader(xmlAsString))); + } catch (Exception var6) { + Exception e = var6; + LOG.error(e, e); + return null; + } + + return buffer.toString(); + } +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index abb42bc..189d57d 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -9,6 +9,6 @@ cas: filter: cas-login: https://sdsfzt.sxu.edu.cn/authserver/login cas-validate: https://sdsfzt.sxu.edu.cn/authserver/serviceValidate - cas-server-name: aef8-218-26-163-214.ngrok-free.app + cas-server-name: https://magnetic-first-yak.ngrok-free.app cas-init-context-class: dev.flyfish.boot.cas.filter.CASLoginFilter debug: true