RestUtilities.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */

  21. package org.openspcoop2.message.rest;

  23. import java.net.MalformedURLException;
  24. import java.net.URL;
  25. import java.util.HashMap;
  26. import java.util.List;
  27. import java.util.Map;

  29. import org.openspcoop2.message.constants.Costanti;
  30. import org.openspcoop2.utils.transport.TransportRequestContext;
  31. import org.openspcoop2.utils.transport.TransportUtils;
  32. import org.openspcoop2.utils.transport.http.HttpServletTransportRequestContext;
  33. import org.slf4j.Logger;

  35. /**
  36.  * RestUtilities
  37.  *
  38.  * @author Poli Andrea (apoli@link.it)
  39.  * @author $Author$
  40.  * @version $Rev$, $Date$
  41.  */
  42. public class RestUtilities {

  44.     public static String getUrlWithoutInterface(TransportRequestContext requestContext, String normalizedInterfaceName) {
  45.         String resourcePath = requestContext.getFunctionParameters();
  46.         if(resourcePath!=null){
  47.             if(resourcePath.startsWith("/")){
  48.                 resourcePath = resourcePath.substring(1);
  49.             }
  50.             if(requestContext.getInterfaceName()!=null) {
  51.                 if(resourcePath.startsWith(requestContext.getInterfaceName())){
  52.                     resourcePath = resourcePath.substring(requestContext.getInterfaceName().length());
  53.                 }       
  54.                 else if(normalizedInterfaceName!=null && resourcePath.startsWith(normalizedInterfaceName)){
  55.                     resourcePath = resourcePath.substring(normalizedInterfaceName.length());
  56.                 }
  57.             }
  58.         }
  59.         return resourcePath;
  60.     }
  61.     
  62.     public static String buildUrl(Logger log, String url,Map<String, List<String>>  p,TransportRequestContext requestContext, String normalizedInterfaceName){
  63.         
  64.         String baseUrl = url;
  65.         String parameterOriginalUrl = null;
  66.         if(url.contains("?")){
  67.             baseUrl = url.split("\\?")[0];
  68.             if(baseUrl!=null){
  69.                 baseUrl = baseUrl.trim();
  70.             }
  71.             parameterOriginalUrl = url.split("\\?")[1]; 
  72.             if(parameterOriginalUrl!=null){
  73.                 parameterOriginalUrl = parameterOriginalUrl.trim();
  74.             }
  75.         }
  76.         
  77.         StringBuilder newUrl = new StringBuilder();
  78.         newUrl.append(baseUrl);
  79.         
  80.         if(requestContext!=null){
  81.             String resourcePath = getUrlWithoutInterface(requestContext,normalizedInterfaceName);
  82.             if(resourcePath!=null){
  83.                 boolean extraPathApplicativoStartWithSlash = false;
  84.                 if(resourcePath.startsWith("/")){
  85.                     extraPathApplicativoStartWithSlash = true;
  86.                     // Lo elimino in modo da evitare doppi '//' se anche il baseUrl finisce con '/'
  87.                     resourcePath = resourcePath.substring(1);
  88.                 }
  89.                 if(resourcePath!=null && !"".equals(resourcePath)){
  90.                     // // extra path contiene ulteriori dati da aggiungere alla url
  91.                     if(baseUrl.endsWith("/")==false){
  92.                         newUrl.append("/");
  93.                     }
  94.                     newUrl.append(resourcePath);
  95.                 }
  96.                 else {
  97.                     if(extraPathApplicativoStartWithSlash) {
  98.                         if(baseUrl.endsWith("/")==false){
  99.                             // extra path terminava semplicemente con '/'. Questo slash va ripristinato poiche' e' importante per l'index
  100.                             newUrl.append("/");
  101.                         }
  102.                     }
  103.                 }
  104.             }
  105.         }
  106.                 
  107.         if(parameterOriginalUrl!=null){
  108.             String [] split = parameterOriginalUrl.split("&");
  109.             if(split!=null){
  110.                 if(p==null){
  111.                     p = new HashMap<> ();
  112.                 }
  113.                 
  114.                 // elimino tutte le proprieta' che sono poi indicate nella base url
  115.                 for (int i = 0; i < split.length; i++) {
  116.                     if(split[i].contains("=")){
  117.                         int indexOf = split[i].indexOf("=");
  118.                         
  119.                         String nome = null;
  120.                         if(indexOf>0) {
  121.                             nome = split[i].substring(0, indexOf);
  122.                         }
  123.                         if(nome!=null){
  124.                             nome = nome.trim();
  125.                         }
  126.                         
  127.                         if(nome!=null){
  128.                             TransportUtils.removeRawObject(p, nome);
  129.                         }
  130.                     }
  131.                 }
  132.                 
  133.                 // adesso le aggiungo
  134.                 for (int i = 0; i < split.length; i++) {
  135.                     if(split[i].contains("=")){
  136.                         int indexOf = split[i].indexOf("=");
  137.                         
  138.                         String nome = null;
  139.                         if(indexOf>0) {
  140.                             nome = split[i].substring(0, indexOf);
  141.                         }
  142.                         if(nome!=null){
  143.                             nome = nome.trim();
  144.                         }
  145.                         
  146.                         String valore = null;
  147.                         if((indexOf+1)<=((split[i].length()-1))) {
  148.                             valore = split[i].substring((indexOf+1));
  149.                         }
  150.                         if(valore!=null){
  151.                             valore = valore.trim();
  152.                         }
  153.                         else {
  154.                             valore = "";
  155.                         }
  156.                         
  157.                         if(nome!=null && valore!=null){
  158.                             TransportUtils.addParameter(p, nome, valore);
  159.                         }
  160.                         
  161.                     }
  162.                 }
  163.             }
  164.         }
  165.         
  166.         return TransportUtils.buildUrlWithParameters(p, newUrl.toString(), log);
  167.         
  168.     }
  169.     
  170.     public static String buildPassReverseUrl(TransportRequestContext transportRequestContext, String baseUrl, String redirectLocationUrlParam, String prefixGatewayUrl,
  171.             String interfaceName) throws MalformedURLException {
  172.                
  173.         String r = baseUrl;
  174.         if(r.contains("?")) {
  175.             r = baseUrl.split("\\?")[0];
  176.         }
  177.          
  178.         URL uri = new URL(r);
  179.         String rRelative= uri.getPath();
  180.         
  181.         String redirectLocationUrl = null;
  182.         String redirectLocationUrlParameters = null;
  183.         if(redirectLocationUrlParam.contains("?")) {
  184.             String [] tmp = redirectLocationUrlParam.split("\\?");
  185.             redirectLocationUrl = tmp[0];
  186.             if(tmp.length>1) {
  187.                 StringBuilder sbc = new StringBuilder();
  188.                 for (int i = 1; i < tmp.length; i++) {
  189.                     if(sbc.length()>0) {
  190.                         sbc.append("?");
  191.                     }
  192.                     sbc.append(tmp[i]);
  193.                 }
  194.                 redirectLocationUrlParameters = sbc.toString();
  195.             }
  196.         }
  197.         else {
  198.             redirectLocationUrl = redirectLocationUrlParam;
  199.         }
  200.         if(redirectLocationUrl.endsWith("/")) {
  201.             if(!r.endsWith("/")) {
  202.                 r = r + "/";
  203.             }
  204.             if(!rRelative.endsWith("/")) {
  205.                 rRelative = rRelative + "/";
  206.             }
  207.         }
  208.         else {
  209.             if(r.endsWith("/")) {
  210.                 r = r.length()<=1 ? "" : r.substring(0,r.length()-1);
  211.             }
  212.             if(rRelative.endsWith("/")) {
  213.                 rRelative = rRelative.length()<=1 ? "" : rRelative.substring(0,rRelative.length()-1);
  214.             }
  215.         }
  216.         
  217.         if(redirectLocationUrl.startsWith(r) || redirectLocationUrl.startsWith(rRelative)) {
  218.             
  219. //          if(redirectLocationUrl.startsWith(r)) {
  220. //              System.out.println("AbsoluteURL redirect["+redirectLocationUrl+"]");
  221. //          }
  222. //          else {
  223. //              System.out.println("RelativeURL redirect["+redirectLocationUrl+"]");
  224. //          }
  225.             
  226.             String contextPath = null;
  227.             if(prefixGatewayUrl==null) {
  228.                 // Context path rappresenta il prefisso della richiesta contenente il contesto dell'applicazione (es. /openspcoop2),
  229.                 // il protocollo e il servizio. Ad esempio /govway/spcoop/out
  230.                 contextPath = transportRequestContext.getWebContext();
  231.                 if(contextPath.endsWith("/")==false) {
  232.                     contextPath = contextPath + "/";
  233.                 }
  234.                 String protocollo = transportRequestContext.getProtocolWebContext();
  235.                 if(Costanti.CONTEXT_EMPTY.equals(protocollo)==false) {
  236.                     contextPath = contextPath + protocollo + "/";
  237.                 }
  238.                 contextPath = contextPath + transportRequestContext.getFunction();
  239.             }
  240.             
  241.             // Il suffisso contiene la parte della url ritornata dalla redirect senza la parte iniziale rappresentata dalla base url del servizio
  242.             String suffix = "";
  243.             if(redirectLocationUrl.startsWith(r)) {
  244.                 if(redirectLocationUrl.equals(r)==false) {
  245.                     suffix=redirectLocationUrl.substring(r.length());
  246.                 }
  247.             }
  248.             else {
  249.                 if(redirectLocationUrl.equals(rRelative)==false) {
  250.                     suffix=redirectLocationUrl.substring(rRelative.length());
  251.                 }
  252.             }
  253.             
  254.             // Viene costruita una nuova url contenente la richiesta iniziale e il nuovo suffisso,
  255.             // in modo che la url ritornata tramite la redirect possa contenere una nuova url che viene veicolata nuovamente sulla PdD
  256.             StringBuilder bf = new StringBuilder();
  257.             if(redirectLocationUrl.startsWith(r)) {
  258.                 // absolute
  259.                 if(prefixGatewayUrl!=null) {
  260.                     prefixGatewayUrl = prefixGatewayUrl.trim();
  261.                     bf.append(prefixGatewayUrl);
  262.                     if(prefixGatewayUrl.endsWith("/")==false) {
  263.                         bf.append("/");
  264.                     }
  265.                 }
  266.                 else {
  267.                     bf.append(contextPath);
  268.                     if(contextPath.endsWith("/")==false) {
  269.                         bf.append("/");
  270.                     }
  271.                 }
  272.             }
  273.             else {
  274.                 // relative
  275.                 if(prefixGatewayUrl!=null) {
  276.                     URL urlPrefixGatewayUrl = new URL(prefixGatewayUrl);
  277.                     String urlPrefixGatewayUrlAsString = urlPrefixGatewayUrl.getPath();
  278.                     bf.append(urlPrefixGatewayUrlAsString);
  279.                     if(urlPrefixGatewayUrlAsString.endsWith("/")==false) {
  280.                         bf.append("/");
  281.                     }
  282.                 }
  283.                 else {
  284.                     bf.append(contextPath);
  285.                     if(contextPath.endsWith("/")==false) {
  286.                         bf.append("/");
  287.                     }
  288.                 }
  289.             }
  290.             String interfaceNameTmp = null;
  291.             if(interfaceName!=null) {
  292.                 interfaceNameTmp = interfaceName;
  293.             }
  294.             else {
  295.                 interfaceNameTmp = transportRequestContext.getInterfaceName();
  296.             }
  297.             if(interfaceNameTmp!=null) {
  298.                 if(interfaceNameTmp.startsWith("/")) {
  299.                     if(interfaceNameTmp.length()>1) {
  300.                         bf.append(interfaceNameTmp.substring(1));
  301.                     }
  302.                 }
  303.                 else {
  304.                     bf.append(interfaceNameTmp);
  305.                 }
  306.             }
  307.             
  308.             
  309.             if(suffix.equals("")) {
  310.                 if(redirectLocationUrl.endsWith("/")) {
  311.                     if(!bf.toString().endsWith("/")) {
  312.                         bf.append("/");
  313.                     }
  314.                 }
  315.             }
  316.             else {
  317.                 if(suffix.startsWith("/")==false) {
  318.                     bf.append("/");
  319.                 }
  320.                 bf.append(suffix);
  321.             }
  322.             
  323. //          if(redirectLocationUrl.startsWith(r)) {
  324. //              System.out.println("AbsoluteURL new["+bf.toString()+"]");
  325. //          }
  326. //          else {
  327. //              System.out.println("RelativeURL new["+bf.toString()+"]");
  328. //          }       
  329.             
  330.             String url = bf.toString();
  331.             if(redirectLocationUrlParameters!=null && !"".equals(redirectLocationUrlParameters)) {
  332.                 if(url.contains("?")) {
  333.                     url = url + "&";
  334.                 }
  335.                 else {
  336.                     url = url + "?";
  337.                 }
  338.                 url = url + redirectLocationUrlParameters;
  339.             }
  340.             
  341.             return url;
  342.             
  343.         }
  344.         else {
  345.             
  346. //          System.out.println("ProxyPass nop redirect["+redirectLocationUrl+"] relative["+rRelative+"] absolute["+r+"]");
  347.             
  348.             return redirectLocationUrlParam;
  349.         }
  350.     }

  352.     public static String buildCookiePassReversePath(TransportRequestContext transportRequestContext, String baseUrl, String cookiePathParam, String prefixGatewayUrl,
  353.             String interfaceName) throws MalformedURLException {
  354.         
  355.         String r = baseUrl;
  356.         if(r.contains("?")) {
  357.             r = baseUrl.split("\\?")[0];
  358.         }
  359.          
  360.         URL uri = new URL(r);
  361.         String rRelative= uri.getPath();
  362.         
  363.         String cookiePath = null;
  364.         String cookieParameters = null;
  365.         if(cookiePathParam.contains("?")) {
  366.             String [] tmp = cookiePathParam.split("\\?");
  367.             cookiePath = tmp[0];
  368.             if(tmp.length>1) {
  369.                 StringBuilder sbc = new StringBuilder();
  370.                 for (int i = 1; i < tmp.length; i++) {
  371.                     if(sbc.length()>0) {
  372.                         sbc.append("?");
  373.                     }
  374.                     sbc.append(tmp[i]);
  375.                 }
  376.                 cookieParameters = sbc.toString();
  377.             }
  378.         }
  379.         else {
  380.             cookiePath = cookiePathParam;
  381.         }
  382.         if(cookiePath.endsWith("/")) {
  383.             if(!rRelative.endsWith("/")) {
  384.                 rRelative = rRelative + "/";
  385.             }
  386.         }
  387.         else {
  388.             if(rRelative.endsWith("/")) {
  389.                 rRelative = rRelative.length()<=1 ? "" : rRelative.substring(0,rRelative.length()-1);
  390.             }
  391.         }
  392.         
  393.         if(cookiePath.startsWith(rRelative)) {
  394.             
  395.             //System.out.println("Cookie - RelativeURL redirect["+cookiePath+"]");
  396.             
  397.             String contextPath = null;
  398.             if(prefixGatewayUrl==null) {
  399.                 // Context path rappresenta il prefisso della richiesta contenente il contesto dell'applicazione (es. /openspcoop2),
  400.                 // il protocollo e il servizio. Ad esempio /govway/spcoop/out
  401.                 contextPath = transportRequestContext.getWebContext();
  402.                 if(contextPath.endsWith("/")==false) {
  403.                     contextPath = contextPath + "/";
  404.                 }
  405.                 String protocollo = transportRequestContext.getProtocolWebContext();
  406.                 if(Costanti.CONTEXT_EMPTY.equals(protocollo)==false) {
  407.                     contextPath = contextPath + protocollo + "/";
  408.                 }
  409.                 contextPath = contextPath + transportRequestContext.getFunction();
  410.             }
  411.             
  412.             // Il suffisso contiene la parte della url ritornata dalla redirect senza la parte iniziale rappresentata dalla base url del servizio
  413.             String suffix = "";
  414.             if(cookiePath.equals(rRelative)==false) {
  415.                 suffix=cookiePath.substring(rRelative.length());
  416.             }
  417.             
  418.             // Viene costruita una nuova url contenente la richiesta iniziale e il nuovo suffisso,
  419.             // in modo che la url ritornata tramite la redirect possa contenere una nuova url che viene veicolata nuovamente sulla PdD
  420.             StringBuilder bf = new StringBuilder();
  421.             // relative
  422.             if(prefixGatewayUrl!=null) {
  423.                 URL urlPrefixGatewayUrl = new URL(prefixGatewayUrl);
  424.                 String urlPrefixGatewayUrlAsString = urlPrefixGatewayUrl.getPath();
  425.                 bf.append(urlPrefixGatewayUrlAsString);
  426.                 if(urlPrefixGatewayUrlAsString.endsWith("/")==false) {
  427.                     bf.append("/");
  428.                 }
  429.             }
  430.             else {
  431.                 bf.append(contextPath);
  432.                 if(contextPath.endsWith("/")==false) {
  433.                     bf.append("/");
  434.                 }
  435.             }

  437.             String interfaceNameTmp = null;
  438.             if(interfaceName!=null) {
  439.                 interfaceNameTmp = interfaceName;
  440.             }
  441.             else {
  442.                 interfaceNameTmp = transportRequestContext.getInterfaceName();
  443.             }
  444.             if(interfaceNameTmp!=null) {
  445.                 if(interfaceNameTmp.startsWith("/")) {
  446.                     if(interfaceNameTmp.length()>1) {
  447.                         bf.append(interfaceNameTmp.substring(1));
  448.                     }
  449.                 }
  450.                 else {
  451.                     bf.append(interfaceNameTmp);
  452.                 }
  453.             }
  454.             
  455.             if(suffix.equals("")) {
  456.                 if(cookiePath.endsWith("/")) {
  457.                     if(!bf.toString().endsWith("/")) {
  458.                         bf.append("/");
  459.                     }
  460.                 }
  461.             }
  462.             else {
  463.                 if(suffix.startsWith("/")==false) {
  464.                     bf.append("/");
  465.                 }
  466.                 bf.append(suffix);
  467.             }
  468.             
  469.             //System.out.println("Cookie relativeURL new["+bf.toString()+"]");
  470.                 
  471.             String url = bf.toString();
  472.             if(cookieParameters!=null && !"".equals(cookieParameters)) {
  473.                 if(url.contains("?")) {
  474.                     url = url + "&";
  475.                 }
  476.                 else {
  477.                     url = url + "?";
  478.                 }
  479.                 url = url + cookieParameters;
  480.             }
  481.             
  482.             return url;
  483.             
  484.         }
  485.         else {
  486.             
  487. //          System.out.println("ProxyPass nop cookiePath["+cookiePath+"] relative["+rRelative+"] absolute["+r+"]");
  488.             
  489.             return cookiePath;
  490.         }
  491.     }
  492.     
  493.     public static String buildCookiePassReverseDomain(TransportRequestContext transportRequestContext, String baseUrl, String cookieDomain, String prefixGatewayUrl) throws MalformedURLException {
  494.                
  495.         String r = baseUrl;
  496.         if(r.contains("?")) {
  497.             r = baseUrl.split("\\?")[0];
  498.         }
  499.          
  500.         URL uri = new URL(r);
  501.         String rDomain= uri.getHost();
  502.         
  503.         if(cookieDomain!=null && cookieDomain.equalsIgnoreCase(rDomain)) {
  504.             
  505.             //System.out.println("CookieDomain cookieDomain["+cookieDomain+"]");
  506.             
  507.             String newDomain = null;
  508.             if(prefixGatewayUrl==null) {
  509.                 if(transportRequestContext!=null && transportRequestContext instanceof HttpServletTransportRequestContext) {
  510.                     HttpServletTransportRequestContext http = (HttpServletTransportRequestContext) transportRequestContext;
  511.                     if(http.getHttpServletRequest()!=null) {
  512.                         String requestUrl = http.getHttpServletRequest().getRequestURL().toString();
  513.                         URL uriRequestUrl = new URL(requestUrl);
  514.                         newDomain = uriRequestUrl.getHost();
  515.                     }
  516.                 }
  517.             }
  518.             else {
  519.                 URL uriRequestUrl = new URL(prefixGatewayUrl);
  520.                 newDomain = uriRequestUrl.getHost();
  521.             }

  523.             if(newDomain!=null) {
  524.                 
  525.                 //System.out.println("ProxyPass cookieDomain["+cookieDomain+"] newCookieDomain["+newDomain+"]");
  526.                 
  527.                 return newDomain;
  528.             }
  529.             else {
  530.                 
  531. //              System.out.println("ProxyPass nop cookieDomain["+cookieDomain+"]");
  532.             
  533.                 return cookieDomain;
  534.             }
  535.             
  536.         }
  537.         else {
  538.             
  539. //          System.out.println("ProxyPass nop cookieDomain["+cookieDomain+"]");
  540.             
  541.             return cookieDomain;
  542.         }
  543.     }
  544. }
Created with JaCoCo 0.8.8.202204050719