ProtocolFactoryManager.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.protocol.engine;

  23. import java.io.InputStream;
  24. import java.net.URL;
  25. import java.util.ArrayList;
  26. import java.util.Enumeration;
  27. import java.util.HashMap;
  28. import java.util.Iterator;
  29. import java.util.List;
  30. import java.util.Map;

  32. import javax.servlet.http.HttpServletRequest;

  34. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  35. import org.openspcoop2.protocol.basic.BasicFactory;
  36. import org.openspcoop2.protocol.engine.mapping.InformazioniServizioURLMapping;
  37. import org.openspcoop2.protocol.manifest.DefaultIntegrationError;
  38. import org.openspcoop2.protocol.manifest.Integration;
  39. import org.openspcoop2.protocol.manifest.IntegrationConfiguration;
  40. import org.openspcoop2.protocol.manifest.IntegrationConfigurationElementName;
  41. import org.openspcoop2.protocol.manifest.IntegrationConfigurationResourceIdentificationMode;
  42. import org.openspcoop2.protocol.manifest.IntegrationError;
  43. import org.openspcoop2.protocol.manifest.Openspcoop2;
  44. import org.openspcoop2.protocol.manifest.RestConfiguration;
  45. import org.openspcoop2.protocol.manifest.SoapConfiguration;
  46. import org.openspcoop2.protocol.manifest.SubContextMapping;
  47. import org.openspcoop2.protocol.manifest.Web;
  48. import org.openspcoop2.protocol.manifest.constants.ActorType;
  49. import org.openspcoop2.protocol.manifest.constants.Costanti;
  50. import org.openspcoop2.protocol.manifest.constants.FunctionType;
  51. import org.openspcoop2.protocol.manifest.constants.MessageType;
  52. import org.openspcoop2.protocol.manifest.constants.ResourceIdentificationType;
  53. import org.openspcoop2.protocol.manifest.constants.ServiceBinding;
  54. import org.openspcoop2.protocol.manifest.utils.XMLUtils;
  55. import org.openspcoop2.protocol.sdk.ConfigurazionePdD;
  56. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  57. import org.openspcoop2.protocol.sdk.ProtocolException;
  58. import org.openspcoop2.protocol.sdk.config.ITraduttore;
  59. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  60. import org.openspcoop2.protocol.sdk.constants.ContestoCodificaEccezione;
  61. import org.openspcoop2.protocol.sdk.constants.IDService;
  62. import org.openspcoop2.protocol.sdk.constants.Inoltro;
  63. import org.openspcoop2.protocol.sdk.constants.LivelloRilevanza;
  64. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  65. import org.openspcoop2.protocol.sdk.constants.TipoOraRegistrazione;
  66. import org.openspcoop2.protocol.sdk.state.FunctionContextsCustom;
  67. import org.openspcoop2.protocol.sdk.state.URLProtocolContext;
  68. import org.openspcoop2.protocol.utils.EsitiProperties;
  69. import org.openspcoop2.utils.Utilities;
  70. import org.openspcoop2.utils.resources.ClassLoaderUtilities;
  71. import org.openspcoop2.utils.resources.MapReader;
  72. import org.slf4j.Logger;

  74. /**
  75.  * Protocol Factory Manager
  76.  *
  77.  * @author Poli Andrea (apoli@link.it)
  78.  * @author $Author$
  79.  * @version $Rev$, $Date$
  80.  */


  83. public class ProtocolFactoryManager {

  85.     private static ProtocolFactoryManager protocolFactoryManager = null;
  86.     public static synchronized void initialize(Logger log,ConfigurazionePdD configPdD,String protocolDefault) throws ProtocolException {
  87.         if(ProtocolFactoryManager.protocolFactoryManager==null){
  88.             ProtocolFactoryManager.protocolFactoryManager = new ProtocolFactoryManager(log,configPdD,protocolDefault,false);
  89.             // Inizializzo anche Esiti.properties
  90.             EsitiProperties.initialize(configPdD.getConfigurationDir(), log, configPdD.getLoader(), protocolFactoryManager.getProtocolFactories());
  91.             // Inizializzo risorse statiche che avevano bisogno di altre informazioni (es. esiti properties)
  92.             protocolFactoryManager.initStaticInstance();
  93.         }
  94.     }
  95.     public static synchronized void initializeSingleProtocol(Logger log,ConfigurazionePdD configPdD,String protocol) throws ProtocolException {
  96.         if(ProtocolFactoryManager.protocolFactoryManager==null){
  97.             ProtocolFactoryManager.protocolFactoryManager = new ProtocolFactoryManager(log,configPdD,protocol,true);
  98.             // Inizializzo anche Esiti.properties
  99.             EsitiProperties.initialize(configPdD.getConfigurationDir(), log, configPdD.getLoader(), protocolFactoryManager.getProtocolFactories());
  100.             // Inizializzo risorse statiche che avevano bisogno di altre informazioni (es. esiti properties)
  101.             protocolFactoryManager.initStaticInstance();
  102.         }
  103.     }
  104.     public static ProtocolFactoryManager getInstance() throws ProtocolException {
  105.         if(ProtocolFactoryManager.protocolFactoryManager==null){
  106.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  107.             synchronized (ProtocolFactoryManager.class) {
  108.                 throw new ProtocolException("ProtocolFactoryManager not initialized");
  109.             }
  110.         }
  111.         return ProtocolFactoryManager.protocolFactoryManager;
  112.     }
  113.     public static void updateLogger(Logger log){
  114.         if(ProtocolFactoryManager.protocolFactoryManager!=null){
  115.             ProtocolFactoryManager.protocolFactoryManager.log = log;
  116.         }
  117.     }
  118.     
  119.     public boolean isSupportedProtocolLogger(String protocol) throws ProtocolException {
  120.         IProtocolFactory<?> p = this.getProtocolFactoryByName(protocol);
  121.         return p.getManifest().getProtocol().isLogger();
  122.     }
  123.     
  124.     public void initializeAllProtocols() throws ProtocolException{
  125.         /**System.out.println("Init All Factories ["+this.factories.size()+"] ...");*/
  126.         if(this.factories!=null){
  127.             Enumeration<IProtocolFactory<?>> factories = this.factories.elements();
  128.             while (factories.hasMoreElements()) {
  129.                 IProtocolFactory<?> iProtocolFactory = (IProtocolFactory<?>) factories.nextElement();
  130.                 /**System.out.println("Init ["+iProtocolFactory.getProtocol()+"] ...");*/
  131.                 
  132.                 // INFO SERVIZIO
  133.                 iProtocolFactory.getProtocol();
  134.                 iProtocolFactory.getInformazioniProtocol();
  135.                 Openspcoop2 manifest = iProtocolFactory.getManifest();
  136.                 iProtocolFactory.getConfigurazionePdD();
  137.                 
  138.                 // LOGGER
  139.                 iProtocolFactory.getLogger();
  140.                 if(manifest.getProtocol().isLogger()) {
  141.                     iProtocolFactory.getProtocolLogger();
  142.                 }
  143.                                 
  144.                 // PROTOCOL BUILDER
  145.                 iProtocolFactory.createBustaBuilder(null);
  146.                 iProtocolFactory.createErroreApplicativoBuilder();
  147.                 iProtocolFactory.createEsitoBuilder();
  148.                 
  149.                 // PROTOCOL VALIDATOR
  150.                 iProtocolFactory.createValidatoreErrori(null);
  151.                 iProtocolFactory.createValidazioneSintattica(null);
  152.                 iProtocolFactory.createValidazioneSemantica(null);
  153.                 iProtocolFactory.createValidazioneConSchema(null);
  154.                 iProtocolFactory.createValidazioneDocumenti();
  155.                 iProtocolFactory.createValidazioneAccordi();
  156.                 
  157.                 // DIAGNOSTICI 
  158.                 iProtocolFactory.createDiagnosticDriver();
  159.                 iProtocolFactory.createDiagnosticProducer();
  160.                 iProtocolFactory.createDiagnosticSerializer();
  161.                 
  162.                 // TRACCE
  163.                 iProtocolFactory.createTracciaDriver();
  164.                 iProtocolFactory.createTracciaProducer();
  165.                 iProtocolFactory.createTracciaSerializer();
  166.                                 
  167.                 // ARCHIVE
  168.                 iProtocolFactory.createArchive();
  169.                 
  170.                 // CONFIG 
  171.                 List<String> versioni = iProtocolFactory.createProtocolConfiguration().getVersioni();
  172.                 for (String version : versioni) {
  173.                     iProtocolFactory.createProtocolVersionManager(version); 
  174.                 }
  175.                 iProtocolFactory.createProtocolManager();
  176.                 ITraduttore traduttore = iProtocolFactory.createTraduttore();
  177.                 traduttore.toString(CodiceErroreCooperazione.AZIONE);
  178.                 traduttore.toString(ContestoCodificaEccezione.INTESTAZIONE);
  179.                 traduttore.toString(Inoltro.CON_DUPLICATI);
  180.                 traduttore.toString(LivelloRilevanza.INFO);
  181.                 traduttore.toString(ProfiloDiCollaborazione.SINCRONO);
  182.                 traduttore.toString(TipoOraRegistrazione.LOCALE);
  183.                 
  184.                 // CONSOLE
  185.                 iProtocolFactory.createDynamicConfigurationConsole();
  186.                 
  187.                 //System.out.println("Init ["+iProtocolFactory.getProtocol()+"] ok");
  188.             }
  189.         }
  190.     }
  191.     
  192.     
  193.     private MapReader<String, Openspcoop2> manifests = null;
  194.     @SuppressWarnings("unused")
  195.     private MapReader<String, URL> manifestURLs = null;
  196.     private MapReader<String, IProtocolFactory<?>> factories = null;
  197.     private StringBuilder protocolLoaded = new StringBuilder();
  198.     private String protocolDefault = null;
  199.     private MapReader<String, List<String>> tipiSoggettiValidi = null;
  200.     private MapReader<String, String> tipiSoggettiDefault = null;
  201.     private MapReader<String, List<String>> tipiServiziValidi_soap = null;
  202.     private MapReader<String, String> tipiServiziDefault_soap = null;
  203.     private MapReader<String, List<String>> tipiServiziValidi_rest = null;
  204.     private MapReader<String, String> tipiServiziDefault_rest = null;
  205.     private MapReader<String, List<String>> versioniValide = null;
  206.     private MapReader<String, String> versioniDefault = null;
  207.     private Logger log = null;
  208.     private ProtocolFactoryManager(Logger log,ConfigurazionePdD configPdD,String protocolDefault, boolean searchSingleManifest) throws ProtocolException {
  209.         try {

  211.             Map<String, Openspcoop2> tmp_manifests = new HashMap<>();
  212.             Map<String, URL> tmp_manifestURLs = new HashMap<>();
  213.             Map<String, IProtocolFactory<?>> tmp_factories = new HashMap<>();
  214.             
  215.             Map<String, List<String>> tmp_tipiSoggettiValidi = new HashMap<>();
  216.             Map<String, String> tmp_tipiSoggettiDefault = new HashMap<>();
  217.             
  218.             Map<String, List<String>> tmp_tipiServiziValidi_soap = new HashMap<>();
  219.             Map<String, String> tmp_tipiServiziDefault_soap = new HashMap<>();
  220.             Map<String, List<String>> tmp_tipiServiziValidi_rest = new HashMap<>();
  221.             Map<String, String> tmp_tipiServiziDefault_rest = new HashMap<>();
  222.             
  223.             Map<String, List<String>> tmp_versioniValide = new HashMap<>();
  224.             Map<String, String> tmp_versioniDefault = new HashMap<>();
  225.             
  226.             this.log = configPdD.getLog();
  227.             this.protocolDefault = protocolDefault;
  228.             
  229.             configPdD.getLog().debug("Init ProtocolFactoryManager ...");
  230.             
  231.             // Loaded Manifest
  232.             if(searchSingleManifest){
  233.                 // Quando si recuper il getClassLoader, nei command line, non viene tornato lo stesso loader delle classi per motivi di sicurezza.
  234.                 // Vedi API del metodo getClassLoader()
  235.                 URL pluginURL = ProtocolFactoryManager.class.getResource("/"+Costanti.MANIFEST_OPENSPCOOP2); // utile nei command line.
  236.                 loadManifest(configPdD, pluginURL, false, tmp_manifests, tmp_manifestURLs);
  237.             }
  238.             else{
  239.                 // 1. Cerco nel classloader (funziona per jboss5.x)
  240.                 Enumeration<URL> en = ProtocolFactoryManager.class.getClassLoader().getResources("/"+Costanti.MANIFEST_OPENSPCOOP2);
  241.                 while(en.hasMoreElements()){
  242.                     URL pluginURL = en.nextElement();
  243.                     loadManifest(configPdD, pluginURL, false, tmp_manifests, tmp_manifestURLs);
  244.                 }
  245.                 
  246.                 if(tmp_manifests.size()<=0){
  247.                     // 2. (funziona per jboss4.x) ma vengono forniti jar duplicati, quelli dentro ear e quelli dentro tmp.
  248.                     en = ProtocolFactoryManager.class.getClassLoader().getResources(Costanti.MANIFEST_OPENSPCOOP2);
  249.                     while(en.hasMoreElements()){
  250.                         URL pluginURL = en.nextElement();
  251.                         loadManifest(configPdD, pluginURL, true, tmp_manifests, tmp_manifestURLs);
  252.                     }
  253.                 }
  254.             }
  255.             
  256.             if(tmp_manifests.size()<=0){
  257.                 throw new Exception("Protocol plugins not found");
  258.             }
  259.             
  260.             // Validate Manifest Loaded
  261.             configPdD.getLog().debug("Validate Manifests ...");
  262.             validateProtocolFactoryLoaded(tmp_manifests,
  263.                     tmp_tipiSoggettiValidi,tmp_tipiSoggettiDefault,
  264.                     tmp_tipiServiziValidi_soap, tmp_tipiServiziDefault_soap,
  265.                     tmp_tipiServiziValidi_rest, tmp_tipiServiziDefault_rest,
  266.                     tmp_versioniValide, tmp_versioniDefault);
  267.             configPdD.getLog().debug("Validate Manifests ok");
  268.             
  269.             // Init protocol factory
  270.             for (String protocolManifest : tmp_manifests.keySet()) {

  272.                 configPdD.getLog().debug("Init ProtocolFactory for protocol ["+protocolManifest+"] ...");
  273.                 Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);              
  274.                 
  275.                 // Factory
  276.                 IProtocolFactory<?> p = this.getProtocolFactoryEngine(manifestOpenspcoop2);
  277.                 p.init(configPdD.getLog(), protocolManifest, configPdD,manifestOpenspcoop2);
  278.                 if(!p.createValidazioneConSchema(null).initialize(OpenSPCoop2MessageFactory.getDefaultMessageFactory())){
  279.                     throw new Exception("[protocol:"+protocolManifest+"] Inizialize with error for ValidazioneConSchema");
  280.                 }
  281.                 tmp_factories.put(protocolManifest, p);
  282.                 
  283.                 // Lista di protocolli caricati
  284.                 if(this.protocolLoaded.length()>0){
  285.                     this.protocolLoaded.append(",");
  286.                 }
  287.                 this.protocolLoaded.append(protocolManifest);
  288.                 
  289.                 // Carico url-mapping
  290.                 InformazioniServizioURLMapping.initMappingProperties(p);
  291.                 
  292.                 // Info di debug
  293.                 StringBuilder context = new StringBuilder();
  294.                 if(manifestOpenspcoop2.getWeb().getEmptyContext()!=null && manifestOpenspcoop2.getWeb().getEmptyContext().getEnabled()){
  295.                     context.append("@EMPTY-CONTEXT@");
  296.                 }
  297.                 for (int i = 0; i < manifestOpenspcoop2.getWeb().sizeContextList(); i++) {
  298.                     if(context.length()>0){
  299.                         context.append(",");
  300.                     }
  301.                     context.append(manifestOpenspcoop2.getWeb().getContext(i).getName());
  302.                 }
  303.                 log.info("Protocol loaded with id["+protocolManifest+"] factory["+manifestOpenspcoop2.getProtocol().getFactory()+"] contexts["+context.toString()+"]");
  304.                 
  305.                 configPdD.getLog().debug("Init ProtocolFactory for protocol ["+protocolManifest+"] ok");
  306.             }
  307.             
  308.             // init
  309.             this.manifests = new MapReader<>(tmp_manifests,true);
  310.             this.manifestURLs = new MapReader<>(tmp_manifestURLs,true);
  311.             this.factories = new MapReader<>(tmp_factories,true);
  312.             
  313.             this.tipiSoggettiValidi = new MapReader<>(tmp_tipiSoggettiValidi,true);
  314.             this.tipiSoggettiDefault = new MapReader<>(tmp_tipiSoggettiDefault,true);
  315.             
  316.             this.tipiServiziValidi_soap = new MapReader<>(tmp_tipiServiziValidi_soap,true);
  317.             this.tipiServiziDefault_soap = new MapReader<>(tmp_tipiServiziDefault_soap,true);
  318.             
  319.             this.tipiServiziValidi_rest = new MapReader<>(tmp_tipiServiziValidi_rest,true);
  320.             this.tipiServiziDefault_rest = new MapReader<>(tmp_tipiServiziDefault_rest,true);
  321.             
  322.             this.versioniValide = new MapReader<>(tmp_versioniValide,true);
  323.             this.versioniDefault = new MapReader<>(tmp_versioniDefault,true);
  324.             
  325.         } catch (Exception e) {
  326.             configPdD.getLog().error("Init ProtocolFactoryManager failed: "+e.getMessage(),e);
  327.             throw new ProtocolException("Inizializzazione ProtocolFactoryManager fallita: " + e, e);
  328.         }
  329.     }
  330.     
  331.     private void loadManifest(ConfigurazionePdD configPdD,URL pluginURL,boolean filtraSenzaErroreProtocolloGiaCaricato,
  332.             Map<String, Openspcoop2> tmp_manifests, Map<String, URL> tmp_manifestURLs) throws Exception{
  333.         // Manifest
  334.         configPdD.getLog().debug("Analyze manifest ["+pluginURL.toString()+"] ...");
  335.         
  336.         InputStream openStream = null;
  337.         byte[] manifest = null;
  338.         try{
  339.             openStream = pluginURL.openStream();
  340.             manifest = Utilities.getAsByteArray(openStream);
  341.         }finally{
  342.             try{
  343.                 if(openStream!=null) {
  344.                     openStream.close();
  345.                 }
  346.             }catch(Exception e){
  347.                 // close
  348.             }
  349.         }
  350.         //System.out.println("CARICATO ["+new String(manifest)+"]");

  352.         configPdD.getLog().debug("Analyze manifest ["+pluginURL.toString()+"] convertToOpenSPCoop2Manifest...");
  353.         Openspcoop2 manifestOpenspcoop2 = XMLUtils.getOpenspcoop2Manifest(configPdD.getLog(),manifest);
  354.         String protocollo = manifestOpenspcoop2.getProtocol().getName();
  355.         configPdD.getLog().debug("Analyze manifest ["+pluginURL.toString()+"] with protocolName: ["+protocollo+"]");
  356.         if(tmp_manifests.containsKey(protocollo)){
  357.         
  358.             URL urlGiaPresente = tmp_manifestURLs.get(protocollo);
  359.             if(filtraSenzaErroreProtocolloGiaCaricato){
  360.                 configPdD.getLog().warn("ProtocolName ["+protocollo+"] is same for more plugin ["+pluginURL.toString()+"] and ["+urlGiaPresente.toURI()+"]");
  361.             }
  362.             else{
  363.                 throw new Exception("ProtocolName ["+protocollo+"] is same for more plugin ["+pluginURL.toString()+"] and ["+urlGiaPresente.toURI()+"]");
  364.             }
  365.             
  366.         }
  367.         tmp_manifests.put(protocollo, manifestOpenspcoop2);
  368.         tmp_manifestURLs.put(protocollo, pluginURL);
  369.         configPdD.getLog().debug("Analyze manifest ["+pluginURL.toString()+"] with success");
  370.     }
  371.     
  372.     private void validateProtocolFactoryLoaded(Map<String, Openspcoop2> tmp_manifests,
  373.             Map<String, List<String>> tmp_tipiSoggettiValidi,Map<String, String> tmp_tipiSoggettiDefault,
  374.             Map<String, List<String>> tmp_tipiServiziValidi_soap, Map<String, String> tmp_tipiServiziDefault_soap,
  375.             Map<String, List<String>> tmp_tipiServiziValidi_rest, Map<String, String> tmp_tipiServiziDefault_rest,
  376.             Map<String, List<String>> tmp_versioniValide,Map<String, String> tmp_versioniDefault) throws Exception{
  377.                 
  378.         // 1. controllare che solo uno possieda il contesto vuoto
  379.         String protocolContextEmpty = null;
  380.         for (String protocolManifest : tmp_manifests.keySet()) {
  381.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  382.             if(manifestOpenspcoop2.getWeb().getEmptyContext()!=null && manifestOpenspcoop2.getWeb().getEmptyContext().getEnabled()){
  383.                 if(protocolContextEmpty==null){
  384.                     protocolContextEmpty = protocolManifest;
  385.                 }
  386.                 else{
  387.                     throw new Exception("Protocol ["+protocolContextEmpty+"] and ["+protocolManifest+"] with empty context. Only one is permitted");
  388.                 }
  389.             }
  390.             
  391.         }
  392.         
  393.         // 2. controllare che i contesti siano tutti diversi
  394.         Map<String, String> mappingContextToProtocol = new HashMap<>();
  395.         for (String protocolManifest : tmp_manifests.keySet()) {
  396.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  397.             
  398.             for (int i = 0; i < manifestOpenspcoop2.getWeb().sizeContextList(); i++) {
  399.                 String context = manifestOpenspcoop2.getWeb().getContext(i).getName();
  400.                 if(!mappingContextToProtocol.containsKey(context)){
  401.                     mappingContextToProtocol.put(context, protocolManifest);
  402.                 }
  403.                 else{
  404.                     throw new Exception("Protocol ["+mappingContextToProtocol.get(context)+"] and ["+protocolManifest+"] with same context ["+context+"]");
  405.                 }
  406.             }
  407.             
  408.         }
  409.         
  410.         // 2.b. controllare che le label siano tutti diversi
  411.         Map<String, String> mappinLabelToProtocol = new HashMap<>();
  412.         for (String protocolManifest : tmp_manifests.keySet()) {
  413.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  414.             
  415.             String label = manifestOpenspcoop2.getProtocol().getLabel();
  416.             if(!mappinLabelToProtocol.containsKey(label)){
  417.                 mappinLabelToProtocol.put(label, protocolManifest);
  418.             }
  419.             else{
  420.                 throw new Exception("Protocol ["+mappinLabelToProtocol.get(label)+"] and ["+protocolManifest+"] with same label ["+label+"]");
  421.             }
  422.             
  423.         }
  424.         
  425.         // 3. controllare e inizializzare i tipi di soggetti in modo che siano tutti diversi
  426.         Map<String, String> mappingTipiSoggettiToProtocol = new HashMap<>();
  427.         for (String protocolManifest : tmp_manifests.keySet()) {
  428.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  429.             
  430.             int size = manifestOpenspcoop2.getRegistry().getOrganization().getTypes().sizeTypeList();
  431.             if(size<=0){
  432.                 throw new Exception("Organization type not defined for protocol ["+protocolManifest+"]");
  433.             }
  434.                         
  435.             for (int i = 0; i < size; i++) {
  436.                 String tipo = manifestOpenspcoop2.getRegistry().getOrganization().getTypes().getType(i).getName();
  437.                 if(!mappingTipiSoggettiToProtocol.containsKey(tipo)){
  438.                     mappingTipiSoggettiToProtocol.put(tipo, protocolManifest);
  439.                     
  440.                     List<String> tipiSoggettiPerProtocollo = null;
  441.                     if(tmp_tipiSoggettiValidi.containsKey(protocolManifest)){
  442.                         tipiSoggettiPerProtocollo = tmp_tipiSoggettiValidi.remove(protocolManifest);
  443.                     }
  444.                     else{
  445.                         tipiSoggettiPerProtocollo = new ArrayList<>();
  446.                     }
  447.                     tipiSoggettiPerProtocollo.add(tipo);
  448.                     tmp_tipiSoggettiValidi.put(protocolManifest, tipiSoggettiPerProtocollo);
  449.                 }
  450.                 else{
  451.                     throw new Exception("Protocol ["+mappingTipiSoggettiToProtocol.get(tipo)+"] and ["+protocolManifest+"] with same subject type ["+tipo+"]");
  452.                 }
  453.             }
  454.             
  455.             for (int i = 0; i < size; i++) {
  456.                 String protocolType = manifestOpenspcoop2.getRegistry().getOrganization().getTypes().getType(i).getProtocol();
  457.                 if(protocolType!=null) {
  458.                     int count = 0;
  459.                     for (int j = 0; j < size; j++) {
  460.                         String protocolTypeCheck = manifestOpenspcoop2.getRegistry().getOrganization().getTypes().getType(j).getProtocol();
  461.                         if(protocolTypeCheck!=null) {
  462.                             if(protocolTypeCheck.equals(protocolType)) {
  463.                                 count++;
  464.                             }
  465.                         }
  466.                     }
  467.                     if(count>1) {
  468.                         throw new Exception("Protocol ["+protocolManifest+"] with same subject 'protocol conversion type' ["+protocolType+"]");
  469.                     }
  470.                 }
  471.             }
  472.             
  473.             String tipoDefault = manifestOpenspcoop2.getRegistry().getOrganization().getTypes().getType(0).getName();
  474.             if(tmp_tipiSoggettiValidi.get(protocolManifest).contains(tipoDefault)==false){
  475.                 throw new Exception("Unknown default subject type ["+tipoDefault+"] defined in protocol ["+protocolManifest+"]");
  476.             }
  477.             tmp_tipiSoggettiDefault.put(protocolManifest, tipoDefault);
  478.             
  479.         }
  480.         
  481.         
  482.         // 4. controllare e inizializzare i tipi di servizi in modo che siano tutti diversi
  483.         String tipoServizioDefaultSoap = null;
  484.         String tipoServizioDefaultRest = null;
  485.         Map<String, String> mappingTipiServiziToProtocol = new HashMap<>();
  486.         for (String protocolManifest : tmp_manifests.keySet()) {
  487.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  488.             
  489.             int size = manifestOpenspcoop2.getRegistry().getService().getTypes().sizeTypeList();
  490.             if(size<=0){
  491.                 throw new Exception("Service type not defined for protocol ["+protocolManifest+"]");
  492.             }
  493.             
  494.             for (int i = 0; i < size; i++) {
  495.                 String tipo = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getName();
  496.                 ServiceBinding serviceBinding = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getBinding();
  497.                 if(!mappingTipiServiziToProtocol.containsKey(tipo)){
  498.                     mappingTipiServiziToProtocol.put(tipo, protocolManifest);
  499.                     
  500.                     List<String> tipiServiziPerProtocollo_soap = null;
  501.                     if(tmp_tipiServiziValidi_soap.containsKey(protocolManifest)){
  502.                         tipiServiziPerProtocollo_soap = tmp_tipiServiziValidi_soap.get(protocolManifest);
  503.                     }
  504.                     else{
  505.                         tipiServiziPerProtocollo_soap = new ArrayList<>();
  506.                         tmp_tipiServiziValidi_soap.put(protocolManifest, tipiServiziPerProtocollo_soap);
  507.                     }
  508.                     
  509.                     List<String> tipiServiziPerProtocollo_rest = null;
  510.                     if(tmp_tipiServiziValidi_rest.containsKey(protocolManifest)){
  511.                         tipiServiziPerProtocollo_rest = tmp_tipiServiziValidi_rest.get(protocolManifest);
  512.                     }
  513.                     else{
  514.                         tipiServiziPerProtocollo_rest = new ArrayList<>();
  515.                         tmp_tipiServiziValidi_rest.put(protocolManifest, tipiServiziPerProtocollo_rest);
  516.                     }
  517.                     
  518.                     if(serviceBinding==null || ServiceBinding.SOAP.equals(serviceBinding)){
  519.                         tipiServiziPerProtocollo_soap.add(tipo);
  520.                         if(tipoServizioDefaultSoap==null){
  521.                             tipoServizioDefaultSoap = tipo;
  522.                         }
  523.                     }
  524.                     
  525.                     if(serviceBinding==null || ServiceBinding.REST.equals(serviceBinding)){
  526.                         tipiServiziPerProtocollo_rest.add(tipo);
  527.                         if(tipoServizioDefaultRest==null){
  528.                             tipoServizioDefaultRest = tipo;
  529.                         }
  530.                     }
  531.                 }
  532.                 else{
  533.                     throw new Exception("Protocol ["+mappingTipiServiziToProtocol.get(tipo)+"] and ["+protocolManifest+"] with same service type ["+tipo+"]");
  534.                 }
  535.             }
  536.             
  537.             for (int i = 0; i < size; i++) {
  538.                 String protocolType = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getProtocol();
  539.                 if(protocolType!=null) {
  540.                     int count = 0;
  541.                     for (int j = 0; j < size; j++) {
  542.                         String protocolTypeCheck = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(j).getProtocol();
  543.                         if(protocolTypeCheck!=null) {
  544.                             if(protocolTypeCheck.equals(protocolType)) {
  545.                                 count++;
  546.                             }
  547.                         }
  548.                     }
  549.                     if(count>1) {
  550.                         throw new Exception("Protocol ["+protocolManifest+"] with same service 'protocol conversion type' ["+protocolType+"]");
  551.                     }
  552.                 }
  553.             }
  554.             
  555.             if(tipoServizioDefaultSoap!=null){
  556.                 tmp_tipiServiziDefault_soap.put(protocolManifest, tipoServizioDefaultSoap);
  557.             }
  558.             if(tipoServizioDefaultRest!=null){
  559.                 tmp_tipiServiziDefault_rest.put(protocolManifest, tipoServizioDefaultRest);
  560.             }
  561.             
  562.         }
  563.         
  564.         
  565.         
  566.         // 5. controllare e inizializzare le versioni dei protocolli
  567.         for (String protocolManifest : tmp_manifests.keySet()) {
  568.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  569.             
  570.             int size = manifestOpenspcoop2.getRegistry().getVersions().sizeVersionList();
  571.             if(size<=0){
  572.                 throw new Exception("Version not defined for protocol ["+protocolManifest+"]");
  573.             }
  574.             
  575.             for (int i = 0; i < size; i++) {
  576.                 String version = manifestOpenspcoop2.getRegistry().getVersions().getVersion(i).getName();
  577.                 
  578.                 List<String> versioniPerProtocollo = null;
  579.                 if(tmp_versioniValide.containsKey(protocolManifest)){
  580.                     versioniPerProtocollo = tmp_versioniValide.remove(protocolManifest);
  581.                 }
  582.                 else{
  583.                     versioniPerProtocollo = new ArrayList<>();
  584.                 }
  585.                 versioniPerProtocollo.add(version);
  586.                 tmp_versioniValide.put(protocolManifest, versioniPerProtocollo);

  588.             }
  589.             
  590.             String versioneDefault = manifestOpenspcoop2.getRegistry().getVersions().getVersion(0).getName();
  591.             if(tmp_versioniValide.get(protocolManifest).contains(versioneDefault)==false){
  592.                 throw new Exception("Unknown default version ["+versioneDefault+"] defined in protocol ["+protocolManifest+"]");
  593.             }
  594.             tmp_versioniDefault.put(protocolManifest, versioneDefault);
  595.         }
  596.         
  597.         
  598.         
  599.         // 6. controllare e inizializzare i service binding di default
  600.         for (String protocolManifest : tmp_manifests.keySet()) {
  601.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  602.             
  603.             if(manifestOpenspcoop2.getBinding()==null){
  604.                 throw new Exception("Binding not defined for protocol ["+protocolManifest+"]");
  605.             }
  606.             if(manifestOpenspcoop2.getBinding().getSoap()==null && manifestOpenspcoop2.getBinding().getRest()==null){
  607.                 throw new Exception("Binding (soap/rest) not defined for protocol ["+protocolManifest+"]");
  608.             }
  609.             if(manifestOpenspcoop2.getBinding().getSoap()!=null && manifestOpenspcoop2.getBinding().getRest()!=null){
  610.                 if(manifestOpenspcoop2.getBinding().getDefault()==null)
  611.                     throw new Exception("Unknown default binding for protocol ["+protocolManifest+"]");
  612.             }
  613.             
  614.             boolean soapEnabled = false;
  615.             if(manifestOpenspcoop2.getBinding().getSoap()!=null){
  616.                 if(!manifestOpenspcoop2.getBinding().getSoap().isSoap11() && !manifestOpenspcoop2.getBinding().getSoap().isSoap12()){
  617.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: none of the soap versions is enabled");
  618.                 }
  619.                 if(manifestOpenspcoop2.getBinding().getSoap().isSoap11Mtom() && !manifestOpenspcoop2.getBinding().getSoap().isSoap11()){
  620.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: if soap 1.1 is not enabled you can not enable MTOM");
  621.                 }
  622.                 if(manifestOpenspcoop2.getBinding().getSoap().isSoap11WithAttachments() && !manifestOpenspcoop2.getBinding().getSoap().isSoap11()){
  623.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: if soap 1.1 is not enabled you can not enable attachments");
  624.                 }
  625.                 if(manifestOpenspcoop2.getBinding().getSoap().isSoap12Mtom() && !manifestOpenspcoop2.getBinding().getSoap().isSoap12()){
  626.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: if soap 1.2 is not enabled you can not enable MTOM");
  627.                 }
  628.                 if(manifestOpenspcoop2.getBinding().getSoap().isSoap12WithAttachments() && !manifestOpenspcoop2.getBinding().getSoap().isSoap12()){
  629.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: if soap 1.2 is not enabled you can not enable attachments");
  630.                 }
  631.                 
  632.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError()==null){
  633.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: it has not defined the configuration for error handling");
  634.                 }
  635.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal()==null){
  636.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: it has not defined the configuration for internal error handling");
  637.                 }
  638.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getDefault()==null){
  639.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: it has not defined the default configuration for internal error handling");
  640.                 }
  641.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getDefault(),"default");
  642.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getAuthentication(),"authentication");
  643.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getAuthorization(),"authorization");
  644.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getNotFound(),"notFound");
  645.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getBadRequest(),"badRequest");
  646.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getConflict(),"conflict");
  647.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getLimitExceeded(),"limitExceeded");
  648.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getTooManyRequests(),"tooManyRequests");
  649.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getServiceUnavailable(),"serviceUnavailable");
  650.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getEndpointRequestTimedOut(),"endpointRequestTimedOut");
  651.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getBadResponse(),"badResponse");
  652.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getInternalRequestError(),"internalRequestError");
  653.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getInternal().getInternalResponseError(),"internalResponseError");
  654.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal()==null){
  655.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: it has not defined the configuration for external error handling");
  656.                 }
  657.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getDefault()==null){
  658.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: it has not defined the default configuration for external error handling");
  659.                 }
  660.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getDefault(),"default");
  661.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getAuthentication(),"authentication");
  662.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getAuthorization(),"authorization");
  663.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getNotFound(),"notFound");
  664.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getBadRequest(),"badRequest");
  665.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getConflict(),"conflict");
  666.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getLimitExceeded(),"limitExceeded");
  667.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getTooManyRequests(),"tooManyRequests");
  668.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getServiceUnavailable(),"serviceUnavailable");
  669.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getEndpointRequestTimedOut(),"endpointRequestTimedOut");
  670.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getBadResponse(),"badResponse");
  671.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getInternalRequestError(),"internalRequestError");
  672.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getSoap().getIntegrationError().getExternal().getInternalResponseError(),"internalResponseError");
  673.                 
  674.                 if(manifestOpenspcoop2.getBinding().getSoap().getMediaTypeCollection()==null){
  675.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: media type collection undefined");
  676.                 }
  677.                 if(manifestOpenspcoop2.getBinding().getSoap().getMediaTypeCollection().sizeMediaTypeList()<=0 && 
  678.                         manifestOpenspcoop2.getBinding().getSoap().getMediaTypeCollection().getDefault()==null && 
  679.                                 manifestOpenspcoop2.getBinding().getSoap().getMediaTypeCollection().getUndefined()==null){
  680.                     throw new Exception("Binding Soap for protocol ["+protocolManifest+"]: media type collection undefined");
  681.                 }
  682.                 
  683.                 soapEnabled = true;
  684.             }
  685.             
  686.             boolean restEnabled = false;
  687.             if(manifestOpenspcoop2.getBinding().getRest()!=null){
  688.                 if(!manifestOpenspcoop2.getBinding().getRest().isBinary() && 
  689.                         !manifestOpenspcoop2.getBinding().getRest().isJson() && 
  690.                         !manifestOpenspcoop2.getBinding().getRest().isXml() && 
  691.                         !manifestOpenspcoop2.getBinding().getRest().isMimeMultipart()){
  692.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: none of the message types is enabled");
  693.                 }
  694.                 
  695.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegrationError()==null){
  696.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: it has not defined the configuration for error handling");
  697.                 }
  698.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal()==null){
  699.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: it has not defined the configuration for internal error handling");
  700.                 }
  701.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getDefault()==null){
  702.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: it has not defined the default configuration for internal error handling");
  703.                 }
  704.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getDefault(),"default");
  705.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getAuthentication(),"authentication");
  706.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getAuthorization(),"authorization");
  707.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getNotFound(),"notFound");
  708.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getBadRequest(),"badRequest");
  709.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getConflict(),"conflict");
  710.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getLimitExceeded(),"limitExceeded");
  711.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getTooManyRequests(),"tooManyRequests");
  712.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getServiceUnavailable(),"serviceUnavailable");
  713.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getEndpointRequestTimedOut(),"endpointRequestTimedOut");
  714.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getBadResponse(),"badResponse");
  715.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getInternalRequestError(),"internalRequestError");
  716.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getInternal().getInternalResponseError(),"internalResponseError");
  717.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal()==null){
  718.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: it has not defined the configuration for external error handling");
  719.                 }
  720.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getDefault()==null){
  721.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: it has not defined the default configuration for external error handling");
  722.                 }
  723.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getDefault(),"default");
  724.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getAuthentication(),"authentication");
  725.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getAuthorization(),"authorization");
  726.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getNotFound(),"notFound");
  727.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getBadRequest(),"badRequest");
  728.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getConflict(),"conflict");
  729.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getLimitExceeded(),"limitExceeded");
  730.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getTooManyRequests(),"tooManyRequests");
  731.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getServiceUnavailable(),"serviceUnavailable");
  732.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getEndpointRequestTimedOut(),"endpointRequestTimedOut");
  733.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getBadResponse(),"badResponse");
  734.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getInternalRequestError(),"internalRequestError");
  735.                 checkHttpReturnCode(manifestOpenspcoop2.getBinding().getRest().getIntegrationError().getExternal().getInternalResponseError(),"internalResponseError"); 
  736.                 
  737.                 if(manifestOpenspcoop2.getBinding().getRest().getMediaTypeCollection()==null){
  738.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: media type collection undefined");
  739.                 }
  740.                 if(manifestOpenspcoop2.getBinding().getRest().getMediaTypeCollection().sizeMediaTypeList()<=0 && 
  741.                         manifestOpenspcoop2.getBinding().getRest().getMediaTypeCollection().getDefault()==null && 
  742.                                 manifestOpenspcoop2.getBinding().getRest().getMediaTypeCollection().getUndefined()==null){
  743.                     throw new Exception("Binding Rest for protocol ["+protocolManifest+"]: media type collection undefined");
  744.                 }
  745.                 
  746.                 restEnabled = true;
  747.             }
  748.             
  749.             for (int i = 0; i < manifestOpenspcoop2.getWeb().sizeContextList(); i++) {
  750.                 String context = manifestOpenspcoop2.getWeb().getContext(i).getName();
  751.                 ServiceBinding serviceBinding = manifestOpenspcoop2.getWeb().getContext(i).getBinding();
  752.                 if(serviceBinding!=null){
  753.                     if(ServiceBinding.REST.equals(serviceBinding)){
  754.                         if(!restEnabled){
  755.                             throw new Exception("Binding Rest for protocol ["+protocolManifest+"] is disabled: cannot define restriction for web context "+context);
  756.                         }
  757.                     }
  758.                     else{
  759.                         if(!soapEnabled){
  760.                             throw new Exception("Binding Soap for protocol ["+protocolManifest+"] is disabled: cannot define restriction for web context "+context);
  761.                         }
  762.                     }
  763.                 }
  764.                 for (int j = 0; j < manifestOpenspcoop2.getWeb().getContext(i).sizeSubContextList(); j++) {
  765.                     SubContextMapping subContext = manifestOpenspcoop2.getWeb().getContext(i).getSubContext(j);
  766.                     checkMessageType(context,subContext.getBase(),subContext.getMessageType(),
  767.                             manifestOpenspcoop2.getBinding().getSoap(),
  768.                             manifestOpenspcoop2.getBinding().getRest());
  769.                 }
  770.                 if(manifestOpenspcoop2.getWeb().getContext(i).getEmptySubContext()!=null){
  771.                     checkMessageType(context,Costanti.CONTEXT_EMPTY,manifestOpenspcoop2.getWeb().getContext(i).getEmptySubContext().getMessageType(),
  772.                             manifestOpenspcoop2.getBinding().getSoap(),
  773.                             manifestOpenspcoop2.getBinding().getRest());
  774.                 }
  775.                 
  776.                 if(manifestOpenspcoop2.getWeb().getContext(i).getSoapMediaTypeCollection()!=null){
  777.                     if(manifestOpenspcoop2.getWeb().getContext(i).getSoapMediaTypeCollection().sizeMediaTypeList()>0 || 
  778.                             manifestOpenspcoop2.getWeb().getContext(i).getSoapMediaTypeCollection().getDefault()!=null || 
  779.                                     manifestOpenspcoop2.getWeb().getContext(i).getSoapMediaTypeCollection().getUndefined()!=null){
  780.                         if(soapEnabled==false){
  781.                             throw new ProtocolException("(Context:"+context+") SoapMediaType not supported; Soap disabled");
  782.                         }
  783.                     }
  784.                 }
  785.                 if(manifestOpenspcoop2.getWeb().getContext(i).getRestMediaTypeCollection()!=null){
  786.                     if(manifestOpenspcoop2.getWeb().getContext(i).getRestMediaTypeCollection().sizeMediaTypeList()>0 || 
  787.                             manifestOpenspcoop2.getWeb().getContext(i).getRestMediaTypeCollection().getDefault()!=null || 
  788.                                     manifestOpenspcoop2.getWeb().getContext(i).getRestMediaTypeCollection().getUndefined()!=null){
  789.                         if(restEnabled==false){
  790.                             throw new ProtocolException("(Context:"+context+") RestMediaType not supported; Rest disabled");
  791.                         }
  792.                     }
  793.                 }
  794.             }
  795.             
  796.             if(manifestOpenspcoop2.getWeb().getEmptyContext()!=null){
  797.                 ServiceBinding serviceBinding = manifestOpenspcoop2.getWeb().getEmptyContext().getBinding();
  798.                 if(serviceBinding!=null){
  799.                     if(ServiceBinding.REST.equals(serviceBinding)){
  800.                         if(!restEnabled){
  801.                             throw new Exception("Binding Rest for protocol ["+protocolManifest+"] is disabled: cannot define restriction for empty web context");
  802.                         }
  803.                     }
  804.                     else{
  805.                         if(!soapEnabled){
  806.                             throw new Exception("Binding Soap for protocol ["+protocolManifest+"] is disabled: cannot define restriction for empty web context");
  807.                         }
  808.                     }
  809.                 }
  810.                 for (int j = 0; j < manifestOpenspcoop2.getWeb().getEmptyContext().sizeSubContextList(); j++) {
  811.                     SubContextMapping subContext = manifestOpenspcoop2.getWeb().getEmptyContext().getSubContext(j);
  812.                     checkMessageType(Costanti.CONTEXT_EMPTY,subContext.getBase(),subContext.getMessageType(),
  813.                             manifestOpenspcoop2.getBinding().getSoap(),
  814.                             manifestOpenspcoop2.getBinding().getRest());
  815.                 }
  816.                 if(manifestOpenspcoop2.getWeb().getEmptyContext().getEmptySubContext()!=null){
  817.                     checkMessageType(Costanti.CONTEXT_EMPTY,Costanti.CONTEXT_EMPTY,manifestOpenspcoop2.getWeb().getEmptyContext().getEmptySubContext().getMessageType(),
  818.                             manifestOpenspcoop2.getBinding().getSoap(),
  819.                             manifestOpenspcoop2.getBinding().getRest());
  820.                 }
  821.                 
  822.                 if(manifestOpenspcoop2.getWeb().getEmptyContext().getSoapMediaTypeCollection()!=null){
  823.                     if(manifestOpenspcoop2.getWeb().getEmptyContext().getSoapMediaTypeCollection().sizeMediaTypeList()>0 || 
  824.                             manifestOpenspcoop2.getWeb().getEmptyContext().getSoapMediaTypeCollection().getDefault()!=null || 
  825.                                     manifestOpenspcoop2.getWeb().getEmptyContext().getSoapMediaTypeCollection().getUndefined()!=null){
  826.                         if(soapEnabled==false){
  827.                             throw new ProtocolException("(Context:"+Costanti.CONTEXT_EMPTY+") SoapMediaType not supported; Soap disabled");
  828.                         }
  829.                     }
  830.                 }
  831.                 if(manifestOpenspcoop2.getWeb().getEmptyContext().getRestMediaTypeCollection()!=null){
  832.                     if(manifestOpenspcoop2.getWeb().getEmptyContext().getRestMediaTypeCollection().sizeMediaTypeList()>0 || 
  833.                             manifestOpenspcoop2.getWeb().getEmptyContext().getRestMediaTypeCollection().getDefault()!=null || 
  834.                                     manifestOpenspcoop2.getWeb().getEmptyContext().getRestMediaTypeCollection().getUndefined()!=null){
  835.                         if(restEnabled==false){
  836.                             throw new ProtocolException("(Context:"+Costanti.CONTEXT_EMPTY+") RestMediaType not supported; Rest disabled");
  837.                         }
  838.                     }
  839.                 }
  840.             }
  841.             
  842.             for (int i = 0; i < manifestOpenspcoop2.getRegistry().getService().getTypes().sizeTypeList(); i++) {
  843.                 String serviceType = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getName();
  844.                 ServiceBinding serviceBinding = manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getBinding();
  845.                 if(serviceBinding!=null){
  846.                     if(ServiceBinding.REST.equals(serviceBinding)){
  847.                         if(!restEnabled){
  848.                             throw new Exception("Binding Rest for protocol ["+protocolManifest+"] is disabled: cannot define restriction for service type "+serviceType);
  849.                         }
  850.                     }
  851.                     else{
  852.                         if(!soapEnabled){
  853.                             throw new Exception("Binding Soap for protocol ["+protocolManifest+"] is disabled: cannot define restriction for service type "+serviceType);
  854.                         }
  855.                     }
  856.                 }
  857.                 
  858.                 if( manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection()!=null){
  859.                     if( manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection().sizeMediaTypeList()>0 || 
  860.                              manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection().getDefault()!=null || 
  861.                                      manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection().getUndefined()!=null){
  862.                         if(soapEnabled==false){
  863.                             throw new ProtocolException("(ServiceType:"+serviceType+") SoapMediaType not supported; Soap disabled");
  864.                         }
  865.                     }
  866.                 }
  867.                 if( manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection()!=null){
  868.                     if( manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection().sizeMediaTypeList()>0 || 
  869.                              manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection().getDefault()!=null || 
  870.                                      manifestOpenspcoop2.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection().getUndefined()!=null){
  871.                         if(restEnabled==false){
  872.                             throw new ProtocolException("(ServiceType:"+serviceType+") RestMediaType not supported; Rest disabled");
  873.                         }
  874.                     }
  875.                 }
  876.             }
  877.         
  878.             if(soapEnabled){
  879.                 if(tipoServizioDefaultSoap==null){
  880.                     throw new Exception("Service type not defined for protocol ["+protocolManifest+"] compatible with soap");
  881.                 }
  882.             }
  883.             if(restEnabled){
  884.                 if(tipoServizioDefaultRest==null){
  885.                     throw new Exception("Service type not defined for protocol ["+protocolManifest+"] compatible with rest");
  886.                 }
  887.             }
  888.         }
  889.         
  890.         // 7. controllo configurazione dei parametri di integrazione
  891.         for (String protocolManifest : tmp_manifests.keySet()) {
  892.             Openspcoop2 manifestOpenspcoop2 = tmp_manifests.get(protocolManifest);
  893.             
  894.             if(manifestOpenspcoop2.getBinding().getRest()!=null) {
  895.                 if(manifestOpenspcoop2.getBinding().getRest().getIntegration()==null){
  896.                     throw new Exception("BindingIntegrationRest not defined for protocol ["+protocolManifest+"]");
  897.                 }
  898.                 Integration integrationRestConfig = manifestOpenspcoop2.getBinding().getRest().getIntegration();
  899.                 checkIntegration(integrationRestConfig, false, protocolManifest);
  900.             }
  901.             
  902.             if(manifestOpenspcoop2.getBinding().getSoap()!=null) {
  903.                 if(manifestOpenspcoop2.getBinding().getSoap().getIntegration()==null){
  904.                     throw new Exception("BindingIntegrationSoap not defined for protocol ["+protocolManifest+"]");
  905.                 }
  906.                 Integration integrationSoapConfig = manifestOpenspcoop2.getBinding().getSoap().getIntegration();
  907.                 checkIntegration(integrationSoapConfig, true, protocolManifest);
  908.             }
  909.         }
  910.     }
  911.     private void checkIntegration(Integration integrationConfig, boolean soap, String protocolManifest) throws Exception {
  912.         String prefix = soap?"Soap":"Rest";
  913.         
  914.         if(integrationConfig.getImplementation()==null){
  915.             throw new Exception("BindingIntegration"+prefix+", implementation not defined for protocol ["+protocolManifest+"]");
  916.         }
  917.         IntegrationConfiguration integrationConfigImpl = integrationConfig.getImplementation();
  918.         checkIntegration(integrationConfigImpl, soap, true, protocolManifest);
  919.         
  920.         if(integrationConfig.getSubscription()==null){
  921.             throw new Exception("BindingIntegration"+prefix+", subscription not defined for protocol ["+protocolManifest+"]");
  922.         }
  923.         IntegrationConfiguration integrationConfigSub = integrationConfig.getSubscription();
  924.         checkIntegration(integrationConfigSub, soap, false, protocolManifest);
  925.     }
  926.     private void checkIntegration(IntegrationConfiguration integrationConfig, boolean soap, boolean impl, String protocolManifest) throws Exception {
  927.         
  928.         String prefix = soap?"Soap":"Rest";
  929.         prefix = prefix + (impl?"Implementation":"Subscription");
  930.         
  931.         if(integrationConfig.getName()==null || integrationConfig.getName().sizeParamList()<=0){
  932.             throw new Exception("BindingIntegration"+prefix+", name not defined for protocol ["+protocolManifest+"]");
  933.         }
  934.         this.checkIntegrationName(integrationConfig.getName().getParamList(), protocolManifest, prefix, "name", false, false);

  936.         if(integrationConfig.getResourceIdentification()==null) {
  937.             throw new Exception("BindingIntegration"+prefix+", resource identification not defined for protocol ["+protocolManifest+"]");
  938.         }
  939.         if(integrationConfig.getResourceIdentification().getIdentificationModes()==null || integrationConfig.getResourceIdentification().getIdentificationModes().sizeModeList()<=0) {
  940.             throw new Exception("BindingIntegration"+prefix+", resource identification modes not defined for protocol ["+protocolManifest+"]");
  941.         }
  942.         ResourceIdentificationType defaultR = integrationConfig.getResourceIdentification().getIdentificationModes().getDefault();
  943.         if(defaultR==null) {
  944.             if(integrationConfig.getResourceIdentification().getIdentificationModes().sizeModeList()>1) {
  945.                 throw new Exception("BindingIntegration"+prefix+", resource identification default mode undefined for protocol ["+protocolManifest+"]");
  946.             }
  947.             else {
  948.                 defaultR = integrationConfig.getResourceIdentification().getIdentificationModes().getMode(0).getName();
  949.             }
  950.         }
  951.         boolean defaultFound = false;
  952.         for (IntegrationConfigurationResourceIdentificationMode mode : integrationConfig.getResourceIdentification().getIdentificationModes().getModeList()) {
  953.             if(!soap) {
  954.                 if(ResourceIdentificationType.SOAP_ACTION.equals(mode.getName())) {
  955.                     throw new Exception("BindingIntegration"+prefix+", resource identification mode '"+mode.getName()+"' not permit in rest binding, founded in protocol ["+protocolManifest+"]");
  956.                 }
  957.             }
  958.             if(!impl) {
  959.                 if(ResourceIdentificationType.PROTOCOL.equals(mode.getName())) {
  960.                     throw new Exception("BindingIntegration"+prefix+", resource identification mode '"+mode.getName()+"' not permit in subscription binding, founded in protocol ["+protocolManifest+"]");
  961.                 }
  962.             }
  963.             if(defaultR!=null) {
  964.                 if(mode.getName().equals(defaultR)) {
  965.                     defaultFound = true;
  966.                 }
  967.             }
  968.         }
  969.         if(!defaultFound) {
  970.             throw new Exception("BindingIntegration"+prefix+", resource identification default mode '"+defaultR+"' not found in supported modes for protocol ["+protocolManifest+"]");
  971.         }
  972.         if(ResourceIdentificationType.CONTENT.equals(defaultR) || 
  973.                 ResourceIdentificationType.HEADER.equals(defaultR) || 
  974.                 ResourceIdentificationType.URL.equals(defaultR)) {
  975.             if(integrationConfig.getResourceIdentification().getIdentificationParameter()==null ||
  976.                     integrationConfig.getResourceIdentification().getIdentificationParameter().sizeParamList()<=0) {
  977.                 throw new Exception("BindingIntegration"+prefix+", resource identification default mode '"+defaultR+"' require identification parameter for protocol ["+protocolManifest+"]");
  978.             }
  979.             this.checkIntegrationName(integrationConfig.getResourceIdentification().getIdentificationParameter().getParamList(), 
  980.                     protocolManifest, prefix, "identificationParameter", true, false);
  981.         }
  982.         
  983.         if(integrationConfig.getResourceIdentification().getSpecificResource()==null) {
  984.             throw new Exception("BindingIntegration"+prefix+", specific resource config not defined for protocol ["+protocolManifest+"]");
  985.         }
  986.         if(integrationConfig.getResourceIdentification().getSpecificResource().getName()==null ||
  987.                 integrationConfig.getResourceIdentification().getSpecificResource().getName().sizeParamList()<=0) {
  988.             throw new Exception("BindingIntegration"+prefix+", specific resource name undefined for protocol ["+protocolManifest+"]");
  989.         }
  990.         this.checkIntegrationName(integrationConfig.getResourceIdentification().getSpecificResource().getName().getParamList(), 
  991.                 protocolManifest, prefix, "specific resource name", true, true);
  992.     }
  993.     private void checkIntegrationName(List<IntegrationConfigurationElementName> list, String protocolManifest, String prefix, String object,
  994.             boolean namePermit, boolean ruleNamePermit) throws Exception {
  995.         for (IntegrationConfigurationElementName name : list) {
  996.             if(name==null) {
  997.                 throw new Exception("BindingIntegration"+prefix+", "+object+" not defined for protocol ["+protocolManifest+"]");
  998.             }
  999.             if( (name.getPrefix()==null || "".equals(name.getPrefix())) &&
  1000.                     (name.getActor()==null) &&
  1001.                     (name.getSuffix()==null || "".equals(name.getSuffix()))) {
  1002.                 throw new Exception("BindingIntegration"+prefix+", "+object+" with wrong param (prefix, actor and suffix undefined) for protocol ["+protocolManifest+"]");
  1003.             }
  1004.             if(ActorType.NAME.equals(name.getActor()) && !namePermit) {
  1005.                 throw new Exception("BindingIntegration"+prefix+", "+object+" with wrong param (actor '"+name.getActor()+"' not permit in this context) for protocol ["+protocolManifest+"]");
  1006.             }
  1007.             if(ActorType.RULE_NAME.equals(name.getActor()) && !ruleNamePermit) {
  1008.                 throw new Exception("BindingIntegration"+prefix+", "+object+" with wrong param (actor '"+name.getActor()+"' not permit in this context) for protocol ["+protocolManifest+"]");
  1009.             }
  1010.             
  1011.         }
  1012.     }
  1013.     
  1014.     private void checkHttpReturnCode(DefaultIntegrationError ir,String function) throws ProtocolException {
  1015.         if(ir!=null){
  1016.             int httpReturnCode = ir.getErrorCode().getHttp();
  1017.             this.checkHttpReturnCode(httpReturnCode, function+".http");
  1018.             
  1019.             int govwayReturnCode = ir.getErrorCode().getGovway();
  1020.             this.checkHttpReturnCode(govwayReturnCode, function+".govway");
  1021.         }
  1022.     }
  1023.     private void checkHttpReturnCode(IntegrationError ir,String function) throws ProtocolException {
  1024.         if(ir!=null){
  1025.             int httpReturnCode = ir.getErrorCode().getHttp();
  1026.             this.checkHttpReturnCode(httpReturnCode, function+".http");
  1027.             
  1028.             int govwayReturnCode = ir.getErrorCode().getGovway();
  1029.             this.checkHttpReturnCode(govwayReturnCode, function+".rfc7807");
  1030.         }
  1031.     }
  1032.     private void checkHttpReturnCode(int httpReturnCode,String function) throws ProtocolException {
  1033.         String msgError = "The value provided ("+httpReturnCode+") is not used as http return code (use [200,299],[400-599])";
  1034.         if(httpReturnCode<200){
  1035.             throw new ProtocolException(msgError);
  1036.         }
  1037.         if(httpReturnCode>=300 && httpReturnCode<400){
  1038.             throw new ProtocolException(msgError);
  1039.         }
  1040.         if(httpReturnCode>=600){
  1041.             throw new ProtocolException(msgError);
  1042.         }
  1043.     }
  1044.     private void checkMessageType(String context, String subContext, MessageType messageType,SoapConfiguration soapBinding, RestConfiguration restBinding) throws ProtocolException {
  1045.         if(MessageType.XML.equals(messageType)){
  1046.             if(restBinding==null){
  1047.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Rest disabled");
  1048.             }
  1049.             if(!restBinding.isXml()){
  1050.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in RestBinding; Xml disabled");
  1051.             }
  1052.         }
  1053.         else if(MessageType.JSON.equals(messageType)){
  1054.             if(restBinding==null){
  1055.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Rest disabled");
  1056.             }
  1057.             if(!restBinding.isJson()){
  1058.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in RestBinding; Json disabled");
  1059.             }
  1060.         }
  1061.         else if(MessageType.BINARY.equals(messageType)){
  1062.             if(restBinding==null){
  1063.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Rest disabled");
  1064.             }
  1065.             if(!restBinding.isBinary()){
  1066.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in RestBinding; Binary disabled");
  1067.             }
  1068.         }
  1069.         else if(MessageType.MIME_MULTIPART.equals(messageType)){
  1070.             if(restBinding==null){
  1071.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Rest disabled");
  1072.             }
  1073.             if(!restBinding.isMimeMultipart()){
  1074.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in RestBinding; MimeMultipart disabled");
  1075.             }
  1076.         }
  1077.         else if(MessageType.SOAP_11.equals(messageType)){
  1078.             if(soapBinding==null){
  1079.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Soap disabled");
  1080.             }
  1081.             if(!soapBinding.isSoap11()){
  1082.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in SoapBinding; Soap11 disabled");
  1083.             }
  1084.         }
  1085.         else if(MessageType.SOAP_12.equals(messageType)){
  1086.             if(soapBinding==null){
  1087.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported; Soap disabled");
  1088.             }
  1089.             if(!soapBinding.isSoap12()){
  1090.                 throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in SoapBinding; Soap12 disabled");
  1091.             }
  1092.         }
  1093.         else{
  1094.             throw new ProtocolException("(Context:"+context+" SubContext:"+subContext+") MessageType ["+messageType+"] not supported in Binding");
  1095.         }
  1096.     }
  1097.     
  1098.     private IProtocolFactory<?> getProtocolFactoryEngine(Openspcoop2 openspcoop2Manifest) throws ProtocolException {
  1099.         
  1100.         String factoryClass = null;
  1101.         try{
  1102.             factoryClass = openspcoop2Manifest.getProtocol().getFactory();
  1103.             IProtocolFactory<?> p = (IProtocolFactory<?>) ClassLoaderUtilities.newInstance(factoryClass);
  1104.             return  p;
  1105.         } catch (Exception e) {
  1106.             throw new ProtocolException("Impossibile caricare la factory indicata ["+factoryClass+"] " + e, e);
  1107.         }
  1108.     }
  1109.     
  1110.     
  1111.     public Openspcoop2 getProtocolManifest(HttpServletRequest request, FunctionContextsCustom customContexts) throws ProtocolException {
  1112.         
  1113.         URLProtocolContext urlProtocolContext = null;
  1114.         try {
  1115.             urlProtocolContext = new URLProtocolContextImpl(request, this.log, true, customContexts);
  1116.         } catch (Exception e) {
  1117.             throw new ProtocolException("Impossibile recuperare il nome del contesto dalla request: ServletContext["+request.getContextPath()+"] RequestURI["+request.getRequestURI()+"]",e);
  1118.         }
  1119.         return getProtocolManifest(urlProtocolContext.getProtocolWebContext()); 
  1120.     }
  1121.     
  1122.     
  1123.     public Openspcoop2 getProtocolManifest(String servletContextName) throws ProtocolException {
  1124.         try {
  1125.             
  1126.             Iterator<Openspcoop2> itProtocols = this.manifests.values().iterator();
  1127.             while (itProtocols.hasNext()) {
  1128.                 Openspcoop2 openspcoop2Manifest = itProtocols.next();
  1129.                 Web webContext = openspcoop2Manifest.getWeb();
  1130.                 
  1131.                 if(Costanti.CONTEXT_EMPTY.equals(servletContextName)){
  1132.                     if(webContext.getEmptyContext()!=null && webContext.getEmptyContext().getEnabled()){
  1133.                         return openspcoop2Manifest;
  1134.                     }
  1135.                 }else{
  1136.                     for (int i = 0; i < webContext.sizeContextList(); i++) {
  1137.                         if(webContext.getContext(i).getName().equals(servletContextName)){
  1138.                             return openspcoop2Manifest;
  1139.                         }
  1140.                     }
  1141.                 }
  1142.                 
  1143.             }
  1144.             
  1145.             throw new ProtocolException("Contesto [" + servletContextName + "] non assegnato a nessun protocollo");

  1147.         } catch (Exception e) {
  1148.             throw new ProtocolException("Impossibile individuare il protocollo assegnato al contesto [" + servletContextName + "]: " + e, e);
  1149.         }
  1150.     }
  1151.     
  1152.     public IProtocolFactory<?> getProtocolFactoryByServletContext(HttpServletRequest request, FunctionContextsCustom customContexts) throws ProtocolException {
  1153.         Openspcoop2 m = this.getProtocolManifest(request,customContexts);
  1154.         if(this.factories.containsKey(m.getProtocol().getName())){
  1155.             return this.factories.get(m.getProtocol().getName());
  1156.         }
  1157.         else{
  1158.             throw new ProtocolException("ProtocolPlugin with name ["+m.getProtocol().getName()+"] not found");
  1159.         }
  1160.     }
  1161.     
  1162.     public IProtocolFactory<?> getProtocolFactoryByServletContext(String servletContext) throws ProtocolException {
  1163.         Openspcoop2 m = this.getProtocolManifest(servletContext);
  1164.         if(this.factories.containsKey(m.getProtocol().getName())){
  1165.             return this.factories.get(m.getProtocol().getName());
  1166.         }
  1167.         else{
  1168.             throw new ProtocolException("ProtocolPlugin with name ["+m.getProtocol().getName()+"] not found");
  1169.         }
  1170.     }
  1171.     
  1172.     public IProtocolFactory<?> getProtocolFactoryByName(String protocol) throws ProtocolException {
  1173.         if(this.factories.containsKey(protocol)){
  1174.             return this.factories.get(protocol);
  1175.         }
  1176.         else{
  1177.             throw new ProtocolException("ProtocolPlugin with name ["+protocol+"] not found");
  1178.         }
  1179.     }
  1180.     
  1181.     public boolean existsProtocolFactory(String protocol) {
  1182.         return this.factories.containsKey(protocol);
  1183.     }
  1184.     
  1185.     public IProtocolFactory<?> getProtocolFactoryByOrganizationType(String organizationType) throws ProtocolException {
  1186.         String protocol = this.getProtocolByOrganizationType(organizationType);
  1187.         return this.getProtocolFactoryByName(protocol);
  1188.     }
  1189.     
  1190.     public IProtocolFactory<?> getProtocolFactoryByServiceType(String serviceType) throws ProtocolException {
  1191.         String protocol = this.getProtocolByServiceType(serviceType);
  1192.         return this.getProtocolFactoryByName(protocol);
  1193.     }
  1194.     
  1195.     public IProtocolFactory<?> getProtocolFactoryWithEmptyContext() throws ProtocolException {
  1196.         Openspcoop2 m = this.getProtocolManifest(Costanti.CONTEXT_EMPTY);
  1197.         if(this.factories.containsKey(m.getProtocol().getName())){
  1198.             return this.factories.get(m.getProtocol().getName());
  1199.         }
  1200.         return null;
  1201.     }
  1202.     public IDService getDefaultServiceForWebContext(String context) throws ProtocolException {
  1203.         IProtocolFactory<?> pf = this.getProtocolFactoryByServletContext(context);
  1204.         if(pf==null) {
  1205.             return null;
  1206.         }
  1207.         if(pf.getManifest().getWeb().sizeContextList()<=0) {
  1208.             return null;
  1209.         }
  1210.         FunctionType fType = null;
  1211.         for (int i = 0; i < pf.getManifest().getWeb().sizeContextList(); i++) {
  1212.             if(pf.getManifest().getWeb().getContext(i).getName().equals(context)){
  1213.                 fType = pf.getManifest().getWeb().getContext(i).getEmptyFunction();
  1214.                 break;
  1215.             }
  1216.         }
  1217.         if(fType==null) {
  1218.             return null;
  1219.         }
  1220.         switch (fType) {
  1221.         case PD:
  1222.             return IDService.PORTA_DELEGATA;
  1223.         case PA:
  1224.             return IDService.PORTA_APPLICATIVA;
  1225.         case PDTO_SOAP:
  1226.             return IDService.PORTA_DELEGATA_XML_TO_SOAP;
  1227.         default:
  1228.             return null;
  1229.         }
  1230.     }
  1231.     public IDService getDefaultServiceForEmptyContext() throws ProtocolException {
  1232.         IProtocolFactory<?> pf = this.getProtocolFactoryWithEmptyContext();
  1233.         if(pf==null) {
  1234.             return null;
  1235.         }
  1236.         if(pf.getManifest().getWeb().getEmptyContext()==null) {
  1237.             return null;
  1238.         }
  1239.         FunctionType fType = pf.getManifest().getWeb().getEmptyContext().getEmptyFunction();
  1240.         if(fType==null) {
  1241.             return null;
  1242.         }
  1243.         switch (fType) {
  1244.         case PD:
  1245.             return IDService.PORTA_DELEGATA;
  1246.         case PA:
  1247.             return IDService.PORTA_APPLICATIVA;
  1248.         case PDTO_SOAP:
  1249.             return IDService.PORTA_DELEGATA_XML_TO_SOAP;
  1250.         default:
  1251.             return null;
  1252.         }
  1253.     }
  1254.     
  1255.     public IProtocolFactory<?> getDefaultProtocolFactory() throws ProtocolException {
  1256.         try {
  1257.             if(this.factories.size()==1){
  1258.                 return this.factories.get((String)this.factories.keys().nextElement());
  1259.             }
  1260.             else{
  1261.                 if(this.protocolDefault==null){
  1262.                     throw new Exception("Non e' stato definito un protocollo di default e sono stati riscontrati piu' protocolli disponibili (size:"+this.factories.size()+")");
  1263.                 }
  1264.                 else{
  1265.                     if(this.factories.containsKey(this.protocolDefault)){
  1266.                         return this.factories.get(this.protocolDefault);
  1267.                     }else{
  1268.                         throw new Exception("Il protocollo di default ["+this.protocolDefault+"] indicato non corrisponde a nessuno di quelli caricati");
  1269.                     }
  1270.                 }
  1271.             }
  1272.         } catch (Exception e) {
  1273.             throw new ProtocolException("Impossibile individuare il protocollo assegnato al contesto: " + e, e);
  1274.         }
  1275.     }
  1276.     
  1277.     
  1278.     public MapReader<String, List<String>> getOrganizationTypes() {
  1279.         return this.tipiSoggettiValidi;
  1280.     }
  1281.     public String[] getOrganizationTypesAsArray() {
  1282.         Enumeration<List<String>> listeTipiSoggettiValidi = this.tipiSoggettiValidi.elements();
  1283.         List<String> listaTipiSoggetti = new ArrayList<>();
  1284.         while(listeTipiSoggettiValidi.hasMoreElements()){
  1285.             listaTipiSoggetti.addAll(listeTipiSoggettiValidi.nextElement());
  1286.         }
  1287.         return listaTipiSoggetti.toArray(new String[1]);
  1288.     }
  1289.     public List<String> getOrganizationTypesAsList() {
  1290.         Enumeration<List<String>> listeTipiSoggettiValidi = this.tipiSoggettiValidi.elements();
  1291.         List<String> listaTipiSoggetti = new ArrayList<>();
  1292.         while(listeTipiSoggettiValidi.hasMoreElements()){
  1293.             listaTipiSoggetti.addAll(listeTipiSoggettiValidi.nextElement());
  1294.         }
  1295.         return listaTipiSoggetti;
  1296.     }
  1297.     public MapReader<String, String> getDefaultOrganizationTypes() {
  1298.         return this.tipiSoggettiDefault;
  1299.     }
  1300.     
  1301.     
  1302.     public HashMap<String, List<String>> _getServiceTypes() {
  1303.         HashMap<String, List<String>> map = new HashMap<>();
  1304.         
  1305.         MapReader<String, List<String>> rest = this.getServiceTypes(ServiceBinding.REST);
  1306.         if(rest!=null && rest.size()>0) {
  1307.             Enumeration<String> en = rest.keys();
  1308.             while (en.hasMoreElements()) {
  1309.                 String protocollo = (String) en.nextElement();
  1310.                 map.put(protocollo, rest.get(protocollo));
  1311.             }
  1312.         }
  1313.         
  1314.         MapReader<String, List<String>> soap = this.getServiceTypes(ServiceBinding.SOAP);
  1315.         if(soap!=null && soap.size()>0) {
  1316.             Enumeration<String> en = soap.keys();
  1317.             while (en.hasMoreElements()) {
  1318.                 String protocollo = (String) en.nextElement();
  1319.                 if(map.containsKey(protocollo)) {
  1320.                     List<String> restP = map.get(protocollo);
  1321.                     List<String> soapP = soap.get(protocollo);
  1322.                     for (String tipo : soapP) {
  1323.                         if(restP.contains(tipo)==false) {
  1324.                             restP.add(tipo);
  1325.                         }
  1326.                     }
  1327.                 }
  1328.                 else {
  1329.                     map.put(protocollo, soap.get(protocollo));
  1330.                 }
  1331.             }
  1332.         }
  1333.         
  1334.         return map;
  1335.     }
  1336.     public MapReader<String, List<String>> getServiceTypes(ServiceBinding serviceBinding) {
  1337.         if(ServiceBinding.SOAP.equals(serviceBinding)){
  1338.             return this.tipiServiziValidi_soap;
  1339.         }
  1340.         else{
  1341.             return this.tipiServiziValidi_rest;
  1342.         }
  1343.     }
  1344.     public String[] getServiceTypesAsArray(ServiceBinding serviceBinding) {
  1345.         Enumeration<List<String>> listeTipiServiziValidi = null;
  1346.         if(ServiceBinding.SOAP.equals(serviceBinding)){
  1347.             listeTipiServiziValidi = this.tipiServiziValidi_soap.elements();
  1348.         }
  1349.         else{
  1350.             listeTipiServiziValidi = this.tipiServiziValidi_rest.elements();
  1351.         }
  1352.         List<String> listaTipiServizi = new ArrayList<>();
  1353.         while(listeTipiServiziValidi.hasMoreElements()){
  1354.             listaTipiServizi.addAll(listeTipiServiziValidi.nextElement());
  1355.         }
  1356.         return listaTipiServizi.toArray(new String[1]);
  1357.     }
  1358.     public List<String> getServiceTypesAsList(ServiceBinding serviceBinding) {
  1359.         Enumeration<List<String>> listeTipiServiziValidi = null;
  1360.         if(ServiceBinding.SOAP.equals(serviceBinding)){
  1361.             listeTipiServiziValidi = this.tipiServiziValidi_soap.elements();
  1362.         }
  1363.         else{
  1364.             listeTipiServiziValidi = this.tipiServiziValidi_rest.elements();
  1365.         }
  1366.         List<String> listaTipiServizi = new ArrayList<>();
  1367.         while(listeTipiServiziValidi.hasMoreElements()){
  1368.             listaTipiServizi.addAll(listeTipiServiziValidi.nextElement());
  1369.         }
  1370.         return listaTipiServizi;
  1371.     }
  1372.     public MapReader<String, String> getDefaultServiceTypes(ServiceBinding serviceBinding) {
  1373.         if(ServiceBinding.SOAP.equals(serviceBinding)){
  1374.             return this.tipiServiziDefault_soap;
  1375.         }
  1376.         else{
  1377.             return this.tipiServiziDefault_rest;
  1378.         }
  1379.     }
  1380.     
  1381.     
  1382.     public MapReader<String, List<String>> getVersion() {
  1383.         return this.versioniValide;
  1384.     }
  1385.     public String[] getVersionAsArray() {
  1386.         Enumeration<List<String>> listeVersioniValidi = this.versioniValide.elements();
  1387.         List<String> listaVersioni = new ArrayList<>();
  1388.         while(listeVersioniValidi.hasMoreElements()){
  1389.             listaVersioni.addAll(listeVersioniValidi.nextElement());
  1390.         }
  1391.         return listaVersioni.toArray(new String[1]);
  1392.     }
  1393.     public List<String> getVersionAsList() {
  1394.         Enumeration<List<String>> listeVersioniValide = this.versioniValide.elements();
  1395.         List<String> listaVersioni = new ArrayList<>();
  1396.         while(listeVersioniValide.hasMoreElements()){
  1397.             listaVersioni.addAll(listeVersioniValide.nextElement());
  1398.         }
  1399.         return listaVersioni;
  1400.     }
  1401.     public MapReader<String, String> getDefaultVersion() {
  1402.         return this.versioniDefault;
  1403.     }
  1404.     
  1405.     
  1406.     public MapReader<String, IProtocolFactory<?>> getProtocolFactories() {
  1407.         return this.factories;
  1408.     }
  1409.     
  1410.     public Enumeration<String> getProtocolNames(){
  1411.         return this.factories.keys();
  1412.     }
  1413.     
  1414.     public List<String> getProtocolNamesAsList(){
  1415.         List<String> protocolli = new ArrayList<>();
  1416.         Enumeration<String> en = getProtocolNames();
  1417.         while (en.hasMoreElements()) {
  1418.             String protocollo = (String) en.nextElement();
  1419.             protocolli.add(protocollo);
  1420.         }
  1421.         return protocolli;
  1422.     }
  1423.     
  1424.     public void initStaticInstance() throws ProtocolException {
  1425.         if(this.factories!=null && this.factories.size()>0) {
  1426.             Enumeration<IProtocolFactory<?>> en = this.factories.elements();
  1427.             if(en!=null) {
  1428.                 while (en.hasMoreElements()) {
  1429.                     IProtocolFactory<?> iProtocolFactory = (IProtocolFactory<?>) en.nextElement();
  1430.                     if(iProtocolFactory!=null && iProtocolFactory instanceof BasicFactory<?> ) {
  1431.                         ((BasicFactory<?>)iProtocolFactory).initStaticInstance();
  1432.                     }
  1433.                 }
  1434.             }
  1435.         }
  1436.     }
  1437.     
  1438.     // ***** Utilities *****
  1439.     
  1440.     public String getProtocolByOrganizationType(String organizationType) throws ProtocolException {
  1441.         
  1442.         Enumeration<String> protocolli = this.factories.keys();
  1443.         while (protocolli.hasMoreElements()) {
  1444.                 
  1445.             String protocollo = protocolli.nextElement();
  1446.             IProtocolFactory<?> protocolFactory = this.factories.get(protocollo);
  1447.             List<String> tipiP = protocolFactory.createProtocolConfiguration().getTipiSoggetti();
  1448.             if(tipiP.contains(organizationType)){
  1449.                 return protocollo;
  1450.             }
  1451.                 
  1452.         }
  1453.             
  1454.         throw new ProtocolException("Non esiste un protocollo associato al tipo di soggetto ["+organizationType+"]");
  1455.             
  1456.     }
  1457.     
  1458.     public String getProtocolByServiceType(String serviceType) throws ProtocolException {
  1459.         
  1460.         Enumeration<String> protocolli = this.factories.keys();
  1461.         while (protocolli.hasMoreElements()) {
  1462.                 
  1463.             String protocollo = protocolli.nextElement();
  1464.             IProtocolFactory<?> protocolFactory = this.factories.get(protocollo);
  1465.             List<String> tipiP = protocolFactory.createProtocolConfiguration().getTipiServizi(org.openspcoop2.message.constants.ServiceBinding.SOAP);
  1466.             if(tipiP.contains(serviceType)){
  1467.                 return protocollo;
  1468.             }
  1469.             tipiP = protocolFactory.createProtocolConfiguration().getTipiServizi(org.openspcoop2.message.constants.ServiceBinding.REST);
  1470.             if(tipiP.contains(serviceType)){
  1471.                 return protocollo;
  1472.             }
  1473.                 
  1474.         }
  1475.             
  1476.         throw new ProtocolException("Non esiste un protocollo associato al tipo di servizio ["+serviceType+"]");
  1477.             
  1478.     }
  1479. }
Created with JaCoCo 0.8.8.202204050719