ModIDynamicConfigurationAccordiParteComuneUtilities.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.  */
  20. package org.openspcoop2.protocol.modipa.properties;

  22. import java.util.ArrayList;
  23. import java.util.List;
  24. import java.util.Map;

  26. import org.openspcoop2.core.id.IDAccordo;
  27. import org.openspcoop2.core.id.IDPortType;
  28. import org.openspcoop2.core.id.IDPortTypeAzione;
  29. import org.openspcoop2.core.id.IDResource;
  30. import org.openspcoop2.core.id.IDSoggetto;
  31. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  32. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  33. import org.openspcoop2.core.registry.PortType;
  34. import org.openspcoop2.core.registry.Resource;
  35. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  36. import org.openspcoop2.core.registry.constants.ServiceBinding;
  37. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  38. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  39. import org.openspcoop2.protocol.engine.constants.Costanti;
  40. import org.openspcoop2.protocol.engine.utils.AzioniUtils;
  41. import org.openspcoop2.protocol.engine.utils.NamingUtils;
  42. import org.openspcoop2.protocol.modipa.config.ModIProperties;
  43. import org.openspcoop2.protocol.modipa.constants.ModIConsoleCostanti;
  44. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  45. import org.openspcoop2.protocol.sdk.ProtocolException;
  46. import org.openspcoop2.protocol.sdk.constants.ConsoleItemType;
  47. import org.openspcoop2.protocol.sdk.constants.ConsoleItemValueType;
  48. import org.openspcoop2.protocol.sdk.constants.ConsoleOperationType;
  49. import org.openspcoop2.protocol.sdk.properties.AbstractConsoleItem;
  50. import org.openspcoop2.protocol.sdk.properties.ConsoleConfiguration;
  51. import org.openspcoop2.protocol.sdk.properties.IConsoleHelper;
  52. import org.openspcoop2.protocol.sdk.properties.ProtocolProperties;
  53. import org.openspcoop2.protocol.sdk.properties.ProtocolPropertiesFactory;
  54. import org.openspcoop2.protocol.sdk.properties.ProtocolPropertiesUtils;
  55. import org.openspcoop2.protocol.sdk.properties.StringConsoleItem;
  56. import org.openspcoop2.protocol.sdk.properties.StringProperty;
  57. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  58. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaAccordi;
  59. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaPortTypeAzioni;
  60. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaRisorse;
  61. import org.openspcoop2.protocol.sdk.registry.RegistryException;
  62. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  63. import org.openspcoop2.utils.SortedMap;
  64. import org.slf4j.Logger;

  66. /**
  67.  * ModIDynamicConfigurationAccordiParteComuneUtilities
  68.  *
  69.  * @author Poli Andrea (apoli@link.it)
  70.  * @author $Author$
  71.  * @version $Rev$, $Date$
  72.  */
  73. public class ModIDynamicConfigurationAccordiParteComuneUtilities {
  74.     
  75.     private ModIDynamicConfigurationAccordiParteComuneUtilities() {}

  77.     static void addProfiloInterazione(ModIProperties modiProperties,ConsoleConfiguration configuration, boolean rest, String httpMethod) throws ProtocolException {
  78.         
  79.         configuration.addConsoleItem(ProtocolPropertiesFactory.newSubTitleItem(ModIConsoleCostanti.MODIPA_API_PROFILO_INTERAZIONE_ID, 
  80.                 ModIConsoleCostanti.MODIPA_API_PROFILO_INTERAZIONE_LABEL));
  81.         
  82.         ModIProfiliInterazioneRESTConfig config = null;
  83.         if(rest) {
  84.             config = new ModIProfiliInterazioneRESTConfig(modiProperties, httpMethod, null);
  85.         }
  86.     
  87.         StringConsoleItem profiloInterazioneItem = (StringConsoleItem) 
  88.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  89.                 ConsoleItemType.SELECT,
  90.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID, 
  91.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL);
  92.         boolean addBloccante = true;
  93.         boolean addNonBloccantePush = true;
  94.         boolean addNonBloccantePull = true;
  95.         if(rest) {
  96.             addBloccante = config.isCompatibileBloccante();
  97.             addNonBloccantePush = config.isCompatibileNonBloccantePush();
  98.             addNonBloccantePull = config.isCompatibileNonBloccantePull();
  99.         }
  100.         if(rest) {
  101.             profiloInterazioneItem.addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL_CRUD,
  102.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_CRUD);
  103.         }
  104.         if(addBloccante) {
  105.             profiloInterazioneItem.addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL_BLOCCANTE,
  106.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_BLOCCANTE);
  107.         }
  108.         if(addNonBloccantePush || addNonBloccantePull) {
  109.             profiloInterazioneItem.addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL_NON_BLOCCANTE,
  110.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE);
  111.         }
  112.         profiloInterazioneItem.setDefaultValue(rest ? ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_REST_VALUE : ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_SOAP_VALUE);
  113.         profiloInterazioneItem.setReloadOnChange(true);
  114.         configuration.addConsoleItem(profiloInterazioneItem);
  115.         
  116.         StringConsoleItem profiloInterazioneItemReadOnly = (StringConsoleItem) 
  117.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  118.                 ConsoleItemType.HIDDEN,
  119.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID_INUSE_READONLY, 
  120.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL);
  121.         configuration.addConsoleItem(profiloInterazioneItemReadOnly);
  122.         
  123.         StringConsoleItem profiloInterazioneAsincronaItem = (StringConsoleItem) 
  124.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  125.                 ConsoleItemType.HIDDEN,
  126.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID, 
  127.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_LABEL);
  128.         profiloInterazioneAsincronaItem.setDefaultValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_DEFAULT_VALUE);
  129.         profiloInterazioneAsincronaItem.setReloadOnChange(true);
  130.         configuration.addConsoleItem(profiloInterazioneAsincronaItem);
  131.         
  132.         StringConsoleItem profiloInterazioneAsincronaItemReadOnly = (StringConsoleItem) 
  133.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  134.                 ConsoleItemType.HIDDEN,
  135.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID_INUSE_READONLY, 
  136.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_LABEL);
  137.         configuration.addConsoleItem(profiloInterazioneAsincronaItemReadOnly);
  138.         
  139.         StringConsoleItem profiloInterazioneAsincronaRelazioneItem = (StringConsoleItem) 
  140.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  141.                 ConsoleItemType.HIDDEN,
  142.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID, 
  143.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL);
  144.         profiloInterazioneAsincronaRelazioneItem.setDefaultValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_DEFAULT_VALUE);
  145.         profiloInterazioneAsincronaRelazioneItem.setReloadOnChange(true);
  146.         configuration.addConsoleItem(profiloInterazioneAsincronaRelazioneItem);
  147.         
  148.         StringConsoleItem profiloInterazioneAsincronaRelazioneItemReadOnly = (StringConsoleItem) 
  149.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  150.                 ConsoleItemType.HIDDEN,
  151.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID_INUSE_READONLY, 
  152.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL);
  153.         configuration.addConsoleItem(profiloInterazioneAsincronaRelazioneItemReadOnly);
  154.         
  155.         StringConsoleItem profiloInterazioneAsincronaCorrelataApiItem = (StringConsoleItem) 
  156.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  157.                 ConsoleItemType.HIDDEN,
  158.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID, 
  159.                 "");
  160.         profiloInterazioneAsincronaCorrelataApiItem.setDefaultValue(ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  161.         profiloInterazioneAsincronaCorrelataApiItem.setReloadOnChange(true);
  162.         configuration.addConsoleItem(profiloInterazioneAsincronaCorrelataApiItem);
  163.         
  164.         StringConsoleItem profiloInterazioneAsincronaCorrelataServizioItem = (StringConsoleItem) 
  165.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  166.                 ConsoleItemType.HIDDEN,
  167.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_SERVIZIO_RICHIESTA_CORRELATA_ID, 
  168.                 "");
  169.         profiloInterazioneAsincronaCorrelataServizioItem.setDefaultValue(ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  170.         profiloInterazioneAsincronaCorrelataServizioItem.setReloadOnChange(true);
  171.         configuration.addConsoleItem(profiloInterazioneAsincronaCorrelataServizioItem);
  172.         
  173.         StringConsoleItem profiloInterazioneAsincronaCorrelataAzioneItem = (StringConsoleItem) 
  174.                 ProtocolPropertiesFactory.newConsoleItem(ConsoleItemValueType.STRING,
  175.                 ConsoleItemType.HIDDEN,
  176.                 ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA_ID, 
  177.                 "");
  178.         profiloInterazioneAsincronaCorrelataAzioneItem.setDefaultValue(ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  179.         profiloInterazioneAsincronaCorrelataAzioneItem.setReloadOnChange(true);
  180.         configuration.addConsoleItem(profiloInterazioneAsincronaCorrelataAzioneItem);
  181.         
  182.     }
  183.     
  184.     private static AccordoServizioParteComune getAccordoServizioParteComune(IRegistryReader registryReader, IDAccordo idAccordoSelected) throws RegistryException{
  185.         AccordoServizioParteComune aspc = null;
  186.         try {
  187.             aspc = registryReader.getAccordoServizioParteComune(idAccordoSelected);
  188.         }catch(RegistryNotFound notFound) {
  189.             // ignore
  190.         }
  191.         return aspc;
  192.     }
  193.     private static List<IDAccordo> findIdAccordiServizioParteComune(IRegistryReader registryReader, ProtocolFiltroRicercaAccordi filtro) throws RegistryException{
  194.         List<IDAccordo> list = null;
  195.         try {
  196.             list = registryReader.findIdAccordiServizioParteComune(filtro);
  197.         }catch(RegistryNotFound notFound) {
  198.             // ignore
  199.         }
  200.         return list;
  201.     }
  202.     
  203.     static void updateProfiloInterazione(ModIProperties modiProperties,IProtocolFactory<?> protocolFactory,Logger log,
  204.             ConsoleConfiguration consoleConfiguration, ConsoleOperationType consoleOperationType, ProtocolProperties properties,
  205.             IRegistryReader registryReader, IDAccordo idAccordo, String idPortType, String idAzione, boolean rest, String httpMethod) throws ProtocolException {
  206.         
  207.         AbstractConsoleItem<?> profiloInterazioneItem =     
  208.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  209.         AbstractConsoleItem<?> profiloInterazioneAsincronaItem =    
  210.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  211.         AbstractConsoleItem<?> profiloInterazioneAsincronaRelazioneItem =   
  212.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  213.         AbstractConsoleItem<?> profiloInterazioneAsincronaCorrelataApiItem =    
  214.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID);
  215.         AbstractConsoleItem<?> profiloInterazioneAsincronaCorrelataServizioItem =   
  216.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_SERVIZIO_RICHIESTA_CORRELATA_ID);
  217.         AbstractConsoleItem<?> profiloInterazioneAsincronaCorrelataAzioneItem =     
  218.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA_ID);
  219.         
  220.         ModIProfiliInterazioneRESTConfig config = null;
  221.         boolean inUse = false;
  222.         if(rest) {
  223.             Resource resource = null;
  224.             if(ConsoleOperationType.CHANGE.equals(consoleOperationType)) {
  225.                 try {
  226.                     IDResource id = new IDResource();
  227.                     id.setIdAccordo(idAccordo);
  228.                     id.setNome(idAzione);
  229.                     resource = registryReader.getResourceAccordo(id);
  230.                     
  231.                     inUse = registryReader.inUso(id);
  232.                 }catch(Exception e) {
  233.                     throw new ProtocolException(e.getMessage(), e);
  234.                 }
  235.             }
  236.             config = new ModIProfiliInterazioneRESTConfig(modiProperties, httpMethod, resource);
  237.         }
  238.         else {
  239.             if(ConsoleOperationType.CHANGE.equals(consoleOperationType)) {
  240.                 try {
  241.                     IDPortType idPT = new IDPortType();
  242.                     idPT.setIdAccordo(idAccordo);
  243.                     idPT.setNome(idPortType);
  244.                     
  245.                     IDPortTypeAzione id = new IDPortTypeAzione();
  246.                     id.setIdPortType(idPT);
  247.                     id.setNome(idAzione);
  248.                     
  249.                     inUse = registryReader.inUso(id);
  250.                 }catch(Exception e) {
  251.                     throw new ProtocolException(e.getMessage(), e);
  252.                 }
  253.             }
  254.         }
  255.         
  256.         boolean addBloccante = true;
  257.         boolean addNonBloccantePush = true;
  258.         boolean addNonBloccantePull = true;
  259.         if(rest) {
  260.             addBloccante = config.isCompatibileBloccante();
  261.             addNonBloccantePush = config.isCompatibileNonBloccantePush();
  262.             addNonBloccantePull = config.isCompatibileNonBloccantePull();
  263.         }
  264.         
  265.         boolean allHidden = true;
  266.         StringProperty profiloInterazioneItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  267.         String profiloInterazione = rest ? ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_REST_VALUE : ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_SOAP_VALUE;
  268.         if(profiloInterazioneItemValue!=null && profiloInterazioneItemValue.getValue()!=null && !"".equals(profiloInterazioneItemValue.getValue())) {
  269.             profiloInterazione = profiloInterazioneItemValue.getValue();
  270.         }   
  271.         
  272.         if(!addBloccante) {
  273.             profiloInterazioneItem.removeLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL_BLOCCANTE);
  274.         }
  275.         if(!addNonBloccantePush && !addNonBloccantePull) {
  276.             profiloInterazioneItem.removeLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_LABEL_NON_BLOCCANTE);
  277.         }
  278.         
  279.         if( 
  280.                 (
  281.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_BLOCCANTE.equals(profiloInterazione) 
  282.                         &&
  283.                         !addBloccante
  284.                 ) 
  285.                 ||
  286.                 (
  287.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(profiloInterazione) 
  288.                         &&
  289.                         !addNonBloccantePush 
  290.                         && 
  291.                         !addNonBloccantePull
  292.                 )
  293.         ) {
  294.             profiloInterazione = rest ? ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_REST_VALUE : ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_SOAP_VALUE;
  295.         }
  296.         
  297.         if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(profiloInterazione)) {
  298.             
  299.             allHidden = false;
  300.             
  301.             profiloInterazioneAsincronaItem.setType(ConsoleItemType.SELECT);
  302.             if(addNonBloccantePush) {
  303.                 ((StringConsoleItem)profiloInterazioneAsincronaItem).addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_LABEL_PUSH,
  304.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH);
  305.             }
  306.             if(addNonBloccantePull) {
  307.                 ((StringConsoleItem)profiloInterazioneAsincronaItem).addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_LABEL_PULL,
  308.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL);
  309.             }
  310.             
  311.             StringProperty profiloInterazioneAsincronaItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  312.             String interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_DEFAULT_VALUE;
  313.             if(profiloInterazioneAsincronaItemValue!=null && profiloInterazioneAsincronaItemValue.getValue()!=null && !"".equals(profiloInterazioneAsincronaItemValue.getValue())) {
  314.                 interazioneMode = profiloInterazioneAsincronaItemValue.getValue();
  315.                 // verifico compatibilita
  316.                 if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(interazioneMode) &&
  317.                     !addNonBloccantePush) {
  318.                     interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL;
  319.                 }
  320.                 else if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL.equals(interazioneMode) &&
  321.                     !addNonBloccantePull) {
  322.                     interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH;
  323.                 }
  324.             }       
  325.             else {
  326.                 // verifico compatibilita default
  327.                 if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(interazioneMode) &&
  328.                     !addNonBloccantePush) {
  329.                     interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL;
  330.                 }
  331.                 else if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL.equals(interazioneMode) &&
  332.                     !addNonBloccantePull) {
  333.                     interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH;
  334.                 }
  335.                 if(profiloInterazioneAsincronaItemValue!=null) {
  336.                     profiloInterazioneAsincronaItemValue.setValue(interazioneMode); // imposto il default
  337.                 }
  338.             }
  339.             boolean push = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(interazioneMode);
  340.             
  341.             boolean addRichiesta = true;
  342.             boolean addRichiestaStato = true;
  343.             boolean addRisposta = true;
  344.             if(push) {
  345.                 addRichiestaStato = false;
  346.                 if(rest) {
  347.                     addRichiesta = config.isCompatibileNonBloccantePushRequest();
  348.                     addRisposta = config.isCompatibileNonBloccantePushResponse();
  349.                 }
  350.             }
  351.             else {
  352.                 if(rest) {
  353.                     addRichiesta = config.isCompatibileNonBloccantePullRequest();
  354.                     addRichiestaStato = config.isCompatibileNonBloccantePullRequestState();
  355.                     addRisposta = config.isCompatibileNonBloccantePullResponse();
  356.                 }
  357.             }
  358.             
  359.             profiloInterazioneAsincronaRelazioneItem.setType(ConsoleItemType.SELECT);
  360.             if(addRichiesta) {
  361.                 ((StringConsoleItem)profiloInterazioneAsincronaRelazioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL_RICHIESTA,
  362.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA);
  363.             }
  364.             if(addRichiestaStato) {
  365.                 ((StringConsoleItem)profiloInterazioneAsincronaRelazioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL_RICHIESTA_STATO,
  366.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO);
  367.             }
  368.             if(addRisposta) {
  369.                 ((StringConsoleItem)profiloInterazioneAsincronaRelazioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL_RISPOSTA,
  370.                         ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA);
  371.             }
  372.             
  373.             StringProperty profiloRelazioneAsincronaItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  374.             String relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_DEFAULT_VALUE;
  375.             if(profiloRelazioneAsincronaItemValue!=null && profiloRelazioneAsincronaItemValue.getValue()!=null && !"".equals(profiloRelazioneAsincronaItemValue.getValue())) {
  376.                 relazioneMode = profiloRelazioneAsincronaItemValue.getValue();
  377.             }   
  378.             if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(relazioneMode) && !addRichiesta) {
  379.                 if(addRisposta) {
  380.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA;
  381.                 }
  382.                 else if(addRichiestaStato) {
  383.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO;
  384.                 }
  385.             }
  386.             else if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(relazioneMode) && !addRichiestaStato) {
  387.                 if(addRichiesta) {
  388.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA;
  389.                 }
  390.                 else if(addRisposta) {
  391.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA;
  392.                 }
  393.             }
  394.             else if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(relazioneMode) && !addRisposta) {
  395.                 if(addRichiesta) {
  396.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA;
  397.                 }
  398.                 else if(addRichiestaStato) {
  399.                     relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO;
  400.                 }
  401.             }
  402.             
  403.             boolean request = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(relazioneMode);         
  404.             if(request) {
  405.                 profiloInterazioneAsincronaCorrelataApiItem.setType(ConsoleItemType.HIDDEN);
  406.                 profiloInterazioneAsincronaCorrelataServizioItem.setType(ConsoleItemType.HIDDEN);
  407.                 profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.HIDDEN);
  408.             }
  409.             else {
  410.                 try {
  411.                                         
  412.                     if(push) {
  413.                         // *** PUSH ***
  414.                         
  415.                         profiloInterazioneAsincronaCorrelataApiItem.setType(ConsoleItemType.SELECT);
  416.                         ((StringConsoleItem)profiloInterazioneAsincronaCorrelataApiItem).addLabelValue(ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED,ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  417.                         profiloInterazioneAsincronaCorrelataApiItem.setLabel(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_CORRELATA_A_API_LABEL);
  418.                                                 
  419.                         profiloInterazioneAsincronaCorrelataServizioItem.setType(ConsoleItemType.HIDDEN);
  420.                         profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.HIDDEN);
  421.                                                 
  422.                         // listo le altre API
  423.                         ProtocolFiltroRicercaAccordi filtro = new ProtocolFiltroRicercaAccordi();
  424.                         filtro.setServiceBinding(idPortType!=null ? ServiceBinding.SOAP : ServiceBinding.REST);
  425.                         filtro.setSoggetto(new IDSoggetto(protocolFactory.createProtocolConfiguration().getTipoSoggettoDefault(), null));
  426.                         List<IDAccordo> list = findIdAccordiServizioParteComune(registryReader, filtro);
  427.                         if(list!=null && !list.isEmpty()) {
  428.                             for (IDAccordo idAccordoTrovato : list) {
  429.                                 String uri = IDAccordoFactory.getInstance().getUriFromIDAccordo(idAccordoTrovato);
  430.                                 ((StringConsoleItem)profiloInterazioneAsincronaCorrelataApiItem).addLabelValue(NamingUtils.getLabelAccordoServizioParteComune(idAccordoTrovato),uri);
  431.                             }
  432.                         }
  433.                         
  434.                         StringProperty apiValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID);
  435.                         if(apiValue!=null && apiValue.getValue()!=null && !"".equals(apiValue.getValue()) &&
  436.                                 !ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(apiValue.getValue())) {
  437.                             String uriAPI = apiValue.getValue();
  438.                             IDAccordo idAccordoSelected = IDAccordoFactory.getInstance().getIDAccordoFromUri(uriAPI);
  439.                         
  440.                             // Utility
  441.                             AccordoServizioParteSpecifica asps = new AccordoServizioParteSpecifica();
  442.                             asps.setTipoSoggettoErogatore(idAccordoSelected.getSoggettoReferente().getTipo());
  443.                             asps.setNomeSoggettoErogatore(idAccordoSelected.getSoggettoReferente().getNome());
  444.                             asps.setNome(idAccordoSelected.getNome());
  445.                             asps.setVersione(idAccordoSelected.getVersione());
  446.                             AccordoServizioParteComune aspcNormale = registryReader.getAccordoServizioParteComune(idAccordoSelected,false,false);
  447.                             AccordoServizioParteComuneSintetico aspcSelected = new AccordoServizioParteComuneSintetico(aspcNormale);
  448.                             boolean addTrattinoSelezioneNonEffettuata = true;
  449.                             boolean throwException = true;
  450.                             
  451.                             AccordoServizioParteComune aspc = getAccordoServizioParteComune(registryReader, idAccordoSelected);
  452.                             
  453.                             if(idPortType!=null) {
  454.                                 // SOAP
  455.                                 profiloInterazioneAsincronaCorrelataServizioItem.setType(ConsoleItemType.SELECT);
  456.                                 ((StringConsoleItem)profiloInterazioneAsincronaCorrelataServizioItem).addLabelValue(ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED,ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  457.                                 profiloInterazioneAsincronaCorrelataServizioItem.setLabel(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_CORRELATA_A_SERVIZIO_LABEL);
  458.                                 
  459.                                 if(aspc!=null && aspc.sizePortTypeList()>0) {
  460.                                     for (PortType pt : aspc.getPortTypeList()) {
  461.                                         if(pt.getNome().equals(idPortType)) {
  462.                                             continue;
  463.                                         }
  464.                                         ((StringConsoleItem)profiloInterazioneAsincronaCorrelataServizioItem).addLabelValue(pt.getNome(), pt.getNome());
  465.                                     }
  466.                                 }
  467.                                 
  468.                                 StringProperty ptValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_SERVIZIO_RICHIESTA_CORRELATA_ID);
  469.                                 if(ptValue!=null && ptValue.getValue()!=null && !"".equals(ptValue.getValue()) &&
  470.                                         !ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(ptValue.getValue())) {
  471.                                 
  472.                                     profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.SELECT);
  473.                                     ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED,ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  474.                                     profiloInterazioneAsincronaCorrelataAzioneItem.setLabel(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_CORRELATA_A_AZIONE_LABEL);
  475.                                                                         
  476.                                     asps.setPortType(ptValue.getValue());
  477.                                                                         
  478.                                     // listo le altre azioni
  479.                                     List<String> filtraAzioniUtilizzate = new ArrayList<>();
  480.                                     filtraAzioniUtilizzate.add(idAzione);
  481.                                     Map<String,String> azioni = AzioniUtils.getAzioniConLabel(asps, aspcSelected, addTrattinoSelezioneNonEffettuata, throwException, 
  482.                                             filtraAzioniUtilizzate, ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED, ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED, log); 
  483.                                     if(azioni!=null && !azioni.isEmpty()) {
  484.                                         for (Map.Entry<String,String> entry : azioni.entrySet()) {
  485.                                             String azioneId = entry.getKey();
  486.                                             String tmpInterazione = AzioniUtils.getProtocolPropertyStringValue(aspc, ptValue.getValue(), azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  487.                                             if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(tmpInterazione)) {
  488.                                                 continue;
  489.                                             }
  490.                                             String tmpRuolo = AzioniUtils.getProtocolPropertyStringValue(aspc, ptValue.getValue(), azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  491.                                             if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(tmpRuolo)) {
  492.                                                 continue;
  493.                                             }
  494.                                             String tmpRelazione = AzioniUtils.getProtocolPropertyStringValue(aspc, ptValue.getValue(), azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  495.                                             if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(tmpRelazione)) {
  496.                                                 continue;
  497.                                             }
  498.                                             String azioneLabel = azioni.get(azioneId);
  499.                                             ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(azioneLabel,azioneId);
  500.                                         }
  501.                                     }
  502.                                 }
  503.                             }
  504.                             else {
  505.                                 // REST
  506.                                 
  507.                                 profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.SELECT);
  508.                                 ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED,ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  509.                                 profiloInterazioneAsincronaCorrelataAzioneItem.setLabel(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_CORRELATA_A_RISORSA_LABEL);
  510.                                 
  511.                                 // listo le altre azioni
  512.                                 List<String> filtraAzioniUtilizzate = new ArrayList<>();
  513.                                 filtraAzioniUtilizzate.add(idAzione);
  514.                                 Map<String,String> azioni = AzioniUtils.getAzioniConLabel(asps, aspcSelected, addTrattinoSelezioneNonEffettuata, throwException, 
  515.                                         filtraAzioniUtilizzate, ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED, ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED, log); 
  516.                                 if(azioni!=null && !azioni.isEmpty()) {
  517.                                     for (String azioneId : azioni.keySet()) {
  518.                                         String tmpInterazione = AzioniUtils.getProtocolPropertyStringValue(aspc, null, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  519.                                         if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(tmpInterazione)) {
  520.                                             continue;
  521.                                         }
  522.                                         String tmpRuolo = AzioniUtils.getProtocolPropertyStringValue(aspc, null, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  523.                                         if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(tmpRuolo)) {
  524.                                             continue;
  525.                                         }
  526.                                         String tmpRelazione = AzioniUtils.getProtocolPropertyStringValue(aspc, null, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  527.                                         if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(tmpRelazione)) {
  528.                                             continue;
  529.                                         }
  530.                                         String azioneLabel = azioni.get(azioneId);
  531.                                         ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(azioneLabel,azioneId);
  532.                                     }
  533.                                 }
  534.                             }
  535.                         }       
  536.                     }
  537.                     else {
  538.                         // *** PULL ***
  539.                         
  540.                         profiloInterazioneAsincronaCorrelataApiItem.setType(ConsoleItemType.HIDDEN);
  541.                         profiloInterazioneAsincronaCorrelataServizioItem.setType(ConsoleItemType.HIDDEN);
  542.                         
  543.                         profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.SELECT);
  544.                         ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED,ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED);
  545.                         profiloInterazioneAsincronaCorrelataAzioneItem.setLabel(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_CORRELATA_A_LABEL);
  546.                         
  547.                         // Utility
  548.                         AccordoServizioParteSpecifica asps = new AccordoServizioParteSpecifica();
  549.                         asps.setTipoSoggettoErogatore(idAccordo.getSoggettoReferente().getTipo());
  550.                         asps.setNomeSoggettoErogatore(idAccordo.getSoggettoReferente().getNome());
  551.                         asps.setNome(idAccordo.getNome());
  552.                         asps.setVersione(idAccordo.getVersione());
  553.                         asps.setPortType(idPortType);
  554.                         AccordoServizioParteComune aspcNormale = registryReader.getAccordoServizioParteComune(idAccordo,false,false);
  555.                         AccordoServizioParteComuneSintetico aspc = new AccordoServizioParteComuneSintetico(aspcNormale);
  556.                         boolean addTrattinoSelezioneNonEffettuata = true;
  557.                         boolean throwException = true;
  558.                         
  559.                         // listo le altre azioni
  560.                         List<String> filtraAzioniUtilizzate = new ArrayList<>();
  561.                         filtraAzioniUtilizzate.add(idAzione);
  562.                         Map<String,String> azioni = AzioniUtils.getAzioniConLabel(asps, aspc, addTrattinoSelezioneNonEffettuata, throwException, 
  563.                                 filtraAzioniUtilizzate, ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED, ModIConsoleCostanti.MODIPA_LABEL_UNDEFINED, log); 
  564.                         if(azioni!=null && !azioni.isEmpty()) {
  565.                             for (String azioneId : azioni.keySet()) {
  566.                                 String tmpInterazione = AzioniUtils.getProtocolPropertyStringValue(aspcNormale, idPortType, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  567.                                 if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(tmpInterazione)) {
  568.                                     continue;
  569.                                 }
  570.                                 String tmpRuolo = AzioniUtils.getProtocolPropertyStringValue(aspcNormale, idPortType, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  571.                                 if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PULL.equals(tmpRuolo)) {
  572.                                     continue;
  573.                                 }
  574.                                 String tmpRelazione = AzioniUtils.getProtocolPropertyStringValue(aspcNormale, idPortType, azioneId, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  575.                                 if(!ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(tmpRelazione)) {
  576.                                     continue;
  577.                                 }
  578.                                 String azioneLabel = azioni.get(azioneId);
  579.                                 ((StringConsoleItem)profiloInterazioneAsincronaCorrelataAzioneItem).addLabelValue(azioneLabel,azioneId);
  580.                             }
  581.                         }

  583.                     }
  584.                 }catch(Exception e) {
  585.                     throw new ProtocolException(e.getMessage(),e);
  586.                 }
  587.             }
  588.         }
  589.         
  590.         if(allHidden) {
  591.             profiloInterazioneAsincronaItem.setType(ConsoleItemType.HIDDEN);
  592.             profiloInterazioneAsincronaRelazioneItem.setType(ConsoleItemType.HIDDEN);
  593.             profiloInterazioneAsincronaCorrelataApiItem.setType(ConsoleItemType.HIDDEN);
  594.             profiloInterazioneAsincronaCorrelataServizioItem.setType(ConsoleItemType.HIDDEN);
  595.             profiloInterazioneAsincronaCorrelataAzioneItem.setType(ConsoleItemType.HIDDEN);
  596.         }
  597.         else if(inUse) {
  598.             
  599.             setLabelInUse(consoleConfiguration, properties, profiloInterazioneItem, 
  600.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID,
  601.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID_INUSE_READONLY);
  602.             
  603.             setLabelInUse(consoleConfiguration, properties, profiloInterazioneAsincronaItem, 
  604.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID,
  605.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID_INUSE_READONLY);
  606.             
  607.             setLabelInUse(consoleConfiguration, properties, profiloInterazioneAsincronaRelazioneItem, 
  608.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID,
  609.                     ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID_INUSE_READONLY);

  611.         }
  612.         
  613.     }

  615.     static void setLabelInUse(ConsoleConfiguration consoleConfiguration, ProtocolProperties properties,
  616.             AbstractConsoleItem<?> item, String id, String idReadOnly) throws ProtocolException {
  617.         if(!ConsoleItemType.HIDDEN.equals(item.getType())){
  618.             
  619.             StringProperty itemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, id);
  620.                         
  621.             item.setType(ConsoleItemType.HIDDEN);
  622.             AbstractConsoleItem<?> itemReadOnly =   
  623.                     ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), idReadOnly);
  624.             itemReadOnly.setType(ConsoleItemType.TEXT);
  625.             String label = null;
  626.             String labelDefault = null;
  627.             if(item instanceof StringConsoleItem) {
  628.                 StringConsoleItem sci = (StringConsoleItem) item;
  629.                 SortedMap<String> map = sci.getMapLabelValues();
  630.                 if(map!=null && !map.isEmpty()) {
  631.                     for (String l : map.keys()) {
  632.                         String v = map.get(l);
  633.                         if(v!=null && v.equals(itemValue.getValue())) {
  634.                             label = l;
  635.                         }
  636.                         if(v!=null && v.equals(item.getDefaultValue())) {
  637.                             labelDefault = l;
  638.                         }
  639.                     }
  640.                 }
  641.             }

  643.             StringProperty itemValueReadOnly = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, idReadOnly);
  644.             if(label!=null) {
  645.                 itemValueReadOnly.setValue(label);
  646.             }
  647.             else {
  648.                 itemValueReadOnly.setValue(labelDefault);
  649.             }
  650.         }
  651.     }
  652.         
  653.     static void validateProfiloInterazione(ProtocolProperties properties,
  654.             String idPortType, boolean rest) throws ProtocolException {
  655.     
  656.         StringProperty profiloInterazioneItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ID);
  657.         String profiloInterazione = rest ? ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_REST_VALUE : ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_DEFAULT_SOAP_VALUE;
  658.         if(profiloInterazioneItemValue!=null && profiloInterazioneItemValue.getValue()!=null && !"".equals(profiloInterazioneItemValue.getValue())) {
  659.             profiloInterazione = profiloInterazioneItemValue.getValue();
  660.         }   
  661.         if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_VALUE_NON_BLOCCANTE.equals(profiloInterazione)) {
  662.             
  663.             StringProperty profiloInterazioneAsincronaItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_ID);
  664.             String interazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_DEFAULT_VALUE;
  665.             if(profiloInterazioneAsincronaItemValue!=null && profiloInterazioneAsincronaItemValue.getValue()!=null && !"".equals(profiloInterazioneAsincronaItemValue.getValue())) {
  666.                 interazioneMode = profiloInterazioneAsincronaItemValue.getValue();
  667.             }       
  668.             boolean push = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(interazioneMode);
  669.             
  670.             StringProperty profiloRelazioneAsincronaItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_ID);
  671.             String relazioneMode = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_DEFAULT_VALUE;
  672.             if(profiloRelazioneAsincronaItemValue!=null && profiloRelazioneAsincronaItemValue.getValue()!=null && !"".equals(profiloRelazioneAsincronaItemValue.getValue())) {
  673.                 relazioneMode = profiloRelazioneAsincronaItemValue.getValue();
  674.             }       
  675.             boolean request = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(relazioneMode);
  676.             
  677.             if(!request) {
  678.                 
  679.                 String labelRelazione = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL_RISPOSTA;
  680.                 if(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(relazioneMode)) {
  681.                     labelRelazione = ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_LABEL_RICHIESTA_STATO;  
  682.                 }
  683.                 
  684.                 if(push) {
  685.                     // *** PUSH ***
  686.                     
  687.                     String prefixPushNonBloccante = "Il profilo non bloccante 'PUSH', relazione '"+labelRelazione+"'";
  688.                     
  689.                     StringProperty apiItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID);
  690.                     if(apiItemValue==null || apiItemValue.getValue()==null || "".equals(apiItemValue.getValue()) ||
  691.                             ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(apiItemValue.getValue())) {
  692.                         throw new ProtocolException(prefixPushNonBloccante+", richiede che sia perfezionata una correlazione verso una API che implementa il servizio di risposta");
  693.                     }
  694.                     
  695.                     if(idPortType!=null) {
  696.                         StringProperty ptItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_SERVIZIO_RICHIESTA_CORRELATA_ID);
  697.                         if(ptItemValue==null || ptItemValue.getValue()==null || "".equals(ptItemValue.getValue()) ||
  698.                                 ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(ptItemValue.getValue())) {
  699.                             throw new ProtocolException(prefixPushNonBloccante+", richiede che sia perfezionata una correlazione verso un servizio di risposta");
  700.                         }
  701.                     }
  702.                     
  703.                     StringProperty azioneItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA_ID);
  704.                     if(azioneItemValue==null || azioneItemValue.getValue()==null || "".equals(azioneItemValue.getValue()) ||
  705.                             ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(azioneItemValue.getValue())) {
  706.                         String az = null;
  707.                         if(idPortType!=null) {
  708.                             az = "un'azione";
  709.                         }
  710.                         else {
  711.                             az = "una risorsa";
  712.                         }
  713.                         throw new ProtocolException(prefixPushNonBloccante+", richiede che sia perfezionata una correlazione verso "+az+" con relazione 'Richiesta'");
  714.                     }
  715.                 }
  716.                 else {
  717.                     // *** PULL ***
  718.                     StringProperty azioneItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA_ID);
  719.                     if(azioneItemValue==null || azioneItemValue.getValue()==null || "".equals(azioneItemValue.getValue()) ||
  720.                             ModIConsoleCostanti.MODIPA_VALUE_UNDEFINED.equals(azioneItemValue.getValue())) {
  721.                         String az = null;
  722.                         if(idPortType!=null) {
  723.                             az = "un'azione";
  724.                         }
  725.                         else {
  726.                             az = "una risorsa";
  727.                         }
  728.                         throw new ProtocolException("Il profilo non bloccante 'PULL', relazione '"+labelRelazione+"', richiede che sia perfezionata una correlazione verso "+az+" con relazione 'Richiesta'");
  729.                     }
  730.                 }
  731.                 
  732.             }
  733.         }
  734.         
  735.     }
  736.     
  737.     static void updateProfiloSicurezzaCanale(ConsoleConfiguration consoleConfiguration, ProtocolProperties properties) {
  738.                 
  739.         AbstractConsoleItem<?> profiloSicurezzaCanaleItem =     
  740.                 ProtocolPropertiesUtils.getAbstractConsoleItem(consoleConfiguration.getConsoleItem(), ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_ID);
  741.         StringProperty sicurezzaCanaleItemValue = (StringProperty) ProtocolPropertiesUtils.getAbstractPropertyById(properties, ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_ID);
  742.         
  743.         String value = sicurezzaCanaleItemValue!=null ? sicurezzaCanaleItemValue.getValue() : null;
  744.         if(ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_VALUE_IDAC01.equals(value)) {
  745.             profiloSicurezzaCanaleItem.setNote(ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_LABEL_IDAC01_NOTE);
  746.         }
  747.         else if(ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_VALUE_IDAC02.equals(value)) {
  748.             profiloSicurezzaCanaleItem.setNote(ModIConsoleCostanti.MODIPA_PROFILO_SICUREZZA_CANALE_LABEL_IDAC02_NOTE);
  749.         }

  751.     }
  752.     
  753.     private static boolean permettiModificaNomeAccordo = true;
  754.     public static boolean isPermettiModificaNomeAccordo() {
  755.         return permettiModificaNomeAccordo;
  756.     }
  757.     public static void setPermettiModificaNomeAccordo(boolean permettiModificaNomeAccordo) {
  758.         ModIDynamicConfigurationAccordiParteComuneUtilities.permettiModificaNomeAccordo = permettiModificaNomeAccordo;
  759.     }

  761.     private static int valueOfVersione(String versioneS) {
  762.         int versione = -1;
  763.         try {
  764.             versione = Integer.valueOf(versioneS);
  765.         }catch(Exception e) {
  766.             // ignore
  767.         }
  768.         return versione;
  769.     }
  770.     
  771.     private static List<IDResource> findIdResourceAccordo(IRegistryReader registryReader,ProtocolFiltroRicercaRisorse filtro) throws RegistryException {
  772.         List<IDResource> list = null;
  773.         try {
  774.             list = registryReader.findIdResourceAccordo(filtro);
  775.         }catch(RegistryNotFound notFound) {
  776.             // ignore
  777.         }
  778.         return list;
  779.     }
  780.     private static List<IDPortTypeAzione> findIdAzionePortType(IRegistryReader registryReader,ProtocolFiltroRicercaPortTypeAzioni filtro) throws RegistryException {
  781.         List<IDPortTypeAzione> list = null;
  782.         try {
  783.             list = registryReader.findIdAzionePortType(filtro);
  784.         }catch(RegistryNotFound notFound) {
  785.             // ignore
  786.         }
  787.         return list;
  788.     }
  789.     
  790.     static void validateDynamicConfigAccordoServizioParteComune(ConsoleOperationType consoleOperationType, IConsoleHelper consoleHelper, ProtocolProperties properties, 
  791.             IRegistryReader registryReader, IDAccordo id) throws ProtocolException{
  792.         
  793.         boolean rest = isApiRest(consoleOperationType, consoleHelper, registryReader, id);
  794.         
  795.         // Lascio il codice se servisse, ma è stato aggiunto la gestione sull'update dell'API
  796.         if(!permettiModificaNomeAccordo && ConsoleOperationType.CHANGE.equals(consoleOperationType) && id!=null) {
  797.             try {
  798.                 String apiGestioneParziale = consoleHelper.getParameter(Costanti.CONSOLE_PARAMETRO_APC_API_GESTIONE_PARZIALE);
  799.                 if(Costanti.CONSOLE_VALORE_PARAMETRO_APC_API_INFORMAZIONI_GENERALI.equals(apiGestioneParziale)) {
  800.                     String nome = consoleHelper.getParameter(Costanti.CONSOLE_PARAMETRO_APC_NOME);
  801.                     String versioneS = consoleHelper.getParameter(Costanti.CONSOLE_PARAMETRO_APC_VERSIONE);
  802.                     int versione = valueOfVersione(versioneS);
  803.                     if(nome!=null && versione>0 &&
  804.                         (!id.getNome().equals(nome) || id.getVersione().intValue()!=versione)
  805.                         ) {
  806.                             
  807.                         AccordoServizioParteComune as = registryReader.getAccordoServizioParteComune(id);
  808.                         if(ServiceBinding.REST.equals(as.getServiceBinding())){
  809.                             
  810.                             ProtocolFiltroRicercaRisorse filtro = new ProtocolFiltroRicercaRisorse();
  811.                             ProtocolProperties protocolPropertiesResources = new ProtocolProperties();
  812.                             protocolPropertiesResources.addProperty(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID, IDAccordoFactory.getInstance().getUriFromIDAccordo(id));
  813.                             filtro.setProtocolPropertiesRisorsa(protocolPropertiesResources);
  814.                             List<IDResource> list = findIdResourceAccordo(registryReader, filtro);
  815.                             if(list!=null && !list.isEmpty()) {
  816.                                 // ne dovrebbe esistere solo una.
  817.                                 IDResource idR = list.get(0);
  818.                                 String uriAPI = NamingUtils.getLabelAccordoServizioParteComune(idR.getIdAccordo());
  819.                                 Resource resource = registryReader.getResourceAccordo(idR);
  820.                                 String labelR = NamingUtils.getLabelResource(resource);
  821.                                 throw new ProtocolException("Non è possibile modificare le informazioni generali dell'API poichè riferita dalla risorsa '"+labelR+"' dell'API '"+uriAPI+"' (Profilo non bloccante PUSH)");
  822.                             }
  823.                             
  824.                         }
  825.                         else {
  826.                         
  827.                             ProtocolFiltroRicercaPortTypeAzioni filtro = new ProtocolFiltroRicercaPortTypeAzioni();
  828.                             ProtocolProperties protocolPropertiesAzioni = new ProtocolProperties();
  829.                             protocolPropertiesAzioni.addProperty(ModIConsoleCostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA_ID, IDAccordoFactory.getInstance().getUriFromIDAccordo(id));
  830.                             filtro.setProtocolPropertiesAzione(protocolPropertiesAzioni);
  831.                             List<IDPortTypeAzione> list = findIdAzionePortType(registryReader,filtro);
  832.                             if(list!=null && !list.isEmpty()) {
  833.                                 // ne dovrebbe esistere solo una.
  834.                                 IDPortTypeAzione idA = list.get(0);
  835.                                 String uriAPI = NamingUtils.getLabelAccordoServizioParteComune(idA.getIdPortType().getIdAccordo());
  836.                                 throw new ProtocolException("Non è possibile modificare le informazioni generali dell'API poichè riferita dall'azione '"+idA.getNome()+"' del Servizio '"+idA.getIdPortType().getNome()+"' nell'API '"+uriAPI+"' (Profilo non bloccante PUSH)");
  837.                             }
  838.                             
  839.                         }
  840.                     }
  841.                 }
  842.             }catch(Exception e) {
  843.                 throw new ProtocolException(e.getMessage(),e);
  844.             }
  845.             
  846.         }
  847.         
  848.         ModIDynamicConfigurationAccordiParteComuneSicurezzaMessaggioUtilities.validateProfiloSicurezzaMessaggio(properties, rest);
  849.     }
  850.     
  851.     static boolean isApiRest(ConsoleOperationType consoleOperationType, IConsoleHelper consoleHelper,
  852.             IRegistryReader registryReader, IDAccordo id) throws ProtocolException {
  853.         boolean rest = true;
  854.         AccordoServizioParteComune aspc = null;
  855.         if(ConsoleOperationType.CHANGE.equals(consoleOperationType) && id!=null) {
  856.             try {
  857.                 aspc = registryReader.getAccordoServizioParteComune(id, false, false);
  858.             }catch(RegistryNotFound notFound) {
  859.                 // ignore
  860.             }
  861.             catch(Exception e) {
  862.                 throw new ProtocolException(e.getMessage(),e);
  863.             }
  864.         }
  865.         if(aspc!=null) {
  866.             rest = ServiceBinding.REST.equals(aspc.getServiceBinding());
  867.         }
  868.         else {
  869.             try {
  870.                 String serviceBinding = consoleHelper.getParameter(Costanti.CONSOLE_PARAMETRO_SERVICE_BINDING);
  871.                 rest = !ServiceBinding.SOAP.name().equals(serviceBinding);
  872.             }catch(Exception e) {
  873.                 throw new ProtocolException(e.getMessage(),e);
  874.             }
  875.         }
  876.         return rest;
  877.     }
  878.     
  879.     private static IDAccordo idAccordoSignalHubPushAPI = null;
  880.     public static IDAccordo getIdAccordoSignalHubPush(IRegistryReader registryReader, ModIProperties modiProperties) throws RegistryNotFound, RegistryException, DriverRegistroServiziException, ProtocolException {
  881.         if(idAccordoSignalHubPushAPI==null) {
  882.             initIdAccordoSignalHubPush(registryReader, modiProperties);
  883.         }
  884.         return idAccordoSignalHubPushAPI;
  885.     }
  886.     private static synchronized void initIdAccordoSignalHubPush(IRegistryReader registryReader, ModIProperties modiProperties) throws RegistryNotFound, RegistryException, DriverRegistroServiziException, ProtocolException {
  887.         if(idAccordoSignalHubPushAPI==null) {
  888.             IDSoggetto idSoggetto = registryReader.getIdSoggettoDefault(Costanti.MODIPA_PROTOCOL_NAME);
  889.             idAccordoSignalHubPushAPI = IDAccordoFactory.getInstance().getIDAccordoFromValues(modiProperties.getSignalHubApiName(), idSoggetto, modiProperties.getSignalHubApiVersion());
  890.         }
  891.     }
  892.     
  893.     public static boolean isApiSignalHubPushAPI(IDAccordo idAccordo, IRegistryReader registryReader, 
  894.             ModIProperties modiProperties, Logger log) {
  895.         if(idAccordo!=null) {
  896.             // è un accordo built-in che si assume esista
  897.             IDAccordo idAccordoSignalHubPushAPIreaded = null;
  898.             try {
  899.                 idAccordoSignalHubPushAPIreaded = ModIDynamicConfigurationAccordiParteComuneUtilities.getIdAccordoSignalHubPush(registryReader, modiProperties);
  900.             }catch(Exception e) {
  901.                 log.error("Lettura id accordo signalhub api push fallita: "+e.getMessage(),e);
  902.             }
  903.             return idAccordoSignalHubPushAPIreaded!=null && idAccordoSignalHubPushAPIreaded.equals(idAccordo);
  904.         }
  905.         return false;
  906.     }
  907. }
Created with JaCoCo 0.8.8.202204050719