ValidazioneSemanticaMainProcessor.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.utils;

  23. import java.io.File;
  24. import java.io.FileInputStream;
  25. import java.net.URL;
  26. import java.sql.Connection;
  27. import java.sql.DriverManager;

  29. import org.apache.logging.log4j.Level;
  30. import org.openspcoop2.core.registry.driver.BeanUtilities;
  31. import org.openspcoop2.core.registry.driver.ValidazioneSemantica;
  32. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  33. import org.openspcoop2.core.registry.driver.uddi.DriverRegistroServiziUDDI;
  34. import org.openspcoop2.core.registry.driver.web.DriverRegistroServiziWEB;
  35. import org.openspcoop2.core.registry.driver.xml.DriverRegistroServiziXML;
  36. import org.openspcoop2.utils.LoggerWrapperFactory;
  37. import org.openspcoop2.utils.Utilities;
  38. import org.openspcoop2.utils.jdbc.JDBCUtilities;
  39. import org.openspcoop2.utils.resources.FileSystemUtilities;
  40. import org.openspcoop2.utils.resources.Loader;
  41. import org.slf4j.Logger;

  43. /**
  44.  * Validazione Semantica
  45.  * 
  46.  * @author Sandra Giangrandi (sandra@link.it)
  47.  * @author $Author$
  48.  * @version $Rev$, $Date$
  49.  */
  50. public class ValidazioneSemanticaMainProcessor {

  52.         /**
  53.      * @param args
  54.      */
  55.     public static void main(String[] args) throws Exception  {
  56.         // TODO Auto-generated method stub
  57.         
  58.         if (args.length  < 4) {
  59.             String errorMsg = "ERROR, Usage:  java ValidazioneSemanticaMainProcessor commonProperties tipoRegistro proprietaRegistro checkURI";
  60.             System.err.println(errorMsg);
  61.             throw new Exception(errorMsg);
  62.         }

  64.         // Inizializzo logger
  65. //      System.out.println("LUNGHEZZA: "+args.length);
  66. //      for (int i = 0; i < args.length; i++) {
  67. //          System.out.println("ARG["+i+"]=["+args[i]+"]");
  68. //      }
  69.         try{
  70.             if(args.length==5){
  71.                 LoggerWrapperFactory.setLogConfiguration(args[4]);
  72.             }else{
  73.                 URL url = ValidazioneSemanticaMainProcessor.class.getResource("/validator.log4j2.properties");
  74.                 if(url!=null){
  75.                     LoggerWrapperFactory.setLogConfiguration(url);
  76.                 }
  77.                 else{
  78.                     File logFile = FileSystemUtilities.createTempFile("testValidazioneSemanticaRegistro_", ".log");
  79.                     System.out.println("LogMessages write in "+logFile.getAbsolutePath());
  80.                     LoggerWrapperFactory.setDefaultLogConfiguration(Level.ALL, false, null, logFile, "%p <%d{dd-MM-yyyy HH:mm:ss}> %C.%M(%L): %m %n %n");
  81.                 }
  82.             }
  83.         }catch(Exception e) {
  84.             String errorMsg = "Errore durante il caricamento del file di log args4["+args[4]+"] : "+e.getMessage();
  85.             System.err.println(errorMsg);
  86.             System.out.println("Args.length: "+args.length);
  87.             for (int i = 0; i < args.length; i++) {
  88.                 System.out.println("Arg["+i+"]=["+args[i]+"]");
  89.             }
  90.             throw new Exception(errorMsg,e);
  91.         }   
  92.         Logger log = LoggerWrapperFactory.getLogger("validatoreDatiRegistro");
  93.         
  94.         
  95.         java.util.Properties commonProperties = new java.util.Properties();
  96.         try{
  97.             try(FileInputStream fin = new FileInputStream(args[0])){
  98.                 commonProperties.load(fin);
  99.             }
  100.         }catch(java.io.IOException e) {
  101.             String errorMsg = "Errore durante il caricamento del file di properties ["+args[0]+"] : "+e.getMessage();
  102.             log.error(errorMsg,e);
  103.             throw new Exception(errorMsg,e);
  104.         }
  105.         
  106.         
  107.         java.util.Properties reader = new java.util.Properties();
  108.         try{
  109.             try(FileInputStream fin = new FileInputStream(args[2])){
  110.                 reader.load(fin);
  111.             }
  112.         }catch(java.io.IOException e) {
  113.             String errorMsg = "Errore durante il caricamento del file di properties ["+args[2]+"] : "+e.getMessage();
  114.             log.error(errorMsg,e);
  115.             throw new Exception(errorMsg,e);
  116.         }
  117.         
  118.                 
  119.         // Lettura registro
  120.         org.openspcoop2.core.registry.RegistroServizi registro = null;
  121.         Connection connectionDB = null;
  122.         String tipoRegistro = args[1];
  123.         boolean checkURI = Boolean.parseBoolean(args[3]);
  124.         
  125.         if("xml".equals(tipoRegistro)){
  126.             
  127.             // RegistroServizi XML
  128.             String path = reader.getProperty("openspcoop2.registroServizi.xml");
  129.             if(path==null){
  130.                 throw new Exception("Non e' stato definito il path dove localizzare il registro servizi xml");
  131.             }else{
  132.                 path = path.trim();
  133.             }
  134.             
  135.             DriverRegistroServiziXML driver = new DriverRegistroServiziXML(path,log);
  136.             if(driver.create)
  137.                 log.info("Inizializzato Registro dei Servizi XML");
  138.             else
  139.                 throw new Exception("RegistroServizi XML non inizializzato");
  140.             
  141.             registro = driver.getImmagineCompletaRegistroServizi();

  143.         }
  144.         else if("db".equals(tipoRegistro)){
  145.             
  146.             // RegistroServizi DB
  147.             
  148.             // Database
  149.             String tipoDatabase = reader.getProperty("openspcoop2.registroServizi.db.tipo");
  150.             if(tipoDatabase==null){
  151.                 throw new Exception("Non e' stato definito il tipo di database");
  152.             }else{
  153.                 tipoDatabase = tipoDatabase.trim();
  154.             }
  155.             
  156.             String dataSource = reader.getProperty("openspcoop2.registroServizi.db.dataSource");
  157.             if(dataSource!=null){
  158.                 dataSource = dataSource.trim();
  159.                 java.util.Properties context = Utilities.readProperties("openspcoop2.registroServizi.db.context.",reader);
  160.                 
  161.                 DriverRegistroServiziDB driver = new DriverRegistroServiziDB(dataSource,context,log,tipoDatabase);
  162.                 if(driver.create)
  163.                     log.info("Inizializzato Registro dei Servizi DB");
  164.                 else
  165.                     throw new Exception("RegistroServizi DB non inizializzato");
  166.                 
  167.                 registro = driver.getImmagineCompletaRegistroServizi();
  168.                 
  169.             }else{
  170.                 String connection = reader.getProperty("openspcoop2.registroServizi.db.url");
  171.                 if(connection==null){
  172.                     throw new Exception("Non e' stata definita una destinazione ne attraverso un datasource, ne attraverso una connessione diretta");
  173.                 }
  174.                 connection = connection.trim();
  175.                 String driverJDBC = reader.getProperty("openspcoop2.registroServizi.db.driver");
  176.                 if(driverJDBC==null){
  177.                     throw new Exception("Connessione diretta: non e' stato definito il Driver");
  178.                 }
  179.                 driverJDBC =driverJDBC.trim();
  180.                 String username = reader.getProperty("openspcoop2.registroServizi.db.user");
  181.                 String password = reader.getProperty("openspcoop2.registroServizi.db.password");
  182.                 if(username!=null){
  183.                     username = username.trim();
  184.                 }
  185.                 if(password!=null){
  186.                     password = password.trim();
  187.                 }
  188.                 
  189.                 // Carico driver JDBC
  190.                 Loader.getInstance().newInstance(driverJDBC);
  191.                 
  192.                 try{
  193.                     if(username!=null){
  194.                         connectionDB = DriverManager.getConnection(connection, username, password); 
  195.                     }else{
  196.                         connectionDB = DriverManager.getConnection(connection); 
  197.                     }
  198.                     
  199.                     DriverRegistroServiziDB driver = new DriverRegistroServiziDB(connectionDB,log,tipoDatabase);
  200.                     if(driver.create)
  201.                         log.info("Inizializzato Registro dei Servizi DB");
  202.                     else
  203.                         throw new Exception("RegistroServizi DB non inizializzato");
  204.                     
  205.                     registro = driver.getImmagineCompletaRegistroServizi();
  206.                     
  207.                 }finally{
  208.                     try{
  209.                         JDBCUtilities.closeConnection(DriverRegistroServiziDB.getCheckLogger(), connectionDB, DriverRegistroServiziDB.isCheckAutocommit(), DriverRegistroServiziDB.isCheckIsClosed());
  210.                     }catch(Exception e){
  211.                         // close
  212.                     }
  213.                 }
  214.             }   
  215.             
  216.         }
  217.         else if("web".equals(tipoRegistro)){
  218.             
  219.             // RegistroServizi WEB
  220.             String urlPrefix = reader.getProperty("openspcoop2.registroServizi.web.urlPrefix");
  221.             if(urlPrefix==null){
  222.                 throw new Exception("Non e' stato definito la url dove localizzare il registro servizi web");
  223.             }else{
  224.                 urlPrefix = urlPrefix.trim();
  225.             }
  226.             String pathPrefix = reader.getProperty("openspcoop2.registroServizi.web.pathPrefix");
  227.             if(pathPrefix==null){
  228.                 throw new Exception("Non e' stato definito il path dove localizzare il registro servizi web");
  229.             }else{
  230.                 pathPrefix = pathPrefix.trim();
  231.             }
  232.             
  233.             DriverRegistroServiziWEB driver = new DriverRegistroServiziWEB(urlPrefix,pathPrefix,log);
  234.             if(driver.create)
  235.                 log.info("Inizializzato Registro dei Servizi WEB");
  236.             else
  237.                 throw new Exception("RegistroServizi WEB non inizializzato");
  238.             
  239.             registro = driver.getImmagineCompletaRegistroServizi();
  240.             
  241.         }
  242.         else if("uddi".equals(tipoRegistro)){
  243.             
  244.             // RegistroServizi UDDI
  245.             
  246.             String inquiryUrl = reader.getProperty("openspcoop2.registroServizi.uddi.inquiryUrl");
  247.             if(inquiryUrl==null){
  248.                 throw new Exception("Non e' stato definito la url dove localizzare il registro servizi uddi");
  249.             }else{
  250.                 inquiryUrl = inquiryUrl.trim();
  251.             }
  252.             String urlPrefix = reader.getProperty("openspcoop2.registroServizi.uddi.urlPrefix");
  253.             if(urlPrefix==null){
  254.                 throw new Exception("Non e' stato definito la url prefix dove localizzare il registro servizi uddi (repository http)");
  255.             }else{
  256.                 urlPrefix = urlPrefix.trim();
  257.             }
  258.             String usernameUDDI = reader.getProperty("openspcoop2.registroServizi.uddi.username");
  259.             if(usernameUDDI!=null)
  260.                 usernameUDDI = usernameUDDI.trim();
  261.             String passwordUDDI = reader.getProperty("openspcoop2.registroServizi.uddi.password");
  262.             if(passwordUDDI!=null)
  263.                 passwordUDDI = passwordUDDI.trim();
  264.                         
  265.             DriverRegistroServiziUDDI driver = new DriverRegistroServiziUDDI(inquiryUrl,null,usernameUDDI,passwordUDDI,urlPrefix,null,log);
  266.             if(driver.create)
  267.                 log.info("Inizializzato Registro dei Servizi UDDI");
  268.             else
  269.                 throw new Exception("RegistroServizi UDDI non inizializzato");
  270.             
  271.             registro = driver.getImmagineCompletaRegistroServizi();
  272.         }
  273.         else if("ws".equals(tipoRegistro)){
  274.             
  275.             // RegistroServizi WS
  276.             String url = reader.getProperty("openspcoop2.registroServizi.ws.url");
  277.             if(url==null){
  278.                 throw new Exception("Non e' stato definito la url dove localizzare il registro servizi ws");
  279.             }else{
  280.                 url = url.trim();
  281.             }
  282.             String username = reader.getProperty("openspcoop2.registroServizi.ws.username");
  283.             if(username!=null)
  284.                 username = username.trim();
  285.             String password = reader.getProperty("openspcoop2.registroServizi.ws.password");
  286.             if(password!=null)
  287.                 password = password.trim();
  288.             
  289.             BeanUtilities driver = DriverRegistroServiziWSInitUtilities.newInstance(url, username, password, log);
  290.             
  291.             registro = driver.getImmagineCompletaRegistroServizi();
  292.         }
  293.         else{
  294.             throw new Exception("Tipo di registro servizi ["+tipoRegistro+"] non gestito");
  295.         }
  296.         

  298.         // VALIDAZIONE SEMANTICA
  299.         try{
  300.             String tipiConnettori = commonProperties.getProperty("openspcoop2.tipiConnettori");
  301.             if(tipiConnettori==null){
  302.                 throw new Exception("Non sono stati definiti i tipi di connettori supportati");
  303.             }else{
  304.                 tipiConnettori = tipiConnettori.trim();
  305.             }
  306.             String [] tipoConnettoriArray = tipiConnettori.split(",");
  307.             for (int i = 0; i < tipoConnettoriArray.length; i++) {
  308.                 tipoConnettoriArray[i]=tipoConnettoriArray[i].trim();
  309.             }
  310.             
  311.             String tipiSoggetti = commonProperties.getProperty("openspcoop2.tipiSoggetti");
  312.             if(tipiSoggetti==null){
  313.                 throw new Exception("Non sono stati definiti i tipi di soggetti supportati");
  314.             }else{
  315.                 tipiSoggetti = tipiSoggetti.trim();
  316.             }
  317.             String [] tipoSoggettiArray = tipiSoggetti.split(",");
  318.             for (int i = 0; i < tipoSoggettiArray.length; i++) {
  319.                 tipoSoggettiArray[i]=tipoSoggettiArray[i].trim();
  320.             }
  321.             
  322.             String tipiServiziSoap = commonProperties.getProperty("openspcoop2.tipiServizi.soap");
  323.             if(tipiServiziSoap==null){
  324.                 throw new Exception("Non sono stati definiti i tipi di Servizi supportati");
  325.             }else{
  326.                 tipiServiziSoap = tipiServiziSoap.trim();
  327.             }
  328.             String [] tipoServiziArraySoap = tipiServiziSoap.split(",");
  329.             for (int i = 0; i < tipoServiziArraySoap.length; i++) {
  330.                 tipoServiziArraySoap[i]=tipoServiziArraySoap[i].trim();
  331.             }
  332.             
  333.             String tipiServiziRest = commonProperties.getProperty("openspcoop2.tipiServizi.rest");
  334.             if(tipiServiziRest==null){
  335.                 throw new Exception("Non sono stati definiti i tipi di Servizi supportati");
  336.             }else{
  337.                 tipiServiziRest = tipiServiziRest.trim();
  338.             }
  339.             String [] tipoServiziArrayRest = tipiServiziRest.split(",");
  340.             for (int i = 0; i < tipoServiziArrayRest.length; i++) {
  341.                 tipoServiziArrayRest[i]=tipoServiziArrayRest[i].trim();
  342.             }
  343.             
  344.             ValidazioneSemantica validatore = new ValidazioneSemantica(registro,checkURI,tipoConnettoriArray,tipoSoggettiArray,tipoServiziArraySoap,tipoServiziArrayRest,log);
  345.             
  346.             validatore.validazioneSemantica(true);
  347.         }catch(Exception e){
  348.             log.error("Errore: "+e.getMessage());
  349.             throw e;
  350.             //e.printStackTrace(System.out);
  351.         }
  352.         
  353.     }

  355.     
  356. }
Created with JaCoCo 0.8.8.202204050719