/**
    * This file Copyright (c) 2003-2014 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.exchange.ActivationManagerFactory;
  import info.magnolia.cms.exchange.ExchangeException;
  import info.magnolia.cms.exchange.Subscriber;
  import info.magnolia.module.exchangesimple.monitor.ActivationMonitor;
  import info.magnolia.objectfactory.Components;
  
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.OutputStream;
  import java.net.HttpURLConnection;
  import java.util.Collection;
  
  import org.apache.commons.io.IOUtils;
  import org.apache.commons.lang.StringUtils;
  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  /**
   * Class responsible for transport of activated content.
   * 
   * @author Sameer Charles $Id$
   */
  public class Transporter {
  
      private static Logger log = LoggerFactory.getLogger(Transporter.class);
  
      /**
       * Content boundary in the multipart request.
       */
      public static final String BOUNDARY = "mgnlExchange-cfc93688d385";
  
      /**
       * Initiates multipart http post to transport content to the subscriber.
       * 
       * @param connection
       * @param activationContent
       * @throws ExchangeException
       */
      public static void transport(HttpURLConnection connection, ActivationContent activationContent)
              throws ExchangeException {
          File tempFile = null;
          FileInputStream is = null;
          OutputStream os = null;
  
          try {
              tempFile = activationContent.getTempFile();
  
              // The only purpose of the method below is to disable buffering. This makes sense since we use IOUtils.copy to copy the content to the output stream, however method is not available in Java 1.4 and have to be commented out as long as we support it.
              // connection.setFixedLengthStreamingMode((int) tempFile.length());
              connection.setDoOutput(true);
              connection.setDoInput(true);
              connection.setUseCaches(false);
              connection.setRequestProperty("Content-type", "multipart/form-data; boundary=" + BOUNDARY);
              connection.setRequestProperty("Cache-Control", "no-cache");
  
              is = new FileInputStream(tempFile);
              if (tempFile.length() > Integer.MAX_VALUE) {
                  connection.setChunkedStreamingMode(4096);
              }
              else {
                  connection.setFixedLengthStreamingMode((int) tempFile.length());
              }
  
              long start = System.currentTimeMillis();
             os = connection.getOutputStream();
             long end = System.currentTimeMillis();
 
             String subscriberName = null;
             Collection<Subscriber> subscribers = ActivationManagerFactory.getActivationManager().getSubscribers();
             for (Subscriber subscriber : subscribers) {
                 if (subscriber.getURL().equals(StringUtils.substringBefore(connection.getURL().toString(), "/" + BaseSyndicatorImpl.DEFAULT_HANDLER))) {
                     subscriberName = subscriber.getName();
                 }
             }
             ActivationMonitor activationMonitor = Components.getComponent(ActivationMonitor.class);
             activationMonitor.setSubscriberResponseTime(subscriberName, end - start);
 
             IOUtils.copy(is, os);
         } catch (Exception e) {
             String msg = "Simple exchange transport failed: " + e.getMessage();
             log.error(msg, e);
             throw new ExchangeException(msg, e);
         } finally {
             IOUtils.closeQuietly(is);
             IOUtils.closeQuietly(os);
         }
     }
 }