OpenSPCoop2MessageFactory_impl.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.message;

  23. import java.io.InputStream;

  25. import javax.xml.soap.MimeHeaders;
  26. import javax.xml.soap.SOAPConnectionFactory;
  27. import javax.xml.soap.SOAPException;
  28. import javax.xml.soap.SOAPMessage;

  30. import org.openspcoop2.message.constants.MessageType;
  31. import org.openspcoop2.message.exception.MessageException;
  32. import org.openspcoop2.message.rest.OpenSPCoop2Message_binary_impl;
  33. import org.openspcoop2.message.rest.OpenSPCoop2Message_json_impl;
  34. import org.openspcoop2.message.rest.OpenSPCoop2Message_mimeMultipart_impl;
  35. import org.openspcoop2.message.rest.OpenSPCoop2Message_xml_impl;
  36. import org.openspcoop2.message.soap.OpenSPCoop2Message_saaj_11_impl;
  37. import org.openspcoop2.message.soap.OpenSPCoop2Message_saaj_12_impl;
  38. import org.openspcoop2.message.soap.OpenSPCoop2Message_soap11_impl;
  39. import org.openspcoop2.message.soap.OpenSPCoop2Message_soap12_impl;
  40. import org.openspcoop2.message.soap.reader.OpenSPCoop2MessageSoapStreamReader;
  41. import org.openspcoop2.utils.transport.TransportRequestContext;
  42. import org.openspcoop2.utils.transport.TransportResponseContext;
  43. import org.openspcoop2.utils.transport.http.HttpConstants;
  44. import org.w3c.dom.Document;
  45. import org.w3c.dom.Element;


  48. /**
  49.  * Factory per la costruzione di messaggi OpenSPCoop2Message. 
  50.  * 
  51.  * @author Lorenzo Nardi (nardi@link.it)
  52.  * @author Poli Andrea (apoli@link.it)
  53.  * @author $Author$
  54.  * @version $Rev$, $Date$
  55.  */

  57. public class OpenSPCoop2MessageFactory_impl extends OpenSPCoop2MessageFactory {

  59.     private static boolean soapPassthroughImpl = true;
  60.     public static void setSoapPassthroughImpl(boolean soapPassthroughImpl) {
  61.         OpenSPCoop2MessageFactory_impl.soapPassthroughImpl = soapPassthroughImpl;
  62.     }

  64.     
  65.     // ********** SOAP - FACTORY *************

  67.     @Override
  68.     protected synchronized void initSoapFactory() {
  69.         try{
  70.             if(OpenSPCoop2MessageFactory.soapFactory11==null || OpenSPCoop2MessageFactory.soapFactory12==null){
  71.                 OpenSPCoop2MessageFactory.initSoapFactory11(new com.sun.xml.messaging.saaj.soap.ver1_1.SOAPFactory1_1Impl());
  72.                 OpenSPCoop2MessageFactory.initSoapFactory12(new com.sun.xml.messaging.saaj.soap.ver1_2.SOAPFactory1_2Impl());
  73.             }
  74.         }catch(Exception e){
  75.                 System.out.println("ERRORE: "+e.getMessage());
  76.         }
  77.     }

  79.     @Override
  80.     protected synchronized void initSoapMessageFactory() throws SOAPException {
  81.         if(OpenSPCoop2MessageFactory.soapMessageFactory==null){
  82.             OpenSPCoop2MessageFactory.initSoapMessageFactory(new com.sun.xml.messaging.saaj.soap.MessageFactoryImpl());
  83.         }
  84.     }
  85.     
  86.     @Override
  87.     public SOAPConnectionFactory getSOAPConnectionFactory()
  88.             throws SOAPException {
  89.         return new com.sun.xml.messaging.saaj.client.p2p.HttpSOAPConnectionFactory();
  90.     }
  91.     
  92.     
  93.     
  94.     
  95.     // ********** SAAJ *************
  96.     
  97.     @Override
  98.     public String getDocumentBuilderFactoryClass() {
  99.         return org.apache.xerces.jaxp.DocumentBuilderFactoryImpl.class.getName();
  100.     }
  101.     
  102.     @Override
  103.     public String getSAXParserFactoryClass() {
  104.         return org.apache.xerces.jaxp.SAXParserFactoryImpl.class.getName();
  105.     }

  107.     @Override
  108.     public Element convertoForXPathSearch(Element contenutoAsElement){
  109.         return contenutoAsElement;
  110.     }
  111.     
  112.     @Override
  113.     public void normalizeDocument(Document document){
  114.         document.normalizeDocument();
  115.     }
  116.     
  117.     
  118.     
  119.     
  120.     // ********** OpenSPCoop2Message builder *************
  121.     
  122.     @Override
  123.     public OpenSPCoop2Message _createMessage(MessageType messageType, SOAPMessage soapMsg) throws MessageException {
  124.         OpenSPCoop2Message msg = null;
  125.         if(MessageType.SOAP_11.equals(messageType)){
  126.             msg = new OpenSPCoop2Message_saaj_11_impl(this, soapMsg);
  127.         } else if(MessageType.SOAP_12.equals(messageType)){
  128.             msg = new OpenSPCoop2Message_saaj_12_impl(this, soapMsg);
  129.         }
  130.         else{
  131.             throw new MessageException("Message Type ["+messageType+"] unsupported");
  132.         }
  133.         
  134.         return msg;
  135.     }
  136.     
  137.     @Override
  138.     public OpenSPCoop2Message _createEmptyMessage(MessageType messageType) throws MessageException  {
  139.         OpenSPCoop2Message msg = null;
  140.         switch (messageType) {
  141.             case SOAP_11:
  142.                 msg = new OpenSPCoop2Message_saaj_11_impl(this);
  143.                 break;
  144.             case SOAP_12:
  145.                 msg = new OpenSPCoop2Message_saaj_12_impl(this);
  146.                 break;
  147.             case XML:
  148.                 msg = new OpenSPCoop2Message_xml_impl(this);
  149.                 break;
  150.             case JSON:
  151.                 msg = new OpenSPCoop2Message_json_impl(this);
  152.                 break;
  153.             case BINARY:
  154.                 msg = new OpenSPCoop2Message_binary_impl(this);
  155.                 break;
  156.             case MIME_MULTIPART:
  157.                 msg = new OpenSPCoop2Message_mimeMultipart_impl(this);
  158.                 break;
  159.         }
  160.         
  161.         return msg;
  162.     }

  164.     @Override
  165.     protected OpenSPCoop2Message _createMessage(MessageType messageType, TransportRequestContext requestContext, InputStream is, 
  166.             AttachmentsProcessingMode attachmentsProcessingMode, long overhead,
  167.             OpenSPCoop2MessageSoapStreamReader soapStreamReader) throws MessageException {
  168.         
  169.         return this._createMessageEngine(messageType, requestContext, is, attachmentsProcessingMode, overhead, soapStreamReader);
  170.     }
  171.     
  172.     @Override
  173.     protected OpenSPCoop2Message _createMessage(MessageType messageType, TransportResponseContext responseContext, InputStream is, 
  174.             AttachmentsProcessingMode attachmentsProcessingMode, long overhead,
  175.             OpenSPCoop2MessageSoapStreamReader soapStreamReader) throws MessageException {
  176.         
  177.         return this._createMessageEngine(messageType, responseContext, is, attachmentsProcessingMode, overhead, soapStreamReader);
  178.     }
  179.     
  180.     @Override
  181.     protected OpenSPCoop2Message _createMessage(MessageType messageType, String contentType, InputStream is,  
  182.             AttachmentsProcessingMode attachmentsProcessingMode, long overhead,
  183.             OpenSPCoop2MessageSoapStreamReader soapStreamReader) throws MessageException{
  184.         
  185.         return this._createMessageEngine(messageType, contentType, is, attachmentsProcessingMode, overhead, soapStreamReader);
  186.     }
  187.     
  188.     private OpenSPCoop2Message _createMessageEngine(MessageType messageType, Object context, InputStream is, 
  189.             AttachmentsProcessingMode attachmentsProcessingMode, long overhead,
  190.             OpenSPCoop2MessageSoapStreamReader soapStreamReader) throws MessageException {
  191.         
  192.         try{
  193.         
  194.             OpenSPCoop2Message msg = null;
  195.             
  196.             String contentType = null;
  197.             TransportRequestContext transportRequestContext = null; 
  198.             TransportResponseContext transportResponseContext = null;
  199.             if(context instanceof TransportRequestContext){
  200.                 transportRequestContext = (TransportRequestContext) context;
  201.                 contentType = transportRequestContext.getHeaderFirstValue(HttpConstants.CONTENT_TYPE);
  202.             }
  203.             else if(context instanceof TransportResponseContext){
  204.                 transportResponseContext = (TransportResponseContext) context;
  205.                 contentType = transportResponseContext.getHeaderFirstValue(HttpConstants.CONTENT_TYPE);
  206.             }
  207.             else if(context instanceof String){
  208.                 contentType = (String) context;
  209.             }
  210.             else{
  211.                 if(context==null) {
  212.                     if(!MessageType.BINARY.equals(messageType)) {
  213.                         throw new MessageException("Unsupported Empty Context for message '"+messageType+"' (No Content Type?)");
  214.                     }
  215.                 }
  216.                 else {
  217.                     throw new MessageException("Unsupported Context ["+context+"]");
  218.                 }
  219.             }
  220.             
  221.             switch (messageType) {
  222.                 case SOAP_11:
  223.                 case SOAP_12:
  224.                     
  225.                     MimeHeaders mhs = new MimeHeaders();
  226.                     if(contentType!=null){
  227.                         mhs.setHeader(HttpConstants.CONTENT_TYPE, contentType);
  228.                     }
  229.                     if(OpenSPCoop2MessageFactory_impl.soapPassthroughImpl) {
  230.                         if(MessageType.SOAP_11.equals(messageType)){
  231.                             msg = new OpenSPCoop2Message_soap11_impl(this, mhs, is, overhead, soapStreamReader);
  232.                         }
  233.                         else{
  234.                             msg = new OpenSPCoop2Message_soap12_impl(this, mhs, is, overhead, soapStreamReader);
  235.                         }
  236.                     }
  237.                     else {
  238.                         if(MessageType.SOAP_11.equals(messageType)){
  239.                             msg = new OpenSPCoop2Message_saaj_11_impl(this, mhs, is);
  240.                             ((OpenSPCoop2Message_saaj_11_impl)msg).initialize(overhead);
  241.                         }
  242.                         else{
  243.                             msg = new OpenSPCoop2Message_saaj_12_impl(this, mhs, is);
  244.                             ((OpenSPCoop2Message_saaj_12_impl)msg).initialize(overhead);
  245.                         }
  246.                     }
  247.                     break;
  248.                 case XML:
  249.                     msg = new OpenSPCoop2Message_xml_impl(this, is,contentType);
  250.                     break;
  251.                 case JSON:
  252.                     msg = new OpenSPCoop2Message_json_impl(this, is,contentType);
  253.                     break;
  254.                 case BINARY:
  255.                     msg = new OpenSPCoop2Message_binary_impl(this, is,contentType);
  256.                     break;
  257.                 case MIME_MULTIPART:
  258.                     msg = new OpenSPCoop2Message_mimeMultipart_impl(this, is,contentType);
  259.                     break;
  260.             }
  261.                     
  262.             return msg;
  263.             
  264.         }catch(Exception e){
  265.             throw new MessageException(e.getMessage(),e);
  266.         }
  267.     }


  270.     
  271. }
Created with JaCoCo 0.8.8.202204050719