/*
 * This library is part of OpenCms -
 * the Open Source Content Management System
 *
 * Copyright (c) Alkacon Software GmbH & Co. KG (http://www.alkacon.com)
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Public License for more details.
 *
 * For further information about Alkacon Software, please see the
 * company website: http://www.alkacon.com
 *
 * For further information about OpenCms, please see the
 * project website: http://www.opencms.org
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package org.opencms.ade.upload;

import org.opencms.db.CmsDbSqlException;
import org.opencms.db.CmsImportFolder;
import org.opencms.file.CmsFile;
import org.opencms.file.CmsObject;
import org.opencms.file.CmsProperty;
import org.opencms.file.CmsPropertyDefinition;
import org.opencms.file.CmsResource;
import org.opencms.file.CmsResourceFilter;
import org.opencms.file.collectors.A_CmsResourceCollector;
import org.opencms.file.collectors.I_CmsCollectorPostCreateHandler;
import org.opencms.file.types.CmsResourceTypeFolder;
import org.opencms.file.types.CmsResourceTypePlain;
import org.opencms.gwt.shared.CmsUploadRestrictionInfo;
import org.opencms.gwt.shared.I_CmsUploadConstants;
import org.opencms.i18n.CmsMessages;
import org.opencms.json.JSONArray;
import org.opencms.json.JSONException;
import org.opencms.json.JSONObject;
import org.opencms.jsp.CmsJspBean;
import org.opencms.loader.CmsLoaderException;
import org.opencms.lock.CmsLockException;
import org.opencms.main.CmsException;
import org.opencms.main.CmsLog;
import org.opencms.main.OpenCms;
import org.opencms.security.CmsSecurityException;
import org.opencms.util.CmsCollectionsGenericWrapper;
import org.opencms.util.CmsPair;
import org.opencms.util.CmsRequestUtil;
import org.opencms.util.CmsStringUtil;
import org.opencms.util.CmsUUID;

import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.jsp.PageContext;

import org.apache.commons.compress.archivers.zip.ZipArchiveEntry;
import org.apache.commons.compress.archivers.zip.ZipFile;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadBase.FileSizeLimitExceededException;
import org.apache.commons.fileupload.FileUploadBase.SizeLimitExceededException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log;

import com.google.common.collect.HashMultimap;

/**
 * Bean to be used in JSP scriptlet code that provides
 * access to the upload functionality.<p>
 *
 * @since 8.0.0
 */
public class CmsUploadBean extends CmsJspBean {

    /**
     * Supplies an input stream (used by the virus scanning mechanism).
     */
    private interface InputStreamProvider {

        /**
         * Gets the input stream.
         *
         * <p>Don't call this more than once.
         *
         * @return the input stream
         * @throws IOException if something IO related fails
         */
        InputStream getStream() throws IOException;
    }

    /** The default upload timeout. */
    public static final int DEFAULT_UPLOAD_TIMEOUT = 20000;

    /** Key name for the session attribute that stores the id of the current listener. */
    public static final String SESSION_ATTRIBUTE_LISTENER_ID = "__CmsUploadBean.LISTENER";

    /** The log object for this class. */
    private static final Log LOG = CmsLog.getLog(CmsUploadBean.class);

    /** A static map of all listeners. */
    private static Map<CmsUUID, CmsUploadListener> m_listeners = new HashMap<CmsUUID, CmsUploadListener>();

    /** The gwt message bundle. */
    private CmsMessages m_bundle = org.opencms.ade.upload.Messages.get().getBundle();

    /** Signals that the start method is called. */
    private boolean m_called;

    /** A list of the file items to upload. */
    private List<FileItem> m_multiPartFileItems;

    /** The map of parameters read from the current request. */
    private Map<String, String[]> m_parameterMap;

    /** The names by id of the resources that have been created successfully. */
    private HashMap<CmsUUID, String> m_resourcesCreated = new HashMap<CmsUUID, String>();

    /** A CMS context for the root site. */
    private CmsObject m_rootCms;

    /** The virus scanner instance to use for uploads. */
    private I_CmsVirusScanner m_scanner;

    /** The server side upload delay. */
    private int m_uploadDelay;

    /** The upload hook URI. */
    private String m_uploadHook;

    private CmsUploadRestrictionInfo m_uploadRestrictionInfo;

    /** The viruses found while processing the uploads, with the file names as keys. */
    private HashMultimap<String, String> m_viruses = HashMultimap.create();

