BasicConfiguration.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.basic.config;

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

  26. import org.openspcoop2.core.constants.TipoPdD;
  27. import org.openspcoop2.core.id.IDServizio;
  28. import org.openspcoop2.message.config.ServiceBindingConfiguration;
  29. import org.openspcoop2.message.constants.ServiceBinding;
  30. import org.openspcoop2.protocol.basic.BasicComponentFactory;
  31. import org.openspcoop2.protocol.manifest.Binding;
  32. import org.openspcoop2.protocol.manifest.CollaborationProfile;
  33. import org.openspcoop2.protocol.manifest.Functionality;
  34. import org.openspcoop2.protocol.manifest.InterfaceConfiguration;
  35. import org.openspcoop2.protocol.manifest.Openspcoop2;
  36. import org.openspcoop2.protocol.manifest.OrganizationType;
  37. import org.openspcoop2.protocol.manifest.Registry;
  38. import org.openspcoop2.protocol.manifest.ServiceType;
  39. import org.openspcoop2.protocol.manifest.SoapHeaderBypassMustUnderstandHeader;
  40. import org.openspcoop2.protocol.manifest.Version;
  41. import org.openspcoop2.protocol.manifest.constants.InterfaceType;
  42. import org.openspcoop2.protocol.sdk.BypassMustUnderstandCheck;
  43. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  44. import org.openspcoop2.protocol.sdk.ProtocolException;
  45. import org.openspcoop2.protocol.sdk.constants.FunzionalitaProtocollo;
  46. import org.openspcoop2.protocol.sdk.constants.InitialIdConversationType;
  47. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  48. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  49. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  50. import org.openspcoop2.utils.certificate.remote.RemoteStoreConfig;
  51. import org.openspcoop2.utils.transport.TransportRequestContext;

  53. /**
  54.  * Classe che implementa, l'interfaccia {@link org.openspcoop2.protocol.sdk.config.IProtocolConfiguration} 
  55.  *
  56.  * @author Poli Andrea (apoli@link.it)
  57.  * @author $Author$
  58.  * @version $Rev$, $Date$
  59.  */
  60. public class BasicConfiguration extends BasicComponentFactory implements org.openspcoop2.protocol.sdk.config.IProtocolConfiguration {

  62.     private Registry registroManifest;
  63.     private Binding bindingManifest;
  64.     private Openspcoop2 manifest;

  66.     public BasicConfiguration(IProtocolFactory<?> factory) throws ProtocolException {
  67.         super(factory);
  68.         this.manifest = this.protocolFactory.getManifest();
  69.         this.registroManifest = this.manifest.getRegistry();
  70.         this.bindingManifest = this.manifest.getBinding();
  71.     }
  72.     

  74.     
  75.     
  76.     @Override
  77.     public ServiceBindingConfiguration getDefaultServiceBindingConfiguration(TransportRequestContext transportRequest) throws ProtocolException{
  78.         return ServiceBindingConfigurationReader.getDefaultServiceBindingConfiguration(this.manifest, transportRequest);
  79.     }
  80.     
  81.     @Override
  82.     public ServiceBinding getIntegrationServiceBinding(IDServizio idServizio, IRegistryReader registryReader) throws ProtocolException, RegistryNotFound{
  83.         return ServiceBindingConfigurationReader.getServiceBinding(idServizio, registryReader);
  84.     }
  85.     
  86.     @Override
  87.     public ServiceBinding getProtocolServiceBinding(ServiceBinding integrationServiceBinding, TransportRequestContext transportRequest) throws ProtocolException{
  88.         return integrationServiceBinding; // stesso service binding tra integration e protocol per default
  89.     }
  90.     
  91.     @Override
  92.     public ServiceBindingConfiguration getServiceBindingConfiguration(TransportRequestContext transportRequest, ServiceBinding serviceBinding,
  93.             IDServizio idServizio, IRegistryReader registryReader) throws ProtocolException, RegistryNotFound{
  94.         return ServiceBindingConfigurationReader.getServiceBindingConfiguration(this.manifest, transportRequest, serviceBinding, idServizio, registryReader);
  95.     }
  96.     
  97.     @Override
  98.     public List<InterfaceType> getInterfacceSupportate(ServiceBinding serviceBinding){
  99.         List<InterfaceType> list = new ArrayList<InterfaceType>();
  100.         switch (serviceBinding) {
  101.         case SOAP:
  102.             if(this.bindingManifest.getSoap()!=null && 
  103.                 this.bindingManifest.getSoap().getInterfaces()!=null &&
  104.                 this.bindingManifest.getSoap().getInterfaces().sizeSpecificationList()>0){
  105.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getSoap().getInterfaces().getSpecificationList()) {
  106.                     list.add(interfaceConfiguration.getType());
  107.                 }
  108.             }
  109.             break;
  110.         case REST:
  111.             if(this.bindingManifest.getRest()!=null && 
  112.                 this.bindingManifest.getRest().getInterfaces()!=null &&
  113.                 this.bindingManifest.getRest().getInterfaces().sizeSpecificationList()>0){
  114.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getRest().getInterfaces().getSpecificationList()) {
  115.                     list.add(interfaceConfiguration.getType());
  116.                 }
  117.             }
  118.             break;
  119.         }
  120.         return list;
  121.     }
  122.     
  123.     @Override
  124.     public boolean isSupportoSchemaEsternoInterfaccia(ServiceBinding serviceBinding, InterfaceType interfaceType) {
  125.         switch (serviceBinding) {
  126.         case SOAP:
  127.             if(this.bindingManifest.getSoap()!=null && 
  128.                 this.bindingManifest.getSoap().getInterfaces()!=null &&
  129.                 this.bindingManifest.getSoap().getInterfaces().sizeSpecificationList()>0){
  130.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getSoap().getInterfaces().getSpecificationList()) {
  131.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  132.                         return interfaceConfiguration.isSchema();
  133.                     }
  134.                 }
  135.             }
  136.             break;
  137.         case REST:
  138.             if(this.bindingManifest.getRest()!=null && 
  139.                 this.bindingManifest.getRest().getInterfaces()!=null &&
  140.                 this.bindingManifest.getRest().getInterfaces().sizeSpecificationList()>0){
  141.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getRest().getInterfaces().getSpecificationList()) {
  142.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  143.                         return interfaceConfiguration.isSchema();
  144.                     }
  145.                 }
  146.             }
  147.             break;
  148.         }
  149.         return false;
  150.     }
  151.     
  152.     @Override
  153.     public boolean isSupportoSpecificaConversazioni(ServiceBinding serviceBinding, InterfaceType interfaceType) {
  154.         switch (serviceBinding) {
  155.         case SOAP:
  156.             if(this.bindingManifest.getSoap()!=null && 
  157.                 this.bindingManifest.getSoap().getInterfaces()!=null &&
  158.                 this.bindingManifest.getSoap().getInterfaces().sizeSpecificationList()>0){
  159.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getSoap().getInterfaces().getSpecificationList()) {
  160.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  161.                         return interfaceConfiguration.isConversations();
  162.                     }
  163.                 }
  164.             }
  165.             break;
  166.         case REST:
  167.             if(this.bindingManifest.getRest()!=null && 
  168.                 this.bindingManifest.getRest().getInterfaces()!=null &&
  169.                 this.bindingManifest.getRest().getInterfaces().sizeSpecificationList()>0){
  170.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getRest().getInterfaces().getSpecificationList()) {
  171.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  172.                         return interfaceConfiguration.isConversations();
  173.                     }
  174.                 }
  175.             }
  176.             break;
  177.         }
  178.         return false;
  179.     }
  180.     
  181.     @Override
  182.     public boolean isSupportoPortiAccessoAccordiParteSpecifica(ServiceBinding serviceBinding, InterfaceType interfaceType) {
  183.         switch (serviceBinding) {
  184.         case SOAP:
  185.             if(this.bindingManifest.getSoap()!=null && 
  186.                 this.bindingManifest.getSoap().getInterfaces()!=null &&
  187.                 this.bindingManifest.getSoap().getInterfaces().sizeSpecificationList()>0){
  188.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getSoap().getInterfaces().getSpecificationList()) {
  189.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  190.                         return interfaceConfiguration.isImplementation();
  191.                     }
  192.                 }
  193.             }
  194.             break;
  195.         case REST:
  196.             if(this.bindingManifest.getRest()!=null && 
  197.                 this.bindingManifest.getRest().getInterfaces()!=null &&
  198.                 this.bindingManifest.getRest().getInterfaces().sizeSpecificationList()>0){
  199.                 for (InterfaceConfiguration interfaceConfiguration : this.bindingManifest.getRest().getInterfaces().getSpecificationList()) {
  200.                     if(interfaceType.equals(interfaceConfiguration.getType())) {
  201.                         return interfaceConfiguration.isImplementation();
  202.                     }
  203.                 }
  204.             }
  205.             break;
  206.         }
  207.         return false;
  208.     }
  209.     
  210.     @Override
  211.     public boolean isSupportoAutenticazioneSoggetti() {
  212.         return this.registroManifest.getOrganization().getAuthentication();
  213.     }
  214.     
  215.     @Override
  216.     public boolean isSupportatoAutenticazioneApplicativiHttpsConToken() {
  217.         return this.registroManifest.getOrganization().getHttpsWithTokenAuthentication();
  218.     }
  219.     
  220.     @Override
  221.     public boolean isSupportoAutenticazioneApplicativiErogazioni() {
  222.         return this.registroManifest.getOrganization().getInboundApplicativeAuthentication();
  223.     }
  224.     
  225.     @Override
  226.     public boolean isSupportatoAutorizzazioneRichiedenteSenzaAutenticazioneErogazioni() {
  227.         return this.registroManifest.getOrganization().getInboundOrganizationAuthorizationWithoutAuthentication();
  228.     }
  229.     
  230.     @Override
  231.     public boolean isSupportoAutenticazioneApplicativiEsterniErogazioni() {
  232.         return this.registroManifest.getOrganization().getInboundExternalApplicationAuthentication();
  233.     }
  234.     
  235.     @Override
  236.     public boolean isSupportoCodiceIPA() {
  237.         return this.registroManifest.getOrganization().isCodeIPA();
  238.     }
  239.     
  240.     @Override
  241.     public boolean isSupportoIdentificativoPortaSoggetto() {
  242.         return this.registroManifest.getOrganization().isCodeDomain();
  243.     }

  245.     @Override
  246.     public boolean isSupportoIndirizzoRisposta(){
  247.         return this.registroManifest.getOrganization().isReplyToAddress();
  248.     }
  249.     
  250.     @Override
  251.     public boolean isSupportoSoggettoUtilizzoTrattino() {
  252.         return this.registroManifest.getOrganization().isDash();
  253.     }
  254.     
  255.     @Override
  256.     public boolean isSupportoSoggettoReferenteAccordiParteComune() {
  257.         return this.registroManifest.getService().isApiReferent();
  258.     }
  259.     
  260.     @Override
  261.     public boolean isSupportoVersionamentoAccordiParteSpecifica() {
  262.         return this.registroManifest.getService().isVersion();
  263.     }
  264.     
  265.     @Override
  266.     public boolean isSupportoSbustamentoProtocollo() {
  267.         return this.registroManifest.getService().isProtocolEnvelopeManagement();
  268.     }
  269.     
  270.     @Override
  271.     public boolean isSupportoSceltaFault() {
  272.         return this.registroManifest.getService().isFaultChoice();
  273.     }
  274.     
  275.     @Override
  276.     public boolean isAbilitatoRiusoIdCorrelazioneApplicativa() {
  277.         return this.registroManifest.getService().isCorrelationReuseProtocolId();
  278.     }
  279.     
  280.     @Override
  281.     public boolean isAbilitataGenerazioneTracce() {
  282.         return this.registroManifest.getService().isTrace();
  283.     }
  284.     
  285.     @Override
  286.     public boolean isAbilitatoSalvataggioHeaderProtocolloTracce() {
  287.         return true;
  288.     }
  289.     
  290.     @Override
  291.     public List<String> getTipiSoggetti() throws ProtocolException {
  292.         List<String> tipi = new ArrayList<>();
  293.         List<OrganizationType> l = this.registroManifest.getOrganization().getTypes().getTypeList();
  294.         for (int i = 0; i < l.size(); i++) {
  295.             tipi.add(l.get(i).getName());
  296.         }
  297.         return tipi;
  298.     }
  299.     
  300.     @Override
  301.     public String getTipoSoggettoDefault() throws ProtocolException {
  302.         return this.registroManifest.getOrganization().getTypes().getType(0).getName();
  303.     }

  305.     private org.openspcoop2.protocol.manifest.constants.ServiceBinding convert(ServiceBinding serviceBinding){
  306.         switch (serviceBinding) {
  307.             case SOAP:
  308.                 return org.openspcoop2.protocol.manifest.constants.ServiceBinding.SOAP;
  309.             case REST:
  310.                 return org.openspcoop2.protocol.manifest.constants.ServiceBinding.REST;
  311.         }
  312.         return null;
  313.     }
  314.     
  315.     @Override
  316.     public List<String> getTipiServizi(ServiceBinding serviceBinding) throws ProtocolException {
  317.         
  318.         org.openspcoop2.protocol.manifest.constants.ServiceBinding sb = null;
  319.         if(serviceBinding!=null) {
  320.             sb = this.convert(serviceBinding);
  321.         }
  322.         
  323.         List<String> tipi = new ArrayList<>();
  324.         List<ServiceType> l = this.registroManifest.getService().getTypes().getTypeList();
  325.         for (int i = 0; i < l.size(); i++) {
  326.             org.openspcoop2.protocol.manifest.constants.ServiceBinding serviceBindingTmp = l.get(i).getBinding();
  327.             if(serviceBindingTmp==null || (sb!=null && serviceBindingTmp.equals(sb))){
  328.                 tipi.add(l.get(i).getName());   
  329.             }
  330.         }
  331.         return tipi;
  332.     }

  334.     @Override
  335.     public String getTipoServizioDefault(ServiceBinding serviceBinding) throws ProtocolException {
  336.         List<String> l = this.getTipiServizi(serviceBinding);
  337.         if(l!=null && l.size()>0){
  338.             return l.get(0);
  339.         }
  340.         return null;
  341.     }
  342.     
  343.     @Override
  344.     public List<String> getVersioni() throws ProtocolException{
  345.         List<String> tipi = new ArrayList<>();
  346.         List<Version> l = this.registroManifest.getVersions().getVersionList();
  347.         for (int i = 0; i < l.size(); i++) {
  348.             tipi.add(l.get(i).getName());
  349.         }
  350.         return tipi;
  351.     }

  353.     @Override
  354.     public String getVersioneDefault() throws ProtocolException {
  355.         return this.registroManifest.getVersions().getVersion(0).getName();
  356.     }
  357.     
  358.     @Override
  359.     public boolean isSupportato(ServiceBinding serviceBinding, ProfiloDiCollaborazione profiloCollaborazione)
  360.             throws ProtocolException {
  361.         if(profiloCollaborazione==null || serviceBinding==null){
  362.             throw new ProtocolException("Params not defined");
  363.         }
  364.         CollaborationProfile profilo = null;
  365.         if(ServiceBinding.REST.equals(serviceBinding)) {
  366.             if(this.bindingManifest.getRest()!=null) {
  367.                 profilo = new CollaborationProfile();
  368.                 if(this.bindingManifest.getRest().getProfile()!=null) {
  369.                     if(this.bindingManifest.getRest().getProfile().isOneway()) {
  370.                         profilo.setInputOutput(false);
  371.                         profilo.setOneway(true);
  372.                     }
  373.                     else {
  374.                         profilo.setInputOutput(true);
  375.                         profilo.setOneway(false);
  376.                     }
  377.                 }
  378.                 else {
  379.                     profilo.setInputOutput(true);
  380.                     profilo.setOneway(false);
  381.                 }
  382.                 profilo.setAsyncInputOutput(false);
  383.                 profilo.setPolledInputOutput(false);
  384.             }
  385.         }
  386.         else {
  387.             if(this.bindingManifest.getSoap()!=null) {
  388.                 profilo = this.bindingManifest.getSoap().getProfile();
  389.             }
  390.         }
  391.         switch (profiloCollaborazione) {
  392.         case ONEWAY:
  393.             return (profilo!=null ? profilo.isOneway() : true); 
  394.         case SINCRONO:      
  395.             return (profilo!=null ? profilo.isInputOutput() : true); 
  396.         case ASINCRONO_SIMMETRICO:      
  397.             return (profilo!=null ? profilo.isAsyncInputOutput() : false); 
  398.         case ASINCRONO_ASIMMETRICO:     
  399.             return (profilo!=null ? profilo.isPolledInputOutput() : false); 
  400.         case UNKNOWN:
  401.             throw new ProtocolException("Param ["+ProfiloDiCollaborazione.UNKNOWN.name()+"] not valid for this method");
  402.         default:
  403.             throw new ProtocolException("Param ["+profiloCollaborazione.getEngineValue()+"] not supported");
  404.         }
  405.     }

  407.     @Override
  408.     public boolean isSupportato(ServiceBinding serviceBinding, FunzionalitaProtocollo funzionalitaProtocollo)
  409.             throws ProtocolException {
  410.         if(funzionalitaProtocollo==null || serviceBinding==null){
  411.             throw new ProtocolException("Params not defined");
  412.         }
  413.         Functionality funzionalita = null;
  414.         if(ServiceBinding.REST.equals(serviceBinding)) {
  415.             if(this.bindingManifest.getRest()!=null) {
  416.                 funzionalita = this.bindingManifest.getRest().getFunctionality();
  417.             }
  418.         }
  419.         else {
  420.             if(this.bindingManifest.getSoap()!=null) {
  421.                 funzionalita = this.bindingManifest.getSoap().getFunctionality();
  422.             }
  423.         }
  424.         switch (funzionalitaProtocollo) {
  425.         case FILTRO_DUPLICATI:
  426.             return (funzionalita!=null ? funzionalita.isDuplicateFilter() : false); 
  427.         case CONFERMA_RICEZIONE:        
  428.             return (funzionalita!=null ? funzionalita.isAcknowledgement() : false); 
  429.         case COLLABORAZIONE:        
  430.             return (funzionalita!=null ? funzionalita.isConversationIdentifier() : false); 
  431.         case RIFERIMENTO_ID_RICHIESTA:      
  432.             return (funzionalita!=null ? funzionalita.isReferenceToRequestIdentifier() : false); 
  433.         case CONSEGNA_IN_ORDINE:        
  434.             return (funzionalita!=null ? funzionalita.isDeliveryOrder() : false); 
  435.         case SCADENZA:      
  436.             return (funzionalita!=null ? funzionalita.isExpiration() : false); 
  437.         case MANIFEST_ATTACHMENTS:      
  438.             return (funzionalita!=null ? funzionalita.getManifestAttachments() : false); 
  439.         default:
  440.             throw new ProtocolException("Param ["+funzionalitaProtocollo.getEngineValue()+"] not supported");
  441.         }
  442.     }
  443.     
  444.     @Override
  445.     public boolean isIntegrationInfoRequired(TipoPdD tipoPdD, ServiceBinding serviceBinding, FunzionalitaProtocollo funzionalitaProtocollo) throws ProtocolException{
  446.         return false;
  447.     }
  448.     
  449.     @Override
  450.     public InitialIdConversationType isGenerateInitialIdConversation(TipoPdD tipoPdD, FunzionalitaProtocollo funzionalitaProtocollo) throws ProtocolException{
  451.         return InitialIdConversationType.ID_TRANSAZIONE;
  452.     }
  453.     
  454.     @Override
  455.     public boolean isDataPresenteInIdentificativoMessaggio() {
  456.         return false;
  457.     }
  458.     
  459.     @Override
  460.     public List<BypassMustUnderstandCheck> getBypassMustUnderstandCheck(){
  461.         List<BypassMustUnderstandCheck> list = new ArrayList<BypassMustUnderstandCheck>();
  462.         if( this.manifest.getBinding().getSoap()!=null &&
  463.                 this.manifest.getBinding().getSoap().getSoapHeaderBypassMustUnderstand()!=null && 
  464.                         this.manifest.getBinding().getSoap().getSoapHeaderBypassMustUnderstand().sizeHeaderList()>0){
  465.             for (SoapHeaderBypassMustUnderstandHeader header : this.manifest.getBinding().getSoap().getSoapHeaderBypassMustUnderstand().getHeaderList()) {
  466.                 BypassMustUnderstandCheck bypassMustUnderstandCheck = new BypassMustUnderstandCheck();
  467.                 bypassMustUnderstandCheck.setElementName(header.getLocalName());
  468.                 bypassMustUnderstandCheck.setNamespace(header.getNamespace());
  469.                 list.add(bypassMustUnderstandCheck);
  470.             }
  471.         }
  472.         return list;
  473.     }
  474.     
  475.     @Override
  476.     public List<RemoteStoreConfig> getRemoteStoreConfig() throws ProtocolException{
  477.         return new ArrayList<>();
  478.     }
  479. }
Created with JaCoCo 0.8.8.202204050719