MTOMUtilities.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.message.soap.mtom;

  22. import java.io.ByteArrayInputStream;
  23. import java.util.ArrayList;
  24. import java.util.Iterator;
  25. import java.util.List;

  27. //import javax.mail.internet.ContentType;
  28. import com.sun.xml.messaging.saaj.packaging.mime.internet.ContentType;
  29. import javax.xml.namespace.QName;
  30. import javax.xml.soap.AttachmentPart;
  31. import javax.xml.soap.MimeHeaders;

  33. import org.openspcoop2.message.OpenSPCoop2Message;
  34. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  35. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  36. import org.openspcoop2.message.constants.MessageType;
  37. import org.openspcoop2.message.exception.MessageException;
  38. import org.openspcoop2.message.exception.MessageNotSupportedException;
  39. import org.openspcoop2.message.soap.SoapUtils;
  40. import org.openspcoop2.message.xml.XPathExpressionEngine;
  41. import org.openspcoop2.utils.Utilities;
  42. import org.openspcoop2.utils.io.Base64Utilities;
  43. import org.openspcoop2.utils.transport.http.ContentTypeUtilities;
  44. import org.openspcoop2.utils.transport.http.HttpConstants;
  45. import org.openspcoop2.utils.xml.AbstractXPathExpressionEngine;
  46. import org.openspcoop2.utils.xml.DynamicNamespaceContext;
  47. import org.openspcoop2.utils.xml.XPathNotFoundException;
  48. import org.openspcoop2.utils.xml.XPathReturnType;
  49. import org.w3c.dom.Document;
  50. import org.w3c.dom.Element;
  51. import org.w3c.dom.NamedNodeMap;
  52. import org.w3c.dom.Node;
  53. import org.w3c.dom.NodeList;

  55. /**
  56.  * MTOMUtilities
  57.  *
  58.  * @author Andrea Poli (apoli@link.it)
  59.  * @author $Author$
  60.  * @version $Rev$, $Date$
  61.  */
  62. public class MTOMUtilities {
  63.     
  64.     public static boolean isMtom(String cType) throws MessageException{
  65.         try{
  66.             return ContentTypeUtilities.isMtom(cType);
  67.         }catch(Exception e){
  68.             throw new MessageException(e.getMessage(),e);
  69.         }
  70.     }
  71.     
  72.     
  73.     public static String readInternalMultipartMtomContentType(String contentType) throws MessageException{
  74.         try{
  75.             return readInternalMultipartMtomContentType(new ContentType(contentType));
  76.         }
  77.         catch(MessageException e){
  78.             throw e;
  79.         }
  80.         catch(Exception e){
  81.             throw new MessageException(e.getMessage(),e);
  82.         }
  83.     }
  84.     public static String readInternalMultipartMtomContentType(ContentType contentType) throws MessageException{
  85.         try{
  86.             return ContentTypeUtilities.readInternalMultipartMtomContentType(contentType);
  87.         }
  88.         catch(Exception e){
  89.             throw new MessageException(e.getMessage(),e);
  90.         }
  91.     }
  92.     
  93.     public static List<MtomXomReference> unpackaging(OpenSPCoop2Message msgParam, boolean fast, boolean body) throws MessageException, MessageNotSupportedException{
  94.         
  95.         if(!MessageType.SOAP_11.equals(msgParam.getMessageType()) && !MessageType.SOAP_12.equals(msgParam.getMessageType())){
  96.             throw MessageNotSupportedException.newMessageNotSupportedException(msgParam.getMessageType());
  97.         }
  98.         OpenSPCoop2SoapMessage message = msgParam.castAsSoap();
  99.         
  100.         try{
  101.             List<MtomXomReference> list = new ArrayList<MtomXomReference>();
  102.             
  103.             Element element = null;
  104.             if(body){
  105.                 element = message.getSOAPBody();
  106.             }
  107.             else{
  108.                 element = message.getSOAPPart().getEnvelope();
  109.             }
  110.             if(element==null){
  111.                 return list;
  112.             }
  113.             
  114.             boolean restoredXomReference = false;
  115.             
  116.             AbstractXPathExpressionEngine xpathEngine = new XPathExpressionEngine(msgParam.getFactory());
  117.             DynamicNamespaceContext dnc = org.openspcoop2.message.xml.MessageDynamicNamespaceContextFactory.getInstance(msgParam.getFactory()).getNamespaceContext(element);
  118.             Object oNode = null;
  119.             try{
  120.                 oNode = xpathEngine.getMatchPattern(element, dnc, org.openspcoop2.message.soap.mtom.Costanti.MTOM_XOP_REFERENCES, XPathReturnType.NODESET);
  121.             }catch(XPathNotFoundException notFound){}
  122.             if(oNode==null){
  123.                 // non esistono xom reference
  124.                 return list;
  125.             }
  126.             if( !(oNode instanceof NodeList) ){
  127.                 throw new MessageException("XpathEngine (expr:"+org.openspcoop2.message.soap.mtom.Costanti.MTOM_XOP_REFERENCES+") return wrong type (expected: "+
  128.                         NodeList.class.getName()+"): "+oNode.getClass().getName());
  129.             }
  130.             NodeList nodeList = (NodeList) oNode;
  131.             //System.out.println("Ritornato: size: "+nodeList.getLength());
  132.             for (int i = 0; i < nodeList.getLength(); i++) {
  133.                 
  134.                 // xomReference
  135.                 Node xomReference = nodeList.item(i);
  136.                 if(xomReference.getAttributes()==null || xomReference.getAttributes().getLength()<=0){
  137.                     throw new MessageException("Found XOM Reference without attributes ('"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' attribute required)");
  138.                 }
  139.                 Node xomHref = xomReference.getAttributes().getNamedItem(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF);
  140.                 if(xomHref == null){
  141.                     throw new MessageException("Found XOM Reference without attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"'");
  142.                 }
  143.                 String contentId = xomHref.getNodeValue();
  144.                 if(contentId == null){
  145.                     throw new MessageException("Found XOM Reference with attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' without value?");
  146.                 }
  147.                 if(contentId.startsWith(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE)){
  148.                     contentId = contentId.substring(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE.length());
  149.                 }
  150.                 MimeHeaders mhs = new MimeHeaders();
  151.                 mhs.addHeader(HttpConstants.CONTENT_ID, contentId);
  152.                 Iterator<?> itAttachments = message.getAttachments(mhs);
  153.                 if(itAttachments == null || itAttachments.hasNext()==false){
  154.                     throw new MessageException("Found XOM Reference with attribute ["+
  155.                             org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but the message hasn't attachments");
  156.                 }
  157.                 AttachmentPart ap = null;
  158.                 while (itAttachments.hasNext()) {
  159.                     if(ap!=null){
  160.                         throw new MessageException("Found XOM Reference with attribute ["+
  161.                                 org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but exists more than one attachment with same id");
  162.                     }
  163.                     ap = (AttachmentPart) itAttachments.next();
  164.                 }
  165.                 if(ap==null){
  166.                     throw new MessageException("Found XOM Reference with attribute ["+
  167.                             org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but not exists attachment with same id");
  168.                 }
  169.         
  170.                 
  171.                 // base64Element
  172.                 Node elementBase64Binary = xomReference.getParentNode();
  173.                 if(elementBase64Binary==null){
  174.                     throw new MessageException("Found XOM Reference without parent node?");
  175.                 }
  176.                 QName qname = new QName(elementBase64Binary.getNamespaceURI(), elementBase64Binary.getLocalName());
  177.                 //System.out.println("Found Element ["+qname.toString()+"]");
  178.                 
  179.         
  180.                 // unpackaging
  181.                 String base64Binary = null;
  182.                 if(fast){
  183.                     // fast unpackaging (for validation)
  184.                     base64Binary = Base64Utilities.encodeAsString("FAST".getBytes());
  185.                 }else{
  186.                     base64Binary = Utilities.getAsByteArrayOuputStream(ap.getBase64Content()).toString();
  187.                     message.removeAttachments(mhs);
  188.                     restoredXomReference = true;
  189.                 }
  190.                 elementBase64Binary.removeChild(xomReference);
  191.                 elementBase64Binary.setTextContent(base64Binary);
  192.                 
  193.                 
  194.                 // add reference
  195.                 MtomXomReference reference = new MtomXomReference();
  196.                 reference.setNodeName(qname);
  197.                 reference.setXomReference(xomReference);
  198.                 reference.setNode(elementBase64Binary);
  199.                 reference.setContentId(contentId);
  200.                 list.add(reference);
  201.             }
  202.             
  203.             
  204.             if(restoredXomReference){
  205.                 
  206.                 message.removeContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_TYPE);
  207.                 message.removeContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_START_INFO);
  208.                 
  209.                 if(message.countAttachments()>0){
  210.                     // esistono altri attachments "originali" non derivati dalla serializzazione mtom
  211.                     if(MessageType.SOAP_11.equals(message.getMessageType())){
  212.                         message.addContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_TYPE, HttpConstants.CONTENT_TYPE_SOAP_1_1);
  213.                     }
  214.                     else if(MessageType.SOAP_12.equals(message.getMessageType())){
  215.                         message.addContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_TYPE, HttpConstants.CONTENT_TYPE_SOAP_1_2);
  216.                     }
  217.                 }
  218.                 else {
  219.                     
  220.                     ContentType cType = null;
  221.                     if(MessageType.SOAP_11.equals(message.getMessageType())){
  222.                         cType = new ContentType(HttpConstants.CONTENT_TYPE_SOAP_1_1);
  223.                     }
  224.                     else if(MessageType.SOAP_12.equals(message.getMessageType())){
  225.                         cType = new ContentType(HttpConstants.CONTENT_TYPE_SOAP_1_2);
  226.                     }
  227.                     
  228.                     String charsetParam =  ContentTypeUtilities.readCharsetFromContentType(message.getContentType());
  229.                     if(charsetParam!=null && !"".equals(charsetParam)) {
  230.                         if(cType!=null) {
  231.                             cType.setParameter(HttpConstants.CONTENT_TYPE_PARAMETER_CHARSET, charsetParam);
  232.                         }
  233.                     }
  234.                     
  235.                     if(cType!=null) {
  236.                         message.setContentType(cType.toString());
  237.                     }
  238.                 }
  239.             }
  240.             
  241.             //message.saveChanges();
  242.             
  243.             return list;
  244.             
  245.         }
  246.         catch(MessageException e){
  247.             throw e;
  248.         }
  249.         catch(MessageNotSupportedException e){
  250.             throw e;
  251.         }
  252.         catch(Exception e){
  253.             throw new MessageException(e.getMessage(),e);
  254.         }
  255.     }
  256.     
  257.     public static List<MtomXomReference> packaging(OpenSPCoop2Message msgParam, List<MtomXomPackageInfo> packageInfos, boolean body) throws MessageException, MessageNotSupportedException{
  258.         
  259.         if(!MessageType.SOAP_11.equals(msgParam.getMessageType()) && !MessageType.SOAP_12.equals(msgParam.getMessageType())){
  260.             throw MessageNotSupportedException.newMessageNotSupportedException(msgParam.getMessageType());
  261.         }
  262.         OpenSPCoop2SoapMessage message = msgParam.castAsSoap();
  263.         
  264.         try{
  265.         
  266.             List<MtomXomReference> list = new ArrayList<MtomXomReference>();
  267.             
  268.             Element element = null;
  269.             Document documentSOAPPart = message.getSOAPPart();
  270.             if(body){
  271.                 element = message.getSOAPBody();
  272.             }
  273.             else{
  274.                 element = message.getSOAPPart().getEnvelope();
  275.             }
  276.             if(element==null){
  277.                 return list;
  278.             }
  279.             AbstractXPathExpressionEngine xpathEngine = new XPathExpressionEngine(msgParam.getFactory());
  280.             DynamicNamespaceContext dnc = org.openspcoop2.message.xml.MessageDynamicNamespaceContextFactory.getInstance(msgParam.getFactory()).getNamespaceContext(element);
  281.             
  282.             boolean addAttachment = false;
  283.             
  284.             if(packageInfos==null || packageInfos.size()<=0){
  285.                 return list;
  286.             }
  287.             for (MtomXomPackageInfo mtomXomPackageInfo : packageInfos) {
  288.                 
  289.                 String xpathExpressionName = mtomXomPackageInfo.getName();
  290.                 String xpathExpression = mtomXomPackageInfo.getXpathExpression();
  291.                 
  292.                 Object oNode = null;
  293.                 try{
  294.                     oNode = xpathEngine.getMatchPattern(element, dnc, xpathExpression, XPathReturnType.NODESET);
  295.                 }catch(XPathNotFoundException notFound){}
  296.                 if(oNode==null){
  297.                     // non esistono reference all'oggetto su cui effetture packaging
  298.                     if(mtomXomPackageInfo.isRequired()){
  299.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") not found reference");
  300.                     }
  301.                     continue;
  302.                 }
  303.                 if( !(oNode instanceof NodeList) ){
  304.                     throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") return wrong type (expected: "+
  305.                             NodeList.class.getName()+"): "+oNode.getClass().getName());
  306.                 }
  307.                 NodeList nodeList = (NodeList) oNode;
  308.                 if(nodeList.getLength()<=0){
  309.                     // non esistono reference all'oggetto su cui effetture packaging
  310.                     if(mtomXomPackageInfo.isRequired()){
  311.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") not found reference (node list is empty)");
  312.                     }
  313.                     continue;
  314.                 }
  315.                 //System.out.println("Ritornato: size: "+nodeList.getLength());
  316.                 for (int i = 0; i < nodeList.getLength(); i++) {
  317.                     
  318.                     // elementBase64
  319.                     Node elementBase64Binary = nodeList.item(i);
  320.                     
  321.                     // verifico che non sia gia un xom reference
  322.                     if(MTOMUtilities.getIfExistsXomReference(msgParam.getFactory(), (Element)elementBase64Binary)!=null){
  323.                         continue; // esiste gia' una xom reference.
  324.                     }
  325.                     
  326.                     QName qname = new QName(elementBase64Binary.getNamespaceURI(), elementBase64Binary.getLocalName());
  327.                     //System.out.println("Found Element ["+qname.toString()+"]");
  328.                     List<Node> elementBase64BinaryChilds = SoapUtils.getNotEmptyChildNodes(msgParam.getFactory(), elementBase64Binary,false);
  329.                     if(elementBase64BinaryChilds!=null && elementBase64BinaryChilds.size()>0){
  330.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  331.                                 ") with childs, mtom optimize packaging is only valid for base64Binary xsd element");
  332.                     }
  333.                     String contentTypeXMIMEAttribute = null;
  334.                     if(elementBase64Binary.hasAttributes()){
  335.                         NamedNodeMap attr = elementBase64Binary.getAttributes();
  336.                         if(attr!=null){
  337.                             for (int j = 0; j < attr.getLength(); j++) {
  338.                                 Node n = attr.item(j);
  339.                                 String localName = n.getNodeName();
  340.                                 if(localName.contains(":")){
  341.                                     localName = localName.split(":")[1];
  342.                                 }
  343.                                 
  344.                                 // ignoro dichiarazioni di namespace (l'xml verra riorganizzato)
  345.                                 if(org.openspcoop2.message.constants.Costanti.XMLNS_NAMESPACE.equals(n.getNamespaceURI()) &&
  346.                                         org.openspcoop2.message.constants.Costanti.XMLNS_LOCAL_NAME.equals(localName)){
  347.                                     continue;
  348.                                 }
  349.                                 
  350.                                 if(org.openspcoop2.message.soap.mtom.Costanti.XMIME_NAMESPACE.equals(n.getNamespaceURI()) &&
  351.                                         org.openspcoop2.message.soap.mtom.Costanti.XMIME_ATTRIBUTE_CONTENT_TYPE.equals(localName)){
  352.                                     contentTypeXMIMEAttribute = n.getNodeValue();
  353.                                 }else{
  354.                                     throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  355.                                             ") with attribute ({"+n.getNamespaceURI()+"}"+localName+
  356.                                             "), mtom optimize packaging is only valid for base64Binary xsd element (permit only {"+
  357.                                             org.openspcoop2.message.soap.mtom.Costanti.XMIME_NAMESPACE+"}"+org.openspcoop2.message.soap.mtom.Costanti.XMIME_ATTRIBUTE_CONTENT_TYPE+")");        
  358.                                 }
  359.                             }
  360.                         }
  361.                     }
  362.                     String base64Content = elementBase64Binary.getTextContent();
  363.                     if(base64Content==null){
  364.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  365.                                 ") without base64 value (textContent), mtom optimize packaging is only valid for base64Binary xsd element");
  366.                     }
  367.                     
  368.                     
  369.                     
  370.                     // Attachment
  371.                     String contentId = null;
  372.                     try{
  373.                         AttachmentPart ap = message.createAttachmentPart();
  374.                         String contentType = mtomXomPackageInfo.getContentType();
  375.                         if(contentType==null){
  376.                             if(contentTypeXMIMEAttribute!=null){
  377.                                 contentType = contentTypeXMIMEAttribute;
  378.                             }
  379.                             else{
  380.                                 contentType = HttpConstants.CONTENT_TYPE_APPLICATION_OCTET_STREAM;
  381.                             }
  382.                         }
  383.                         ap.setContentId(message.createContentID(org.openspcoop2.message.soap.mtom.Costanti.OPENSPCOOP2_MTOM_NAMESPACE));
  384.                         contentId = ap.getContentId();
  385.                         if(contentId.startsWith("<")){
  386.                             contentId = contentId.substring(1);
  387.                         }
  388.                         if(contentId.endsWith(">")){
  389.                             contentId = contentId.substring(0,contentId.length()-1);
  390.                         }
  391.                         ap.setBase64Content(new ByteArrayInputStream(base64Content.getBytes()), contentType);
  392.                         message.addAttachmentPart(ap);
  393.                         addAttachment = true;
  394.                     }catch(Exception e){
  395.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  396.                                 ") with base64 value (textContent). Error occurs during mtom optimize packaging (decodeBase64/createAttach): "+e.getMessage(),e);
  397.                     }
  398.                     
  399.                     
  400.                     // packaging
  401.                     elementBase64Binary.setTextContent(null);
  402.                     Element xomReference = documentSOAPPart.createElementNS(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_NAMESPACE, "xop:"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_LOCAL_NAME);
  403.                     // Non funziona in axiom
  404.                     //Attr xomReferenceHrefAttribute = documentSOAPPart.createAttribute(org.openspcoop2.message.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF);
  405.                     //xomReferenceHrefAttribute.setTextContent(org.openspcoop2.message.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE+contentId);
  406.                     //xomReference.getAttributes().setNamedItem(xomReferenceHrefAttribute);
  407.                     xomReference.setAttribute(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF, org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE+contentId);
  408.                     elementBase64Binary.appendChild(xomReference);
  409.                     
  410.                     // add reference
  411.                     MtomXomReference reference = new MtomXomReference();
  412.                     reference.setNodeName(qname);
  413.                     reference.setXomReference(xomReference);
  414.                     reference.setNode(elementBase64Binary);
  415.                     reference.setContentId(contentId);
  416.                     list.add(reference);
  417.                 }
  418.                 
  419.                 
  420.             }
  421.             
  422.             if(addAttachment){
  423.                 message.addContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_TYPE, HttpConstants.CONTENT_TYPE_APPLICATION_XOP_XML);
  424.                 if(MessageType.SOAP_11.equals(message.getMessageType())){
  425.                     message.addContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_START_INFO, HttpConstants.CONTENT_TYPE_SOAP_1_1);
  426.                 }
  427.                 else if(MessageType.SOAP_12.equals(message.getMessageType())){
  428.                     message.addContentTypeParameter(HttpConstants.CONTENT_TYPE_MULTIPART_PARAMETER_START_INFO, HttpConstants.CONTENT_TYPE_SOAP_1_2);
  429.                 }
  430.             }
  431.             
  432.             //message.saveChanges();
  433.             
  434.             return list;
  435.             
  436.         }
  437.         catch(MessageException e){
  438.             throw e;
  439.         }
  440.         catch(MessageNotSupportedException e){
  441.             throw e;
  442.         }
  443.         catch(Exception e){
  444.             throw new MessageException(e.getMessage(),e);
  445.         }
  446.                 
  447.     }
  448.     
  449.     public static List<MtomXomReference> verify(OpenSPCoop2Message msgParam, List<MtomXomPackageInfo> packageInfos, boolean body) throws MessageException,MessageNotSupportedException {
  450.         
  451.         if(!MessageType.SOAP_11.equals(msgParam.getMessageType()) && !MessageType.SOAP_12.equals(msgParam.getMessageType())){
  452.             throw MessageNotSupportedException.newMessageNotSupportedException(msgParam.getMessageType());
  453.         }
  454.         OpenSPCoop2SoapMessage message = msgParam.castAsSoap();
  455.         
  456.         try{
  457.             
  458.             List<MtomXomReference> list = new ArrayList<MtomXomReference>();
  459.             
  460.             Element element = null;
  461.             if(body){
  462.                 element = message.getSOAPBody();
  463.             }
  464.             else{
  465.                 element = message.getSOAPPart().getEnvelope();
  466.             }
  467.             if(element==null){
  468.                 return list;
  469.             }
  470.             AbstractXPathExpressionEngine xpathEngine = new XPathExpressionEngine(msgParam.getFactory());
  471.             DynamicNamespaceContext dnc = org.openspcoop2.message.xml.MessageDynamicNamespaceContextFactory.getInstance(msgParam.getFactory()).getNamespaceContext(element);
  472.             
  473.             if(packageInfos==null || packageInfos.size()<=0){
  474.                 return list;
  475.             }
  476.             for (MtomXomPackageInfo mtomXomPackageInfo : packageInfos) {
  477.                 
  478.                 String xpathExpressionName = mtomXomPackageInfo.getName();
  479.                 String xpathExpression = mtomXomPackageInfo.getXpathExpression();
  480.                 
  481.                 Object oNode = null;
  482.                 try{
  483.                     oNode = xpathEngine.getMatchPattern(element, dnc, xpathExpression, XPathReturnType.NODESET);
  484.                 }catch(XPathNotFoundException notFound){}
  485.                 if(oNode==null){
  486.                     // non esistono reference all'oggetto su cui effetture packaging
  487.                     if(mtomXomPackageInfo.isRequired()){
  488.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") not found reference");
  489.                     }
  490.                     continue;
  491.                 }
  492.                 if( !(oNode instanceof NodeList) ){
  493.                     throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") return wrong type (expected: "+
  494.                             NodeList.class.getName()+"): "+oNode.getClass().getName());
  495.                 }
  496.                 NodeList nodeList = (NodeList) oNode;
  497.                 if(nodeList.getLength()<=0){
  498.                     // non esistono reference all'oggetto su cui effetture packaging
  499.                     if(mtomXomPackageInfo.isRequired()){
  500.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") not found reference (node list is empty)");
  501.                     }
  502.                     continue;
  503.                 }
  504.                 //System.out.println("Ritornato: size: "+nodeList.getLength());
  505.                 for (int i = 0; i < nodeList.getLength(); i++) {
  506.                     
  507.                     // elementBase64
  508.                     Node elementBase64Binary = nodeList.item(i);
  509.                     QName qname = new QName(elementBase64Binary.getNamespaceURI(), elementBase64Binary.getLocalName());
  510.                     //System.out.println("Found Element ["+qname.toString()+"]");
  511.                     if(elementBase64Binary.hasAttributes()){
  512.                         NamedNodeMap attr = elementBase64Binary.getAttributes();
  513.                         if(attr!=null){
  514.                             for (int j = 0; j < attr.getLength(); j++) {
  515.                                 Node n = attr.item(j);
  516.                                 String localName = n.getNodeName();
  517.                                 if(localName.contains(":")){
  518.                                     localName = localName.split(":")[1];
  519.                                 }
  520.                                 
  521.                                 // ignoro dichiarazioni di namespace (l'xml verra riorganizzato)
  522.                                 if(org.openspcoop2.message.constants.Costanti.XMLNS_NAMESPACE.equals(n.getNamespaceURI()) &&
  523.                                         org.openspcoop2.message.constants.Costanti.XMLNS_LOCAL_NAME.equals(localName)){
  524.                                     continue;
  525.                                 }
  526.                                 
  527.                                 // ignoro dichiarazione di content type
  528.                                 if(org.openspcoop2.message.soap.mtom.Costanti.XMIME_NAMESPACE.equals(n.getNamespaceURI()) &&
  529.                                         org.openspcoop2.message.soap.mtom.Costanti.XMIME_ATTRIBUTE_CONTENT_TYPE.equals(localName)){
  530.                                     continue;
  531.                                 }
  532.                                 
  533.                                 throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  534.                                         ") with attribute ({"+n.getNamespaceURI()+"}"+localName+
  535.                                             "), mtom optimize packaging structure invalid");
  536.                             }
  537.                         }
  538.                             
  539.                     }
  540.                     List<Node> nodeListBase64 = SoapUtils.getNotEmptyChildNodes(msgParam.getFactory(), elementBase64Binary,false);
  541.                     if(nodeListBase64==null || nodeListBase64.size()<=0){
  542.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  543.                                 ") without childs, mtom optimize packaging require xop:"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_LOCAL_NAME+" element");
  544.                     }
  545.                     if(nodeListBase64.size()>1){
  546.                         throw new MessageException("XpathEngine (expr("+xpathExpressionName+"):"+xpathExpression+") found element ("+qname+
  547.                                 ") with more than one child, mtom optimize packaging structure invalid");
  548.                     }
  549.                     
  550.                     // xomReference
  551.                     Node xomReference = nodeListBase64.get(0);
  552.                     if(xomReference.getAttributes()==null || xomReference.getAttributes().getLength()<=0){
  553.                         throw new MessageException("Found XOM Reference without attributes ('"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' attribute required)");
  554.                     }
  555.                     Node xomHref = xomReference.getAttributes().getNamedItem(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF);
  556.                     if(xomHref == null){
  557.                         throw new MessageException("Found XOM Reference without attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"'");
  558.                     }
  559.                     String contentId = xomHref.getNodeValue();
  560.                     if(contentId == null){
  561.                         throw new MessageException("Found XOM Reference with attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' without value?");
  562.                     }
  563.                     if(contentId.startsWith(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE)){
  564.                         contentId = contentId.substring(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE.length());
  565.                     }
  566.                     MimeHeaders mhs = new MimeHeaders();
  567.                     mhs.addHeader(HttpConstants.CONTENT_ID, contentId);
  568.                     Iterator<?> itAttachments = message.getAttachments(mhs);
  569.                     if(itAttachments == null || itAttachments.hasNext()==false){
  570.                         throw new MessageException("Found XOM Reference with attribute ["+
  571.                                 org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but the message hasn't attachments");
  572.                     }
  573.                     AttachmentPart ap = null;
  574.                     while (itAttachments.hasNext()) {
  575.                         if(ap!=null){
  576.                             throw new MessageException("Found XOM Reference with attribute ["+
  577.                                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but exists more than one attachment with same id");
  578.                         }
  579.                         ap = (AttachmentPart) itAttachments.next();
  580.                     }
  581.                     if(ap==null){
  582.                         throw new MessageException("Found XOM Reference with attribute ["+
  583.                                 org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"] but not exists attachment with same id");
  584.                     }   
  585.                     String contentType = mtomXomPackageInfo.getContentType();
  586.                     if(contentType==null){
  587.                         contentType = HttpConstants.CONTENT_TYPE_APPLICATION_OCTET_STREAM;
  588.                     }
  589.                     if(ap.getContentType()==null){
  590.                         throw new MessageException("Found XOM Reference with attribute ["+
  591.                                 org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"]. The attachment hasn't content-type");
  592.                     }
  593.                     else{
  594.                         String apCT = ap.getContentType();
  595.                         String base = ContentTypeUtilities.readBaseTypeFromContentType(apCT);
  596.                         if(contentType.equals(base)==false){
  597.                             throw new MessageException("Found XOM Reference with attribute ["+
  598.                                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+contentId+"]. The attachment has wrong content-type (expected:"+contentType+"): "+ap.getContentType());
  599.                         }
  600.                     }
  601.                                         
  602.                     // add reference
  603.                     MtomXomReference reference = new MtomXomReference();
  604.                     reference.setNodeName(qname);
  605.                     reference.setXomReference(xomReference);
  606.                     reference.setNode(elementBase64Binary);
  607.                     reference.setContentId(contentId);
  608.                     list.add(reference);
  609.                 }
  610.                 
  611.                 
  612.             }
  613.             
  614.             return list;
  615.             
  616.         }
  617.         catch(MessageException e){
  618.             throw e;
  619.         }
  620.         catch(MessageNotSupportedException e){
  621.             throw e;
  622.         }
  623.         catch(Exception e){
  624.             throw new MessageException(e.getMessage(),e);
  625.         }
  626.         
  627.     }
  628.     
  629.     public static void restoreAfterFastUnpackaging(OpenSPCoop2Message msgParam, List<MtomXomReference> references, boolean body) throws MessageException,MessageNotSupportedException {
  630.     
  631.         if(!MessageType.SOAP_11.equals(msgParam.getMessageType()) && !MessageType.SOAP_12.equals(msgParam.getMessageType())){
  632.             throw MessageNotSupportedException.newMessageNotSupportedException(msgParam.getMessageType());
  633.         }
  634.         OpenSPCoop2SoapMessage message = msgParam.castAsSoap();
  635.         
  636.         try{
  637.         
  638.             Element element = null;
  639.             if(body){
  640.                 element = message.getSOAPBody();
  641.             }
  642.             else{
  643.                 element = message.getSOAPPart().getEnvelope();
  644.             }
  645.             if(element==null){
  646.                 return;
  647.             }
  648.             
  649.             if(references==null || references.size()<=0){
  650.                 return;
  651.             }
  652.             
  653.             for (MtomXomReference mtomXomReference : references) {
  654.                 
  655.                 if(mtomXomReference.getNode()==null){
  656.                     throw new MessageException("XomReference ["+mtomXomReference.getNodeName()+"] with undefined node");
  657.                 }
  658.                 if(mtomXomReference.getXomReference()==null){
  659.                     throw new MessageException("XomReference ["+mtomXomReference.getNodeName()+"] with undefined xomRerefence");
  660.                 }
  661.                 mtomXomReference.getNode().setTextContent(null);
  662.                 mtomXomReference.getNode().appendChild(mtomXomReference.getXomReference());
  663.                 
  664.             }
  665.             
  666.             //message.saveChanges();
  667.         }
  668.         catch(MessageException e){
  669.             throw e;
  670.         }
  671.         catch(MessageNotSupportedException e){
  672.             throw e;
  673.         }
  674.         catch(Exception e){
  675.             throw new MessageException(e.getMessage(),e);
  676.         }
  677.         
  678.     }
  679.     
  680.     public static Element getIfExistsXomReference(OpenSPCoop2MessageFactory messageFactory, Element element){
  681.         
  682.         try{
  683.             Node n = SoapUtils.getFirstNotEmptyChildNode(messageFactory, element,false);
  684.             if(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_LOCAL_NAME.equals(n.getLocalName()) &&
  685.                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_NAMESPACE.equals(n.getNamespaceURI())){
  686.                 return (Element)n;
  687.             }
  688. //          
  689. //          La ricerca con XPath ritornava anche gli elementi del padre. 
  690. //          AbstractXPathExpressionEngine xpathEngine = new XPathExpressionEngine();
  691. //          DynamicNamespaceContext dnc = org.openspcoop2.message.DynamicNamespaceContextFactory.getInstance().getNamespaceContext(element);
  692. //          Object oNode = xpathEngine.getMatchPattern(element, dnc, org.openspcoop2.message.mtom.Costanti.MTOM_XOP_REFERENCES, XPathReturnType.NODE);
  693. //          return (Element) oNode;
  694.             
  695.             return null;
  696.             
  697.         }catch(Exception e){
  698.             return null;
  699.         }
  700.     }
  701.     
  702.     public static String getCidXomReference(Element element) throws MessageException {
  703.         if(element.getAttributes()==null || element.getAttributes().getLength()<=0){
  704.             throw new MessageException("Found XOM Reference without attributes ('"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' attribute required)");
  705.         }
  706.         Node xomHref = element.getAttributes().getNamedItem(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF);
  707.         if(xomHref == null){
  708.             throw new MessageException("Found XOM Reference without attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"'");
  709.         }
  710.         String contentId = xomHref.getNodeValue();
  711.         if(contentId == null){
  712.             throw new MessageException("Found XOM Reference with attribute '"+org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"' without value?");
  713.         }
  714.         if(contentId.startsWith(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE)){
  715.             contentId = contentId.substring(org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF_CID_PREFIX_VALUE.length());
  716.         }
  717.         return contentId;
  718.     }
  719.     
  720.     public static AttachmentPart getAttachmentPart(OpenSPCoop2Message msgParam, String cidReference) throws MessageException,MessageNotSupportedException {
  721.         
  722.         if(!MessageType.SOAP_11.equals(msgParam.getMessageType()) && !MessageType.SOAP_12.equals(msgParam.getMessageType())){
  723.             throw MessageNotSupportedException.newMessageNotSupportedException(msgParam.getMessageType());
  724.         }
  725.         OpenSPCoop2SoapMessage message = msgParam.castAsSoap();
  726.         
  727.         MimeHeaders mhs = new MimeHeaders();
  728.         mhs.addHeader(HttpConstants.CONTENT_ID, cidReference);
  729.         Iterator<?> itAttachments = message.getAttachments(mhs);
  730.         if(itAttachments == null || itAttachments.hasNext()==false){
  731.             throw new MessageException("Found XOM Reference with attribute ["+
  732.                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+cidReference+"] but the message hasn't attachments");
  733.         }
  734.         AttachmentPart ap = null;
  735.         while (itAttachments.hasNext()) {
  736.             if(ap!=null){
  737.                 throw new MessageException("Found XOM Reference with attribute ["+
  738.                         org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+cidReference+"] but exists more than one attachment with same id");
  739.             }
  740.             ap = (AttachmentPart) itAttachments.next();
  741.         }
  742.         if(ap==null){
  743.             throw new MessageException("Found XOM Reference with attribute ["+
  744.                     org.openspcoop2.message.soap.mtom.Costanti.XOP_INCLUDE_ATTRIBUTE_HREF+"]=["+cidReference+"] but not exists attachment with same id");
  745.         }
  746.         return ap;
  747.     }
  748. }
Created with JaCoCo 0.8.8.202204050719