/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.servicemix.soap.marshalers;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.InputStream;
import java.net.URI;
import java.util.Iterator;
import java.util.Properties;

import javax.activation.DataHandler;
import javax.activation.FileDataSource;
import javax.mail.Session;
import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;
import javax.xml.namespace.QName;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamSource;

import junit.framework.TestCase;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.servicemix.jbi.jaxp.BytesSource;
import org.apache.servicemix.jbi.jaxp.SourceTransformer;
import org.apache.servicemix.jbi.util.DOMUtil;
import org.apache.servicemix.jbi.util.FileUtil;
import org.apache.xpath.CachedXPathAPI;
import org.w3c.dom.Document;
import org.w3c.dom.DocumentFragment;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.traversal.NodeIterator;

/**
 * 
 * @author Guillaume Nodet
 * @version $Revision: 1.5 $
 */
public class SoapMessageMarshalerTest extends TestCase {

	private static final Log log = LogFactory.getLog(SoapMessageMarshalerTest.class);
	
	private SourceTransformer sourceTransformer = new SourceTransformer();
	
	public void testReadNonSoapMessage() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(false);
		SoapMessage msg = marshaler.createReader().read(getClass().getResourceAsStream("soap.xml"));
		assertNotNull(msg);
		assertFalse(msg.hasAttachments());
		assertFalse(msg.hasHeaders());
		assertNotNull(msg.getSource());
		Node node = sourceTransformer.toDOMNode(msg.getSource());
		checkServiceNameNamespace(node);
		checkUserIdNamespace(node);
	}
	
	public void testWriteAndReadNonSoapMessage() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(false);
		SoapMessage msg = new SoapMessage();
		msg.setSource(new StreamSource(getClass().getResourceAsStream("soap.xml")));
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		marshaler.createWriter(msg).write(baos);
		log.info(baos.toString());
		
		SoapMessage msg2 = marshaler.createReader().read(new ByteArrayInputStream(baos.toByteArray()));
		assertNotNull(msg2);
		assertFalse(msg2.hasAttachments());
		assertFalse(msg2.hasHeaders());
		assertNotNull(msg2.getSource());
		Node node = sourceTransformer.toDOMNode(msg2.getSource());
		checkServiceNameNamespace(node);
		checkUserIdNamespace(node);
	}
	
	public void testWriteAndReadNonSoapMessageWithAttachments() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(false);
		SoapMessage msg = new SoapMessage();
		msg.setSource(new StreamSource(getClass().getResourceAsStream("soap.xml")));
		msg.addAttachment("servicemix.jpg", new DataHandler(new FileDataSource(new File(new URI(getClass().getResource("servicemix.jpg").toString())))));
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		SoapWriter writer = marshaler.createWriter(msg);
		writer.write(baos);
		log.info(baos.toString());
		
		SoapMessage msg2 = marshaler.createReader().read(new ByteArrayInputStream(baos.toByteArray()), writer.getContentType());
		assertNotNull(msg2);
		assertTrue(msg2.hasAttachments());
		assertEquals(1, msg2.getAttachments().size());
        DataHandler handler1 = (DataHandler) msg.getAttachments().get(msg.getAttachments().keySet().iterator().next());
		DataHandler handler2 = (DataHandler) msg2.getAttachments().get(msg2.getAttachments().keySet().iterator().next());
        assertNotNull(handler2);
        InputStream is1 = handler1.getInputStream();
        InputStream is2 = handler2.getInputStream();
        ByteArrayOutputStream baos1 = new ByteArrayOutputStream();
        ByteArrayOutputStream baos2 = new ByteArrayOutputStream();
        FileUtil.copyInputStream(is1, baos1);
        FileUtil.copyInputStream(is2, baos2);
        assertEquals(baos1.toString(), baos2.toString());
		assertFalse(msg2.hasHeaders());
		assertNotNull(msg2.getSource());
		Node node = sourceTransformer.toDOMNode(msg2.getSource());
		checkServiceNameNamespace(node);
		checkUserIdNamespace(node);
	}
	
	public void testWriteNonSoapMessageWithHeaders() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(false);
		SoapMessage msg = new SoapMessage();
		msg.addHeader(new QName("test"), null);
		msg.setSource(null);
		try {
			marshaler.createWriter(msg).write(new ByteArrayOutputStream());
			fail("Exception should have been thrown");
		} catch (Exception e) {
			// ok
		}
	}
	
	public void testSoapMessage() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(true);
		
		SoapMessage msg = marshaler.createReader().read(getClass().getResourceAsStream("soap.xml"));
		assertNotNull(msg);
		assertFalse(msg.hasAttachments());
		assertTrue(msg.hasHeaders());
		assertNotNull(msg.getSource());
		
		Iterator headers = msg.getHeaders().values().iterator();
        checkHeadersForServiceName(headers);

        Node node2 = sourceTransformer.toDOMNode(msg.getSource()); 
        checkUserIdNamespace(node2);
        
        msg.setSource(new DOMSource(node2));
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        marshaler.createWriter(msg).write(baos);
        Node node = sourceTransformer.toDOMNode(new BytesSource(baos.toByteArray()));
        checkUserIdNamespace(node);
	}
    
    public void testSoapMessage2() throws Exception {
        SoapMarshaler marshaler = new SoapMarshaler(true);
        SoapMessage msg = marshaler.createReader().read(getClass().getResourceAsStream("soap2.xml"));
        assertNotNull(msg);
    }
    
    public void testSoap11Message() throws Exception {
        SoapMarshaler marshaler = new SoapMarshaler(true);
        marshaler.setSoapUri(SoapMarshaler.SOAP_11_URI);
        SoapMessage msg = new SoapMessage();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        marshaler.createWriter(msg).write(baos);
        Node node = sourceTransformer.toDOMNode(new BytesSource(baos.toByteArray()));
        assertNotNull(node);
        Element root = ((Document) node).getDocumentElement();
        assertEquals(SoapMarshaler.SOAP_11_URI, root.getNamespaceURI());
    }
    
	public void testWriteAndReadSoapMessageWithAttachments() throws Exception {
		SoapMarshaler marshaler = new SoapMarshaler(true);
		SoapMessage msg = marshaler.createReader().read(getClass().getResourceAsStream("soap.xml"));
		msg.addAttachment("servicemix.jpg", new DataHandler(new FileDataSource(new File(new URI(getClass().getResource("servicemix.jpg").toString())))));
		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		SoapWriter writer = marshaler.createWriter(msg);
		writer.write(baos);
		log.info(baos.toString());
		
		SoapMessage msg2 = marshaler.createReader().read(new ByteArrayInputStream(baos.toByteArray()), writer.getContentType());
		assertNotNull(msg2);
		assertTrue(msg2.hasAttachments());
		assertEquals(1, msg2.getAttachments().size());
		DataHandler handler = (DataHandler) msg2.getAttachments().get(msg2.getAttachments().keySet().iterator().next());
		assertNotNull(handler);
		assertNotNull(msg2.getSource());
        checkUserIdNamespace(sourceTransformer.toDOMNode(msg2.getSource()));
		assertTrue(msg2.hasHeaders());
		Iterator headers = msg2.getHeaders().values().iterator();
        checkHeadersForServiceName(headers);
    }

    public void testReadNonSoapMessageWithAttachmentsAndNoSource()  throws Exception {
        Session session = Session.getDefaultInstance(new Properties(), null);
        MimeMessage message = new MimeMessage(session);
        MimeMultipart multipart = new MimeMultipart();
        MimeBodyPart mimePart = new MimeBodyPart();
        mimePart.setText("This is a dummy text");
        mimePart.setContentID("<bla1>");
        multipart.addBodyPart(mimePart);
        mimePart = new MimeBodyPart();
        mimePart.setContentID("<bla2>");
        mimePart.setContent("<html>dummy</html>", "text/html");
        multipart.addBodyPart(mimePart);
        message.setContent(multipart);
        message.setHeader("Content-Type", multipart.getContentType());
        message.saveChanges();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        message.writeTo(baos);
        log.info(baos.toString());
        
        SoapMarshaler marshaler = new SoapMarshaler(true);
        SoapMessage msg = marshaler.createReader().read(new ByteArrayInputStream(baos.toByteArray()), multipart.getContentType());
        assertTrue(msg.getSource().equals(SoapReader.EMPTY_CONTENT));
        SoapWriter writer = marshaler.createWriter(msg);
        baos = new ByteArrayOutputStream();
        writer.write(baos);
        log.info(baos.toString());
    }

    private void checkHeadersForServiceName(Iterator headers) throws Exception {
        CachedXPathAPI cachedXPathAPI = new CachedXPathAPI();
        boolean foundServiceNameNode = false;
        int headerCount = 0;
        while (headers.hasNext()) {
            headerCount++;
            DocumentFragment df = (DocumentFragment)headers.next();
            Element root = (Element)(cachedXPathAPI.selectNodeIterator(df, "//*[local-name() = 'ServiceName']").nextNode());
            if (root != null) {
                foundServiceNameNode = true;
                checkServiceNameNamespace(df);
            }
        }
        assertTrue(foundServiceNameNode);
        assertEquals(headerCount, 2);
    }

    protected void checkUserIdNamespace(Node node) throws Exception {
        CachedXPathAPI cachedXPathAPI = new CachedXPathAPI(); 
        NodeIterator iterator = cachedXPathAPI.selectNodeIterator(node, "//*[local-name() = 'userId']"); 
        Element root = (Element) iterator.nextNode(); 
        QName qname = DOMUtil.createQName(root, root.getAttributeNS("http://www.w3.org/2001/XMLSchema-instance", "type")); 
        assertEquals("http://www.w3.org/2001/XMLSchema", qname.getNamespaceURI()); 
        assertEquals("string", qname.getLocalPart()); 
	}
	
	protected void checkServiceNameNamespace(Node node) throws Exception {
        CachedXPathAPI cachedXPathAPI = new CachedXPathAPI(); 
        NodeIterator iterator = cachedXPathAPI.selectNodeIterator(node, "//*[local-name() = 'ServiceName']"); 
        Element root = (Element) iterator.nextNode(); 
        assertEquals(new QName("http://schemas.xmlsoap.org/ws/2003/03/addressing", "ServiceName"), 
        		     new QName(root.getNamespaceURI(), root.getLocalName()));
        QName qname = DOMUtil.createQName(root, DOMUtil.getElementText(root)); 
        assertEquals(new QName("uri:test", "MyConsumerService"), qname); 
	}
    
}
