ServiceBindingConfigurationReader.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 org.openspcoop2.core.id.IDAccordo;
  24. import org.openspcoop2.core.id.IDServizio;
  25. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  26. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  27. import org.openspcoop2.core.registry.PortType;
  28. import org.openspcoop2.core.registry.Resource;
  29. import org.openspcoop2.core.registry.ResourceRepresentation;
  30. import org.openspcoop2.core.registry.ResourceResponse;
  31. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  32. import org.openspcoop2.message.config.ConfigurationRFC7807;
  33. import org.openspcoop2.message.config.ConfigurationServiceBindingRest;
  34. import org.openspcoop2.message.config.ConfigurationServiceBindingSoap;
  35. import org.openspcoop2.message.config.ContextUrlCollection;
  36. import org.openspcoop2.message.config.IntegrationErrorCollection;
  37. import org.openspcoop2.message.config.IntegrationErrorReturnConfiguration;
  38. import org.openspcoop2.message.config.RestBinding;
  39. import org.openspcoop2.message.config.ServiceBindingConfiguration;
  40. import org.openspcoop2.message.config.SoapBinding;
  41. import org.openspcoop2.message.constants.IntegrationError;
  42. import org.openspcoop2.message.constants.MessageType;
  43. import org.openspcoop2.message.constants.ServiceBinding;
  44. import org.openspcoop2.message.exception.MessageException;
  45. import org.openspcoop2.protocol.manifest.Context;
  46. import org.openspcoop2.protocol.manifest.EmptySubContextMapping;
  47. import org.openspcoop2.protocol.manifest.IntegrationErrorCode;
  48. import org.openspcoop2.protocol.manifest.Openspcoop2;
  49. import org.openspcoop2.protocol.manifest.RFC7807;
  50. import org.openspcoop2.protocol.manifest.RestConfiguration;
  51. import org.openspcoop2.protocol.manifest.RestMediaTypeCollection;
  52. import org.openspcoop2.protocol.manifest.RestMediaTypeDefaultMapping;
  53. import org.openspcoop2.protocol.manifest.RestMediaTypeMapping;
  54. import org.openspcoop2.protocol.manifest.RestMediaTypeUndefinedMapping;
  55. import org.openspcoop2.protocol.manifest.SoapConfiguration;
  56. import org.openspcoop2.protocol.manifest.SoapMediaTypeCollection;
  57. import org.openspcoop2.protocol.manifest.SoapMediaTypeDefaultMapping;
  58. import org.openspcoop2.protocol.manifest.SoapMediaTypeMapping;
  59. import org.openspcoop2.protocol.manifest.SoapMediaTypeUndefinedMapping;
  60. import org.openspcoop2.protocol.manifest.SubContextMapping;
  61. import org.openspcoop2.protocol.manifest.constants.Costanti;
  62. import org.openspcoop2.protocol.manifest.constants.DefaultIntegrationErrorMessageType;
  63. import org.openspcoop2.protocol.manifest.constants.IntegrationErrorMessageDetailType;
  64. import org.openspcoop2.protocol.manifest.constants.IntegrationErrorMessageType;
  65. import org.openspcoop2.protocol.manifest.constants.IntegrationErrorProblemType;
  66. import org.openspcoop2.protocol.manifest.constants.RestMessageType;
  67. import org.openspcoop2.protocol.manifest.constants.SoapMessageType;
  68. import org.openspcoop2.protocol.sdk.ProtocolException;
  69. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  70. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  71. import org.openspcoop2.utils.transport.TransportRequestContext;

  73. /**
  74.  * ServiceBindingConfigurationReader
  75.  *
  76.  * @author Poli Andrea (apoli@link.it)
  77.  * @author $Author$
  78.  * @version $Rev$, $Date$
  79.  */
  80. public class ServiceBindingConfigurationReader  {

  82.     public static ServiceBinding getServiceBinding(IDServizio idServizio, IRegistryReader registryReader) throws ProtocolException, RegistryNotFound{
  83.         try{
  84.             
  85.             AccordoServizioParteSpecifica aps = registryReader.getAccordoServizioParteSpecifica(idServizio);
  86.             IDAccordo idAccordoParteComune = IDAccordoFactory.getInstance().getIDAccordoFromUri(aps.getAccordoServizioParteComune());
  87.             AccordoServizioParteComune apc = registryReader.getAccordoServizioParteComune(idAccordoParteComune);
  88.             switch (apc.getServiceBinding()) {
  89.                 case SOAP:
  90.                     return ServiceBinding.SOAP;
  91.                 case REST:
  92.                     return ServiceBinding.REST;
  93.             }
  94.             throw new ProtocolException("Service ["+idServizio+"] not found");
  95.             
  96.         }
  97.         catch(RegistryNotFound notFound) {
  98.             throw notFound;
  99.         }
  100.         catch(Exception e){
  101.             throw new ProtocolException(e.getMessage(),e);
  102.         }
  103.     }

  105.     public static ServiceBindingConfiguration getDefaultServiceBindingConfiguration(Openspcoop2 manifest, TransportRequestContext transportRequest) throws ProtocolException{
  106.         return getServiceBindingConfiguration(manifest, transportRequest, null, null, null);
  107.     }
  108.     
  109.     private static MessageType convertMessageType(org.openspcoop2.core.registry.constants.MessageType mt) {
  110.         if(mt!=null) {
  111.             switch (mt) {
  112.             case SOAP_11:
  113.                 return MessageType.SOAP_11;
  114.             case SOAP_12:
  115.                 return MessageType.SOAP_12;
  116.             case XML:
  117.                 return MessageType.XML;
  118.             case JSON:
  119.                 return MessageType.JSON;
  120.             case BINARY:
  121.                 return MessageType.BINARY;
  122.             case MIME_MULTIPART:
  123.                 return MessageType.MIME_MULTIPART;
  124.             }
  125.         }
  126.         return null;
  127.     }
  128.     
  129.     public static ServiceBindingConfiguration getServiceBindingConfiguration(Openspcoop2 manifest, TransportRequestContext transportRequest, 
  130.             ServiceBinding serviceBinding, IDServizio idServizio, IRegistryReader registryReader) throws ProtocolException{
  131.         
  132.         try{
  133.         
  134.             String protocolWebContext = null;
  135.             if(transportRequest!=null && transportRequest.getProtocolWebContext()!=null && !"".equals(transportRequest.getProtocolWebContext())) {
  136.                 protocolWebContext = transportRequest.getProtocolWebContext();
  137.             }
  138.             ServiceBinding defaultBinding = getServiceBindingDefault(manifest, protocolWebContext);
  139.             ConfigurationServiceBindingSoap soap = readConfigurationServiceBindingSoap(manifest);
  140.             ConfigurationServiceBindingRest rest = readConfigurationServiceBindingRest(manifest);
  141.             ContextUrlCollection contextUrlCollection = readContextUrlCollection(manifest,soap,rest);
  142.             
  143.             // aggiornamento per contesto
  144.             String context = null;
  145.             if(transportRequest!=null) {
  146.                 context = transportRequest.getProtocolWebContext();
  147.             }
  148.             if(context!=null && !Costanti.CONTEXT_EMPTY.equals(context)){
  149.                 for (int i = 0; i < manifest.getWeb().sizeContextList(); i++) {
  150.                     if(manifest.getWeb().getContext(i).getName().equals(context)){
  151.                         if(manifest.getWeb().getContext(i).getSoapMediaTypeCollection()!=null){
  152.                             updateMediaTypeCollection(soap, manifest.getWeb().getContext(i).getSoapMediaTypeCollection(), true, true);
  153.                         }
  154.                         if(manifest.getWeb().getContext(i).getRestMediaTypeCollection()!=null){
  155.                             updateMediaTypeCollection(rest, manifest.getWeb().getContext(i).getRestMediaTypeCollection(), true, true);
  156.                         }
  157.                     }
  158.                 }
  159.             }
  160.             else if(manifest.getWeb().getEmptyContext()!=null){
  161.                 if(manifest.getWeb().getEmptyContext().getSoapMediaTypeCollection()!=null){
  162.                     updateMediaTypeCollection(soap, manifest.getWeb().getEmptyContext().getSoapMediaTypeCollection(), true, true);
  163.                 }
  164.                 if(manifest.getWeb().getEmptyContext().getRestMediaTypeCollection()!=null){
  165.                     updateMediaTypeCollection(rest, manifest.getWeb().getEmptyContext().getRestMediaTypeCollection(), true, true);
  166.                 }
  167.             }
  168.             
  169.             if(serviceBinding!=null && idServizio!=null){
  170.                 
  171.                 // aggiornamento per tipo servizio
  172.                 for (int i = 0; i < manifest.getRegistry().getService().getTypes().sizeTypeList(); i++) {
  173.                     String serviceType = manifest.getRegistry().getService().getTypes().getType(i).getName();
  174.                     if(serviceType.equals(idServizio.getTipo())){
  175.                         if( manifest.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection()!=null){
  176.                             updateMediaTypeCollection(soap, manifest.getRegistry().getService().getTypes().getType(i).getSoapMediaTypeCollection(), true, true);
  177.                         }
  178.                         if( manifest.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection()!=null){
  179.                             updateMediaTypeCollection(rest, manifest.getRegistry().getService().getTypes().getType(i).getRestMediaTypeCollection(), true, true);
  180.                         }
  181.                     }
  182.                 }               
  183.                 
  184.                 // Accordi
  185.                 AccordoServizioParteComune aspc = null;
  186.                 AccordoServizioParteSpecifica asps = null;
  187.                 try {
  188.                     asps = registryReader.getAccordoServizioParteSpecifica(idServizio, false);
  189.                 }catch(RegistryNotFound notFound) {}
  190.                 if(asps!=null) {
  191.                     try {
  192.                         IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromUri(asps.getAccordoServizioParteComune());
  193.                         aspc = registryReader.getAccordoServizioParteComune(idAccordo, false, 
  194.                                 false); // non si legge i dati di request e response per API REST. L'override del MessageType e' stato eliminato per default dalla console
  195.                     }catch(RegistryNotFound notFound) {}
  196.                 }
  197.                 
  198.                 // ricerca per servizio dell'accordo parte comune
  199.                 // Se presente viene forzato un message type indipendente dal mediaType e valido sia per la richiesta che per la risposta
  200.                 if(aspc!=null) {
  201.                     MessageType messageTypeService = convertMessageType(aspc.getMessageType());
  202.                     if(messageTypeService!=null){
  203.                         if(ServiceBinding.SOAP.equals(serviceBinding)){
  204.                             updateSoapMediaTypeCollection(soap, messageTypeService, true, true);
  205.                         }
  206.                         else if(ServiceBinding.REST.equals(serviceBinding)){
  207.                             updateRestMediaTypeCollection(rest, messageTypeService, true, true);
  208.                         }
  209.                     }
  210.                 }
  211.                 
  212.                 if(ServiceBinding.SOAP.equals(serviceBinding) && aspc!=null && asps!=null && asps.getPortType()!=null) {
  213.                     // ricerca per port-type dell'accordo parte comune
  214.                     // Se presente viene forzato un message type indipendente dal mediaType e valido sia per la richiesta che per la risposta
  215.                     for (PortType pt : aspc.getPortTypeList()) {
  216.                         if(pt.getNome().equals(asps.getPortType())) {
  217.                             MessageType messageTypeService = convertMessageType(pt.getMessageType());
  218.                             if(messageTypeService!=null){
  219.                                 if(ServiceBinding.SOAP.equals(serviceBinding)){
  220.                                     updateSoapMediaTypeCollection(soap, messageTypeService, true, true);
  221.                                 }
  222.                             }
  223.                             break;
  224.                         }
  225.                     }
  226.                 }
  227.                 
  228.                 // ricerca per servizio dell'accordo parte specifica
  229.                 // Se presente viene forzato un message type indipendente dal mediaType e valido sia per la richiesta che per la risposta
  230.                 if(asps!=null) {
  231.                     MessageType messageTypeParteSpecifica = convertMessageType(asps.getMessageType());
  232.                     if(messageTypeParteSpecifica!=null){
  233.                         if(ServiceBinding.SOAP.equals(serviceBinding)){
  234.                             updateSoapMediaTypeCollection(soap, messageTypeParteSpecifica, true, true);
  235.                         }
  236.                         else if(ServiceBinding.REST.equals(serviceBinding)){
  237.                             updateRestMediaTypeCollection(rest, messageTypeParteSpecifica, true, true);
  238.                         }
  239.                     }
  240.                 }
  241.                 
  242.                 if(idServizio.getAzione()!=null && aspc!=null && ServiceBinding.REST.equals(serviceBinding)) {
  243.                 
  244.                     if(aspc.sizeResourceList()>0) {
  245.                         for (Resource resource : aspc.getResourceList()) {
  246.                             if(resource.getNome().equals(idServizio.getAzione())) {
  247.                                 
  248.                                 // Se presente viene forzato un message type indipendente dal mediaType e valido sia per la richiesta che per la risposta
  249.                                 MessageType messageTypeRisorsa = convertMessageType(resource.getMessageType());
  250.                                 if(messageTypeRisorsa!=null){
  251.                                     updateRestMediaTypeCollection(rest, messageTypeRisorsa, true, true);
  252.                                 }
  253.                                 
  254.                                 // Se presente viene forzato un message type indipendente dal mediaType ma valido solo per la richiesta
  255.                                 MessageType messageTypeAzioneRichiesta = convertMessageType(resource.getRequestMessageType());
  256.                                 if(messageTypeAzioneRichiesta!=null){
  257.                                     updateRestMediaTypeCollection(rest, messageTypeAzioneRichiesta, true, false);
  258.                                 }
  259.                                 
  260.                                 // Se presente viene forzato un message type indipendente dal mediaType ma valido solo per la risposta
  261.                                 MessageType messageTypeAzioneRisposta = convertMessageType(resource.getResponseMessageType());
  262.                                 if(messageTypeAzioneRisposta!=null){
  263.                                     updateRestMediaTypeCollection(rest, messageTypeAzioneRisposta, false, true);
  264.                                 }
  265.                                 
  266.                                 // ultimo step di replace singolo mediaType sulla richiesta o sulla risposta (solo per REST)
  267.                                 if(resource.getRequest()!=null && resource.getRequest().sizeRepresentationList()>0) {
  268.                                     for (ResourceRepresentation rr : resource.getRequest().getRepresentationList()) {
  269.                                         MessageType messageTypeMediaType = convertMessageType(rr.getMessageType());
  270.                                         if(messageTypeMediaType!=null) {
  271.                                             rest.getRequest().addOrReplaceMediaType(rr.getMediaType(), messageTypeMediaType, false);
  272.                                         }
  273.                                     }
  274.                                 }
  275.                                 if(resource.sizeResponseList()>0) {
  276.                                     for (ResourceResponse response : resource.getResponseList()) {
  277.                                         if(response.sizeRepresentationList()>0) {
  278.                                             for (ResourceRepresentation rr : response.getRepresentationList()) {
  279.                                                 MessageType messageTypeMediaType = convertMessageType(rr.getMessageType());
  280.                                                 if(messageTypeMediaType!=null) {
  281.                                                     rest.getResponse().addOrReplaceMediaType(rr.getMediaType(), response.getStatus(), messageTypeMediaType, false);
  282.                                                 }
  283.                                             }
  284.                                         }
  285.                                     }
  286.                                 }
  287.                                 break;
  288.                             }
  289.                         }
  290.                     }

  292.                 }
  293.             }
  294.             
  295.             ServiceBindingConfiguration config = new ServiceBindingConfiguration(defaultBinding, soap, rest, contextUrlCollection);
  296.             addServiceBindingRestriction(manifest, config);
  297.             return config;
  298.             
  299.         }catch(Exception e){
  300.             throw new ProtocolException(e.getMessage(),e);
  301.         }
  302.     }
  303.         
  304.     private static ServiceBinding getServiceBindingDefault(Openspcoop2 manifest, String protocolWebContext){
  305.         
  306.         ServiceBinding defaultBinding = null;
  307.         
  308.         // Default
  309.         org.openspcoop2.protocol.manifest.constants.ServiceBinding defaultBindingManifest = manifest.getBinding().getDefault();
  310.         if(defaultBindingManifest!=null){
  311.             switch (defaultBindingManifest) {
  312.             case SOAP:
  313.                 defaultBinding = ServiceBinding.SOAP;
  314.                 break;
  315.             case REST:
  316.                 defaultBinding = ServiceBinding.REST;
  317.                 break;
  318.             }
  319.         }
  320.         else{
  321.             if(manifest.getBinding().getSoap()!=null){
  322.                 defaultBinding = ServiceBinding.SOAP;
  323.             }
  324.             else{
  325.                 defaultBinding = ServiceBinding.REST;
  326.             }
  327.         }
  328.         
  329.         if(protocolWebContext!=null) {
  330.             if(manifest.getWeb()!=null && manifest.getWeb().sizeContextList()>0) {
  331.                 for (Context webContext : manifest.getWeb().getContextList()) {
  332.                     if(webContext.getName()!=null && webContext.getName().equals(protocolWebContext)) {
  333.                         if(webContext.getBinding()!=null) {
  334.                             switch (webContext.getBinding()) {
  335.                             case SOAP:
  336.                                 defaultBinding = ServiceBinding.SOAP;
  337.                                 break;
  338.                             case REST:
  339.                                 defaultBinding = ServiceBinding.REST;
  340.                                 break;
  341.                             }
  342.                         }
  343.                         break;
  344.                     }
  345.                 }
  346.             }
  347.         }
  348.         
  349.         return defaultBinding;
  350.     }
  351.     
  352.     private static ConfigurationServiceBindingSoap readConfigurationServiceBindingSoap(Openspcoop2 manifest) throws MessageException{
  353.         
  354.         SoapConfiguration soapConfig = manifest.getBinding().getSoap();
  355.         boolean enabled = soapConfig!=null;
  356.         SoapBinding binding = null;
  357.         IntegrationErrorCollection internalIntegrationErrorConfiguration = null;
  358.         IntegrationErrorCollection externalIntegrationErrorConfiguration = null;
  359.         
  360.         if(enabled){
  361.             
  362.             binding = new SoapBinding(soapConfig.isSoap11(), soapConfig.isSoap11WithAttachments(), soapConfig.isSoap11Mtom(), 
  363.                     soapConfig.isSoap12(), soapConfig.isSoap12WithAttachments(), soapConfig.isSoap12Mtom());
  364.             
  365.             internalIntegrationErrorConfiguration = readIntegrationErrorConfiguration(soapConfig.getIntegrationError().getInternal());
  366.             externalIntegrationErrorConfiguration = readIntegrationErrorConfiguration(soapConfig.getIntegrationError().getExternal());
  367.             
  368.         }
  369.         
  370.         ConfigurationServiceBindingSoap soap = new ConfigurationServiceBindingSoap(enabled, binding, internalIntegrationErrorConfiguration, externalIntegrationErrorConfiguration);
  371.         soap.init();
  372.         
  373.         if(enabled){
  374.             
  375.             if(soapConfig.getMediaTypeCollection()!=null){
  376.                 updateMediaTypeCollection(soap, soapConfig.getMediaTypeCollection(), true, true);
  377.             }
  378.             
  379.         }
  380.         
  381.         return soap;
  382.             
  383.     }
  384.     
  385.     private static void updateMediaTypeCollection(ConfigurationServiceBindingSoap soap, SoapMediaTypeCollection mediaTypesCollection, 
  386.             boolean request, boolean response) throws MessageException{
  387.         
  388.         if(mediaTypesCollection.sizeMediaTypeList()<=0 && mediaTypesCollection.getDefault()==null && mediaTypesCollection.getUndefined()==null){
  389.             return;
  390.         }
  391.         if(request){
  392.             soap.getRequest().clear();
  393.         }
  394.         if(response){
  395.             soap.getResponse().clear();
  396.         }
  397.         
  398.         for (int i = 0; i < mediaTypesCollection.sizeMediaTypeList(); i++) {
  399.             SoapMediaTypeMapping mapping = mediaTypesCollection.getMediaType(i);
  400.             if(request){
  401.                 soap.getRequest().addMediaType(mapping.getBase(),  convertToMessageType(mapping.getMessageType()), mapping.isRegExpr());
  402.             }
  403.             if(response){
  404.                 soap.getResponse().addMediaType(mapping.getBase(), convertToMessageType(mapping.getMessageType()), mapping.isRegExpr());
  405.             }
  406.         }
  407.         
  408.         if(mediaTypesCollection.getDefault()!=null){
  409.             if(request){
  410.                 soap.getRequest().addDefaultMediaType(convertToMessageType(mediaTypesCollection.getDefault().getMessageType()));
  411.             }
  412.             if(response){
  413.                 soap.getResponse().addDefaultMediaType(convertToMessageType(mediaTypesCollection.getDefault().getMessageType()));
  414.             }
  415.         }
  416.         
  417.         if(mediaTypesCollection.getUndefined()!=null){
  418.             if(request){
  419.                 soap.getRequest().addUndefinedMediaType(convertToMessageType(mediaTypesCollection.getUndefined().getMessageType()));
  420.             }
  421.             if(response){
  422.                 soap.getResponse().addUndefinedMediaType(convertToMessageType(mediaTypesCollection.getUndefined().getMessageType()));
  423.             }
  424.         }
  425.     }
  426.     
  427.     private static void updateSoapMediaTypeCollection(ConfigurationServiceBindingSoap soap, MessageType messageType, boolean request, boolean response) throws MessageException{
  428.         SoapMediaTypeCollection mediaTypeCollection = new SoapMediaTypeCollection();
  429.         
  430.         SoapMediaTypeDefaultMapping defaultMapping = new SoapMediaTypeDefaultMapping();
  431.         defaultMapping.setMessageType(convertToSoapMessageType(messageType));
  432.         mediaTypeCollection.setDefault(defaultMapping);
  433.         
  434.         SoapMediaTypeUndefinedMapping undefinedMapping = new SoapMediaTypeUndefinedMapping();
  435.         undefinedMapping.setMessageType(convertToSoapMessageType(messageType));
  436.         mediaTypeCollection.setUndefined(undefinedMapping);
  437.         
  438.         updateMediaTypeCollection(soap, mediaTypeCollection, request, response);
  439.     }
  440.     
  441.     private static MessageType convertToMessageType(SoapMessageType messageType){
  442.         switch (messageType) {
  443.         case SOAP_11:
  444.             return MessageType.SOAP_11;
  445.         case SOAP_12:
  446.             return MessageType.SOAP_12;
  447.         }
  448.         return null;
  449.     }
  450.     
  451.     @SuppressWarnings("incomplete-switch")
  452.     private static SoapMessageType convertToSoapMessageType(MessageType messageType){
  453.         switch (messageType) {
  454.         case SOAP_11:
  455.             return SoapMessageType.SOAP_11;
  456.         case SOAP_12:
  457.             return SoapMessageType.SOAP_12;
  458.         }
  459.         return null;
  460.     }
  461.     
  462.     private static ConfigurationServiceBindingRest readConfigurationServiceBindingRest(Openspcoop2 manifest) throws MessageException{
  463.         
  464.         RestConfiguration restConfig = manifest.getBinding().getRest();
  465.         boolean enabled = restConfig!=null;
  466.         RestBinding binding = null;
  467.         IntegrationErrorCollection internalIntegrationErrorConfiguration = null;
  468.         IntegrationErrorCollection externalIntegrationErrorConfiguration = null;
  469.         
  470.         if(enabled){
  471.             
  472.             binding = new RestBinding(restConfig.isXml(), restConfig.isJson(), restConfig.isBinary(), restConfig.isMimeMultipart());
  473.             
  474.             internalIntegrationErrorConfiguration = readIntegrationErrorConfiguration(restConfig.getIntegrationError().getInternal());
  475.             externalIntegrationErrorConfiguration = readIntegrationErrorConfiguration(restConfig.getIntegrationError().getExternal());
  476.         }
  477.         
  478.         ConfigurationServiceBindingRest rest = new ConfigurationServiceBindingRest(enabled, binding, internalIntegrationErrorConfiguration, externalIntegrationErrorConfiguration);
  479.         rest.init();
  480.         
  481.         if(enabled){
  482.             
  483.             if(restConfig.getMediaTypeCollection()!=null){
  484.                 updateMediaTypeCollection(rest, restConfig.getMediaTypeCollection(), true, true);
  485.             }
  486.             
  487.         }
  488.         
  489.         return rest;
  490.             
  491.     }
  492.     
  493.     private static void updateMediaTypeCollection(ConfigurationServiceBindingRest rest, RestMediaTypeCollection mediaTypesCollection, boolean request, boolean response) throws MessageException{
  494.         
  495.         if(mediaTypesCollection.sizeMediaTypeList()<=0 && mediaTypesCollection.getDefault()==null && mediaTypesCollection.getUndefined()==null){
  496.             return;
  497.         }
  498.         if(request){
  499.             rest.getRequest().clear();
  500.         }
  501.         if(response){
  502.             rest.getResponse().clear();
  503.         }
  504.         
  505.         for (int i = 0; i < mediaTypesCollection.sizeMediaTypeList(); i++) {
  506.             RestMediaTypeMapping mapping = mediaTypesCollection.getMediaType(i);
  507.             if(request){
  508.                 rest.getRequest().addMediaType(mapping.getBase(), convertToMessageType(mapping.getMessageType()), mapping.isRegExpr());
  509.             }
  510.             if(response){
  511.                 rest.getResponse().addMediaType(mapping.getBase(), convertToMessageType(mapping.getMessageType()), mapping.isRegExpr());
  512.             }
  513.         }
  514.         
  515.         if(mediaTypesCollection.getDefault()!=null){
  516.             if(request){
  517.                 rest.getRequest().addDefaultMediaType(convertToMessageType(mediaTypesCollection.getDefault().getMessageType()));
  518.             }
  519.             if(response){
  520.                 rest.getResponse().addDefaultMediaType(convertToMessageType(mediaTypesCollection.getDefault().getMessageType()));
  521.             }
  522.         }
  523.         
  524.         if(mediaTypesCollection.getUndefined()!=null){
  525.             if(request){
  526.                 rest.getRequest().addUndefinedMediaType(convertToMessageType(mediaTypesCollection.getUndefined().getMessageType()));
  527.             }
  528.             if(response){
  529.                 rest.getResponse().addUndefinedMediaType(convertToMessageType(mediaTypesCollection.getUndefined().getMessageType()));
  530.             }
  531.         }
  532.     }
  533.     
  534.     private static void updateRestMediaTypeCollection(ConfigurationServiceBindingRest rest, MessageType messageType, boolean request, boolean response) throws MessageException{
  535.         RestMediaTypeCollection mediaTypeCollection = new RestMediaTypeCollection();
  536.         
  537.         RestMediaTypeDefaultMapping defaultMapping = new RestMediaTypeDefaultMapping();
  538.         defaultMapping.setMessageType(convertToRestMessageType(messageType));
  539.         mediaTypeCollection.setDefault(defaultMapping);
  540.         
  541.         RestMediaTypeUndefinedMapping undefinedMapping = new RestMediaTypeUndefinedMapping();
  542.         undefinedMapping.setMessageType(convertToRestMessageType(messageType));
  543.         mediaTypeCollection.setUndefined(undefinedMapping);
  544.         
  545.         updateMediaTypeCollection(rest, mediaTypeCollection, request, response);
  546.     }
  547.     
  548.     private static MessageType convertToMessageType(RestMessageType messageType){
  549.         switch (messageType) {
  550.         case XML:
  551.             return MessageType.XML;
  552.         case JSON:
  553.             return MessageType.JSON;
  554.         case BINARY:
  555.             return MessageType.BINARY;
  556.         case MIME_MULTIPART:
  557.             return MessageType.MIME_MULTIPART;
  558.         }
  559.         return null;
  560.     }
  561.     
  562.     @SuppressWarnings("incomplete-switch")
  563.     private static RestMessageType convertToRestMessageType(MessageType messageType){
  564.         switch (messageType) {
  565.         case XML:
  566.             return RestMessageType.XML;
  567.         case JSON:
  568.             return RestMessageType.JSON;
  569.         case BINARY:
  570.             return RestMessageType.BINARY;
  571.         case MIME_MULTIPART:
  572.             return RestMessageType.MIME_MULTIPART;
  573.         }
  574.         return null;
  575.     }
  576.     
  577.     private static IntegrationErrorReturnConfiguration to(IntegrationErrorCode errorCode, boolean retry, IntegrationErrorMessageDetailType errorMessage) {
  578.         IntegrationErrorReturnConfiguration conf = new IntegrationErrorReturnConfiguration();
  579.         conf.setHttpReturnCode(errorCode.getHttp());
  580.         conf.setGovwayReturnCode(errorCode.getGovway());
  581.         conf.setRetry(retry);
  582.         conf.setGenericDetails(IntegrationErrorMessageDetailType.GENERIC.equals(errorMessage));
  583.         return conf;
  584.     }
  585.     
  586.     private static IntegrationErrorCollection readIntegrationErrorConfiguration(org.openspcoop2.protocol.manifest.IntegrationErrorCollection config) throws MessageException{
  587.         IntegrationErrorCollection integrationErrorConfiguration = new IntegrationErrorCollection();
  588.         
  589.         ConfigurationRFC7807 rfc7807 = null;
  590.         if(IntegrationErrorProblemType.RFC_7807.equals(config.getProblemType())) {
  591.             RFC7807 rfc7807_protocolManifest = config.getRfc7807();
  592.             rfc7807 = new ConfigurationRFC7807();
  593.             rfc7807.setType(rfc7807_protocolManifest.isType());
  594.             rfc7807.setTypeFormat(rfc7807_protocolManifest.getTypeFormat());
  595.             rfc7807.setUseAcceptHeader(rfc7807_protocolManifest.getUseAcceptHeader());
  596.             rfc7807.setInstance(rfc7807_protocolManifest.getInstance());
  597.             rfc7807.setGovwayType(rfc7807_protocolManifest.getGovwayType());
  598.             rfc7807.setGovwayStatus(rfc7807_protocolManifest.getGovwayStatus());
  599.             rfc7807.setGovwayTransactionId(rfc7807_protocolManifest.getGovwayTransactionId());
  600.             rfc7807.setDetails(rfc7807_protocolManifest.getDetails());
  601.         }
  602.         
  603.         if(config.getDefault()!=null){
  604.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.DEFAULT, 
  605.                     convertToMessageType(config.getDefault().getMessageType()), 
  606.                     to(config.getDefault().getErrorCode(), config.getDefault().getRetry(), config.getDefault().getErrorMessage()),
  607.                     config.isUseInternalFault());
  608.         }
  609.         if(config.getAuthentication()!=null){
  610.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.AUTHENTICATION, 
  611.                     convertToMessageType(config.getAuthentication().getMessageType()), 
  612.                     to(config.getAuthentication().getErrorCode(), config.getAuthentication().getRetry(), config.getAuthentication().getErrorMessage()),
  613.                     config.isUseInternalFault());
  614.         }
  615.         if(config.getAuthorization()!=null){
  616.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.AUTHORIZATION, 
  617.                     convertToMessageType(config.getAuthorization().getMessageType()), 
  618.                     to(config.getAuthorization().getErrorCode(), config.getAuthorization().getRetry(), config.getAuthorization().getErrorMessage()),
  619.                     config.isUseInternalFault());
  620.         }
  621.         if(config.getNotFound()!=null){
  622.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.NOT_FOUND, 
  623.                     convertToMessageType(config.getNotFound().getMessageType()), 
  624.                     to(config.getNotFound().getErrorCode(), config.getNotFound().getRetry(), config.getNotFound().getErrorMessage()),
  625.                     config.isUseInternalFault());
  626.         }
  627.         if(config.getBadRequest()!=null){
  628.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.BAD_REQUEST, 
  629.                     convertToMessageType(config.getBadRequest().getMessageType()), 
  630.                     to(config.getBadRequest().getErrorCode(), config.getBadRequest().getRetry(), config.getBadRequest().getErrorMessage()),
  631.                     config.isUseInternalFault());
  632.         }
  633.         if(config.getConflict()!=null){
  634.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.CONFLICT, 
  635.                     convertToMessageType(config.getConflict().getMessageType()), 
  636.                     to(config.getConflict().getErrorCode(), config.getConflict().getRetry(), config.getConflict().getErrorMessage()),
  637.                     config.isUseInternalFault());
  638.         }
  639.         if(config.getRequestTooLarge()!=null){
  640.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.REQUEST_TOO_LARGE, 
  641.                     convertToMessageType(config.getRequestTooLarge().getMessageType()), 
  642.                     to(config.getRequestTooLarge().getErrorCode(), config.getRequestTooLarge().getRetry(), config.getRequestTooLarge().getErrorMessage()),
  643.                     config.isUseInternalFault());
  644.         }
  645.         if(config.getLimitExceeded()!=null){
  646.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.LIMIT_EXCEEDED, 
  647.                     convertToMessageType(config.getLimitExceeded().getMessageType()), 
  648.                     to(config.getLimitExceeded().getErrorCode(), config.getLimitExceeded().getRetry(), config.getLimitExceeded().getErrorMessage()),
  649.                     config.isUseInternalFault());
  650.         }
  651.         if(config.getTooManyRequests()!=null){
  652.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.TOO_MANY_REQUESTS, 
  653.                     convertToMessageType(config.getTooManyRequests().getMessageType()), 
  654.                     to(config.getTooManyRequests().getErrorCode(), config.getTooManyRequests().getRetry(), config.getTooManyRequests().getErrorMessage()),
  655.                     config.isUseInternalFault());
  656.         }
  657.         if(config.getServiceUnavailable()!=null){
  658.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.SERVICE_UNAVAILABLE, 
  659.                     convertToMessageType(config.getServiceUnavailable().getMessageType()), 
  660.                     to(config.getServiceUnavailable().getErrorCode(), config.getServiceUnavailable().getRetry(), config.getServiceUnavailable().getErrorMessage()),
  661.                     config.isUseInternalFault());
  662.         }
  663.         if(config.getEndpointRequestTimedOut()!=null){
  664.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.ENDPOINT_REQUEST_TIMED_OUT, 
  665.                     convertToMessageType(config.getEndpointRequestTimedOut().getMessageType()), 
  666.                     to(config.getEndpointRequestTimedOut().getErrorCode(), config.getEndpointRequestTimedOut().getRetry(), config.getEndpointRequestTimedOut().getErrorMessage()),
  667.                     config.isUseInternalFault());
  668.         }
  669.         if(config.getBadResponse()!=null){
  670.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.BAD_RESPONSE, 
  671.                     convertToMessageType(config.getBadResponse().getMessageType()), 
  672.                     to(config.getBadResponse().getErrorCode(), config.getBadResponse().getRetry(), config.getBadResponse().getErrorMessage()),
  673.                     config.isUseInternalFault());
  674.         }
  675.         if(config.getInternalRequestError()!=null){
  676.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.INTERNAL_REQUEST_ERROR, 
  677.                     convertToMessageType(config.getInternalRequestError().getMessageType()), 
  678.                     to(config.getInternalRequestError().getErrorCode(), config.getInternalRequestError().getRetry(), config.getInternalRequestError().getErrorMessage()),
  679.                     config.isUseInternalFault());
  680.         }
  681.         if(config.getInternalResponseError()!=null){
  682.             integrationErrorConfiguration.addIntegrationError(rfc7807, IntegrationError.INTERNAL_RESPONSE_ERROR, 
  683.                     convertToMessageType(config.getInternalResponseError().getMessageType()), 
  684.                     to(config.getInternalResponseError().getErrorCode(), config.getInternalResponseError().getRetry(), config.getInternalResponseError().getErrorMessage()),
  685.                     config.isUseInternalFault());
  686.         }

  688.         return integrationErrorConfiguration;
  689.     }
  690.     
  691.     private static org.openspcoop2.message.constants.IntegrationErrorMessageType convertToMessageType(DefaultIntegrationErrorMessageType messageType){
  692.         switch (messageType) {
  693.         case SOAP_11:
  694.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SOAP_11;
  695.         case SOAP_12:
  696.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SOAP_12;
  697.         case XML:
  698.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.XML;
  699.         case JSON:
  700.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.JSON;
  701.         case NONE:
  702.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.NONE;
  703.         }
  704.         return null;
  705.     }
  706.     
  707.     private static org.openspcoop2.message.constants.IntegrationErrorMessageType convertToMessageType(IntegrationErrorMessageType messageType){
  708.         switch (messageType) {
  709.         case SOAP_AS_REQUEST:
  710.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SOAP_AS_REQUEST;
  711.         case SOAP_11:
  712.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SOAP_11;
  713.         case SOAP_12:
  714.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SOAP_12;
  715.         case XML:
  716.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.XML;
  717.         case JSON:
  718.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.JSON;
  719.         case NONE:
  720.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.NONE;
  721.         case SAME_AS_REQUEST:
  722.             return org.openspcoop2.message.constants.IntegrationErrorMessageType.SAME_AS_REQUEST;
  723.         }
  724.         return null;
  725.     }
  726.     
  727.     private static void addServiceBindingRestriction(Openspcoop2 manifest,ServiceBindingConfiguration config){
  728.         
  729.         for (int i = 0; i < manifest.getWeb().sizeContextList(); i++) {
  730.             String context = manifest.getWeb().getContext(i).getName();
  731.             org.openspcoop2.protocol.manifest.constants.ServiceBinding serviceBinding = manifest.getWeb().getContext(i).getBinding();
  732.             if(serviceBinding!=null){
  733.                 config.addServiceBindingContextRestriction(convertToServiceBinding(serviceBinding), context);
  734.             }
  735.         }
  736.         
  737.         if(manifest.getWeb().getEmptyContext()!=null){
  738.             org.openspcoop2.protocol.manifest.constants.ServiceBinding serviceBinding = manifest.getWeb().getEmptyContext().getBinding();
  739.             if(serviceBinding!=null){
  740.                 config.addServiceBindingEmptyContextRestriction(convertToServiceBinding(serviceBinding));
  741.             }
  742.         }
  743.         
  744.         for (int i = 0; i < manifest.getRegistry().getService().getTypes().sizeTypeList(); i++) {
  745.             String serviceType = manifest.getRegistry().getService().getTypes().getType(i).getName();
  746.             org.openspcoop2.protocol.manifest.constants.ServiceBinding serviceBinding = manifest.getRegistry().getService().getTypes().getType(i).getBinding();
  747.             if(serviceBinding!=null){
  748.                 config.addServiceBindingServiceTypeRestriction(convertToServiceBinding(serviceBinding), serviceType);
  749.             }
  750.         }
  751.         
  752.     }
  753.     
  754.     private static ServiceBinding convertToServiceBinding(org.openspcoop2.protocol.manifest.constants.ServiceBinding serviceBinding){
  755.         switch (serviceBinding) {
  756.         case SOAP:
  757.             return ServiceBinding.SOAP;
  758.         case REST:
  759.             return ServiceBinding.REST;
  760.         }
  761.         return null;
  762.     }
  763.     
  764.     private static ContextUrlCollection readContextUrlCollection(Openspcoop2 manifest, ConfigurationServiceBindingSoap soap, ConfigurationServiceBindingRest rest) throws MessageException{
  765.         
  766.         ContextUrlCollection urlCollection = new ContextUrlCollection(soap.getBinding(), rest.getBinding());    
  767.         
  768.         for (int i = 0; i < manifest.getWeb().sizeContextList(); i++) {
  769.             String context = manifest.getWeb().getContext(i).getName();
  770.             if(manifest.getWeb().getContext(i).sizeSubContextList()>0){
  771.                 for (int j = 0; j < manifest.getWeb().getContext(i).sizeSubContextList(); j++) {
  772.                     SubContextMapping subContext = manifest.getWeb().getContext(i).getSubContext(j);
  773.                     urlCollection.addContext(context,subContext.getFunctionRawEnumValue(),subContext.getBase(),convertToMessageType(subContext.getMessageType()));
  774.                 }
  775.             }
  776.             if(manifest.getWeb().getContext(i).getEmptySubContext()!=null){
  777.                 EmptySubContextMapping subContext = manifest.getWeb().getContext(i).getEmptySubContext();
  778.                 urlCollection.addContext(context,subContext.getFunctionRawEnumValue(),null, convertToMessageType(subContext.getMessageType()));
  779.             }
  780.         }
  781.         
  782.         if(manifest.getWeb().getEmptyContext()!=null){
  783.             if(manifest.getWeb().getEmptyContext().sizeSubContextList()>0){
  784.                 for (int j = 0; j < manifest.getWeb().getEmptyContext().sizeSubContextList(); j++) {
  785.                     SubContextMapping subContext = manifest.getWeb().getEmptyContext().getSubContext(j);
  786.                     urlCollection.addContext(null,subContext.getFunctionRawEnumValue(),subContext.getBase(), convertToMessageType(subContext.getMessageType()));
  787.                 }
  788.             }
  789.             if(manifest.getWeb().getEmptyContext().getEmptySubContext()!=null){
  790.                 EmptySubContextMapping subContext = manifest.getWeb().getEmptyContext().getEmptySubContext();
  791.                 urlCollection.addContext(null,subContext.getFunctionRawEnumValue(),null, convertToMessageType(subContext.getMessageType()));
  792.             }
  793.         }
  794.         
  795.         return urlCollection;
  796.             
  797.     }
  798.     
  799.     private static MessageType convertToMessageType(org.openspcoop2.protocol.manifest.constants.MessageType messageType){
  800.         switch (messageType) {
  801.         case SOAP_11:
  802.             return MessageType.SOAP_11;
  803.         case SOAP_12:
  804.             return MessageType.SOAP_12;
  805.         case XML:
  806.             return MessageType.XML;
  807.         case JSON:
  808.             return MessageType.JSON;
  809.         case BINARY:
  810.             return MessageType.BINARY;
  811.         case MIME_MULTIPART:
  812.             return MessageType.MIME_MULTIPART;
  813.         }
  814.         return null;
  815.     }
  816. }
Created with JaCoCo 0.8.8.202204050719