/**
    * This file Copyright (c) 2003-2011 Magnolia International
    * Ltd.  (http://www.magnolia-cms.com). All rights reserved.
    *
    *
    * This file is dual-licensed under both the Magnolia
    * Network Agreement and the GNU General Public License.
    * You may elect to use one or the other of these licenses.
    *
   * This file is distributed in the hope that it will be
   * useful, but AS-IS and WITHOUT ANY WARRANTY; without even the
   * implied warranty of MERCHANTABILITY or FITNESS FOR A
   * PARTICULAR PURPOSE, TITLE, or NONINFRINGEMENT.
   * Redistribution, except as permitted by whichever of the GPL
   * or MNA you select, is prohibited.
   *
   * 1. For the GPL license (GPL), you can redistribute and/or
   * modify this file under the terms of the GNU General
   * Public License, Version 3, as published by the Free Software
   * Foundation.  You should have received a copy of the GNU
   * General Public License, Version 3 along with this program;
   * if not, write to the Free Software Foundation, Inc., 51
   * Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
   *
   * 2. For the Magnolia Network Agreement (MNA), this file
   * and the accompanying materials are made available under the
   * terms of the MNA which accompanies this distribution, and
   * is available at http://www.magnolia-cms.com/mna.html
   *
   * Any modifications to this file must keep this entire header
   * intact.
   *
   */
  package info.magnolia.module.exchangesimple;
  
  import info.magnolia.cms.beans.config.ContentRepository;
  import info.magnolia.cms.core.Content;
  import info.magnolia.cms.core.HierarchyManager;
  import info.magnolia.cms.core.ItemType;
  import info.magnolia.cms.core.MetaData;
  import info.magnolia.cms.core.Path;
  import info.magnolia.cms.core.SystemProperty;
  import info.magnolia.cms.core.version.ContentVersion;
  import info.magnolia.cms.exchange.ExchangeException;
  import info.magnolia.cms.exchange.Subscriber;
  import info.magnolia.cms.exchange.Subscription;
  import info.magnolia.cms.exchange.Syndicator;
  import info.magnolia.cms.security.AccessDeniedException;
  import info.magnolia.cms.security.User;
  import info.magnolia.cms.util.ContentUtil;
  import info.magnolia.cms.util.Rule;
  import info.magnolia.cms.util.RuleBasedContentFilter;
  import info.magnolia.context.MgnlContext;
  import info.magnolia.logging.AuditLoggingUtil;
  
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.FileOutputStream;
  import java.io.IOException;
  import java.io.OutputStream;
  import java.io.UnsupportedEncodingException;
  import java.net.HttpURLConnection;
  import java.net.MalformedURLException;
  import java.net.URL;
  import java.net.URLConnection;
  import java.net.URLEncoder;
  import java.util.Iterator;
  import java.util.List;
  import java.util.zip.GZIPOutputStream;
  
  import javax.jcr.RepositoryException;
  import javax.jcr.Session;
  
  import org.apache.commons.codec.binary.Base64;
  import org.apache.commons.io.IOUtils;
  import org.apache.commons.lang.StringUtils;
  import org.apache.xml.serialize.OutputFormat;
  import org.apache.xml.serialize.XMLSerializer;
  import org.jdom.Document;
  import org.jdom.Element;
  import org.jdom.output.XMLOutputter;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.xml.sax.InputSource;
  import org.xml.sax.SAXException;
  import org.xml.sax.XMLReader;
  import org.xml.sax.helpers.XMLReaderFactory;
  
  import EDU.oswego.cs.dl.util.concurrent.Sync;
  
  /**
   * Default implementation of {@link Syndicator}. Activates all the content to a subscriber configured on the server.
   * @author Sameer Charles
   * $Id: $
   */
  public abstract class BaseSyndicatorImpl implements Syndicator {
      private static final Logger log = LoggerFactory.getLogger(BaseSyndicatorImpl.class);
  
      /**
      * URI used for activation.
      */
     public static final String DEFAULT_HANDLER = ".magnolia/activation"; //$NON-NLS-1$
 
     public static final String PARENT_PATH = "mgnlExchangeParentPath";
 
     public static final String MAPPED_PARENT_PATH = "mgnlExchangeMappedParent";
 
     /**
      * Path to be activated or deactivated.
      */
     public static final String PATH = "mgnlExchangePath";
 
     public static final String NODE_UUID = "mgnlExchangeNodeUUID";
 
     public static final String REPOSITORY_NAME = "mgnlExchangeRepositoryName";
 
     public static final String WORKSPACE_NAME = "mgnlExchangeWorkspaceName";
 
     public static final String VERSION_NAME = "mgnlExchangeVersionName";
 
     /**
      * Name of the resource containing reading sequence for importing the data in activation target.
      */
     public static final String RESOURCE_MAPPING_FILE = "mgnlExchangeResourceMappingFile";
 
     public static final String UTF8_STATUS = "mgnlUTF8Status";
 
     /**
      * Name of the element in the resource file describing siblings of activated node.
      * Siblings element will contain all siblings of the same node type which are "before"
      * this node.
      */
     public static final String SIBLINGS_ROOT_ELEMENT = "NodeSiblings";
 
     public static final String SIBLINGS_ELEMENT = "sibling";
 
     public static final String SIBLING_UUID = "siblingUUID";
 
     public static final String RESOURCE_MAPPING_FILE_ELEMENT = "File";
 
     public static final String RESOURCE_MAPPING_NAME_ATTRIBUTE = "name";
 
     public static final String RESOURCE_MAPPING_UUID_ATTRIBUTE = "contentUUID";
 
     public static final String RESOURCE_MAPPING_ID_ATTRIBUTE = "resourceId";
 
     public static final String RESOURCE_MAPPING_ROOT_ELEMENT = "Resources";
 
     public static final String ACTION = "mgnlExchangeAction";
 
     public static final String ACTIVATE = "activate"; //$NON-NLS-1$
 
     public static final String DEACTIVATE = "deactivate"; //$NON-NLS-1$
 
     public static final String COMMIT = "commit";
 
     public static final String ROLLBACK = "rollback";
 
     public static final String AUTHORIZATION = "Authorization";
 
     public static final String AUTH_CREDENTIALS= "mgnlUserPSWD";
 
     public static final String AUTH_USER = "mgnlUserId";
 
     public static final String CONTENT_FILTER_RULE = "mgnlExchangeFilterRule";
 
     public static final String ACTIVATION_SUCCESSFUL = "sa_success"; //$NON-NLS-1$
 
     public static final String ACTIVATION_FAILED = "sa_failed"; //$NON-NLS-1$
 
     public static final String ACTIVATION_ATTRIBUTE_STATUS = "sa_attribute_status"; //$NON-NLS-1$
 
     public static final String ACTIVATION_ATTRIBUTE_MESSAGE = "sa_attribute_message"; //$NON-NLS-1$
 
     public static final String ACTIVATION_ATTRIBUTE_VERSION = "sa_attribute_version"; //$NON-NLS-1$
 
     /**
      * Runs a given job in the thread pool.
      *
      * @param job the job to run
      * @throws ExchangeException if the job could not be put in the pool
      */
     protected static void executeInPool(Runnable job) throws ExchangeException {
         try {
             ThreadPool.getInstance().execute(job);
         } catch (InterruptedException e) {
             // this is kind of a problem, we could not add the job to the pool
             // retrying might or might not work now that the interruption
             // status is cleared but there is not much we can do so throwing
             // an ExchangeException seems like the least bad choice
             String message = "could not execute job in pool";
             log.error(message, e);
             throw new ExchangeException(message, e);
         }
     }
 
     /**
      * Acquires a {@link Sync} ignoring any interruptions. Should any
      * interruption occur the interruption status will be set. Might
      * potentially block/wait forever.
      *
      * @see Sync#acquire()
      *
      * @param latch the latch on which to wait
      */
     protected static void acquireIgnoringInterruption(Sync latch) {
         try {
             latch.acquire();
         } catch (InterruptedException e) {
             // waken up externally - ignore try again
             acquireIgnoringInterruption(latch);
             // be a good citizen and set back the interruption status
             Thread.currentThread().interrupt();
         }
     }
 
     protected String repositoryName;
 
     protected String workspaceName;
 
     protected String parent;
 
     protected Content.ContentFilter contentFilter;
 
     protected Rule contentFilterRule;
 
     protected User user;
 
     protected String basicCredentials;
 
     /**
      * @param user
      * @param repositoryName repository ID
      * @param workspaceName workspace ID
      * @param rule content filter rule
      * @see info.magnolia.cms.exchange.Syndicator#init(info.magnolia.cms.security.User, String, String,
      * info.magnolia.cms.util.Rule)
      */
     public void init(User user, String repositoryName, String workspaceName, Rule rule) {
         this.user = user;
         this.basicCredentials = "Basic "
             + new String(Base64.encodeBase64((this.user.getName() + ":" + this.user.getPassword()).getBytes()));
         this.contentFilter = new RuleBasedContentFilter(rule);
         this.contentFilterRule = rule;
         this.repositoryName = repositoryName;
         this.workspaceName = workspaceName;
     }
 
     /**
      * This will activate specifies page (sub pages) to all configured subscribers.
      *
      * @param parent parent under which this page will be activated
      * @param content to be activated
      * @throws javax.jcr.RepositoryException
      * @throws info.magnolia.cms.exchange.ExchangeException
      */
     public void activate(String parent, Content content) throws ExchangeException, RepositoryException {
         this.activate(parent, content, null);
     }
 
     /**
      * This will activate specified node to all configured subscribers.
      *
      * @param parent parent under which this page will be activated
      * @param content to be activated
      * @param orderBefore List of UUID to be used by the implementation to order this node after activation
      * @throws javax.jcr.RepositoryException
      * @throws info.magnolia.cms.exchange.ExchangeException
      *
      */
     public void activate(String parent, Content content, List<String> orderBefore) throws ExchangeException, RepositoryException {
         this.activate(null, parent, content, orderBefore);
     }
 
     /**
      * This will activate specifies page (sub pages) to the specified subscriber.
      *
      * @param subscriber
      * @param parent parent under which this page will be activated
      * @param content to be activated
      * @throws javax.jcr.RepositoryException
      * @throws info.magnolia.cms.exchange.ExchangeException
      */
     public void activate(Subscriber subscriber, String parent, Content content) throws ExchangeException, RepositoryException {
         this.activate(subscriber, parent, content, null);
     }
 
     /**
      * This will activate specifies node to the specified subscriber.
      *
      * @param subscriber
      * @param parent      parent under which this page will be activated
      * @param content     to be activated
      * @param orderBefore List of UUID to be used by the subscriber to order this node after activation
      * @throws javax.jcr.RepositoryException
      * @throws info.magnolia.cms.exchange.ExchangeException
      */
     public void activate(Subscriber subscriber, String parent, Content content, List<String> orderBefore) throws ExchangeException, RepositoryException {
         this.parent = parent;
         String path = content.getHandle();
 
         ActivationContent activationContent = null;
         try {
             activationContent = this.collect(content, orderBefore);
             if (null == subscriber) {
                 this.activate(activationContent, path);
             } else {
                 this.activate(subscriber, activationContent, path);
             }
             if (Boolean.parseBoolean(activationContent.getproperty(ItemType.DELETED_NODE_MIXIN))) {
                 final HierarchyManager hm = content.getHierarchyManager();
                 String uuid = content.getUUID();
                 if (StringUtils.isNotBlank(uuid)) {
                     if (content instanceof ContentVersion) {
                         // replace versioned content with the real node
                         content = hm.getContentByUUID(uuid);
                     }
                     Content parentContent = content.getParent();
                     content.delete();
                     parentContent.save();
                 } else {
                     log.warn("Content {}:{} was already removed.", new String[] {hm.getName(), path});
                 }
             } else {
                 this.updateActivationDetails(path);
             }
             log.info("Exchange: activation succeeded [{}]", path);
         } catch (Exception e) {
             if (log.isDebugEnabled()) {
                 log.error("Exchange: activation failed for path:" + ((path != null) ? path : "[null]"), e);
                 long timestamp = System.currentTimeMillis();
                 log.warn("moving files from failed activation to *.failed" + timestamp );
                 Iterator<File> keys = activationContent.getFiles().values().iterator();
                 while (keys.hasNext()) {
                     File f = keys.next();
                     f.renameTo(new File(f.getAbsolutePath()+".failed" + timestamp));
                 }
                 activationContent.getFiles().clear();
 
             }
             throw new ExchangeException(e);
         } finally {
             log.debug("Cleaning temporary files");
             cleanTemporaryStore(activationContent);
         }
     }
 
     /**
      * @throws ExchangeException
      */
     public abstract void activate(ActivationContent activationContent, String nodePath) throws ExchangeException;
 
 
     /**
      * Send request of activation of activationContent to the subscriber. Subscriber might choose not to react if it is not subscribed to the URI under which activationContent exists.
      */
     public String activate(Subscriber subscriber, ActivationContent activationContent, String nodePath) throws ExchangeException {
         // FYI: this method is invoked from multiple threads at a same time (one for each subscriber, activationContent is assumed to be NOT shared between threads (cloned or by other means replicated) )
         log.debug("activate");
         if (null == subscriber) {
             throw new ExchangeException("Null Subscriber");
         }
 
         String parentPath = null;
 
         // concurrency: from path and repo name are same for all subscribers
         Subscription subscription = subscriber.getMatchedSubscription(nodePath, this.repositoryName);
         if (null != subscription) {
             // its subscribed since we found the matching subscription
             parentPath = this.getMappedPath(this.parent, subscription);
             activationContent.setProperty(PARENT_PATH, parentPath);
         } else {
             log.debug("Exchange : subscriber [{}] is not subscribed to {}", subscriber.getName(), nodePath);
             return "not subscribed";
         }
         log.debug("Exchange : sending activation request to {} with user {}", subscriber.getName(), this.user.getName());
 
         URLConnection urlConnection = null;
         String versionName = null;
         try {
             urlConnection = prepareConnection(subscriber, getActivationURL(subscriber));
             this.addActivationHeaders(urlConnection, activationContent);
 
             Transporter.transport((HttpURLConnection) urlConnection, activationContent);
 
             String status = urlConnection.getHeaderField(ACTIVATION_ATTRIBUTE_STATUS);
             versionName = urlConnection.getHeaderField(ACTIVATION_ATTRIBUTE_VERSION);
 
             // check if the activation failed
             if (StringUtils.equals(status, ACTIVATION_FAILED)) {
                 String message = urlConnection.getHeaderField(ACTIVATION_ATTRIBUTE_MESSAGE);
                 throw new ExchangeException("Message received from subscriber: " + message);
             }
             urlConnection.getContent();
             log.debug("Exchange : activation request sent to {}", subscriber.getName());
         }
         catch (ExchangeException e) {
             throw e;
         }
         catch (IOException e) {
             log.debug("Failed to transport following activated content {" + StringUtils.join(activationContent.getProperties().keySet().iterator(), ',') + "} due to " + e.getMessage(), e);
             String url = (urlConnection == null ? null : urlConnection.getURL().toString());
             url = stripPasswordFromUrl(url);
             // hide pwd if present
             throw new ExchangeException("Not able to send the activation request [" + url + "]: " + e.getMessage(), e);
         }
         catch (Exception e) {
             throw new ExchangeException(e);
         }
         return versionName;
     }
 
     protected static String stripPasswordFromUrl(String escapedUrl) {
         if (escapedUrl != null) {
             int idx = escapedUrl.indexOf("mgnlUserPSWD");
             if (idx > 0) {
                 int endIdx = escapedUrl.indexOf("&", idx);
                 if (endIdx > 0) {
                     escapedUrl = escapedUrl.substring(0, idx) + escapedUrl.substring(endIdx + 1);
                 } else {
                     escapedUrl = escapedUrl.substring(0, idx - 1);
                 }
             }
         }
         return escapedUrl;
     }
 
 
     /**
      * Cleans up temporary file store after activation.
      */
     protected void cleanTemporaryStore(ActivationContent activationContent) {
         if (activationContent == null) {
             log.debug("Clean temporary store - nothing to do");
             return;
         }
         if (log.isDebugEnabled()) {
             log.debug("Debugging is enabled. Keeping temporary files in store for debugging purposes. Clean the store manually once done with debugging.");
             return;
         }
 
         Iterator<String> keys = activationContent.getFiles().keySet().iterator();
         while (keys.hasNext()) {
             String key = keys.next();
             log.debug("Removing temporary file {}", key);
             activationContent.getFile(key).delete();
         }
     }
 
     public synchronized void deactivate(String path) throws ExchangeException, RepositoryException {
         final Content node = getHierarchyManager().getContent(path);
         deactivate(node);
     }
 
     /**
      * @param node to deactivate
      * @throws RepositoryException
      * @throws ExchangeException
      */
     public synchronized void deactivate(Content node) throws ExchangeException, RepositoryException {
         String nodeUUID = node.getUUID();
         String path = node.getHandle();
         this.doDeactivate(nodeUUID, path);
         updateDeactivationDetails(nodeUUID);
     }
 
     /**
      * @param node , to deactivate
      * @param subscriber
      * @throws RepositoryException
      * @throws ExchangeException
      */
     public synchronized void deactivate(Subscriber subscriber, Content node) throws ExchangeException, RepositoryException {
         String nodeUUID = node.getUUID();
         String path = node.getHandle();
         this.doDeactivate(subscriber, nodeUUID, path);
         updateDeactivationDetails(nodeUUID);
     }
 
     /**
      * @throws ExchangeException
      */
     public abstract void doDeactivate(String nodeUUID, String nodePath) throws ExchangeException;
 
     /**
      * Deactivate content from specified subscriber.
      * @param subscriber
      * @throws ExchangeException
      */
     public abstract String doDeactivate(Subscriber subscriber, String nodeUUID, String nodePath) throws ExchangeException;
 
     /**
      * Return URI set for deactivation.
      * @param subscriberInfo
      */
     protected String getDeactivationURL(Subscriber subscriberInfo) {
         return getActivationURL(subscriberInfo);
     }
 
     /**
      * Adds header fields describing deactivation request.
      * @param connection
      */
     protected void addDeactivationHeaders(URLConnection connection, String nodeUUID) {
         connection.addRequestProperty(REPOSITORY_NAME, this.repositoryName);
         connection.addRequestProperty(WORKSPACE_NAME, this.workspaceName);
         if (nodeUUID != null) {
             connection.addRequestProperty(NODE_UUID, nodeUUID);
         }
         connection.addRequestProperty(ACTION, DEACTIVATE);
     }
 
     /**
      * Retrieves URL subscriber is listening on for (de)activation requests.
      */
     protected String getActivationURL(Subscriber subscriberInfo) {
         final String url = subscriberInfo.getURL();
         if (!url.endsWith("/")) {
             return url + "/" + DEFAULT_HANDLER;
         }
         return url + DEFAULT_HANDLER;
     }
 
     /**
      * Adds headers fields describing activation request.
      */
     protected void addActivationHeaders(URLConnection connection, ActivationContent activationContent) {
         Iterator<String> headerKeys = activationContent.getProperties().keySet().iterator();
         while (headerKeys.hasNext()) {
             String key = headerKeys.next();
             String value = activationContent.getproperty(key);
             if(SystemProperty.getBooleanProperty(SystemProperty.MAGNOLIA_UTF8_ENABLED)) {
                 try {
                     value = URLEncoder.encode(value, "UTF-8");
                 }
                 catch (UnsupportedEncodingException e) {
                     // do nothing
                 }
             }
             connection.setRequestProperty(key, value);
         }
     }
 
     /**
      * Updates current content activation meta data with the time stamp and user details of the activation.
      */
     protected void updateActivationDetails(String path) throws RepositoryException {
         // page activated already use system context to ensure meta data is activated even if activating user has no rights to the activated page children
         Content page = getSystemHierarchyManager().getContent(path);
         updateMetaData(page, ACTIVATE);
         page.save();
         AuditLoggingUtil.log(AuditLoggingUtil.ACTION_ACTIVATE, this.workspaceName, page.getItemType(), path );
     }
 
     /**
      * Updates current content activation meta data with the timestamp and user details of the deactivation.
      */
     protected void updateDeactivationDetails(String nodeUUID) throws RepositoryException {
         // page deactivated already use system context to ensure meta data is activated even if activating user has no rights to the activated page children
         Content page = getSystemHierarchyManager().getContentByUUID(nodeUUID);
         updateMetaData(page, DEACTIVATE);
         page.save();
         AuditLoggingUtil.log(AuditLoggingUtil.ACTION_DEACTIVATE, this.workspaceName, page.getItemType(), page.getHandle() );
     }
 
 
     private HierarchyManager getHierarchyManager() {
         return MgnlContext.getHierarchyManager(this.repositoryName, this.workspaceName);
     }
 
     private HierarchyManager getSystemHierarchyManager() {
         return MgnlContext.getSystemContext().getHierarchyManager(this.repositoryName, this.workspaceName);
     }
 
     /**
      * @param node
      * @param type (activate / deactivate)
      */
     protected void updateMetaData(Content node, String type) throws AccessDeniedException {
         // update the passed node
         MetaData md = node.getMetaData();
         if (type.equals(ACTIVATE)) {
             md.setActivated();
         }
         else {
             md.setUnActivated();
         }
         md.setActivatorId(this.user.getName());
         md.setLastActivationActionDate();
 
         Iterator<Content> children;
         if (type.equals(ACTIVATE)) {
             // use syndicator rule based filter
             children = node.getChildren(this.contentFilter).iterator();
         }
         else {
             // all children
             children = node.getChildren(ContentUtil.EXCLUDE_META_DATA_CONTENT_FILTER).iterator();
         }
 
         while (children.hasNext()) {
             Content child = children.next();
             this.updateMetaData(child, type);
         }
 
 
     }
 
     /**
      * Collects all information about activated content and its children (those that are set to be activated with the parent by filter rules).
      * @throws Exception
      */
     protected ActivationContent collect(Content node, List<String> orderBefore) throws Exception {
         // make sure resource file is unique
         File resourceFile = File.createTempFile("resources", ".xml", Path.getTempDirectory());
 
         ActivationContent activationContent = new ActivationContent();
         // add global properties true for this path/hierarchy
         activationContent.addProperty(PARENT_PATH, this.parent);
         activationContent.addProperty(WORKSPACE_NAME, this.workspaceName);
         activationContent.addProperty(REPOSITORY_NAME, this.repositoryName);
         activationContent.addProperty(RESOURCE_MAPPING_FILE, resourceFile.getName());//"resources.xml");
         activationContent.addProperty(ACTION, ACTIVATE);
         activationContent.addProperty(CONTENT_FILTER_RULE, this.contentFilterRule.toString());
         activationContent.addProperty(NODE_UUID, node.getUUID());
         activationContent.addProperty(UTF8_STATUS, SystemProperty.getProperty(SystemProperty.MAGNOLIA_UTF8_ENABLED));
 
 
         Document document = new Document();
         Element root = new Element(RESOURCE_MAPPING_ROOT_ELEMENT);
         document.setRootElement(root);
         // collect exact order of this node within its same nodeType siblings
         addOrderingInfo(root, orderBefore);
 
         this.addResources(root, node.getWorkspace().getSession(), node, this.contentFilter, activationContent);
         XMLOutputter outputter = new XMLOutputter();
         outputter.output(document, new FileOutputStream(resourceFile));
         // add resource file to the list
         activationContent.addFile(resourceFile.getName(), resourceFile);
 
         // add deletion info
         activationContent.addProperty(ItemType.DELETED_NODE_MIXIN, "" + node.hasMixin(ItemType.DELETED_NODE_MIXIN));
 
         return activationContent;
     }
 
     /**
      * Adds ordering information to the resource mapping file.
      * @param root element of the resource file under which ordering info must be added
      * @param orderBefore
      */
     protected void addOrderingInfo(Element root, List<String> orderBefore) {
         //do not use magnolia Content class since these objects are only meant for a single use to read UUID
         Element siblingRoot = new Element(SIBLINGS_ROOT_ELEMENT);
         root.addContent(siblingRoot);
         if (orderBefore == null) {
             return;
         }
         Iterator<String> siblings = orderBefore.iterator();
         while (siblings.hasNext()) {
             String uuid = siblings.next();
             Element e = new Element(SIBLINGS_ELEMENT);
             e.setAttribute(SIBLING_UUID, uuid);
             siblingRoot.addContent(e);
         }
     }
 
     protected void addResources(Element resourceElement, Session session, final Content content, Content.ContentFilter filter, ActivationContent activationContent) throws IOException, RepositoryException, SAXException, Exception {
         final String workspaceName = content.getWorkspace().getName();
         log.debug("Preparing content {}:{} for publishing.", new String[] {workspaceName, content.getHandle()});
         final String uuid = content.getUUID();
 
         File file = File.createTempFile("exchange_" + uuid, ".xml.gz", Path.getTempDirectory());
         GZIPOutputStream gzipOutputStream = new GZIPOutputStream(new FileOutputStream(file));
 
         // TODO: remove the second check. It should not be necessary. The only safe way to identify the versioned node is by looking at its type since the type is mandated by spec. and the frozen nodes is what the filter below removes anyway
         if (content.isNodeType("nt:frozenNode") || workspaceName.equals(ContentRepository.VERSION_STORE)) {
             XMLReader elementfilter = new FrozenElementFilter(XMLReaderFactory
                     .createXMLReader(org.apache.xerces.parsers.SAXParser.class.getName()));
             ((FrozenElementFilter) elementfilter).setNodeName(content.getName());
             /**
              * nt:file node type has mandatory sub nodes
              */
             boolean noRecurse = !content.isNodeType(ItemType.NT_FILE);
             exportAndParse(session, content, elementfilter, gzipOutputStream, noRecurse);
         } else {
             /**
              * nt:file node type has mandatory sub nodes
              */
             if (content.isNodeType(ItemType.NT_FILE)) {
                 session.exportSystemView(content.getJCRNode().getPath(), gzipOutputStream, false, false);
             } else {
                 session.exportSystemView(content.getJCRNode().getPath(), gzipOutputStream, false, true);
             }
         }
 
         IOUtils.closeQuietly(gzipOutputStream);
         // add file entry in mapping.xml
         Element element = new Element(RESOURCE_MAPPING_FILE_ELEMENT);
         element.setAttribute(RESOURCE_MAPPING_NAME_ATTRIBUTE, content.getName());
         element.setAttribute(RESOURCE_MAPPING_UUID_ATTRIBUTE, uuid);
         element.setAttribute(RESOURCE_MAPPING_ID_ATTRIBUTE, file.getName());
         resourceElement.addContent(element);
         // add this file element as resource in activation content
         activationContent.addFile(file.getName(), file);
 
         Iterator<Content> children = content.getChildren(filter).iterator();
         while (children.hasNext()) {
             Content child = children.next();
             this.addResources(element, session, child, filter, activationContent);
         }
     }
 
     protected void exportAndParse(Session session, Content content, XMLReader elementfilter, OutputStream os, boolean noRecurse) throws Exception {
         File tempFile = File.createTempFile("Frozen_"+content.getName(), ".xml"); //$NON-NLS-1$ //$NON-NLS-2$
         OutputStream tmpFileOutStream = null;
         FileInputStream tmpFileInStream = null;
         try {
             tmpFileOutStream = new FileOutputStream(tempFile);
             // has to get path via JCR node since if "content" is of type ContentVersion, getHandle() call would have returned path to the base
             session.exportSystemView(content.getJCRNode().getPath(), tmpFileOutStream, false, noRecurse);
             tmpFileOutStream.flush();
             tmpFileOutStream.close();
 
             OutputFormat outputFormat = new OutputFormat();
             outputFormat.setPreserveSpace(false);
 
             tmpFileInStream = new FileInputStream(tempFile);
             elementfilter.setContentHandler(new XMLSerializer(os, outputFormat));
             elementfilter.parse(new InputSource(tmpFileInStream));
             tmpFileInStream.close();
         } catch (Throwable t) {
             log.error("Failed to parse XML using FrozenElementFilter",t);
             throw new Exception(t);
         } finally {
             IOUtils.closeQuietly(tmpFileInStream);
             IOUtils.closeQuietly(tmpFileOutStream);
             tempFile.delete();
         }
     }
 
     /**
      * Gets target path to which the current path is mapped in given subscription. Provided path should be without trailing slash.
      */
     protected String getMappedPath(String path, Subscription subscription) {
         String toURI = subscription.getToURI();
         if (null != toURI) {
             String fromURI = subscription.getFromURI();
             // remove trailing slash if any
             fromURI = StringUtils.removeEnd(fromURI, "/");
             toURI = StringUtils.removeEnd(toURI, "/");
             // apply path transformation if any
             path = path.replaceFirst(fromURI, toURI);
             if (path.equals("")) {
                 path = "/";
             }
         }
         return path;
     }
 
     protected URLConnection prepareConnection(Subscriber subscriber, String urlString) throws ExchangeException {
 
         //String handle = getActivationURL(subscriber);
 
         try {
             String authMethod = subscriber.getAuthenticationMethod();
             // authentication headers
             if (authMethod != null && "form".equalsIgnoreCase(authMethod)) {
                 urlString += (urlString.indexOf('?') > 0 ? "&" : "?") + AUTH_USER + "=" + this.user.getName();
                 urlString += "&" + AUTH_CREDENTIALS + "=" + this.user.getPassword();
             }
             URL url = new URL(urlString);
             URLConnection urlConnection = url.openConnection();
             urlConnection.setConnectTimeout(subscriber.getConnectTimeout());
             urlConnection.setReadTimeout(subscriber.getReadTimeout());
             // authentication headers
             if (authMethod == null || "basic".equalsIgnoreCase(authMethod)) {
                 urlConnection.setRequestProperty(AUTHORIZATION, this.basicCredentials);
             } else if (!"form".equalsIgnoreCase(subscriber.getAuthenticationMethod())) {
                 log.info("Unknown Authentication method for deactivation: " + subscriber.getAuthenticationMethod());
             }
 
             return urlConnection;
         } catch (MalformedURLException e) {
             throw new ExchangeException("Incorrect URL for subscriber " + subscriber + "[" + stripPasswordFromUrl(urlString) + "]");
         } catch (IOException e) {
             throw new ExchangeException("Not able to send the activation request [" + stripPasswordFromUrl(urlString) + "]: " + e.getMessage());
         } catch (Exception e) {
             throw new ExchangeException(e);
         }
     }
 
 
 }