    /**
     * Constructor, with parameters.<p>
     *
     * @param context the JSP page context object
     * @param req the JSP request
     * @param res the JSP response
     *
     * @throws CmsException if something goes wrong
     */
    public CmsUploadBean(PageContext context, HttpServletRequest req, HttpServletResponse res)
    throws CmsException {

        super();
        init(context, req, res);

        m_rootCms = OpenCms.initCmsObject(getCmsObject());
        m_rootCms.getRequestContext().setSiteRoot("");
        m_uploadRestrictionInfo = OpenCms.getWorkplaceManager().getUploadRestriction().getUploadRestrictionInfo(
            m_rootCms);
        if (OpenCms.getWorkplaceManager().isVirusScannerEnabled()) {
            m_scanner = OpenCms.getWorkplaceManager().getVirusScanner();
        }
    }

    /**
     * Returns the listener for given CmsUUID.<p>
     *
     * @param listenerId the uuid
     *
     * @return the according listener
     */
    public static CmsUploadListener getCurrentListener(CmsUUID listenerId) {

        return m_listeners.get(listenerId);
    }

    /**
     * Returns the VFS path for the given filename and folder.<p>
     *
     * @param cms the cms object
     * @param fileName the filename to combine with the folder
     * @param folder the folder to combine with the filename
     * @param keepFileNames skip file name translation if true
     *
     * @return the VFS path for the given filename and folder
     */
    public static String getNewResourceName(CmsObject cms, String fileName, String folder, boolean keepFileNames) {

        String newResname = CmsResource.getName(fileName.replace('\\', '/'));
        if (!keepFileNames) {
            newResname = cms.getRequestContext().getFileTranslator().translateResource(newResname);
        }
        newResname = folder + newResname;
        return newResname;
    }

    /**
     * Sets the uploadDelay.<p>
     *
     * @param uploadDelay the uploadDelay to set
     */
    public void setUploadDelay(int uploadDelay) {

        m_uploadDelay = uploadDelay;
    }

