PreLoadingConfig.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.pdd.config;

  23. import java.io.ByteArrayOutputStream;
  24. import java.io.File;
  25. import java.io.IOException;
  26. import java.io.InputStream;
  27. import java.sql.Connection;
  28. import java.util.ArrayList;
  29. import java.util.HashMap;
  30. import java.util.Iterator;
  31. import java.util.List;
  32. import java.util.zip.ZipEntry;
  33. import java.util.zip.ZipFile;

  35. import org.apache.commons.lang.StringUtils;
  36. import org.openspcoop2.core.config.AccessoRegistro;
  37. import org.openspcoop2.core.config.AccessoRegistroRegistro;
  38. import org.openspcoop2.core.config.Configurazione;
  39. import org.openspcoop2.core.config.GenericProperties;
  40. import org.openspcoop2.core.config.InoltroBusteNonRiscontrate;
  41. import org.openspcoop2.core.config.MessaggiDiagnostici;
  42. import org.openspcoop2.core.config.Openspcoop2;
  43. import org.openspcoop2.core.config.PortaApplicativa;
  44. import org.openspcoop2.core.config.PortaDelegata;
  45. import org.openspcoop2.core.config.ServizioApplicativo;
  46. import org.openspcoop2.core.config.Soggetto;
  47. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  48. import org.openspcoop2.core.config.constants.RegistroTipo;
  49. import org.openspcoop2.core.config.constants.Severita;
  50. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  51. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  52. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  53. import org.openspcoop2.core.config.utils.CleanerOpenSPCoop2Extensions;
  54. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;
  55. import org.openspcoop2.core.controllo_traffico.IdPolicy;
  56. import org.openspcoop2.core.id.IDSoggetto;
  57. import org.openspcoop2.core.registry.RegistroServizi;
  58. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  59. import org.openspcoop2.core.registry.constants.StatiAccordo;
  60. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  61. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  62. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  63. import org.openspcoop2.generic_project.exception.NotImplementedException;
  64. import org.openspcoop2.generic_project.exception.ServiceException;
  65. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  66. import org.openspcoop2.message.xml.MessageXMLUtils;
  67. import org.openspcoop2.protocol.registry.RegistroServiziReader;
  68. import org.openspcoop2.utils.Utilities;
  69. import org.openspcoop2.utils.UtilsException;
  70. import org.openspcoop2.utils.beans.WriteToSerializerType;
  71. import org.openspcoop2.utils.io.ZipUtilities;
  72. import org.openspcoop2.utils.regexp.RegExpException;
  73. import org.openspcoop2.utils.regexp.RegExpNotFoundException;
  74. import org.openspcoop2.utils.regexp.RegExpNotValidException;
  75. import org.openspcoop2.utils.regexp.RegularExpressionEngine;
  76. import org.openspcoop2.utils.resources.FileSystemUtilities;
  77. import org.slf4j.Logger;
  78. import org.w3c.dom.Element;

  80. /**
  81.  *  ZipConfigurationReader
  82.  *
  83.  * @author Poli Andrea (apoli@link.it)
  84.  * @author $Author$
  85.  * @version $Rev$, $Date$
  86.  */
  87. public class PreLoadingConfig  {

  89.     private static final String SOGGETTO_LOCALE = "@SOGGETTO_LOCALE@";
  90.     private static final String GOVWAY_ENTITY_NAME = "GOVWAY_DEFAULT_ENTITY_NAME";
  91.     private static final String VARIABLE_GOVWAY_ENTITY_NAME = "${"+GOVWAY_ENTITY_NAME+"}";
  92.     
  93.     private Logger log;
  94.     private Logger logDriver;
  95.     private String protocolloDefault;
  96.     private IDSoggetto dominio;
  97.     public PreLoadingConfig(Logger log, Logger logDriver, String protocolloDefault, IDSoggetto dominio) {
  98.         this.log = log;
  99.         this.logDriver = logDriver;
  100.         this.protocolloDefault = protocolloDefault;
  101.         this.dominio = dominio;
  102.     }

  104.     public Logger getLogDriver() {
  105.         return this.logDriver;
  106.     }
  107.     private void logInfo(String msg) {
  108.         if(this.log!=null) {
  109.             this.log.info(msg);
  110.         }
  111.     }
  112.     private void logError(String msg, Exception e) {
  113.         if(this.log!=null) {
  114.             this.log.error(msg,e);
  115.         }
  116.     }
  117.     
  118.     public void loadConfig(List<byte[]> zipContent) throws UtilsException, IOException, DriverConfigurazioneException, ServiceException, NotImplementedException {
  119.         if(zipContent!=null && !zipContent.isEmpty()) {
  120.             for (byte[] bs : zipContent) {
  121.                 this.loadConfig(bs);
  122.             }
  123.         }
  124.     }
  125.     public void loadConfig(byte[] zipContent) throws UtilsException, IOException, DriverConfigurazioneException, ServiceException, NotImplementedException {
  126.         
  127.         List<String> configNameList = new ArrayList<>();
  128.         List<byte[]> configList = new ArrayList<>();
  129.         
  130.         List<String> registryNameList = new ArrayList<>();
  131.         List<byte[]> registryList = new ArrayList<>();
  132.         
  133.         List<String> controllaTrafficoConfigPolicyNameList = new ArrayList<>();
  134.         List<byte[]> controllaTrafficoConfigPolicyList = new ArrayList<>();
  135.         
  136.         List<String> controllaTrafficoActivePolicyNameList = new ArrayList<>();
  137.         List<byte[]> controllaTrafficoActivePolicyList = new ArrayList<>();
  138.         
  139.         HashMap<String, Document> contentList = new HashMap<>();
  140.         
  141.         File fTmp = FileSystemUtilities.createTempFile("preLoadConfiguration", ".zip");
  142.         /**System.out.println("TMP: "+fTmp.getAbsolutePath());*/
  143.         try {
  144.             FileSystemUtilities.writeFile(fTmp, zipContent);
  145.             ZipFile zip = new ZipFile(fTmp);
  146.             Iterator<ZipEntry> itZip = ZipUtilities.entries(zip, true);
  147.             while (itZip.hasNext()) {
  148.                 ZipEntry zipEntry = itZip.next();
  149.                 if(!zipEntry.isDirectory()) {
  150.                     InputStream isZip = zip.getInputStream(zipEntry);
  151.                     try {
  152.                         /**System.out.println("LEGGO ["+zipEntry.getName()+"]");*/
  153.                         byte [] bytes = Utilities.getAsByteArray(isZip);
  154.                         String sBytes = new String(bytes);
  155.                         if(sBytes.contains(SOGGETTO_LOCALE)) {
  156.                             while(sBytes.contains(SOGGETTO_LOCALE)) {
  157.                                 sBytes = sBytes.replace(SOGGETTO_LOCALE, this.dominio.getNome());
  158.                             }
  159.                             bytes = sBytes.getBytes();
  160.                         }
  161.                         if(sBytes.contains(VARIABLE_GOVWAY_ENTITY_NAME)) {
  162.                             String valueSystemProperty = convertVariabile(GOVWAY_ENTITY_NAME);
  163.                             if(valueSystemProperty==null || StringUtils.isEmpty(valueSystemProperty)) {
  164.                                 throw new ServiceException("Una configurazione creata con la variabile '"+VARIABLE_GOVWAY_ENTITY_NAME+"' richiede la sua definizione come variabile di sistema o java");
  165.                             }
  166.                         }
  167.                         String afterVariable = null;
  168.                         try {
  169.                             afterVariable = convertVariable(sBytes);
  170.                         }catch(Exception e) {
  171.                             throw new UtilsException(e.getMessage(),e);
  172.                         }
  173.                         if(afterVariable!=null && !afterVariable.equals(sBytes)) {
  174.                             bytes = afterVariable.getBytes();
  175.                         }
  176.                         try {
  177.                             
  178.                             String entryName = zipEntry.getName();
  179.                             int indexOfWsdl = -1;
  180.                             String name = null;
  181.                             if(entryName.endsWith(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_CONCETTUALE_WSDL) ) {
  182.                                 indexOfWsdl = entryName.indexOf(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_CONCETTUALE_WSDL);
  183.                                 name = CostantiRegistroServizi.SPECIFICA_INTERFACCIA_CONCETTUALE_WSDL;
  184.                             }
  185.                             else if(entryName.endsWith(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_EROGATORE_WSDL) ) {
  186.                                 indexOfWsdl = entryName.indexOf(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_EROGATORE_WSDL);
  187.                                 name = CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_EROGATORE_WSDL;
  188.                             }
  189.                             else if(entryName.endsWith(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_FRUITORE_WSDL) ) {
  190.                                 indexOfWsdl = entryName.indexOf(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_FRUITORE_WSDL);
  191.                                 name = CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_FRUITORE_WSDL;
  192.                             }
  193.                             if(indexOfWsdl>0) {
  194.                                 String prefixEntryName = entryName.substring(0, indexOfWsdl-1);
  195.                                 int posizione = 0; // default
  196.                                 if(prefixEntryName.contains(".") && !prefixEntryName.endsWith(".")) {
  197.                                     String posizioneEntry = prefixEntryName.substring(prefixEntryName.lastIndexOf(".")+1, prefixEntryName.length());
  198.                                     posizione = converPosizione(posizioneEntry);
  199.                                     prefixEntryName = prefixEntryName.substring(0, prefixEntryName.lastIndexOf("."));
  200.                                 }
  201.                                 Document d = new Document();
  202.                                 d.content = bytes;
  203.                                 d.index = posizione;
  204.                                 d.name = name;
  205.                                 contentList.put(prefixEntryName, d);
  206.                             }
  207.                             else {
  208.                             
  209.                                 Element element = MessageXMLUtils.DEFAULT.newElement(bytes);
  210.                                 if(org.openspcoop2.core.config.utils.XMLUtils.isConfigurazione(element)) {
  211.                                     configNameList.add(entryName);
  212.                                     configList.add(bytes);
  213.                                 }
  214.                                 else if(org.openspcoop2.core.registry.utils.XMLUtils.isRegistroServizi(element)) {
  215.                                     registryNameList.add(entryName);
  216.                                     registryList.add(bytes);
  217.                                 }
  218.                                 else if(org.openspcoop2.core.controllo_traffico.utils.XMLUtils.isConfigurazionePolicy(element)) {
  219.                                     controllaTrafficoConfigPolicyNameList.add(entryName);
  220.                                     controllaTrafficoConfigPolicyList.add(bytes);
  221.                                 }
  222.                                 else if(org.openspcoop2.core.controllo_traffico.utils.XMLUtils.isAttivazionePolicy(element)) {
  223.                                     controllaTrafficoActivePolicyNameList.add(entryName);
  224.                                     controllaTrafficoActivePolicyList.add(bytes);
  225.                                 }
  226.                                 else {
  227.                                     throw new UtilsException("unknown type");
  228.                                 }
  229.                                 
  230.                             }
  231.                         }catch(Exception e) {
  232.                             this.logError("PreLoading entry ["+zipEntry.getName()+"] error: "+e.getMessage(),e);
  233.                         }
  234.                     }finally {
  235.                         try {
  236.                             if(isZip!=null) {
  237.                                 isZip.close();
  238.                             }
  239.                         }catch(Exception e) {
  240.                             // close
  241.                         }
  242.                     }
  243.                 }
  244.             }
  245.         }finally {
  246.             try {
  247.                 java.nio.file.Files.delete(fTmp.toPath());
  248.             }catch(Exception e) {
  249.                 // ignore
  250.             }
  251.         }

  253.         if(!registryNameList.isEmpty()) {
  254.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializerRegistry = new  org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer (); 
  255.             java.util.Map<String, IDriverRegistroServiziGet> mapRegistri = RegistroServiziReader.getDriverRegistroServizi();
  256.             DriverRegistroServiziDB driverRegistroServizi = (DriverRegistroServiziDB) mapRegistri.values().iterator().next();
  257.             
  258.             for (int i = 0; i < registryNameList.size(); i++) {
  259.                 String name = registryNameList.get(i);
  260.                 byte [] content = registryList.get(i);
  261.                 
  262.                 convert(contentList, content, name, deserializerRegistry, driverRegistroServizi);
  263.             }
  264.         }
  265.         
  266.         if(!configNameList.isEmpty()) {
  267.             org.openspcoop2.core.config.utils.serializer.JaxbDeserializer deserializerConfig = new  org.openspcoop2.core.config.utils.serializer.JaxbDeserializer (); 
  268.             DriverConfigurazioneDB driverConfigurazione = (DriverConfigurazioneDB) ConfigurazionePdDReader.getDriverConfigurazionePdD();
  269.             
  270.             for (int i = 0; i < configNameList.size(); i++) {
  271.                 String name = configNameList.get(i);
  272.                 byte [] content = configList.get(i);
  273.                 
  274.                 try {
  275.                     this.logInfo(getMessageInCorso(ID_CONFIG, name));
  276.                     Openspcoop2 op2 = deserializerConfig.readOpenspcoop2(content);
  277.                     
  278.                     Configurazione config = op2.getConfigurazione();
  279.                     if(config!=null &&
  280.                         config.getGenericPropertiesList()!=null && !config.getGenericPropertiesList().isEmpty()) {
  281.                         for (GenericProperties genericProperties : config.getGenericPropertiesList()) {
  282.                             boolean exists = existsGenericProperties(driverConfigurazione, genericProperties);
  283.                             if(!exists) {
  284.                                 driverConfigurazione.createGenericProperties(genericProperties);
  285.                             }
  286.                         }
  287.                     }
  288.                     
  289.                     if(op2.sizeSoggettoList()>0) {
  290.                         convert(driverConfigurazione, content, config, op2);
  291.                     }
  292.                     
  293.                     this.logInfo(getMessageEffettuataConSuccesso(ID_CONFIG, name));
  294.     
  295.                 }catch(Exception e) {
  296.                     this.logError(getMessageError(ID_CONFIG, name, e),e);
  297.                 }
  298.             }
  299.         }
  300.         
  301.         
  302.         
  303.         if(!controllaTrafficoConfigPolicyNameList.isEmpty()) {
  304.             org.openspcoop2.core.controllo_traffico.utils.serializer.JaxbDeserializer deserializerCT = new  org.openspcoop2.core.controllo_traffico.utils.serializer.JaxbDeserializer (); 
  305.             DriverConfigurazioneDB driverConfigurazione = (DriverConfigurazioneDB) ConfigurazionePdDReader.getDriverConfigurazionePdD();
  306.             Connection con = null;
  307.             try {
  308.                 con = driverConfigurazione.getConnection("preloading controllaTrafficoConfigPolicies");
  309.                 ServiceManagerProperties jdbcProperties = new ServiceManagerProperties();
  310.                 jdbcProperties.setDatabaseType(driverConfigurazione.getTipoDB());
  311.                 jdbcProperties.setShowSql(true);
  312.                 org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = 
  313.                         new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, jdbcProperties, this.log);
  314.                 org.openspcoop2.core.controllo_traffico.dao.IConfigurazionePolicyService service = serviceManager.getConfigurazionePolicyService();
  315.                 
  316.                 org.openspcoop2.core.controllo_traffico.utils.CleanerOpenSPCoop2Extensions cleaner = new org.openspcoop2.core.controllo_traffico.utils.CleanerOpenSPCoop2Extensions();
  317.                 
  318.                 for (int i = 0; i < controllaTrafficoConfigPolicyNameList.size(); i++) {
  319.                     String name = controllaTrafficoConfigPolicyNameList.get(i);
  320.                     byte [] content = controllaTrafficoConfigPolicyList.get(i);
  321.                     
  322.                     try {
  323.                         this.logInfo(getMessageInCorso(ID_CONTROLLO_TRAFFICO_CONFIG_POLICY, name));
  324.                         org.openspcoop2.core.controllo_traffico.ConfigurazionePolicy policy = deserializerCT.readConfigurazionePolicy(content);
  325.                         IdPolicy id = new IdPolicy();
  326.                         id.setNome(policy.getIdPolicy());
  327.                         if(!service.exists(id)) {
  328.                             cleaner.clean(policy);
  329.                             service.create(policy);
  330.                         }
  331.                         this.logInfo(getMessageEffettuataConSuccesso(ID_CONTROLLO_TRAFFICO_CONFIG_POLICY, name));
  332.         
  333.                     }catch(Exception e) {
  334.                         this.logError(getMessageError(ID_CONTROLLO_TRAFFICO_CONFIG_POLICY, name, e),e);
  335.                     }
  336.                 }
  337.             }finally {
  338.                 driverConfigurazione.releaseConnection(con);
  339.             }
  340.         }
  341.         
  342.         if(!controllaTrafficoActivePolicyNameList.isEmpty()) {
  343.             org.openspcoop2.core.controllo_traffico.utils.serializer.JaxbDeserializer deserializerCT = new  org.openspcoop2.core.controllo_traffico.utils.serializer.JaxbDeserializer (); 
  344.             DriverConfigurazioneDB driverConfigurazione = (DriverConfigurazioneDB) ConfigurazionePdDReader.getDriverConfigurazionePdD();
  345.             Connection con = null;
  346.             try {
  347.                 con = driverConfigurazione.getConnection("preloading controllaTrafficoActivePolicies");
  348.                 ServiceManagerProperties jdbcProperties = new ServiceManagerProperties();
  349.                 jdbcProperties.setDatabaseType(driverConfigurazione.getTipoDB());
  350.                 jdbcProperties.setShowSql(true);
  351.                 org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager serviceManager = 
  352.                         new org.openspcoop2.core.controllo_traffico.dao.jdbc.JDBCServiceManager(con, jdbcProperties, this.log);
  353.                 org.openspcoop2.core.controllo_traffico.dao.IAttivazionePolicyService service = serviceManager.getAttivazionePolicyService();
  354.                 
  355.                 org.openspcoop2.core.controllo_traffico.utils.CleanerOpenSPCoop2Extensions cleaner = new org.openspcoop2.core.controllo_traffico.utils.CleanerOpenSPCoop2Extensions();
  356.                 
  357.                 for (int i = 0; i < controllaTrafficoActivePolicyNameList.size(); i++) {
  358.                     String name = controllaTrafficoActivePolicyNameList.get(i);
  359.                     byte [] content = controllaTrafficoActivePolicyList.get(i);
  360.                     
  361.                     try {
  362.                         this.logInfo(getMessageInCorso(ID_CONTROLLO_TRAFFICO_ACTIVE_POLICY, name));
  363.                         org.openspcoop2.core.controllo_traffico.AttivazionePolicy policy = deserializerCT.readAttivazionePolicy(content);
  364.                         IdActivePolicy id = new IdActivePolicy();
  365.                         id.setNome(policy.getIdActivePolicy());
  366.                         if(!service.exists(id)) {
  367.                             cleaner.clean(policy);
  368.                             service.create(policy);
  369.                         }
  370.                         this.logInfo(getMessageEffettuataConSuccesso(ID_CONTROLLO_TRAFFICO_ACTIVE_POLICY, name));
  371.         
  372.                     }catch(Exception e) {
  373.                         this.logError(getMessageError(ID_CONTROLLO_TRAFFICO_ACTIVE_POLICY, name, e),e);
  374.                     }
  375.                 }
  376.             }finally {
  377.                 driverConfigurazione.releaseConnection(con);
  378.             }
  379.         }

  381.     }
  382.     
  383.     private int converPosizione(String posizioneEntry) throws UtilsException {
  384.         try {
  385.             return Integer.valueOf(posizioneEntry);
  386.         }catch(Exception e) {
  387.             throw new UtilsException("Nome file 'wsdl' con posizione non intera '"+posizioneEntry+"': "+e.getMessage());
  388.         }
  389.     }
  390.     
  391.     private String convertVariable(String tmp) throws RegExpException, RegExpNotValidException {
  392.         String pattern = "\\$\\{([A-Za-z0-9_]+)\\}";
  393.         List<String> l = null;
  394.         try {
  395.             l = RegularExpressionEngine.getAllStringFindPattern(tmp, pattern);
  396.         }catch(RegExpNotFoundException notFound) {
  397.             // ignore
  398.         }
  399.         return convertVariable(l, tmp);
  400.     }
  401.     private String convertVariable(List<String> l, String tmp) {
  402.         if(l!=null && !l.isEmpty()) {
  403.             for (String varName : l) {
  404.                 String valueSystemProperty = convertVariabile(varName);
  405.                 if(valueSystemProperty!=null) {
  406.                     String expr = "${"+varName+"}";
  407.                     int i = 0;
  408.                     int max = 1000;
  409.                     while(tmp.contains(expr) && i<max) {
  410.                         tmp = tmp.replace(expr, valueSystemProperty);
  411.                         i++;
  412.                     }
  413.                 }
  414.             }
  415.         }
  416.         return tmp;
  417.     }
  418.     private String convertVariabile(String varName) {
  419.         String valueSystemProperty = System.getenv(varName); // sistema
  420.         if(valueSystemProperty==null) {
  421.             valueSystemProperty = System.getProperty(varName); // java
  422.         }
  423.         return valueSystemProperty;
  424.     }
  425.         
  426.     private static final String PRELOADING_PREFIX = "PreLoading ";
  427.     private String getMessageInCorso(String type, String name) {
  428.         return PRELOADING_PREFIX+type+" ["+name+"] ...";
  429.     }
  430.     private String getMessageEffettuataConSuccesso(String type, String name) {
  431.         return PRELOADING_PREFIX+type+" ["+name+"] effettuato con successo";
  432.     }
  433.     private String getMessageError(String type, String name, Exception e) {
  434.         return PRELOADING_PREFIX+type+" ["+name+"] failed: "+e.getMessage();
  435.     }
  436.     private static final String ID_REGISTRY = "Registry";
  437.     private static final String ID_CONFIG = "Config";
  438.     private static final String ID_CONTROLLO_TRAFFICO_CONFIG_POLICY = "ControlloTraffico ConfigPolicy";
  439.     private static final String ID_CONTROLLO_TRAFFICO_ACTIVE_POLICY = "ControlloTraffico ActivePolicy";
  440.     
  441.     private UtilsException getUtilsExceptionDocumentoNonAssociabileApi(Document d, RegistroServizi registry) {
  442.         return new UtilsException("Documento '"+d.name+"' non associabile all'Api; la posizione indicata '"+d.index+"' รจ maggiore delle api disponibili '"+registry.sizeAccordoServizioParteComuneList()+"'");
  443.     }
  444.     
  445.     private void convert(HashMap<String, Document> contentList, byte[] content, String name, org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializerRegistry,
  446.             DriverRegistroServiziDB driverRegistroServizi) {
  447.         try {
  448.             this.logInfo(getMessageInCorso(ID_REGISTRY, name));
  449.             RegistroServizi registry = deserializerRegistry.readRegistroServizi(content); // verifico file
  450.             
  451.             setContent(contentList, name, registry);
  452.             
  453.             convert(registry, driverRegistroServizi);
  454.             
  455.             this.logInfo(getMessageEffettuataConSuccesso(ID_REGISTRY, name));

  457.         }catch(Exception e) {
  458.             this.logError(getMessageError(ID_REGISTRY, name, e),e);
  459.         }
  460.     }
  461.     private void setContent(HashMap<String, Document> contentList, String name, RegistroServizi registry) throws UtilsException {
  462.         if(contentList!=null && contentList.containsKey(name)) {
  463.             Document d = contentList.get(name);
  464.             if(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_CONCETTUALE_WSDL.equals(d.name)) {
  465.                 if(registry.sizeAccordoServizioParteComuneList()<=d.index) {
  466.                     throw getUtilsExceptionDocumentoNonAssociabileApi(d,  registry);
  467.                 }
  468.                 registry.getAccordoServizioParteComune(d.index).setByteWsdlConcettuale(d.content);
  469.             }
  470.             else if(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_EROGATORE_WSDL.equals(d.name)) {
  471.                 if(registry.sizeAccordoServizioParteComuneList()<=d.index) {
  472.                     throw getUtilsExceptionDocumentoNonAssociabileApi(d,  registry);
  473.                 }
  474.                 registry.getAccordoServizioParteComune(d.index).setByteWsdlLogicoErogatore(d.content);
  475.             }
  476.             else if(CostantiRegistroServizi.SPECIFICA_INTERFACCIA_LOGICA_FRUITORE_WSDL.equals(d.name)) {
  477.                 if(registry.sizeAccordoServizioParteComuneList()<=d.index) {
  478.                     throw getUtilsExceptionDocumentoNonAssociabileApi(d,  registry);
  479.                 }
  480.                 registry.getAccordoServizioParteComune(d.index).setByteWsdlLogicoFruitore(d.content);
  481.             }
  482.         }
  483.     }
  484.     private void convert(RegistroServizi registry, DriverRegistroServiziDB driverRegistroServizi) throws DriverRegistroServiziException {
  485.         try {
  486.             String superUser = null;
  487.             
  488.             org.openspcoop2.core.registry.driver.utils.XMLDataConverter xmlDataConverter = 
  489.                     new org.openspcoop2.core.registry.driver.utils.XMLDataConverter(registry,driverRegistroServizi,CostantiConfigurazione.REGISTRO_DB.getValue(),
  490.                             superUser,this.protocolloDefault,
  491.                             this.log,this.log);
  492.             boolean reset = false;
  493.             boolean mantieniFruitoriEsistenti = true;
  494.             boolean aggiornamentoSoggetti = false;
  495.             boolean updateEnabled = false; // per non modificare eventuali configurazioni gia' caricate, che possono essere state modificate
  496.             xmlDataConverter.convertXML(reset, mantieniFruitoriEsistenti,aggiornamentoSoggetti,StatiAccordo.operativo, updateEnabled);
  497.         }
  498.         finally {
  499.             // nop
  500.         }
  501.     }
  502.     
  503.     private boolean existsGenericProperties(DriverConfigurazioneDB driverConfigurazione, GenericProperties genericProperties) throws DriverConfigurazioneException {
  504.         try {
  505.             return driverConfigurazione.getGenericProperties(genericProperties.getTipologia(), genericProperties.getNome()) != null;
  506.         }catch(DriverConfigurazioneNotFound notFound) {
  507.             // ignore
  508.         }
  509.         return false;
  510.     }
  511.     
  512.     private void convert(DriverConfigurazioneDB driverConfigurazione, byte[] content, Configurazione config, Openspcoop2 op2) throws UtilsException, DriverConfigurazioneException {
  513.         byte [] contentXml = content;

  515.         if(config==null) {
  516.             op2.setConfigurazione(new Configurazione());
  517.             // ne carico una dummy, tanto non la uso
  518.             op2.getConfigurazione().setAccessoRegistro(new AccessoRegistro());
  519.             AccessoRegistroRegistro registro = new AccessoRegistroRegistro();
  520.             registro.setTipo(RegistroTipo.DB);
  521.             registro.setNome("dummy");
  522.             registro.setLocation("dummy");
  523.             op2.getConfigurazione().getAccessoRegistro().addRegistro(registro);
  524.             op2.getConfigurazione().setInoltroBusteNonRiscontrate(new InoltroBusteNonRiscontrate());
  525.             op2.getConfigurazione().getInoltroBusteNonRiscontrate().setCadenza("1");
  526.             op2.getConfigurazione().setMessaggiDiagnostici(new MessaggiDiagnostici());
  527.             op2.getConfigurazione().getMessaggiDiagnostici().setSeverita(Severita.INFO_INTEGRATION);
  528.             op2.getConfigurazione().getMessaggiDiagnostici().setSeveritaLog4j(Severita.INFO_INTEGRATION);
  529.             
  530.             CleanerOpenSPCoop2Extensions cleaner = new CleanerOpenSPCoop2Extensions();
  531.             cleaner.clean(op2.getConfigurazione());
  532.             for (Soggetto soggettoConfig : op2.getSoggettoList()) {
  533.                 cleaner.clean(soggettoConfig);
  534.                 
  535.                 for (PortaDelegata pdConfig : soggettoConfig.getPortaDelegataList()) {
  536.                     cleaner.clean(pdConfig);
  537.                 }
  538.                 for (PortaApplicativa paConfig : soggettoConfig.getPortaApplicativaList()) {
  539.                     cleaner.clean(paConfig);
  540.                 }
  541.                 for (ServizioApplicativo saConfig : soggettoConfig.getServizioApplicativoList()) {
  542.                     cleaner.clean(saConfig);
  543.                 }
  544.             }
  545.             
  546.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  547.             op2.writeTo(bout, WriteToSerializerType.XML_JAXB);
  548.             contentXml = bout.toByteArray();
  549.             
  550.         }
  551.         
  552.         boolean udpateConfigurazioneDisabled = false;
  553.         boolean tabellaSoggettiCondivisaPddRegserv = true;
  554.         String superUser = null;
  555.         org.openspcoop2.core.config.driver.utils.XMLDataConverter xmlDataConverter = 
  556.                 new org.openspcoop2.core.config.driver.utils.XMLDataConverter(contentXml,driverConfigurazione,CostantiConfigurazione.CONFIGURAZIONE_DB,
  557.                         udpateConfigurazioneDisabled,tabellaSoggettiCondivisaPddRegserv,superUser,this.protocolloDefault,
  558.                         this.log,this.log);
  559.         boolean reset = false;
  560.         boolean aggiornamentoSoggetti = false;
  561.         boolean createMappingErogazioneFruizione = true; // serve per creare il mapping ad es. sulle fruizioni ed erogazioni
  562.         boolean updateEnabled = false; // per non modificare eventuali configurazioni gia' caricate, che possono essere state modificate
  563.         xmlDataConverter.convertXML(reset, aggiornamentoSoggetti, createMappingErogazioneFruizione, updateEnabled);
  564.     }
  565. }

  567. class Document{
  568.     
  569.     byte[] content;
  570.     int index;
  571.     String name;
  572.     
  573. }
Created with JaCoCo 0.8.8.202204050719