OpenSPCoop2Message_xml_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.rest;

  23. import java.io.ByteArrayInputStream;
  24. import java.io.FileInputStream;
  25. import java.io.InputStream;
  26. import java.io.InputStreamReader;
  27. import java.io.OutputStream;
  28. import java.util.ArrayList;
  29. import java.util.List;

  31. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  32. import org.openspcoop2.message.OpenSPCoop2RestXmlMessage;
  33. import org.openspcoop2.message.exception.MessageException;
  34. import org.openspcoop2.message.exception.MessageNotSupportedException;
  35. import org.openspcoop2.message.xml.MessageXMLUtils;
  36. import org.openspcoop2.message.xml.XPathExpressionEngine;
  37. import org.openspcoop2.utils.io.DumpByteArrayOutputStream;
  38. import org.openspcoop2.utils.transport.http.ContentTypeUtilities;
  39. import org.openspcoop2.utils.transport.http.HttpConstants;
  40. import org.openspcoop2.utils.xml.DynamicNamespaceContext;
  41. import org.openspcoop2.utils.xml.XPathReturnType;
  42. import org.w3c.dom.Element;
  43. import org.w3c.dom.Node;
  44. import org.xml.sax.InputSource;

  46. /**
  47.  * Implementazione dell'OpenSPCoop2Message utilizzabile per messaggi xml
  48.  *
  49.  * @author Andrea Poli (poli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52.  */
  53. public class OpenSPCoop2Message_xml_impl extends AbstractBaseOpenSPCoop2RestMessage<Element> implements OpenSPCoop2RestXmlMessage {

  55.     public OpenSPCoop2Message_xml_impl(OpenSPCoop2MessageFactory messageFactory) {
  56.         super(messageFactory);
  57.     }
  58.     public OpenSPCoop2Message_xml_impl(OpenSPCoop2MessageFactory messageFactory, InputStream is,String contentType) throws MessageException {
  59.         super(messageFactory, is, contentType);
  60.     }
  61.     
  62.     @Override
  63.     protected Element buildContent() throws MessageException{
  64.         try{
  65.             return buildContent(this._getInputStream());
  66.         }finally{
  67.             try{
  68.                 this._getInputStream().close();
  69.             }catch(Exception eClose){
  70.                 // close
  71.             }
  72.         }
  73.     }
  74.     @Override
  75.     protected Element buildContent(DumpByteArrayOutputStream contentBuffer) throws MessageException{
  76.         try{
  77.             if(contentBuffer.isSerializedOnFileSystem()) {
  78.                 try(InputStream is = new FileInputStream(contentBuffer.getSerializedFile())){
  79.                     return buildContent(is);
  80.                 }
  81.             }
  82.             else {
  83.                 try(InputStream is = new ByteArrayInputStream(contentBuffer.toByteArray())){
  84.                     return buildContent(is);
  85.                 }
  86.             }
  87.         }
  88.         catch(MessageException me) {
  89.             throw me;
  90.         }
  91.         catch(Exception e){
  92.             throw new MessageException(e.getMessage(),e);
  93.         }
  94.     }
  95.     protected Element buildContent(InputStream is) throws MessageException{
  96.         InputStreamReader isr = null;
  97.         InputSource isSax = null;
  98.         try{
  99.             isr = new InputStreamReader(is,this.contentTypeCharsetName);
  100.             isSax = new InputSource(isr);
  101.             isSax.setEncoding(this.contentTypeCharsetName);
  102.             return MessageXMLUtils.getInstance(this.messageFactory).newElement(isSax);
  103.         }catch(Exception e){
  104.             throw new MessageException(e.getMessage(),e);
  105.         }finally{
  106.             try{
  107.                 if(isr!=null){
  108.                     isr.close();
  109.                 }
  110.             }catch(Exception eClose){
  111.                 // close
  112.             }
  113.         }
  114.     }

  116.     @Override
  117.     protected String buildContentAsString() throws MessageException{
  118.         try{
  119.             return this.getAsString(this.content, false);
  120.         }catch(Exception e){
  121.             throw new MessageException(e.getMessage(),e);
  122.         }
  123.     }
  124.     
  125.     @Override
  126.     protected byte[] buildContentAsByteArray() throws MessageException{
  127.         try{
  128.             return this.getAsString(this.content, false).getBytes(this.contentTypeCharsetName);
  129.         }catch(Exception e){
  130.             throw new MessageException(e.getMessage(),e);
  131.         }
  132.     }
  133.     
  134.     @Override
  135.     protected void serializeContent(OutputStream os, boolean consume) throws MessageException {
  136.         try{
  137.             MessageXMLUtils.getInstance(this.messageFactory).writeTo(this.content, os, true, this.contentTypeCharsetName);
  138.             os.flush();
  139.         }catch(Exception e){
  140.             throw new MessageException(e.getMessage(),e);
  141.         }
  142.     }

  144.     @Override
  145.     public boolean isProblemDetailsForHttpApis_RFC7807() throws MessageException,MessageNotSupportedException {
  146.         try{
  147.             if(this.contentType==null) {
  148.                 return false;
  149.             }
  150.             String baseType = ContentTypeUtilities.readBaseTypeFromContentType(this.contentType);
  151.             return HttpConstants.CONTENT_TYPE_XML_PROBLEM_DETAILS_RFC_7807.equalsIgnoreCase(baseType);
  152.         }catch(Exception e){
  153.             throw new MessageException(e.getMessage(),e);
  154.         }
  155.     }

  157.     
  158.     @Override
  159.     public void addElement(String name, String value)  throws MessageException,MessageNotSupportedException{
  160.          _processElement(name, null, value, true, false, null);
  161.     }
  162.     @Override
  163.     public void addElement(String name, String namespace, String value)  throws MessageException,MessageNotSupportedException{
  164.         _processElement(name, namespace, value, true, false, null);
  165.     }
  166.     
  167.     @Override
  168.     public void addElementIn(String pattern, String name, String value)  throws MessageException,MessageNotSupportedException{
  169.         _processElement(name, null, value, true, false, pattern);
  170.     }
  171.     @Override
  172.     public void addElementIn(String pattern, String name, String namespace, String value)  throws MessageException,MessageNotSupportedException{
  173.         _processElement(name, namespace, value, true, false, pattern);
  174.     }
  175.     
  176.     @Override
  177.     public void removeElement(String name) throws MessageException,MessageNotSupportedException{
  178.          _processElement(name, null, null, false, true, null);
  179.     }
  180.     @Override
  181.     public void removeElement(String name, String namespace) throws MessageException,MessageNotSupportedException{
  182.          _processElement(name, namespace, null, false, true, null);
  183.     }
  184.     
  185.     @Override
  186.     public void removeElementIn(String pattern, String name) throws MessageException,MessageNotSupportedException{
  187.          _processElement(name, null, null, false, true, pattern);
  188.     }
  189.     @Override
  190.     public void removeElementIn(String pattern, String name, String namespace) throws MessageException,MessageNotSupportedException{
  191.          _processElement(name, namespace, null, false, true, pattern);
  192.     }
  193.     
  194.     public void _processElement(String name, String namespace, String value, boolean add, boolean remove, String pattern) throws MessageException {
  195.         try {
  196.             if(!this.hasContent()) {
  197.                 return;
  198.             }
  199.             
  200.             Element content = this.getContent();
  201.             Node element = null;
  202.             if(pattern!=null) {
  203.                 XPathExpressionEngine engine = new XPathExpressionEngine(this.messageFactory);
  204.                 DynamicNamespaceContext dnc = new DynamicNamespaceContext();
  205.                 dnc.findPrefixNamespace(content);
  206.                 element = (Node) engine.getMatchPattern(content, dnc, pattern, XPathReturnType.NODE);
  207.             }
  208.             else {
  209.                 element = content;
  210.             }
  211.                 
  212.             if(remove) {
  213.                 List<Node> list = MessageXMLUtils.getInstance(this.messageFactory).getNotEmptyChildNodes(element, false);
  214.                 List<Node> removeNodes = new ArrayList<Node>();
  215.                 if(list!=null && !list.isEmpty()) {
  216.                     for (Node node : list) {
  217.                         if(namespace!=null) {
  218.                             if(namespace.equals(node.getNamespaceURI()) && name.equals(node.getLocalName())) {
  219.                                 removeNodes.add(node);
  220.                             }
  221.                         }
  222.                         else {
  223.                             if(node.getNamespaceURI()==null && name.equals(node.getLocalName())) {
  224.                                 removeNodes.add(node);
  225.                             }
  226.                         }
  227.                     }
  228.                 }
  229.                 while(!removeNodes.isEmpty()) {
  230.                     Node n = removeNodes.remove(0);
  231.                     element.removeChild(n);
  232.                 }
  233.                 
  234.                 /*NodeList list = null;
  235.                 if(namespace!=null) {
  236.                     list = element.getElementsByTagNameNS(namespace, name);
  237.                 }
  238.                 else {
  239.                     list = element.getElementsByTagName(name);
  240.                 }
  241.                 if(list!=null && list.getLength()>0) {
  242.                     for (int i = 0; i < list.getLength(); i++) {
  243.                         Node n = list.item(i);
  244.                         element.removeChild(n);
  245.                     }
  246.                 }*/
  247.             }
  248.             else if(add) {
  249.                 Element eAdd = null;
  250.                 if(namespace!=null) {
  251.                     eAdd = element.getOwnerDocument().createElementNS(namespace, name);
  252.                 }
  253.                 else {
  254.                     eAdd = element.getOwnerDocument().createElement(name);
  255.                 }
  256.                 eAdd.setTextContent(value);
  257.                 element.appendChild(eAdd);
  258.             }
  259.             
  260.         }catch(Exception e) {
  261.             if(pattern!=null) {
  262.                 throw new MessageException("Operazione fallita (pattern: "+pattern+"): "+e.getMessage(),e);
  263.             }
  264.             else {
  265.                 throw new MessageException("Operazione fallita: "+e.getMessage(),e);
  266.             }
  267.         }
  268.     }
  269. }
Created with JaCoCo 0.8.8.202204050719