AccordoServizioUtils.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.core.registry.driver;

  23. import java.io.File;
  24. import java.net.URL;
  25. import java.util.ArrayList;
  26. import java.util.HashMap;
  27. import java.util.List;
  28. import java.util.Map;

  30. import javax.xml.validation.Schema;

  32. import org.slf4j.Logger;
  33. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  34. import org.openspcoop2.core.registry.Documento;
  35. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  36. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  37. import org.openspcoop2.message.xml.MessageXMLUtils;
  38. import org.openspcoop2.utils.LoggerWrapperFactory;
  39. import org.openspcoop2.utils.resources.FileSystemUtilities;
  40. import org.openspcoop2.utils.transport.http.HttpUtilities;
  41. import org.openspcoop2.utils.wsdl.WSDLUtilities;
  42. import org.openspcoop2.utils.xml.AbstractXMLUtils;
  43. import org.openspcoop2.utils.xml.XSDSchemaCollection;
  44. import org.openspcoop2.utils.xml.XSDUtils;
  45. import org.w3c.dom.Document;
  46. import org.w3c.dom.Element;
  47. import org.w3c.dom.Node;

  49. /**
  50.  * AccordoServizioUtils
  51.  * 
  52.  * @author Andrea Poli (apoli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  *
  56.  */
  57. public class AccordoServizioUtils {

  59.     private Logger logger = null;
  60.     private AbstractXMLUtils xmlUtils = null;
  61.     private XSDUtils xsdUtils = null;
  62.     private OpenSPCoop2MessageFactory messageFactory;
  63.     public AccordoServizioUtils(OpenSPCoop2MessageFactory messageFactory, Logger log){
  64.         if(log!=null)
  65.             this.logger = log;
  66.         else
  67.             this.logger = LoggerWrapperFactory.getLogger(AccordoServizioUtils.class);
  68.         this.messageFactory = messageFactory;
  69.         this.xmlUtils = MessageXMLUtils.getInstance(this.messageFactory);
  70.         this.xsdUtils = new XSDUtils(this.xmlUtils);
  71.     }
  72.     
  73.     


  76.     
  77.     public Schema buildSchema(AccordoServizioParteComune as,boolean fromBytes) throws DriverRegistroServiziException {
  78.         XSDSchemaCollection schemaCollections = this.buildSchemaCollection(as, fromBytes);
  79.         try{
  80.             return schemaCollections.buildSchema(this.logger);
  81.         }catch(Exception e){
  82.             throw new DriverRegistroServiziException(e.getMessage(),e);
  83.         }
  84.     }
  85.     public XSDSchemaCollection buildSchemaCollection(AccordoServizioParteComune as,boolean fromBytes) throws DriverRegistroServiziException {

  87.         boolean definitorioPresente = false;
  88.         if(fromBytes){
  89.             definitorioPresente = as.getByteWsdlDefinitorio()!=null;
  90.         }else{
  91.             definitorioPresente = as.getWsdlDefinitorio()!=null;
  92.         }
  93.         
  94.         List<Node> schemiInWsdl = new ArrayList<Node>();
  95.         List<Node> schemiInWsdlFruitore = new ArrayList<Node>();
  96.         WSDLUtilities wsdlUtilities = null;
  97.         Document dWsdl = null;
  98.         Document dWsdlFruitore = null;
  99.         byte [] wsdl = null;
  100.         byte [] wsdlFruitore = null;
  101.         if(fromBytes){
  102.             if(as.getByteWsdlConcettuale()!=null){
  103.                 wsdl = as.getByteWsdlConcettuale();
  104.             }
  105.             else{
  106.                 if(as.getByteWsdlLogicoErogatore()!=null){
  107.                     wsdl = as.getByteWsdlLogicoErogatore();
  108.                 }
  109.                 if(as.getByteWsdlLogicoFruitore()!=null){
  110.                     wsdlFruitore = as.getByteWsdlLogicoFruitore();
  111.                 }
  112.             }
  113.         }
  114.         else{
  115.             if(as.getWsdlConcettuale()!=null){
  116.                 try{
  117.                     String location = as.getWsdlConcettuale();
  118.                     if(location.startsWith("http://") || location.startsWith("file://")){
  119.                         URL url = new URL(location);
  120.                         wsdl = HttpUtilities.requestHTTPFile(url.toString());
  121.                     }
  122.                     else{
  123.                         File f = new File(location);
  124.                         wsdl = FileSystemUtilities.readBytesFromFile(f);
  125.                     }
  126.                 }catch(Exception e){
  127.                     throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl concettuale corrotto: "+e.getMessage(),e);
  128.                 }
  129.             }
  130.             else{
  131.                 if(as.getWsdlLogicoErogatore()!=null){
  132.                     try{
  133.                         String location = as.getWsdlLogicoErogatore();
  134.                         if(location.startsWith("http://") || location.startsWith("file://")){
  135.                             URL url = new URL(location);
  136.                             wsdl = HttpUtilities.requestHTTPFile(url.toString());
  137.                         }
  138.                         else{
  139.                             File f = new File(location);
  140.                             wsdl = FileSystemUtilities.readBytesFromFile(f);
  141.                         }
  142.                     }catch(Exception e){
  143.                         throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl logico erogatore corrotto: "+e.getMessage(),e);
  144.                     }
  145.                 }
  146.                 if(as.getWsdlLogicoFruitore()!=null){
  147.                     try{
  148.                         String location = as.getWsdlLogicoFruitore();
  149.                         if(location.startsWith("http://") || location.startsWith("file://")){
  150.                             URL url = new URL(location);
  151.                             wsdlFruitore = HttpUtilities.requestHTTPFile(url.toString());
  152.                         }
  153.                         else{
  154.                             File f = new File(location);
  155.                             wsdlFruitore = FileSystemUtilities.readBytesFromFile(f);
  156.                         }
  157.                     }catch(Exception e){
  158.                         throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl logico fruitore corrotto: "+e.getMessage(),e);
  159.                     }
  160.                 }
  161.             }
  162.         }
  163.         if(wsdl!=null){
  164.             try{
  165.                 wsdlUtilities = new WSDLUtilities(this.xmlUtils);
  166.                 dWsdl = this.xmlUtils.newDocument(wsdl);
  167.                 List<Node> schemi = wsdlUtilities.getSchemiXSD(dWsdl);
  168.                 if(schemi!=null && schemi.size()>0){
  169.                     for (Node schema : schemi) {
  170.                         boolean schemaWithOnlyImport = this.xsdUtils.isSchemaWithOnlyImports(schema);
  171.                         if(schemaWithOnlyImport==false){
  172.                             schemiInWsdl.add(schema);       
  173.                         }
  174.                     }
  175.                 }
  176.             }catch(Exception e){
  177.                 throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl corrotto: "+e.getMessage(),e);
  178.             }
  179.         }
  180.         if(wsdlFruitore!=null){
  181.             try{
  182.                 wsdlUtilities = new WSDLUtilities(this.xmlUtils);
  183.                 dWsdlFruitore = this.xmlUtils.newDocument(wsdlFruitore);
  184.                 List<Node> schemi = wsdlUtilities.getSchemiXSD(dWsdlFruitore);
  185.                 if(schemi!=null && schemi.size()>0){
  186.                     for (Node schema : schemi) {
  187.                         boolean schemaWithOnlyImport = this.xsdUtils.isSchemaWithOnlyImports(schema);
  188.                         if(schemaWithOnlyImport==false){
  189.                             schemiInWsdlFruitore.add(schema);       
  190.                         }
  191.                     }
  192.                 }
  193.             }catch(Exception e){
  194.                 throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl fruitore corrotto: "+e.getMessage(),e);
  195.             }
  196.         }
  197.         
  198.         
  199.         if( (schemiInWsdl.size()<=0) && (schemiInWsdlFruitore.size()<=0) && (!definitorioPresente) && as.sizeAllegatoList()==0 && as.sizeSpecificaSemiformaleList()==0){
  200.             throw new DriverRegistroServiziException("L'accordo di servizio parte comune non contiene schemi XSD");
  201.         }

  203.         Map<String, byte[]> resources = new HashMap<String, byte[]>();
  204.         Map<String, List<String>> mappingNamespaceLocations = new HashMap<>();

  206.         
  207.         
  208.         // --------- WSDL CONCETTUALE/LOGICO EROGATORE ---------------------
  209.         if(schemiInWsdl.size()>0){

  211.             Map<String, String> declarationNamespacesWSDL = null;
  212.             try{
  213.                 declarationNamespacesWSDL = this.xmlUtils.getNamespaceDeclaration(dWsdl.getDocumentElement());
  214.             }catch(Exception e){
  215.                 throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl corrotto (Analisi namespace declarations): "+e.getMessage(),e);
  216.             }
  217.             for (int i = 0; i < schemiInWsdl.size(); i++) {
  218.                 Node schema = schemiInWsdl.get(i);
  219.                 try{
  220.                     if(declarationNamespacesWSDL!=null && declarationNamespacesWSDL.size()>0){
  221.                         this.xmlUtils.addNamespaceDeclaration(declarationNamespacesWSDL, (Element) schema);
  222.                     }
  223.                     byte[] resource = this.xmlUtils.toByteArray(schema); 
  224.                     String systemId = "internalWsdlTypes_"+(i+1)+".xsd";
  225.                     
  226.                     // registro risorsa con systemid
  227.                     //System.out.println("ADD CONCETTUALE ["+systemId+"] ");
  228.                     resources.put(systemId, resource);

  230.                     // registro namespace
  231.                     this.xsdUtils.registraMappingNamespaceLocations(resource, systemId, mappingNamespaceLocations);
  232.                     
  233.                 }catch(Exception e){
  234.                     throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl corrotto (Estrazione schema): "+e.getMessage(),e);
  235.                 }
  236.             }
  237.         }
  238.         
  239.         // --------- WSDL CONCETTUALE/LOGICO EROGATORE ---------------------
  240.         if(schemiInWsdlFruitore.size()>0){

  242.             Map<String, String> declarationNamespacesWSDL = null;
  243.             try{
  244.                 if(dWsdlFruitore!=null) {
  245.                     declarationNamespacesWSDL = this.xmlUtils.getNamespaceDeclaration(dWsdlFruitore.getDocumentElement());
  246.                 }
  247.             }catch(Exception e){
  248.                 throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl corrotto (Analisi namespace declarations): "+e.getMessage(),e);
  249.             }
  250.             for (int i = 0; i < schemiInWsdlFruitore.size(); i++) {
  251.                 Node schema = schemiInWsdlFruitore.get(i);
  252.                 try{
  253.                     if(declarationNamespacesWSDL!=null && declarationNamespacesWSDL.size()>0){
  254.                         this.xmlUtils.addNamespaceDeclaration(declarationNamespacesWSDL, (Element) schema);
  255.                     }
  256.                     byte[] resource = this.xmlUtils.toByteArray(schema); 
  257.                     String systemId = "internalWsdlFruitoreTypes_"+(i+1)+".xsd";
  258.                     
  259.                     // registro risorsa con systemid
  260.                     //System.out.println("ADD CONCETTUALE ["+systemId+"] ");
  261.                     resources.put(systemId, resource);

  263.                     // registro namespace
  264.                     this.xsdUtils.registraMappingNamespaceLocations(resource, systemId, mappingNamespaceLocations);
  265.                     
  266.                 }catch(Exception e){
  267.                     throw new DriverRegistroServiziException("L'accordo di servizio parte comune contiene un wsdl corrotto (Estrazione schema): "+e.getMessage(),e);
  268.                 }
  269.             }
  270.         }

  272.         // --------- WSDL DEFINITORIO ---------------------
  273.         if( (fromBytes && as.getByteWsdlDefinitorio()!=null) ||
  274.                 (!fromBytes && as.getWsdlDefinitorio()!=null)
  275.                 ){

  277.             byte[] resource = null;
  278.             String systemId = null;
  279.             if(fromBytes){
  280.                 systemId = CostantiRegistroServizi.ALLEGATO_DEFINITORIO_XSD;
  281.                 resource = as.getByteWsdlDefinitorio();
  282.             }else{
  283.                 String location = as.getWsdlDefinitorio();
  284.                 try{
  285.                     if(location.startsWith("http://") || location.startsWith("file://")){
  286.                         URL url = new URL(location);
  287.                         resource = HttpUtilities.requestHTTPFile(url.toString());
  288.                         systemId = (new File(url.getFile())).getName();
  289.                     }
  290.                     else{
  291.                         File f = new File(location);
  292.                         resource = FileSystemUtilities.readBytesFromFile(f);
  293.                         systemId = f.getName();
  294.                     }
  295.                 }catch(Exception e){
  296.                     throw new DriverRegistroServiziException("L'accordo di servizio parte comune indirizza un wsdl definitorio ["+location+"] non esistente");
  297.                 }
  298.             }

  300.             try{
  301.                 if(this.xsdUtils.isXSDSchema(resource)){

  303.                     // registro risorsa con systemid
  304.                     //System.out.println("ADD DEFINITIORIO ["+systemId+"] ");
  305.                     resources.put(systemId, resource);

  307.                     // registro namespace
  308.                     this.xsdUtils.registraMappingNamespaceLocations(resource, systemId, mappingNamespaceLocations);
  309.                 }
  310.             }catch(Exception e){
  311.                 throw new DriverRegistroServiziException("La lettura del wsdl definitorio ha causato un errore: "+e.getMessage(),e);
  312.             }
  313.         }

  315.         // --------- ALLEGATI --------- 
  316.         if(as.sizeAllegatoList()>0){
  317.             for(int i=0; i<as.sizeAllegatoList();i++){

  319.                 Documento allegato = as.getAllegato(i);
  320.                 byte[] resource = null;
  321.                 String systemId = null;
  322.                 //String location = null;
  323.                 if(fromBytes){
  324.                     //location = allegato.getFile();
  325.                     systemId = allegato.getFile();
  326.                     resource = allegato.getByteContenuto();
  327.                     if(resource==null){
  328.                         throw new DriverRegistroServiziException("Allegato ["+systemId+"] non contiene i bytes che ne definiscono il contenuto");
  329.                     }
  330.                 }
  331.                 else{
  332.                     String location = allegato.getFile();
  333.                     try{
  334.                         if(location.startsWith("http://") || location.startsWith("file://")){
  335.                             URL url = new URL(location);
  336.                             resource = HttpUtilities.requestHTTPFile(url.toString());
  337.                             systemId = (new File(url.getFile())).getName();
  338.                         }
  339.                         else{
  340.                             File f = new File(location);
  341.                             resource = FileSystemUtilities.readBytesFromFile(f);
  342.                             systemId = f.getName();
  343.                         }   
  344.                     }catch(Exception e){
  345.                         throw new DriverRegistroServiziException("Allegato ["+location+"] indirizza un documento non esistente");
  346.                     }
  347.                 }

  349.                 try{
  350.                     if(this.xsdUtils.isXSDSchema(resource)){

  352.                         if(resources.containsKey(systemId)){
  353.                             throw new Exception("Esiste più di un documento xsd, registrato tra allegati e specifiche semiformali, con nome ["+systemId+"] (La validazione xsd di OpenSPCoop richiede l'utilizzo di nomi diversi)");
  354.                         }
  355.                         resources.put(systemId,resource); 

  357.                         // registro namespace
  358.                         this.xsdUtils.registraMappingNamespaceLocations(resource, systemId, mappingNamespaceLocations);
  359.                     }
  360.                 }catch(Exception e){
  361.                     throw new DriverRegistroServiziException("La lettura dell'allegato ["+systemId+"] ha causato un errore: "+e.getMessage(),e);
  362.                 }

  364.             }
  365.         }


  368.         // --------- SPECIFICHE SEMIFORMALI --------- 
  369.         if(as.sizeSpecificaSemiformaleList()>0){
  370.             for(int i=0; i<as.sizeSpecificaSemiformaleList();i++){

  372.                 Documento specificaSemiformale = as.getSpecificaSemiformale(i);
  373.                 byte[] resource = null;
  374.                 String systemId = null;
  375.                 //String location = null;
  376.                 if(fromBytes){
  377.                     //location = specificaSemiformale.getFile();
  378.                     systemId = specificaSemiformale.getFile();
  379.                     resource = specificaSemiformale.getByteContenuto();
  380.                     if(resource==null){
  381.                         throw new DriverRegistroServiziException("Specifica Semiformale ["+systemId+"] non contiene i bytes che ne definiscono il contenuto");
  382.                     }
  383.                 }
  384.                 else{
  385.                     String location = specificaSemiformale.getFile();
  386.                     try{
  387.                         if(location.startsWith("http://") || location.startsWith("file://")){
  388.                             URL url = new URL(location);
  389.                             resource = HttpUtilities.requestHTTPFile(url.toString());
  390.                             systemId = (new File(url.getFile())).getName();
  391.                         }
  392.                         else{
  393.                             File f = new File(location);
  394.                             resource = FileSystemUtilities.readBytesFromFile(f);
  395.                             systemId = f.getName();
  396.                         }   
  397.                     }catch(Exception e){
  398.                         throw new DriverRegistroServiziException("Specifica Semiformale ["+location+"] indirizza un documento non esistente");
  399.                     }
  400.                 }

  402.                 try{
  403.                     if(this.xsdUtils.isXSDSchema(resource)){

  405.                         if(resources.containsKey(systemId)){
  406.                             throw new Exception("Esiste più di un documento xsd, registrato tra allegati e specifiche semiformali, con nome ["+systemId+"] (La validazione xsd di OpenSPCoop richiede l'utilizzo di nomi diversi)");
  407.                         }
  408.                         resources.put(systemId,resource); 

  410.                         // registro namespace
  411.                         this.xsdUtils.registraMappingNamespaceLocations(resource, systemId, mappingNamespaceLocations);
  412.                     }
  413.                 }catch(Exception e){
  414.                     throw new DriverRegistroServiziException("La lettura della specifica semiformale ["+systemId+"] ha causato un errore: "+e.getMessage(),e);
  415.                 }

  417.             }
  418.         }

  420.         try{
  421.             return this.xsdUtils.buildSchemaCollection(resources, mappingNamespaceLocations, this.logger);
  422.         }catch(Exception e){
  423.             throw new DriverRegistroServiziException(e.getMessage(),e);
  424.         }
  425.             
  426.     }

  428.     
  429. }
Created with JaCoCo 0.8.8.202204050719