ServizioApplicativoContentBasedBehaviour.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.  */
  20. package org.openspcoop2.pdd.core.behaviour.built_in;

  22. import org.openspcoop2.core.config.PortaApplicativa;
  23. import org.openspcoop2.core.config.Proprieta;
  24. import org.openspcoop2.core.id.IDPortaApplicativa;
  25. import org.openspcoop2.core.id.IDServizioApplicativo;
  26. import org.openspcoop2.core.id.IDSoggetto;
  27. import org.openspcoop2.message.OpenSPCoop2Message;
  28. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  29. import org.openspcoop2.message.OpenSPCoop2RestJsonMessage;
  30. import org.openspcoop2.message.OpenSPCoop2RestXmlMessage;
  31. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  32. import org.openspcoop2.message.constants.MessageType;
  33. import org.openspcoop2.message.constants.ServiceBinding;
  34. import org.openspcoop2.message.xml.XPathExpressionEngine;
  35. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  36. import org.openspcoop2.pdd.core.AbstractCore;
  37. import org.openspcoop2.pdd.core.GestoreMessaggi;
  38. import org.openspcoop2.pdd.core.GestoreMessaggiException;
  39. import org.openspcoop2.pdd.core.behaviour.Behaviour;
  40. import org.openspcoop2.pdd.core.behaviour.BehaviourEmitDiagnosticException;
  41. import org.openspcoop2.pdd.core.behaviour.BehaviourException;
  42. import org.openspcoop2.pdd.core.behaviour.BehaviourForwardTo;
  43. import org.openspcoop2.pdd.core.behaviour.BehaviourForwardToFilter;
  44. import org.openspcoop2.pdd.core.behaviour.IBehaviour;
  45. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  46. import org.openspcoop2.protocol.sdk.Busta;
  47. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  48. import org.openspcoop2.utils.xml.AbstractXPathExpressionEngine;
  49. import org.openspcoop2.utils.xml2json.JsonXmlPathExpressionEngine;
  50. import org.w3c.dom.Element;

  52. /**
  53.  * ServizioApplicativoBustaBehaviour
  54.  *
  55.  * @author Andrea Poli (apoli@link.it)
  56.  * @author $Author$
  57.  * @version $Rev$, $Date$
  58.  */
  59. public class ServizioApplicativoContentBasedBehaviour extends AbstractCore implements IBehaviour {

  61.     private static final String PATTERN_GENERICO = "pattern";
  62.     private static final String PATTERN_MODE_NOT_FOUND = "notFound";
  63.     private static final String PATTERN_MODE_PREFIX_SA_NAME = "prefix";
  64.     private static final String PATTERN_MODE_SUFFIX_SA_NAME = "suffix";
  65.     private static final String PATTERN_SA_DEFAULT = "saDefault";
  66.     
  67.     @Override
  68.     public Behaviour behaviour(GestoreMessaggi gestoreMessaggioRichiesta, Busta busta,
  69.             PortaApplicativa pa, RequestInfo requestInfo) throws BehaviourException,BehaviourEmitDiagnosticException {
  70.         
  71.         Behaviour behaviour = null;
  72.         BehaviourForwardTo forwardTo = null;
  73.         try{
  74.             behaviour = new Behaviour();
  75.             forwardTo = new BehaviourForwardTo();
  76.             behaviour.getForwardTo().add(forwardTo);
  77.             
  78.             if(busta==null) {
  79.                 throw new BehaviourException("Param busta is null");
  80.             }
  81.             
  82.             BehaviourForwardToFilter filter = new BehaviourForwardToFilter();
  83.             IDServizioApplicativo id = new IDServizioApplicativo();
  84.             id.setIdSoggettoProprietario(new IDSoggetto(busta.getTipoDestinatario(),busta.getDestinatario()));
  85.             
  86.             if(pa==null && requestInfo!=null && requestInfo.getProtocolContext()!=null) {
  87.                 String nomePA = requestInfo.getProtocolContext().getInterfaceName();
  88.                 IDPortaApplicativa idPA = new IDPortaApplicativa();
  89.                 idPA.setNome(nomePA);
  90.                 ConfigurazionePdDManager configPdDManager = ConfigurazionePdDManager.getInstance(gestoreMessaggioRichiesta.getOpenspcoopstate()!=null ? gestoreMessaggioRichiesta.getOpenspcoopstate().getStatoRichiesta() : null);
  91.                 pa = configPdDManager.getPortaApplicativaSafeMethod(idPA, requestInfo);
  92.             }
  93.             
  94.             String azione = null;
  95.             if(busta!=null) {
  96.                 azione = busta.getAzione();
  97.             }
  98.             
  99.             String pattern = null;
  100.             String patternDefault = null;
  101.             NotFoundMode notFoundMode = NotFoundMode.error;
  102.             String prefix = null;
  103.             String suffix = null;
  104.             String saDefault = null;
  105.             if(pa!=null && pa.sizeProprietaList()>0) {
  106.                 for (Proprieta proprietaPA : pa.getProprietaList()) {
  107.                     String nomeProprietaPA = proprietaPA.getNome().trim().toLowerCase();
  108.                     if(PATTERN_GENERICO.toLowerCase().equals(nomeProprietaPA)) {
  109.                         patternDefault = proprietaPA.getValore();
  110.                     }
  111.                     else if(azione!=null && azione.toLowerCase().equals(nomeProprietaPA)) {
  112.                         pattern = proprietaPA.getValore();
  113.                     }
  114.                     else if(PATTERN_MODE_NOT_FOUND.toLowerCase().equals(nomeProprietaPA)) {
  115.                         notFoundMode = NotFoundMode.valueOf(proprietaPA.getValore().toLowerCase());
  116.                     }
  117.                     else if(PATTERN_MODE_PREFIX_SA_NAME.toLowerCase().equals(nomeProprietaPA)) {
  118.                         prefix = proprietaPA.getValore();
  119.                     }
  120.                     else if(PATTERN_MODE_SUFFIX_SA_NAME.toLowerCase().equals(nomeProprietaPA)) {
  121.                         suffix = proprietaPA.getValore();
  122.                     }
  123.                     else if(PATTERN_SA_DEFAULT.toLowerCase().equals(nomeProprietaPA)) {
  124.                         saDefault = proprietaPA.getValore();
  125.                     }
  126.                 }
  127.             }
  128.             
  129.             boolean found = false;
  130.             if(pattern!=null || patternDefault!=null) {
  131.                 
  132.                 Element element = null;
  133.                 String elementJson = null;
  134.                 OpenSPCoop2MessageFactory messageFactory = null;
  135.                 try{
  136.                     OpenSPCoop2Message message = gestoreMessaggioRichiesta.getMessage();
  137.                     messageFactory = message.getFactory();
  138.                     if(ServiceBinding.SOAP.equals(message.getServiceBinding())){
  139.                         OpenSPCoop2SoapMessage soapMessage = message.castAsSoap();
  140.                         element = soapMessage.getSOAPPart().getEnvelope();
  141.                     }
  142.                     else{
  143.                         if(MessageType.XML.equals(message.getMessageType())){
  144.                             OpenSPCoop2RestXmlMessage xml = message.castAsRestXml();
  145.                             element = xml.getContent(); 
  146.                         }
  147.                         else if(MessageType.JSON.equals(message.getMessageType())){
  148.                             OpenSPCoop2RestJsonMessage json = message.castAsRestJson();
  149.                             elementJson = json.getContent();
  150.                         }
  151.                     }
  152.                 }catch(Exception e){
  153.                     throw new GestoreMessaggiException(e.getMessage(),e);
  154.                 }
  155.                 
  156.                 String patternUsed = pattern;
  157.                 if(patternUsed==null) {
  158.                     patternUsed = patternDefault;
  159.                 }
  160.                 
  161.                 String saNome = null;
  162.                 try {
  163.                     if(element==null && elementJson==null){
  164.                         throw new Exception("Contenuto non disponibile su cui effettuare un match");
  165.                     }
  166.                     if(element!=null) {
  167.                         XPathExpressionEngine xPathEngine = new XPathExpressionEngine(messageFactory);
  168.                         saNome = AbstractXPathExpressionEngine.extractAndConvertResultAsString(element, xPathEngine, patternUsed, OpenSPCoop2Logger.getLoggerOpenSPCoopCore());
  169.                     }
  170.                     else {
  171.                         saNome = JsonXmlPathExpressionEngine.extractAndConvertResultAsString(elementJson, patternUsed, OpenSPCoop2Logger.getLoggerOpenSPCoopCore());
  172.                     }
  173.                     if(saNome==null) {
  174.                         throw new Exception("Nessun valore trovato");
  175.                     }
  176.                 }catch(Exception e) {
  177.                     String msgErrore = "Identificazione del Servizio Applicativo tramite pattern ["+patternUsed+"] fallita: "+e.getMessage();
  178.                     switch (notFoundMode) {
  179.                     case error:
  180.                         OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error(msgErrore,e);
  181.                         throw new Exception(msgErrore);
  182.                     case warning:
  183.                         OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error(msgErrore,e);
  184.                         break;
  185.                     case accept:
  186.                         OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug(msgErrore,e);
  187.                         break;
  188.                     }
  189.                     
  190.                 }
  191.                                 
  192.                 if(saNome!=null) {
  193.                 
  194.                     StringBuilder bf = new StringBuilder();
  195.                     if(prefix!=null) {
  196.                         bf.append(prefix);
  197.                     }
  198.                     bf.append(saNome);
  199.                     if(suffix!=null) {
  200.                         bf.append(suffix);
  201.                     }
  202.                     id.setNome(bf.toString());
  203.                     filter.getAccessListServiziApplicativi().add(id);
  204.                     forwardTo.setFilter(filter);
  205.                     
  206.                     found = true;
  207.                 }
  208.                     
  209.             }
  210.             
  211.             if(!found && saDefault!=null) {
  212.                 
  213.                 id.setNome(saDefault);
  214.                 filter.getAccessListServiziApplicativi().add(id);
  215.                 forwardTo.setFilter(filter);
  216.                 
  217.             }
  218.             
  219.         }catch(Exception e){
  220.             throw new BehaviourException(e.getMessage(),e);
  221.         }
  222.         
  223.         
  224.         return behaviour;
  225.     }

  227. }

  229. enum NotFoundMode{
  230.     
  231.     error, warning, accept
  232.     
  233. }
Created with JaCoCo 0.8.8.202204050719