XMLUtils.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.  */



  23. package it.gov.spcoop.sica.wsbl.driver;

  25. import it.cnipa.collprofiles.driver.XMLUtilsException;
  26. import it.gov.spcoop.sica.wsbl.ConceptualBehavior;
  27. import it.gov.spcoop.sica.wsbl.MessageBehavior;
  28. import it.gov.spcoop.sica.wsbl.TransitionType;

  30. import java.io.ByteArrayInputStream;
  31. import java.io.ByteArrayOutputStream;
  32. import java.io.File;
  33. import java.io.FileInputStream;
  34. import java.io.FileOutputStream;
  35. import java.io.InputStream;
  36. import java.io.OutputStream;

  38. import org.slf4j.Logger;
  39. import org.openspcoop2.utils.xml.AbstractXMLUtils;
  40. import org.openspcoop2.utils.xml.JaxbUtils;
  41. import org.openspcoop2.utils.xml.ValidatoreXSD;
  42. import org.w3c.dom.Document;
  43. import org.w3c.dom.Element;


  46. /**
  47.  * Classe utilizzata per lavorare sul documento semiformale che contiene le informazioni eGov dei servizi di un accordo
  48.  *
  49.  *
  50.  * @author Poli Andrea (apoli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */

  55. public class XMLUtils  {

  57.     /** Validatore XSD */
  58.     static ValidatoreXSD validatoreXSD = null;
  59.     public static synchronized ValidatoreXSD getValidatoreXSD(Logger log) throws Exception{
  60.         if(XMLUtils.validatoreXSD==null){
  61.             XMLUtils.validatoreXSD = new ValidatoreXSD(log,XMLUtils.class.getResourceAsStream("/WSBL_originale.xsd"));
  62.         }
  63.         return XMLUtils.validatoreXSD;
  64.     }
  65.     public static boolean validate(ConceptualBehavior conceptual,StringBuilder motivoErroreValidazione){
  66.         
  67.         int size = motivoErroreValidazione.length();
  68.         
  69.         // TODO
  70.         
  71.         if(motivoErroreValidazione.length()!=size)
  72.             return false;
  73.         else
  74.             return true;

  76.     }
  77.     public static boolean validate(MessageBehavior conceptual,StringBuilder motivoErroreValidazione){
  78.         
  79.         int size = motivoErroreValidazione.length();
  80.         
  81.         // TODO
  82.         
  83.         if(motivoErroreValidazione.length()!=size)
  84.             return false;
  85.         else
  86.             return true;

  88.     }
  89.     
  90.     
  91.     
  92.     
  93.     /* ----- Unmarshall ----- */
  94.     
  95.     /**
  96.      * Ritorna la rappresentazione java
  97.      * 
  98.      * @param m byte[]
  99.      * @return EgovDeclType
  100.      * @throws XMLUtilsException
  101.      */
  102.     public static ConceptualBehavior getConceptualBehavior(Logger log,byte[] m) throws XMLUtilsException{
  103.         ByteArrayInputStream bin = null;
  104.         try{
  105.             bin = new ByteArrayInputStream(m);
  106.             return XMLUtils.getConceptualBehavior(log,bin);
  107.         }catch(Exception e){
  108.             throw new XMLUtilsException(e.getMessage(),e);
  109.         }finally{
  110.             try{
  111.                 if(bin!=null)
  112.                     bin.close();
  113.             }catch(Exception eClose){
  114.                 // close
  115.             }
  116.         }
  117.     }
  118.     
  119.     /**
  120.      * Ritorna la rappresentazione java
  121.      * 
  122.      * @param m File
  123.      * @return EgovDeclType
  124.      * @throws XMLUtilsException
  125.      */
  126.     public static ConceptualBehavior getConceptualBehavior(Logger log,File m) throws XMLUtilsException{
  127.         FileInputStream fin = null;
  128.         try{
  129.             fin = new FileInputStream(m);
  130.             return XMLUtils.getConceptualBehavior(log,fin);
  131.         }catch(Exception e){
  132.             throw new XMLUtilsException(e.getMessage(),e);
  133.         }finally{
  134.             try{
  135.                 if(fin!=null)
  136.                     fin.close();
  137.             }catch(Exception eClose){
  138.                 // close
  139.             }
  140.         }
  141.     }
  142.     
  143.     /**
  144.      * Ritorna la rappresentazione java
  145.      * 
  146.      * @param m String
  147.      * @return EgovDeclType
  148.      * @throws XMLUtilsException
  149.      */
  150.     public static ConceptualBehavior getConceptualBehavior(Logger log,String m) throws XMLUtilsException{
  151.         return XMLUtils.getConceptualBehavior(log,m.getBytes());
  152.     }
  153.     
  154.     /**
  155.      * Ritorna la rappresentazione java
  156.      * 
  157.      * @param m InputStream
  158.      * @return EgovDeclType
  159.      * @throws XMLUtilsException
  160.      */
  161.     public static ConceptualBehavior getConceptualBehavior(Logger log,InputStream m) throws XMLUtilsException{
  162.         try{
  163.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  164.             byte[]reads = new byte[1024];
  165.             int letti = 0;
  166.             while( (letti=m.read(reads)) != -1){
  167.                 bout.write(reads, 0, letti);
  168.             }
  169.             bout.flush();
  170.             bout.close();
  171.             byte [] xml = XMLUtils.unescapeXMLConceptualBehaviorForClientSICA(bout.toString());
  172.             ByteArrayInputStream binValidazione = new ByteArrayInputStream(xml);
  173.             
  174.             ValidatoreXSD validatoreXSD = XMLUtils.getValidatoreXSD(log);
  175.             validatoreXSD.valida(binValidazione);
  176.             
  177.             ByteArrayInputStream binTrasformazione = new ByteArrayInputStream(xml);
  178.             
  179.             return (ConceptualBehavior) JaxbUtils.xmlToObj(binTrasformazione, ConceptualBehavior.class);
  180.         }catch(Exception e){
  181.             throw new XMLUtilsException(e.getMessage(),e);
  182.         }
  183.     }
  184.     
  185.     private static byte[] unescapeXMLConceptualBehaviorForClientSICA(String xml) throws Exception{
  186.         String xmlS = new String(xml);
  187.         xmlS = xmlS.replace("<wsbl:ConceptualBehavior","<ConceptualBehavior");
  188.         //xmlS = xmlS.replace("xmlns:wscp=\"http://spcoop.gov.it/sica/wscp\" xmlns","xmlns");
  189.         xmlS = xmlS.replace("xmlns:wsbl","xmlns");
  190.         xmlS = xmlS.replace("</wsbl:ConceptualBehavior","</ConceptualBehavior");
  191.         return xmlS.getBytes();
  192.     }
  193.     
  194.     
  195.     
  196.     /* ----- Marshall Manifest dell'accordo di servizio ----- */
  197.     public static void generateConceptualBehavior(ConceptualBehavior manifest,File out) throws XMLUtilsException{
  198.         FileOutputStream fout = null;
  199.         try{
  200.             fout = new FileOutputStream(out);
  201.             byte[] xml = XMLUtils.escapeXMLConceptualBehaviorForClientSICA(manifest);
  202.             fout.write(xml);
  203.             fout.flush();       
  204.         }catch(Exception e){
  205.             throw new XMLUtilsException(e.getMessage(),e);
  206.         }finally{
  207.             if(fout!=null){
  208.                 try{
  209.                     fout.close();
  210.                 }catch(Exception e){
  211.                     // close
  212.                 }
  213.             }
  214.         }
  215.     }
  216.     
  217.     public static void generateConceptualBehavior(ConceptualBehavior manifest,String fileName) throws XMLUtilsException{
  218.         XMLUtils.generateConceptualBehavior(manifest,new File(fileName));
  219.     }
  220.     
  221.     public static byte[] generateConceptualBehavior(ConceptualBehavior manifest) throws XMLUtilsException{
  222.         try{
  223.             return XMLUtils.escapeXMLConceptualBehaviorForClientSICA(manifest);
  224.         }catch(Exception e){
  225.             throw new XMLUtilsException(e.getMessage(),e);
  226.         }
  227.     }

  229.     public static void generateConceptualBehavior(ConceptualBehavior manifest,OutputStream out) throws XMLUtilsException{
  230.         try{
  231.             byte[] xml =  XMLUtils.escapeXMLConceptualBehaviorForClientSICA(manifest);
  232.             out.write(xml);     
  233.         }catch(Exception e){
  234.             throw new XMLUtilsException(e.getMessage(),e);
  235.         }
  236.     }

  238.     private static byte[] escapeXMLConceptualBehaviorForClientSICA(ConceptualBehavior manifest) throws Exception{
  239.         StringBuilder risultatoValidazione = new StringBuilder();
  240.         if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  241.             throw new Exception(risultatoValidazione.toString());
  242.         }
  243.         
  244.         ByteArrayOutputStream bout = new ByteArrayOutputStream();
  245.         JaxbUtils.objToXml(bout, ConceptualBehavior.class, manifest);
  246.         String xml = bout.toString();
  247.         xml = xml.replace("<ConceptualBehavior", "<wsbl:ConceptualBehavior");
  248.         //xml = xml.replace("xmlns", "xmlns:wscp=\"http://spcoop.gov.it/sica/wscp\" xmlns");
  249.         xml = xml.replace("xmlns", "xmlns:wsbl");
  250.         xml = xml.replace("</ConceptualBehavior", "</wsbl:ConceptualBehavior");
  251.         return xml.getBytes();
  252.     }

  254.     
  255.     
  256.     
  257.     

  259.     public static boolean isConceptualBehavior(byte [] doc){
  260.         try{
  261.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  262.             Document docXML = xmlUtils.newDocument(doc);
  263.             Element elemXML = docXML.getDocumentElement();
  264.             //System.out.println("LOCAL["+Costanti.ROOT_LOCAL_NAME+"]vs["+elemXML.getLocalName()+"]  NAMESPACE["+Costanti.TARGET_NAMESPACE+"]vs["+elemXML.getNamespaceURI()+"]");
  265.             if(Costanti.ROOT_CONCEPTUAL_LOCAL_NAME.equals(elemXML.getLocalName()) && 
  266.                     Costanti.TARGET_NAMESPACE.equals(elemXML.getNamespaceURI()) ){
  267.                 return true;
  268.             }
  269.             else{
  270.                 return false;
  271.             }
  272.         }catch(Exception e){
  273.             //System.out.println("NON e' un DOCUMENTO VALIDO: "+e.getMessage());
  274.             return false;
  275.         }
  276.     }
  277.     
  278.     
  279.     public static String[] getOperazioniAsincrone(ConceptualBehavior wsblConcettuale) throws XMLUtilsException{
  280.         try{
  281.             String [] operationsAsincrone = new String[2];
  282.             String statoIniziale = null;
  283.             String statoFinale = null;
  284.             if(wsblConcettuale.getStates()==null){
  285.                 throw new Exception("Non sono presenti stati nel documento WSBL ConceptualBehavior");
  286.             }else{
  287.                 if(wsblConcettuale.getStates().getStateInitial()==null || wsblConcettuale.getStates().getStateInitial().getName()==null){
  288.                     throw new Exception("Stato iniziale non presente nel documento WSBL ConceptualBehavior");
  289.                 }
  290.                 statoIniziale = wsblConcettuale.getStates().getStateInitial().getName();
  291.                 if(wsblConcettuale.getStates().getStateFinal()==null || wsblConcettuale.getStates().getStateFinal().getName()==null){
  292.                     throw new Exception("Stato finale non presente nel documento WSBL ConceptualBehavior");
  293.                 }
  294.                 statoFinale = wsblConcettuale.getStates().getStateFinal().getName();
  295.             }
  296.             
  297.             if(wsblConcettuale.getTransitions()==null || wsblConcettuale.getTransitions().sizeTransitionList()<=0 ){
  298.                 throw new Exception("Non sono presenti transizioni nel documento WSBL ConceptualBehavior");
  299.             }else{
  300.                 for(int i=0; i<wsblConcettuale.getTransitions().sizeTransitionList(); i++){
  301.                     TransitionType tr = wsblConcettuale.getTransitions().getTransition(i);
  302.                     if(tr.getSource()==null){
  303.                         throw new Exception("Presente una transizione con source non definita nel documento WSBL ConceptualBehavior");
  304.                     }
  305.                     if(tr.getTarget()==null){
  306.                         throw new Exception("Presente una transizione con target non definito nel documento WSBL ConceptualBehavior");
  307.                     }
  308.                     if(tr.getSource().equals(statoIniziale)){
  309.                         if(tr.getEvents()==null || tr.getEvents().sizeEventList()<=0){
  310.                             throw new Exception("Presente una transizione senza eventi nel documento WSBL ConceptualBehavior");
  311.                         }
  312.                         operationsAsincrone[0] = tr.getEvents().getEvent(0).getName();
  313.                         if(operationsAsincrone[0]==null){
  314.                             throw new Exception("Presente una transizione con un evento senza nome nel documento WSBL ConceptualBehavior");
  315.                         }
  316.                         continue;
  317.                     }
  318.                     if(tr.getTarget().equals(statoFinale)){
  319.                         if(tr.getEvents()==null || tr.getEvents().sizeEventList()<=0){
  320.                             throw new Exception("Presente una transizione senza eventi nel documento WSBL ConceptualBehavior");
  321.                         }
  322.                         operationsAsincrone[1] = tr.getEvents().getEvent(0).getName();
  323.                         if(operationsAsincrone[1]==null){
  324.                             throw new Exception("Presente una transizione con un evento senza nome nel documento WSBL ConceptualBehavior");
  325.                         }
  326.                         continue;
  327.                     }
  328.                 }
  329.                 if(operationsAsincrone[0]==null){
  330.                     throw new Exception("Non e' stata trovata una transizione che possiede come source lo stato iniziale "+statoIniziale+" nel documento WSBL ConceptualBehavior");
  331.                 }
  332.                 if(operationsAsincrone[1]==null){
  333.                     throw new Exception("Non e' stata trovata una transizione che possiede come target lo stato finale "+statoFinale+" nel documento WSBL ConceptualBehavior");
  334.                 }
  335.                 return operationsAsincrone;
  336.             }
  337.             
  338.         }catch(Exception e){
  339.             throw new XMLUtilsException(e.getMessage(),e);
  340.         }
  341.     }
  342.     
  343.     
  344.     
  345.     
  346.     
  347.     
  348.     
  349.     /* ----- Unmarshall ----- */
  350.     
  351.     /**
  352.      * Ritorna la rappresentazione java
  353.      * 
  354.      * @param m byte[]
  355.      * @return EgovDeclType
  356.      * @throws XMLUtilsException
  357.      */
  358.     public static MessageBehavior getMessageBehavior(Logger log,byte[] m) throws XMLUtilsException{
  359.         ByteArrayInputStream bin = null;
  360.         try{
  361.             bin = new ByteArrayInputStream(m);
  362.             return XMLUtils.getMessageBehavior(log,bin);
  363.         }catch(Exception e){
  364.             throw new XMLUtilsException(e.getMessage(),e);
  365.         }finally{
  366.             try{
  367.                 if(bin!=null)
  368.                     bin.close();
  369.             }catch(Exception eClose){
  370.                 // close
  371.             }
  372.         }
  373.     }
  374.     
  375.     /**
  376.      * Ritorna la rappresentazione java
  377.      * 
  378.      * @param m File
  379.      * @return EgovDeclType
  380.      * @throws XMLUtilsException
  381.      */
  382.     public static MessageBehavior getMessageBehavior(Logger log,File m) throws XMLUtilsException{
  383.         FileInputStream fin = null;
  384.         try{
  385.             fin = new FileInputStream(m);
  386.             return XMLUtils.getMessageBehavior(log,fin);
  387.         }catch(Exception e){
  388.             throw new XMLUtilsException(e.getMessage(),e);
  389.         }finally{
  390.             try{
  391.                 if(fin!=null)
  392.                     fin.close();
  393.             }catch(Exception eClose){
  394.                 // close
  395.             }
  396.         }
  397.     }
  398.     
  399.     /**
  400.      * Ritorna la rappresentazione java
  401.      * 
  402.      * @param m String
  403.      * @return EgovDeclType
  404.      * @throws XMLUtilsException
  405.      */
  406.     public static MessageBehavior getMessageBehavior(Logger log,String m) throws XMLUtilsException{
  407.         return XMLUtils.getMessageBehavior(log,m.getBytes());
  408.     }
  409.     
  410.     /**
  411.      * Ritorna la rappresentazione java
  412.      * 
  413.      * @param m InputStream
  414.      * @return EgovDeclType
  415.      * @throws XMLUtilsException
  416.      */
  417.     public static MessageBehavior getMessageBehavior(Logger log,InputStream m) throws XMLUtilsException{
  418.         try{
  419.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  420.             byte[]reads = new byte[1024];
  421.             int letti = 0;
  422.             while( (letti=m.read(reads)) != -1){
  423.                 bout.write(reads, 0, letti);
  424.             }
  425.             bout.flush();
  426.             bout.close();
  427.             byte [] xml = XMLUtils.unescapeXMLMessageBehaviorForClientSICA(bout.toString());
  428.             ByteArrayInputStream binValidazione = new ByteArrayInputStream(xml);
  429.             
  430.             ValidatoreXSD validatoreXSD = XMLUtils.getValidatoreXSD(log);
  431.             validatoreXSD.valida(binValidazione);
  432.             
  433.             ByteArrayInputStream binTrasformazione = new ByteArrayInputStream(xml);
  434.             
  435.             return (MessageBehavior) JaxbUtils.xmlToObj(binTrasformazione, MessageBehavior.class);
  436.         }catch(Exception e){
  437.             throw new XMLUtilsException(e.getMessage(),e);
  438.         }
  439.     }
  440.     
  441.     private static byte[] unescapeXMLMessageBehaviorForClientSICA(String xml) throws Exception{
  442.         String xmlS = new String(xml);
  443.         xmlS = xmlS.replace("<wsbl:MessageBehavior","<MessageBehavior");
  444.         //xmlS = xmlS.replace("xmlns:wscp=\"http://spcoop.gov.it/sica/wscp\" xmlns","xmlns");
  445.         xmlS = xmlS.replace("xmlns:wsbl","xmlns");
  446.         xmlS = xmlS.replace("</wsbl:MessageBehavior","</MessageBehavior");
  447.         return xmlS.getBytes();
  448.     }
  449.     
  450.     
  451.     
  452.     
  453.     
  454.     /* ----- Marshall Manifest dell'accordo di servizio ----- */
  455.     public static void generateMessageBehavior(MessageBehavior manifest,File out) throws XMLUtilsException{
  456.         FileOutputStream fout = null;
  457.         try{
  458.             fout = new FileOutputStream(out);
  459.             byte[] xml = XMLUtils.escapeXMLMessageBehaviorForClientSICA(manifest);
  460.             fout.write(xml);
  461.             fout.flush();       
  462.         }catch(Exception e){
  463.             throw new XMLUtilsException(e.getMessage(),e);
  464.         }finally{
  465.             if(fout!=null){
  466.                 try{
  467.                     fout.close();
  468.                 }catch(Exception e){
  469.                     // close
  470.                 }
  471.             }
  472.         }
  473.     }
  474.     
  475.     public static void generateMessageBehavior(MessageBehavior manifest,String fileName) throws XMLUtilsException{
  476.         XMLUtils.generateMessageBehavior(manifest,new File(fileName));
  477.     }
  478.     
  479.     public static byte[] generateMessageBehavior(MessageBehavior manifest) throws XMLUtilsException{
  480.         try{
  481.             return XMLUtils.escapeXMLMessageBehaviorForClientSICA(manifest);
  482.         }catch(Exception e){
  483.             throw new XMLUtilsException(e.getMessage(),e);
  484.         }
  485.     }

  487.     public static void generateMessageBehavior(MessageBehavior manifest,OutputStream out) throws XMLUtilsException{
  488.         try{
  489.             byte[] xml = XMLUtils.escapeXMLMessageBehaviorForClientSICA(manifest);
  490.             out.write(xml);     
  491.         }catch(Exception e){
  492.             throw new XMLUtilsException(e.getMessage(),e);
  493.         }
  494.     }
  495.     
  496.     private static byte[] escapeXMLMessageBehaviorForClientSICA(MessageBehavior manifest) throws Exception{
  497.         StringBuilder risultatoValidazione = new StringBuilder();
  498.         if(XMLUtils.validate(manifest, risultatoValidazione)==false){
  499.             throw new Exception(risultatoValidazione.toString());
  500.         }
  501.         
  502.         ByteArrayOutputStream bout = new ByteArrayOutputStream();
  503.         JaxbUtils.objToXml(bout, MessageBehavior.class, manifest);
  504.         String xml = bout.toString();
  505.         xml = xml.replace("<MessageBehavior", "<wsbl:MessageBehavior");
  506.         //xml = xml.replace("xmlns", "xmlns:wscp=\"http://spcoop.gov.it/sica/wscp\" xmlns");
  507.         xml = xml.replace("xmlns", "xmlns:wsbl");
  508.         xml = xml.replace("</MessageBehavior", "</wsbl:MessageBehavior");
  509.         return xml.getBytes();
  510.     }
  511.     
  512.     public static boolean isMessageBehavior(byte [] doc){
  513.         try{
  514.             AbstractXMLUtils xmlUtils = org.openspcoop2.message.xml.MessageXMLUtils.DEFAULT;        
  515.             Document docXML = xmlUtils.newDocument(doc);
  516.             Element elemXML = docXML.getDocumentElement();
  517.             //System.out.println("LOCAL["+Costanti.ROOT_LOCAL_NAME+"]vs["+elemXML.getLocalName()+"]  NAMESPACE["+Costanti.TARGET_NAMESPACE+"]vs["+elemXML.getNamespaceURI()+"]");
  518.             if(Costanti.ROOT_MESSAGE_LOCAL_NAME.equals(elemXML.getLocalName()) && 
  519.                     Costanti.TARGET_NAMESPACE.equals(elemXML.getNamespaceURI()) ){
  520.                 return true;
  521.             }
  522.             else{
  523.                 return false;
  524.             }
  525.         }catch(Exception e){
  526.             //System.out.println("NON e' un DOCUMENTO VALIDO: "+e.getMessage());
  527.             return false;
  528.         }
  529.     }
  530.     
  531.     
  532. }
Created with JaCoCo 0.8.8.202204050719