    /**
     * Starts the upload.<p>
     *
     * @return the response String (JSON)
     */
    public String start() {

        // ensure that this method can only be called once
        if (m_called) {
            throw new UnsupportedOperationException();
        }
        m_called = true;

        // create a upload listener
        CmsUploadListener listener = createListener();
        try {
            // try to parse the request
            parseRequest(listener);
            // try to create the resources on the VFS
            createResources(listener);
            // trigger update offline indexes, important for gallery search
            OpenCms.getSearchManager().updateOfflineIndexes();
        } catch (CmsException e) {
            // an error occurred while creating the resources on the VFS, create a special error message
            LOG.error(e.getMessage(), e);
            return generateResponse(Boolean.FALSE, getCreationErrorMessage(), formatStackTrace(e));
        } catch (CmsUploadException e) {
            // an expected error occurred while parsing the request, the error message is already set in the exception
            LOG.debug(e.getMessage(), e);
            return generateResponse(Boolean.FALSE, e.getMessage(), formatStackTrace(e));
        } catch (Throwable e) {
            // an unexpected error occurred while parsing the request, create a non-specific error message
            LOG.error(e.getMessage(), e);
            String message = m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_UNEXPECTED_0);
            return generateResponse(Boolean.FALSE, message, formatStackTrace(e));
        } finally {
            removeListener(listener.getId());
        }
        // the upload was successful inform the user about success
        return generateResponse(Boolean.TRUE, m_bundle.key(org.opencms.ade.upload.Messages.LOG_UPLOAD_SUCCESS_0), "");
    }

    /**
     * Creates a upload listener and puts it into the static map.<p>
     *
     * @return the listener
     */
    private CmsUploadListener createListener() {

        CmsUploadListener listener = new CmsUploadListener(getRequest().getContentLength());
        listener.setDelay(m_uploadDelay);
        m_listeners.put(listener.getId(), listener);
        getRequest().getSession().setAttribute(SESSION_ATTRIBUTE_LISTENER_ID, listener.getId());
        return listener;
    }

    /**
     * Creates the resources.<p>
     * @param listener the listener
     *
     * @throws CmsException if something goes wrong
     * @throws UnsupportedEncodingException in case the encoding is not supported
     */
    private void createResources(CmsUploadListener listener) throws CmsException, UnsupportedEncodingException {

        CmsObject cms = getCmsObject();
        String[] isRootPathVals = m_parameterMap.get(I_CmsUploadConstants.UPLOAD_IS_ROOT_PATH_FIELD_NAME);
        if ((isRootPathVals != null) && (isRootPathVals.length > 0) && Boolean.parseBoolean(isRootPathVals[0])) {
            cms = m_rootCms;
        }
        // get the target folder
        String targetFolder = getTargetFolder(cms);
        m_uploadHook = OpenCms.getWorkplaceManager().getUploadHook(cms, targetFolder);
        if (m_scanner != null) {
            m_scanner.test();
        }

        List<String> filesToUnzip = getFilesToUnzip();

        // iterate over the list of files to upload and create each single resource
        for (FileItem fileItem : m_multiPartFileItems) {
            if ((fileItem != null) && (!fileItem.isFormField())) {
                // read the content of the file
                byte[] content = fileItem.get();
                fileItem.delete();

                // determine the new resource name
                String fileName = m_parameterMap.get(
                    fileItem.getFieldName() + I_CmsUploadConstants.UPLOAD_FILENAME_ENCODED_SUFFIX)[0];
                String originalFileName = m_parameterMap.get(
                    fileItem.getFieldName() + I_CmsUploadConstants.UPLOAD_ORIGINAL_FILENAME_ENCODED_SUFFIX)[0];
                String context = "(file: " + originalFileName + ")";
                List<String> viruses = scan(context, content);

                fileName = URLDecoder.decode(fileName, "UTF-8");
                originalFileName = URLDecoder.decode(originalFileName, "UTF-8");
                if (viruses.size() > 0) {
                    m_viruses.putAll(originalFileName, viruses);
                } else {
                    if (filesToUnzip.contains(CmsResource.getName(fileName.replace('\\', '/')))) {

                        // scan all contents of ZIP before creating anything in the VFS
                        boolean foundVirus = false;
                        try {
                            ZipFile zip = ZipFile.builder().setByteArray(content).get();
                            for (ZipArchiveEntry entry : (Iterable<ZipArchiveEntry>)() -> zip.getEntries().asIterator()) {
                                if (entry.isDirectory() || entry.isUnixSymlink()) {
                                    continue;
                                }
                                String zipEntryContext = "(file: "
                                    + originalFileName
                                    + ", entry: "
                                    + entry.getName()
                                    + ")";
                                viruses = scan(zipEntryContext, zip, entry);
                                if (viruses.size() > 0) {
                                    foundVirus = true;
                                    m_viruses.putAll(originalFileName, viruses);
                                    break;
                                }
                            }
                        } catch (IOException e) {
                            LOG.error(e.getLocalizedMessage(), e);
                        }
                        if (foundVirus) {
                            continue;
                        }

                        // import the zip
                        CmsImportFolder importZip = new CmsImportFolder();
                        try {
                            importZip.importZip(content, targetFolder, cms, false);
                        } finally {
                            // get the created resource names
                            for (CmsResource importedResource : importZip.getImportedResources()) {
                                m_resourcesCreated.put(importedResource.getStructureId(), importedResource.getName());
                            }
                        }
                    } else {
                        // create the resource
                        CmsResource importedResource = createSingleResource(cms, fileName, targetFolder, content);
                        if (importedResource != null) {
                            // add the name of the created resource to the list of successful created resources
                            m_resourcesCreated.put(importedResource.getStructureId(), importedResource.getName());
                        }
                    }
                }

                if (listener.isCanceled()) {
                    throw listener.getException();
                }
            }
        }

        String postCreateHandlerStr = getPostCreateHandler();
        if (postCreateHandlerStr != null) {
            try {
                CmsPair<String, String> classAndConfig = I_CmsCollectorPostCreateHandler.splitClassAndConfig(
                    postCreateHandlerStr);
                String className = classAndConfig.getFirst();
                String config = classAndConfig.getSecond();
                I_CmsCollectorPostCreateHandler handler = A_CmsResourceCollector.getPostCreateHandler(className);
                for (Map.Entry<CmsUUID, String> resourceEntry : m_resourcesCreated.entrySet()) {
                    try {
                        CmsUUID structureId = resourceEntry.getKey();
                        CmsResource resource = cms.readResource(structureId, CmsResourceFilter.IGNORE_EXPIRATION);
                        if (!resource.isFolder()) {
                            handler.onCreate(cms, resource, false, config);
                        }
                    } catch (Exception e) {
                        LOG.error(e.getLocalizedMessage(), e);
                    }
                }
            } catch (Exception e) {
                LOG.error(e.getLocalizedMessage(), e);
            }

        }
    }

    /**
     * Creates a single resource and returns the new resource.<p>
     *
     * @param cms the CMS context to use
     * @param fileName the name of the resource to create
     * @param targetFolder the folder to store the new resource
     * @param content the content of the resource to create
     *
     * @return the new resource
     *
     * @throws CmsException if something goes wrong
     * @throws CmsLoaderException if something goes wrong
     * @throws CmsDbSqlException if something goes wrong
     */
    @SuppressWarnings("deprecation")
    private CmsResource createSingleResource(CmsObject cms, String fileName, String targetFolder, byte[] content)
    throws CmsException, CmsLoaderException, CmsDbSqlException {

        String folderRootPath = cms.getRequestContext().addSiteRoot(targetFolder);
        if (!m_uploadRestrictionInfo.isUploadEnabled(folderRootPath)) {
            LOG.error("Upload not enabled for folder " + targetFolder);
            return null;
        }

        String newResname = getNewResourceName(cms, fileName, targetFolder, isKeepFileNames());
        CmsResource createdResource = null;

        // determine Title property value to set on new resource
        String title = fileName;
        if (title.lastIndexOf('.') != -1) {
            title = title.substring(0, title.lastIndexOf('.'));
        }

        // fileName really shouldn't contain the full path, but for some reason it does sometimes when the client is
        // running on IE7, so we eliminate anything before and including the last slash or backslash in the title
        // before setting it as a property.

        int backslashIndex = title.lastIndexOf('\\');
        if (backslashIndex != -1) {
            title = title.substring(backslashIndex + 1);
        }

        int slashIndex = title.lastIndexOf('/');
        if (slashIndex != -1) {
            title = title.substring(slashIndex + 1);
        }

        List<CmsProperty> properties = new ArrayList<CmsProperty>(1);
        CmsProperty titleProp = new CmsProperty();
        titleProp.setName(CmsPropertyDefinition.PROPERTY_TITLE);
        if (OpenCms.getWorkplaceManager().isDefaultPropertiesOnStructure()) {
            titleProp.setStructureValue(title);
        } else {
            titleProp.setResourceValue(title);
        }
        properties.add(titleProp);

        int plainId = OpenCms.getResourceManager().getResourceType(
            CmsResourceTypePlain.getStaticTypeName()).getTypeId();
        if (!cms.existsResource(newResname, CmsResourceFilter.IGNORE_EXPIRATION)) {
            // if the resource does not exist, create it

            try {
                // create the resource
                int resTypeId = OpenCms.getResourceManager().getDefaultTypeForName(newResname).getTypeId();
                createdResource = cms.createResource(newResname, resTypeId, content, properties);
                try {
                    cms.unlockResource(newResname);
                } catch (CmsLockException e) {
                    LOG.info("Couldn't unlock uploaded file", e);
                }
            } catch (CmsSecurityException e) {
                // in case of not enough permissions, try to create a plain text file
                createdResource = cms.createResource(newResname, plainId, content, properties);
                cms.unlockResource(newResname);
            } catch (CmsDbSqlException sqlExc) {
                // SQL error, probably the file is too large for the database settings, delete file
                cms.lockResource(newResname);
                cms.deleteResource(newResname, CmsResource.DELETE_PRESERVE_SIBLINGS);
                throw sqlExc;
            } catch (OutOfMemoryError e) {
                // the file is to large try to clear up
                cms.lockResource(newResname);
                cms.deleteResource(newResname, CmsResource.DELETE_PRESERVE_SIBLINGS);
                throw e;
            }

        } else {
            // if the resource already exists, replace it
            CmsResource res = cms.readResource(newResname, CmsResourceFilter.ALL);
            boolean wasLocked = false;
            try {
                if (!cms.getLock(res).isOwnedBy(cms.getRequestContext().getCurrentUser())) {
                    cms.lockResource(res);
                    wasLocked = true;
                }
                CmsFile file = cms.readFile(res);
                byte[] contents = file.getContents();
                try {
                    cms.replaceResource(newResname, res.getTypeId(), content, null);
                    createdResource = res;
                } catch (CmsDbSqlException sqlExc) {
                    // SQL error, probably the file is too large for the database settings, restore content
                    file.setContents(contents);
                    cms.writeFile(file);
                    throw sqlExc;
                } catch (OutOfMemoryError e) {
                    // the file is to large try to clear up
                    file.setContents(contents);
                    cms.writeFile(file);
                    throw e;
                }
            } finally {
                if (wasLocked) {
                    cms.unlockResource(res);
                }
            }
        }
        return createdResource;
    }

    /**
     * Creates the upload target folder.
     *
     * @param cms the CMS context
     * @param targetFolder the upload target folder
     * @return the new folder
     * @throws CmsException if something goes wrong
     */
    private CmsResource createTargetFolder(CmsObject cms, String targetFolder) throws CmsException {

        List<String> parentFolders = new ArrayList<>();
        String currentFolder = targetFolder;
        while ((currentFolder != null) && !cms.existsResource(currentFolder, CmsResourceFilter.IGNORE_EXPIRATION)) {
            parentFolders.add(currentFolder);
            currentFolder = CmsResource.getParentFolder(currentFolder);
        }
        Collections.reverse(parentFolders);
        CmsResource lastCreated = null;
        CmsResource firstCreated = null;
        for (String parentFolder : parentFolders) {

            CmsResource createdFolder = cms.createResource(
                parentFolder,
                OpenCms.getResourceManager().getResourceType(CmsResourceTypeFolder.getStaticTypeName()));
            lastCreated = createdFolder;
            if (firstCreated == null) {
                firstCreated = createdFolder;
            }
        }
        cms.unlockResource(firstCreated);
        return lastCreated;

    }

    /**
     * Returns the stacktrace of the given exception as String.<p>
     *
     * @param e the exception
     *
     * @return the stacktrace as String
     */
    private String formatStackTrace(Throwable e) {

        return StringUtils.join(CmsLog.render(e), '\n');
    }

    /**
     * Generates a JSON object and returns its String representation for the response.<p>
     *
     * @param success <code>true</code> if the upload was successful
     * @param message the message to display
     * @param stacktrace the stack trace in case of an error
     *
     * @return the the response String
     */
    private String generateResponse(Boolean success, String message, String stacktrace) {

        JSONObject result = new JSONObject();
        try {
            result.put(I_CmsUploadConstants.KEY_SUCCESS, success);
            result.put(I_CmsUploadConstants.KEY_MESSAGE, message);
            result.put(I_CmsUploadConstants.KEY_STACKTRACE, stacktrace);
            result.put(I_CmsUploadConstants.KEY_REQUEST_SIZE, getRequest().getContentLength());

            // UUIDs get converted to strings when generating the JSON text
            result.put(I_CmsUploadConstants.KEY_UPLOADED_FILES, new JSONArray(m_resourcesCreated.keySet()));

            result.put(I_CmsUploadConstants.KEY_UPLOADED_FILE_NAMES, new JSONArray(m_resourcesCreated.values()));

            JSONObject virusWarnings = new JSONObject();
            for (String filename : m_viruses.keys()) {
                JSONArray viruses = new JSONArray(new ArrayList<>(m_viruses.get(filename)));
                virusWarnings.put(filename, viruses);
            }
            result.put(I_CmsUploadConstants.ATTR_VIRUS_WARNINGS, virusWarnings);

            if (m_uploadHook != null) {
                result.put(I_CmsUploadConstants.KEY_UPLOAD_HOOK, m_uploadHook);
            }
        } catch (JSONException e) {
            LOG.error(m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_JSON_0), e);
        }
        return result.toString();
    }

    /**
     * Returns the error message if an error occurred during the creation of resources in the VFS.<p>
     *
     * @return the error message
     */
    private String getCreationErrorMessage() {

        String message = new String();
        if (!m_resourcesCreated.isEmpty()) {
            // some resources have been created, tell the user which resources were created successfully
            StringBuffer buf = new StringBuffer(64);
            for (String name : m_resourcesCreated.values()) {
                buf.append("<br />");
                buf.append(name);
            }
            message = m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_CREATING_1, buf.toString());
        } else {
            // no resources have been created on the VFS
            message = m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_CREATING_0);
        }
        return message;
    }

    /**
     * Gets the list of file names that should be unziped.<p>
     *
     * @return the list of file names that should be unziped
     *
     * @throws UnsupportedEncodingException if something goes wrong
     */
    private List<String> getFilesToUnzip() throws UnsupportedEncodingException {

        if (m_parameterMap.get(I_CmsUploadConstants.UPLOAD_UNZIP_FILES_FIELD_NAME) != null) {
            String[] filesToUnzip = m_parameterMap.get(I_CmsUploadConstants.UPLOAD_UNZIP_FILES_FIELD_NAME);
            if (filesToUnzip != null) {
                List<String> result = new ArrayList<String>();
                for (String filename : filesToUnzip) {
                    result.add(URLDecoder.decode(filename, "UTF-8"));
                }
                return result;
            }
        }
        return Collections.emptyList();
    }

    /**
     * Gets the post-create handler.
     *
     * @return the post-create handler
     */
    private String getPostCreateHandler() {

        String[] values = m_parameterMap.get(I_CmsUploadConstants.POST_CREATE_HANDLER);
        return ((values != null) && (values.length > 0)) ? values[0] : null;
    }

    /**
     * Returns the target folder for the new resource,
     * if the given folder does not exist root folder
     * of the current site is returned.<p>
     *
     * @param cms the CMS context to use
     *
     * @return the target folder for the new resource
     *
     * @throws CmsException if something goes wrong
     */
    private String getTargetFolder(CmsObject cms) throws CmsException {

        // get the target folder on the vfs
        CmsResource target = cms.readResource("/", CmsResourceFilter.IGNORE_EXPIRATION);
        if (m_parameterMap.get(I_CmsUploadConstants.UPLOAD_TARGET_FOLDER_FIELD_NAME) != null) {
            String targetFolder = m_parameterMap.get(I_CmsUploadConstants.UPLOAD_TARGET_FOLDER_FIELD_NAME)[0];
            if (!CmsStringUtil.isEmptyOrWhitespaceOnly(targetFolder)) {
                if (cms.existsResource(targetFolder, CmsResourceFilter.IGNORE_EXPIRATION)) {
                    CmsResource tmpTarget = cms.readResource(targetFolder, CmsResourceFilter.IGNORE_EXPIRATION);
                    if (tmpTarget.isFolder()) {
                        target = tmpTarget;
                    }
                } else {
                    target = createTargetFolder(cms, targetFolder);
                }
            }
        }
        String targetFolder = cms.getRequestContext().removeSiteRoot(target.getRootPath());
        if (!targetFolder.endsWith("/")) {
            // add folder separator to currentFolder
            targetFolder += "/";
        }
        return targetFolder;
    }

    /**
     * Returns true if file name translation should be skipped for the upload.
     *
     * <p>This is mainly used for the file replacement dialog.
     *
     * @return true if file name translation should be skipped
     */
    private boolean isKeepFileNames() {

        String[] values = m_parameterMap.get(I_CmsUploadConstants.KEEP_FILE_NAMES);
        boolean result = (values != null) && (values.length > 0) && Boolean.parseBoolean(values[0]);
        return result;
    }

    /**
     * Parses the request.<p>
     *
     * Stores the file items and the request parameters in a local variable if present.<p>
     *
     * @param listener the upload listener
     *
     * @throws Exception if anything goes wrong
     */
    private void parseRequest(CmsUploadListener listener) throws Exception {

        // check if the request is a multipart request
        if (!ServletFileUpload.isMultipartContent(getRequest())) {
            // no multipart request: Abort the upload
            throw new CmsUploadException(m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_NO_MULTIPART_0));
        }

        // this was indeed a multipart form request, read the files
        m_multiPartFileItems = readMultipartFileItems(listener);

        // check if there were any multipart file items in the request
        if ((m_multiPartFileItems == null) || m_multiPartFileItems.isEmpty()) {
            // no file items found stop process
            throw new CmsUploadException(m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_NO_FILEITEMS_0));
        }

        // there are file items in the request, get the request parameters
        m_parameterMap = CmsRequestUtil.readParameterMapFromMultiPart(
            getCmsObject().getRequestContext().getEncoding(),
            m_multiPartFileItems);

        listener.setFinished(true);
    }

    /**
     * Parses a request of the form <code>multipart/form-data</code>.<p>
     *
     * The result list will contain items of type <code>{@link FileItem}</code>.
     * If the request has no file items, then <code>null</code> is returned.<p>
     *
     * @param listener the upload listener
     *
     * @return the list of <code>{@link FileItem}</code> extracted from the multipart request,
     *      or <code>null</code> if the request has no file items
     *
     * @throws Exception if anything goes wrong
     */
    private List<FileItem> readMultipartFileItems(CmsUploadListener listener) throws Exception {

        DiskFileItemFactory factory = new DiskFileItemFactory();
        // maximum size that will be stored in memory
        factory.setSizeThreshold(4096);
        // the location for saving data that is larger than the threshold
        File temp = new File(OpenCms.getSystemInfo().getPackagesRfsPath());
        if (temp.exists() || temp.mkdirs()) {
            // make sure the folder exists
            factory.setRepository(temp);
        }

        // create a file upload servlet
        ServletFileUpload fu = new ServletFileUpload(factory);
        // set the listener
        fu.setProgressListener(listener);
        // set encoding to correctly handle special chars (e.g. in filenames)
        fu.setHeaderEncoding(getRequest().getCharacterEncoding());
        // set the maximum size for a single file (value is in bytes)
        long maxFileSizeBytes = OpenCms.getWorkplaceManager().getFileBytesMaxUploadSize(getCmsObject());
        if (maxFileSizeBytes > 0) {
            fu.setFileSizeMax(maxFileSizeBytes);
        }

        // try to parse the request
        try {
            return CmsCollectionsGenericWrapper.list(fu.parseRequest(getRequest()));
        } catch (SizeLimitExceededException e) {
            // request size is larger than maximum allowed request size, throw an error
            Integer actualSize = Integer.valueOf((int)(e.getActualSize() / 1024));
            Integer maxSize = Integer.valueOf((int)(e.getPermittedSize() / 1024));
            throw new CmsUploadException(
                m_bundle.key(org.opencms.ade.upload.Messages.ERR_UPLOAD_REQUEST_SIZE_LIMIT_2, actualSize, maxSize),
                e);
        } catch (FileSizeLimitExceededException e) {
            // file size is larger than maximum allowed file size, throw an error
            Integer actualSize = Integer.valueOf((int)(e.getActualSize() / 1024));
            Integer maxSize = Integer.valueOf((int)(e.getPermittedSize() / 1024));
            throw new CmsUploadException(
                m_bundle.key(
                    org.opencms.ade.upload.Messages.ERR_UPLOAD_FILE_SIZE_LIMIT_3,
                    actualSize,
                    e.getFileName(),
                    maxSize),
                e);
        }
    }

    /**
     * Remove the listener active in this session.
     *
     * @param listenerId the id of the listener to remove
     */
    private void removeListener(CmsUUID listenerId) {

        getRequest().getSession().removeAttribute(SESSION_ATTRIBUTE_LISTENER_ID);
        m_listeners.remove(listenerId);
    }

    /**
     * Scans a byte buffer for viruses if possible.
     * @param data the file data
     * @return the list of detected viruses
     */
    private List<String> scan(String context, byte[] data) {

        return scanInternal(context, () -> new ByteArrayInputStream(data));
    }

    /**
     * Scans a zip file entry for viruses if possible.
     * @param zip the zip file
     * @param entry the entry
     * @return the list of detected viruses
     */
    private List<String> scan(String context, ZipFile zip, ZipArchiveEntry entry) {

        return scanInternal(context, () -> zip.getInputStream(entry));
    }

    /**
     * Internal helper method for calling the virus scanner implementation and handling logging.
     *
     * @param context the context string to include into the log; contains information about what is being scanned
     * @param streamProvider supplier for the data stream to be scanned
     *
     * @return the list of found virus names
     */
    private List<String> scanInternal(String context, InputStreamProvider streamProvider) {

        if (m_scanner != null) {
            List<String> result = null;
            long t1 = System.currentTimeMillis();
            try (InputStream stream = streamProvider.getStream()) {
                result = m_scanner.scan(stream);
            } catch (IOException e) {
                result = Collections.emptyList();
            } finally {
                long t2 = System.currentTimeMillis();
                CmsVirusScannerLog.LOG.debug("Virus scan in context " + context + " took " + (t2 - t1) + "ms");
            }
            if (result.isEmpty()) {
                CmsVirusScannerLog.LOG.info("Found no viruses, context=" + context);
            } else {
                CmsVirusScannerLog.LOG.warn(
                    "Found viruses: "
                        + result
                        + ", context="
                        + context
                        + ", user="
                        + getCmsObject().getRequestContext().getCurrentUser().getName());
            }
            return result;
        } else {
            return Collections.emptyList();
        }
    }

}