/*
 * Copyright 2000-2021 Vaadin Ltd.
 *
 * Licensed 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 com.vaadin.ui;

import java.io.OutputStream;
import java.io.Serializable;
import java.lang.reflect.Method;
import java.util.Collections;
import java.util.LinkedHashSet;
import java.util.Map;
import java.util.Objects;

import com.vaadin.event.SerializableEventListener;
import com.vaadin.server.NoInputStreamException;
import com.vaadin.server.NoOutputStreamException;
import com.vaadin.server.PaintException;
import com.vaadin.server.PaintTarget;
import com.vaadin.server.StreamVariable.StreamingProgressEvent;
import com.vaadin.shared.EventId;
import com.vaadin.shared.Registration;
import com.vaadin.shared.ui.upload.UploadClientRpc;
import com.vaadin.shared.ui.upload.UploadServerRpc;
import com.vaadin.shared.ui.upload.UploadState;
import com.vaadin.util.ReflectTools;

/**
 * Component for uploading files from client to server.
 *
 * <p>
 * The visible component consists of a file name input box and a browse button
 * and an upload submit button to start uploading.
 *
 * <p>
 * The Upload component needs a java.io.OutputStream to write the uploaded data.
 * You need to implement the Upload.Receiver interface and return the output
 * stream in the receiveUpload() method.
 *
 * <p>
 * You can get an event regarding starting (StartedEvent), progress
 * (ProgressEvent), and finishing (FinishedEvent) of upload by implementing
 * StartedListener, ProgressListener, and FinishedListener, respectively. The
 * FinishedListener is called for both failed and succeeded uploads. If you wish
 * to separate between these two cases, you can use SucceededListener
 * (SucceededEvenet) and FailedListener (FailedEvent).
 *
 * <p>
 * The upload component does not itself show upload progress, but you can use
 * the ProgressIndicator for providing progress feedback by implementing
 * ProgressListener and updating the indicator in updateProgress().
 *
 * <p>
 * Setting upload component immediate with {@link #setImmediateMode(boolean)}
 * initiates the upload as soon as a file is selected, instead of the common
 * pattern of file selection field and upload button.
 *
 * <p>
 * Note! Because of browser dependent implementations of <input type="file">
 * element, setting size for Upload component is not supported. For some
 * browsers setting size may work to some extend.
 *
 * @author Vaadin Ltd.
 * @since 3.0
 */
@SuppressWarnings("serial")
public class Upload extends AbstractComponent
        implements Component.Focusable, LegacyComponent {

    /**
     * Should the field be focused on next repaint?
     */
    private final boolean focus = false;

    /**
     * The tab order number of this field.
     */
    private int tabIndex = 0;

    /**
     * The output of the upload is redirected to this receiver.
     */
    private Receiver receiver;

    private boolean isUploading;

    private long contentLength = -1;

    private int totalBytes;

    /**
     * ProgressListeners to which information about progress is sent during
     * upload
     */
    private LinkedHashSet<ProgressListener> progressListeners;

    private boolean interrupted = false;

    private boolean notStarted;

    private int nextid;

    /**
     * Creates a new instance of Upload.
     *
     * The receiver must be set before performing an upload.
     */
    public Upload() {
        registerRpc(new UploadServerRpc() {
            @Override
            public void change(String filename) {
                fireEvent(new ChangeEvent(Upload.this, filename));
            }

            @Override
            public void poll() {
                // Nothing to do, called only to visit the server
            }
        });
    }

    public Upload(String caption, Receiver uploadReceiver) {
        this();
        setCaption(caption);
        receiver = uploadReceiver;
    }

    /**
     * Invoked when the value of a variable has changed.
     *
     * @see com.vaadin.ui.LegacyComponent#changeVariables(java.lang.Object,
     *      java.util.Map)
     */
    @Override
    public void changeVariables(Object source, Map<String, Object> variables) {
        if (variables.containsKey("pollForStart")) {
            int id = (Integer) variables.get("pollForStart");
            if (!isUploading && id == nextid) {
                notStarted = true;
                markAsDirty();
            } else {
            }
        }
    }

    /**
     * Paints the content of this component.
     *
     * @param target
     *            Target to paint the content on.
     * @throws PaintException
     *             if the paint operation failed.
     */
    @Override
    public void paintContent(PaintTarget target) throws PaintException {
        if (notStarted) {
            target.addAttribute("notStarted", true);
            notStarted = false;
            return;
        }
        // The field should be focused
        if (focus) {
            target.addAttribute("focus", true);
        }

        // The tab ordering number
        if (tabIndex >= 0) {
            target.addAttribute("tabindex", tabIndex);
        }

        target.addAttribute("state", isUploading);

        target.addAttribute("nextid", nextid);

        // Post file to this stream variable
        target.addVariable(this, "action", getStreamVariable());

    }

    /**
     * Interface that must be implemented by the upload receivers to provide the
     * Upload component an output stream to write the uploaded data.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    @FunctionalInterface
    public interface Receiver extends Serializable {

        /**
         * Invoked when a new upload arrives.
         *
         * @param filename
         *            the desired filename of the upload, usually as specified
         *            by the client.
         * @param mimeType
         *            the MIME type of the uploaded file.
         * @return Stream to which the uploaded file should be written.
         */
        public OutputStream receiveUpload(String filename, String mimeType);
    }

    /* Upload events */

    private static final Method UPLOAD_FINISHED_METHOD;

    private static final Method UPLOAD_FAILED_METHOD;

    private static final Method UPLOAD_SUCCEEDED_METHOD;

    private static final Method UPLOAD_STARTED_METHOD;

    static {
        try {
            UPLOAD_FINISHED_METHOD = FinishedListener.class
                    .getDeclaredMethod("uploadFinished", FinishedEvent.class);
            UPLOAD_FAILED_METHOD = FailedListener.class
                    .getDeclaredMethod("uploadFailed", FailedEvent.class);
            UPLOAD_STARTED_METHOD = StartedListener.class
                    .getDeclaredMethod("uploadStarted", StartedEvent.class);
            UPLOAD_SUCCEEDED_METHOD = SucceededListener.class
                    .getDeclaredMethod("uploadSucceeded", SucceededEvent.class);
        } catch (final NoSuchMethodException e) {
            // This should never happen
            throw new RuntimeException(
                    "Internal error finding methods in Upload");
        }
    }

    /**
     * Upload.FinishedEvent is sent when the upload receives a file, regardless
     * of whether the reception was successful or failed. If you wish to
     * distinguish between the two cases, use either SucceededEvent or
     * FailedEvent, which are both subclasses of the FinishedEvent.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    public static class FinishedEvent extends Component.Event {

        /**
         * Length of the received file.
         */
        private final long length;

        /**
         * MIME type of the received file.
         */
        private final String type;

        /**
         * Received file name.
         */
        private final String filename;

        /**
         *
         * @param source
         *            the source of the file.
         * @param filename
         *            the received file name.
         * @param mimeType
         *            the MIME type of the received file.
         * @param length
         *            the length of the received file.
         */
        public FinishedEvent(Upload source, String filename, String mimeType,
                long length) {
            super(source);
            type = mimeType;
            this.filename = filename;
            this.length = length;
        }

        /**
         * Uploads where the event occurred.
         *
         * @return the Source of the event.
         */
        public Upload getUpload() {
            return (Upload) getSource();
        }

        /**
         * Gets the file name.
         *
         * @return the filename.
         */
        public String getFilename() {
            return filename;
        }

        /**
         * Gets the MIME Type of the file.
         *
         * @return the MIME type.
         */
        public String getMIMEType() {
            return type;
        }

        /**
         * Gets the length of the file.
         *
         * @return the length.
         */
        public long getLength() {
            return length;
        }

    }

    /**
     * Upload.FailedEvent event is sent when the upload is received, but the
     * reception is interrupted for some reason.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    public static class FailedEvent extends FinishedEvent {

        private Exception reason = null;

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param length
         * @param reason
         */
        public FailedEvent(Upload source, String filename, String mimeType,
                long length, Exception reason) {
            this(source, filename, mimeType, length);
            this.reason = reason;
        }

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param length
         */
        public FailedEvent(Upload source, String filename, String mimeType,
                long length) {
            super(source, filename, mimeType, length);
        }

        /**
         * Gets the exception that caused the failure.
         *
         * @return the exception that caused the failure, null if n/a
         */
        public Exception getReason() {
            return reason;
        }

    }

    /**
     * FailedEvent that indicates that an output stream could not be obtained.
     */
    public static class NoOutputStreamEvent extends FailedEvent {

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param length
         */
        public NoOutputStreamEvent(Upload source, String filename,
                String mimeType, long length) {
            super(source, filename, mimeType, length);
        }
    }

    /**
     * FailedEvent that indicates that an input stream could not be obtained.
     */
    public static class NoInputStreamEvent extends FailedEvent {

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param length
         */
        public NoInputStreamEvent(Upload source, String filename,
                String mimeType, long length) {
            super(source, filename, mimeType, length);
        }
    }

    /**
     * Upload.SucceededEvent event is sent when the upload is received
     * successfully.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    public static class SucceededEvent extends FinishedEvent {

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param length
         */
        public SucceededEvent(Upload source, String filename, String mimeType,
                long length) {
            super(source, filename, mimeType, length);
        }
    }

    /**
     * Upload.StartedEvent event is sent when the upload is started to received.
     *
     * @author Vaadin Ltd.
     * @since 5.0
     */
    public static class StartedEvent extends Component.Event {

        private final String filename;
        private final String type;
        /**
         * Length of the received file.
         */
        private final long length;

        /**
         *
         * @param source
         * @param filename
         * @param mimeType
         * @param contentLength
         */
        public StartedEvent(Upload source, String filename, String mimeType,
                long contentLength) {
            super(source);
            this.filename = filename;
            type = mimeType;
            length = contentLength;
        }

        /**
         * Uploads where the event occurred.
         *
         * @return the Source of the event.
         */
        public Upload getUpload() {
            return (Upload) getSource();
        }

        /**
         * Gets the file name.
         *
         * @return the filename.
         */
        public String getFilename() {
            return filename;
        }

        /**
         * Gets the MIME Type of the file.
         *
         * @return the MIME type.
         */
        public String getMIMEType() {
            return type;
        }

        /**
         * @return the length of the file that is being uploaded
         */
        public long getContentLength() {
            return length;
        }

    }

    /**
     * Upload.ChangeEvent event is sent when the value (filename) of the upload
     * changes.
     *
     * @since 7.2
     */
    public static class ChangeEvent extends Component.Event {

        private final String filename;

        public ChangeEvent(Upload source, String filename) {
            super(source);
            this.filename = filename;
        }

        /**
         * Uploads where the event occurred.
         *
         * @return the Source of the event.
         */
        @Override
        public Upload getSource() {
            return (Upload) super.getSource();
        }

        /**
         * Gets the file name.
         *
         * @return the filename.
         */
        public String getFilename() {
            return filename;
        }

    }

    /**
     * Receives the events when the upload starts.
     *
     * @author Vaadin Ltd.
     * @since 5.0
     */
    @FunctionalInterface
    public interface StartedListener extends SerializableEventListener {

        /**
         * Upload has started.
         *
         * @param event
         *            the Upload started event.
         */
        public void uploadStarted(StartedEvent event);
    }

    /**
     * Receives the events when the uploads are ready.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    @FunctionalInterface
    public interface FinishedListener extends SerializableEventListener {

        /**
         * Upload has finished.
         *
         * @param event
         *            the Upload finished event.
         */
        public void uploadFinished(FinishedEvent event);
    }

    /**
     * Receives events when the uploads are finished, but unsuccessful.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    @FunctionalInterface
    public interface FailedListener extends SerializableEventListener {

        /**
         * Upload has finished unsuccessfully.
         *
         * @param event
         *            the Upload failed event.
         */
        public void uploadFailed(FailedEvent event);
    }

    /**
     * Receives events when the uploads are successfully finished.
     *
     * @author Vaadin Ltd.
     * @since 3.0
     */
    @FunctionalInterface
    public interface SucceededListener extends SerializableEventListener {

        /**
         * Upload successful.
         *
         * @param event
         *            the Upload successful event.
         */
        public void uploadSucceeded(SucceededEvent event);
    }

    /**
     * Listener for {@link ChangeEvent}.
     *
     * @since 7.2
     */
    @FunctionalInterface
    public interface ChangeListener extends SerializableEventListener {

        Method FILENAME_CHANGED = ReflectTools.findMethod(ChangeListener.class,
                "filenameChanged", ChangeEvent.class);

        /**
         * A file has been selected but upload has not yet started.
         *
         * @param event
         *            the change event
         */
        public void filenameChanged(ChangeEvent event);
    }

    /**
     * Adds the upload started event listener.
     *
     * @param listener
     *            the Listener to be added, not null
     * @since 8.0
     */
    public Registration addStartedListener(StartedListener listener) {
        return addListener(StartedEvent.class, listener, UPLOAD_STARTED_METHOD);
    }

    /**
     * Removes the upload started event listener.
     *
     * @param listener
     *            the Listener to be removed.
     */
    @Deprecated
    public void removeStartedListener(StartedListener listener) {
        removeListener(StartedEvent.class, listener, UPLOAD_STARTED_METHOD);
    }

    /**
     * Adds the upload received event listener.
     *
     * @param listener
     *            the Listener to be added, not null
     * @since 8.0
     */
    public Registration addFinishedListener(FinishedListener listener) {
        return addListener(FinishedEvent.class, listener,
                UPLOAD_FINISHED_METHOD);
    }

    /**
     * Removes the upload received event listener.
     *
     * @param listener
     *            the Listener to be removed.
     */
    @Deprecated
    public void removeFinishedListener(FinishedListener listener) {
        removeListener(FinishedEvent.class, listener, UPLOAD_FINISHED_METHOD);
    }

    /**
     * Adds the upload interrupted event listener.
     *
     * @param listener
     *            the Listener to be added, not null
     * @since 8.0
     */
    public Registration addFailedListener(FailedListener listener) {
        return addListener(FailedEvent.class, listener, UPLOAD_FAILED_METHOD);
    }

    /**
     * Removes the upload interrupted event listener.
     *
     * @param listener
     *            the Listener to be removed.
     */
    @Deprecated
    public void removeFailedListener(FailedListener listener) {
        removeListener(FailedEvent.class, listener, UPLOAD_FAILED_METHOD);
    }

    /**
     * Adds the upload success event listener.
     *
     * @param listener
     *            the Listener to be added, not null
     * @since 8.0
     */
    public Registration addSucceededListener(SucceededListener listener) {
        return addListener(SucceededEvent.class, listener,
                UPLOAD_SUCCEEDED_METHOD);
    }

    /**
     * Removes the upload success event listener.
     *
     * @param listener
     *            the Listener to be removed.
     */
    @Deprecated
    public void removeSucceededListener(SucceededListener listener) {
        removeListener(SucceededEvent.class, listener, UPLOAD_SUCCEEDED_METHOD);
    }

    /**
     * Adds the upload progress event listener.
     *
     * @param listener
     *            the progress listener to be added
     * @since 8.0
     */
    public Registration addProgressListener(ProgressListener listener) {
        Objects.requireNonNull(listener, "Listener must not be null.");
        if (progressListeners == null) {
            progressListeners = new LinkedHashSet<>();
        }
        progressListeners.add(listener);
        return () -> {
            if (progressListeners != null) {
                progressListeners.remove(listener);
            }
        };
    }

    /**
     * Removes the upload progress event listener.
     *
     * @param listener
     *            the progress listener to be removed
     */
    @Deprecated
    public void removeProgressListener(ProgressListener listener) {
        if (progressListeners != null) {
            progressListeners.remove(listener);
        }
    }

    /**
     * Adds a filename change event listener.
     *
     * @param listener
     *            the Listener to add, not null
     * @since 8.0
     */
    public Registration addChangeListener(ChangeListener listener) {
        return addListener(EventId.CHANGE, ChangeEvent.class, listener,
                ChangeListener.FILENAME_CHANGED);
    }

    /**
     * Removes a filename change event listener.
     *
     * @param listener
     *            the listener to be removed
     */
    @Deprecated
    public void removeChangeListener(ChangeListener listener) {
        super.removeListener(EventId.CHANGE, ChangeEvent.class, listener);
    }

    /**
     * Emit upload received event.
     *
     * @param filename
     * @param mimeType
     */
    protected void fireStarted(String filename, String mimeType) {
        fireEvent(new Upload.StartedEvent(this, filename, mimeType,
                contentLength));
    }

    /**
     * Emits the upload failed event.
     *
     * @param filename
     * @param mimeType
     * @param length
     */
    protected void fireUploadInterrupted(String filename, String mimeType,
            long length) {
        fireEvent(new Upload.FailedEvent(this, filename, mimeType, length));
    }

    protected void fireNoInputStream(String filename, String mimeType,
            long length) {
        fireEvent(new Upload.NoInputStreamEvent(this, filename, mimeType,
                length));
    }

    protected void fireNoOutputStream(String filename, String mimeType,
            long length) {
        fireEvent(new Upload.NoOutputStreamEvent(this, filename, mimeType,
                length));
    }

    protected void fireUploadInterrupted(String filename, String mimeType,
            long length, Exception e) {
        fireEvent(new Upload.FailedEvent(this, filename, mimeType, length, e));
    }

    /**
     * Emits the upload success event.
     *
     * @param filename
     * @param MIMEType
     * @param length
     *
     */
    protected void fireUploadSuccess(String filename, String MIMEType,
            long length) {
        fireEvent(new Upload.SucceededEvent(this, filename, MIMEType, length));
    }

    /**
     * Emits the progress event.
     *
     * @param totalBytes
     *            bytes received so far
     * @param contentLength
     *            actual size of the file being uploaded, if known
     *
     */
    protected void fireUpdateProgress(long totalBytes, long contentLength) {
        // this is implemented differently than other listeners to maintain
        // backwards compatibility
        if (progressListeners != null) {
            for (ProgressListener l : progressListeners) {
                l.updateProgress(totalBytes, contentLength);
            }
        }
    }

    /**
     * Returns the current receiver.
     *
     * @return the StreamVariable.
     */
    public Receiver getReceiver() {
        return receiver;
    }

    /**
     * Sets the receiver.
     *
     * @param receiver
     *            the receiver to set.
     */
    public void setReceiver(Receiver receiver) {
        this.receiver = receiver;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public void focus() {
        super.focus();
    }

    /**
     * Gets the Tabulator index of this Focusable component.
     *
     * @see com.vaadin.ui.Component.Focusable#getTabIndex()
     */
    @Override
    public int getTabIndex() {
        return tabIndex;
    }

    /**
     * Sets the Tabulator index of this Focusable component.
     *
     * @see com.vaadin.ui.Component.Focusable#setTabIndex(int)
     */
    @Override
    public void setTabIndex(int tabIndex) {
        this.tabIndex = tabIndex;
    }

    /**
     * Go into upload state. This is to prevent double uploading on same
     * component.
     *
     * Warning: this is an internal method used by the framework and should not
     * be used by user of the Upload component. Using it results in the Upload
     * component going in wrong state and not working. It is currently public
     * because it is used by another class.
     */
    public void startUpload() {
        if (isUploading) {
            throw new IllegalStateException("uploading already started");
        }
        isUploading = true;
        nextid++;
    }

    /**
     * Interrupts the upload currently being received. The interruption will be
     * done by the receiving thread so this method will return immediately and
     * the actual interrupt will happen a bit later.
     */
    public void interruptUpload() {
        if (isUploading) {
            interrupted = true;
        }
    }

    /**
     * Go into state where new uploading can begin.
     *
     * Warning: this is an internal method used by the framework and should not
     * be used by user of the Upload component.
     */
    private void endUpload() {
        isUploading = false;
        contentLength = -1;
        interrupted = false;
        markAsDirty();
    }

    public boolean isUploading() {
        return isUploading;
    }

    /**
     * Gets read bytes of the file currently being uploaded.
     *
     * @return bytes
     */
    public long getBytesRead() {
        return totalBytes;
    }

    /**
     * Returns size of file currently being uploaded. Value sane only during
     * upload.
     *
     * @return size in bytes
     */
    public long getUploadSize() {
        return contentLength;
    }

    /**
     * ProgressListener receives events to track progress of upload.
     */
    @FunctionalInterface
    public interface ProgressListener extends Serializable {
        /**
         * Updates progress to listener.
         *
         * @param readBytes
         *            bytes transferred
         * @param contentLength
         *            total size of file currently being uploaded, -1 if unknown
         */
        public void updateProgress(long readBytes, long contentLength);
    }

    /**
     * Returns the string rendered into button that fires uploading.
     *
     * @return String to be rendered into button that fires uploading
     */
    public String getButtonCaption() {
        return getState(false).buttonCaption;
    }

    /**
     * Returns the style name rendered into button that fires uploading.
     *
     * @return Style name to be rendered into button that fires uploading
     * @since 8.2
     */
    public String getButtonStyleName() {
        return getState(false).buttonStyleName;
    }

    /**
     * Checks whether the caption of the button that fires uploading is rendered
     * as HTML
     * <p>
     * The default is {@code false}, i.e. to render that caption as plain text.
     *
     * @return {@code true} if the caption is rendered as HTML, {@code false} if
     *         rendered as plain text
     * @since 8.11
     */
    public boolean isButtonCaptionAsHtml() {
        return getState(false).buttonCaptionAsHtml;
    }

    /**
     * In addition to the actual file chooser, upload components have button
     * that starts actual upload progress. This method is used to set text in
     * that button.
     * <p>
     * In case the button text is set to null, the button is hidden. In this
     * case developer must explicitly initiate the upload process with
     * {@link #submitUpload()}.
     * <p>
     * In case the Upload is used in immediate mode using
     * {@link #setImmediateMode(boolean)}, the file chooser (HTML input with
     * type "file") is hidden and only the button with this text is shown.
     * <p>
     *
     * <p>
     * <strong>Note</strong> the string given is set as is to the button. HTML
     * formatting is not stripped. Be sure to properly validate your value
     * according to your needs.
     *
     * @param buttonCaption
     *            text for upload components button.
     */
    public void setButtonCaption(String buttonCaption) {
        getState().buttonCaption = buttonCaption;
    }

    /**
     * In addition to the actual file chooser, upload components have button
     * that starts actual upload progress. This method is used to set a style
     * name to that button.
     * <p>
     * Note: Unlike {@code Button.setStyleName()} this method overrides all the
     * styles from the button. If you wish to preserve the default styles, enter
     * the style name as {@code "v-button yourStyleName"}.
     *
     * @param buttonStyleName
     *            style name for upload components button.
     * @see #setButtonCaption(String) about when the button is shown / hidden.
     * @since 8.2
     */
    public void setButtonStyleName(String buttonStyleName) {
        getState().buttonStyleName = buttonStyleName;
    }

    /**
     * In addition to the actual file chooser, upload components have button
     * that starts actual upload progress. This method is used to set whether
     * the caption on that button is rendered as HTML.
     * <p>
     * If set to {@code true}, the caption is rendered in the browser as HTML
     * and the developer is responsible for ensuring no harmful HTML is used. If
     * set to {@code false}, the caption is rendered in the browser as plain
     * text.
     * <p>
     * The default is {@code false}, i.e. to render the caption as plain text.
     *
     * @param buttonCaptionAsHtml
     *            {@code true} if the caption is rendered as HTML, {@code false}
     *            if rendered as plain text
     * @since 8.11
     */
    public void setButtonCaptionAsHtml(boolean buttonCaptionAsHtml) {
        getState().buttonCaptionAsHtml = buttonCaptionAsHtml;
    }

    /**
     * Instructs the upload component to send selected file to the server.
     * <p>
     * In case developer wants to use this feature, he/she will most probably
     * want to hide the upload component's internal submit button by setting its
     * caption to null with {@link #setButtonCaption(String)} method.
     * <p>
     * Note that the upload runs asynchronously. Developer should use normal
     * upload listeners to track the process of upload. If the file name field
     * is empty, no upload will be triggered.
     * <p>
     * Also note that the developer should not remove or modify the upload
     * component in the same user transaction where the upload submit is
     * requested. The upload component can be safely hidden or removed once the
     * upload started event has been fired.
     */
    public void submitUpload() {
        markAsDirty();
        getRpcProxy(UploadClientRpc.class).submitUpload();
    }

    @Override
    public void markAsDirty() {
        super.markAsDirty();
    }

    /*
     * Handle to terminal via Upload monitors and controls the upload during it
     * is being streamed.
     */
    private com.vaadin.server.StreamVariable streamVariable;

    protected com.vaadin.server.StreamVariable getStreamVariable() {
        if (streamVariable == null) {
            streamVariable = new com.vaadin.server.StreamVariable() {
                private StreamingStartEvent lastStartedEvent;

                @Override
                public boolean listenProgress() {
                    return progressListeners != null
                            && !progressListeners.isEmpty();
                }

                @Override
                public void onProgress(StreamingProgressEvent event) {
                    fireUpdateProgress(event.getBytesReceived(),
                            event.getContentLength());
                }

                @Override
                public boolean isInterrupted() {
                    return interrupted;
                }

                @Override
                public OutputStream getOutputStream() {
                    if (getReceiver() == null) {
                        throw new IllegalStateException(
                                "Upload cannot be performed without a receiver set");
                    }
                    OutputStream receiveUpload = getReceiver().receiveUpload(
                            lastStartedEvent.getFileName(),
                            lastStartedEvent.getMimeType());
                    lastStartedEvent = null;
                    return receiveUpload;
                }

                @Override
                public void streamingStarted(StreamingStartEvent event) {
                    startUpload();
                    contentLength = event.getContentLength();
                    fireStarted(event.getFileName(), event.getMimeType());
                    lastStartedEvent = event;
                }

                @Override
                public void streamingFinished(StreamingEndEvent event) {
                    fireUploadSuccess(event.getFileName(), event.getMimeType(),
                            event.getContentLength());
                    endUpload();
                    if (lastStartedEvent != null)
                        lastStartedEvent.disposeStreamVariable();
                }

                @Override
                public void streamingFailed(StreamingErrorEvent event) {
                    try {
                        Exception exception = event.getException();
                        if (exception instanceof NoInputStreamException) {
                            fireNoInputStream(event.getFileName(),
                                    event.getMimeType(), 0);
                        } else if (exception instanceof NoOutputStreamException) {
                            fireNoOutputStream(event.getFileName(),
                                    event.getMimeType(), 0);
                        } else {
                            fireUploadInterrupted(event.getFileName(),
                                    event.getMimeType(), 0, exception);
                        }
                    } finally {
                        endUpload();
                        if (lastStartedEvent != null)
                            lastStartedEvent.disposeStreamVariable();
                    }
                }
            };
        }
        return streamVariable;
    }

    @Override
    public java.util.Collection<?> getListeners(java.lang.Class<?> eventType) {
        if (StreamingProgressEvent.class.isAssignableFrom(eventType)) {
            if (progressListeners == null) {
                return Collections.emptyList();
            } else {
                return Collections.unmodifiableCollection(progressListeners);
            }

        }
        return super.getListeners(eventType);
    }

    /**
     * Sets the immediate mode of the upload.
     * <p>
     * If the upload is in immediate mode, the file upload is started
     * immediately after the user has selected the file.
     * <p>
     * If the upload is not in immediate mode, after selecting the file the user
     * must click another button to start the upload.
     * <p>
     * The default mode of an Upload component is immediate.
     *
     * @param immediateMode
     *            {@code true} for immediate mode, {@code false} for not
     * @since 8.0
     */
    public void setImmediateMode(boolean immediateMode) {
        getState().immediateMode = immediateMode;
    }

    /**
     * Returns the immediate mode of the upload.
     * <p>
     * The default mode of an Upload component is immediate.
     *
     * @return {@code true} if the upload is in immediate mode, {@code false} if
     *         the upload is not in immediate mode
     * @see #setImmediateMode(boolean)
     * @since 8.0
     */
    public boolean isImmediateMode() {
        return getState(false).immediateMode;
    }

    @Override
    protected UploadState getState() {
        return (UploadState) super.getState();
    }

    @Override
    protected UploadState getState(boolean markAsDirty) {
        return (UploadState) super.getState(markAsDirty);
    }

    /**
     * Returns the component's list of accepted content-types. According to RFC
     * 1867, if the attribute is present, the browser might constrain the file
     * patterns prompted for to match those with the corresponding appropriate
     * file extensions for the platform.
     *
     * @return comma-separated list of desired mime types to be uploaded
     * @see #setAcceptMimeTypes
     * @since 8.5
     */
    public String getAcceptMimeTypes() {
        return getState(false).acceptMimeTypes;
    }

    /**
     * Sets the component's list of accepted content-types. According to RFC
     * 1867, if the attribute is present, the browser might constrain the file
     * patterns prompted for to match those with the corresponding appropriate
     * file extensions for the platform. Good examples are: {@code image/*} or
     * {@code image/png,text/plain}
     *
     * @param acceptMimeTypes
     *            comma-separated list of desired mime types to be uploaded
     * @see #getAcceptMimeTypes
     * @since 8.5
     */
    public void setAcceptMimeTypes(String acceptMimeTypes) {
        getState().acceptMimeTypes = acceptMimeTypes;
    }

}
><span class="p">(</span><span class="s">&quot;shutdownPort&quot;</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;8889&quot;</span><span class="p">);</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="kt">int</span><span class="w"> </span><span class="n">port</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Integer</span><span class="p">.</span><span class="na">parseInt</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;shutdownPort&quot;</span><span class="p">));</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">port</span><span class="w"> </span><span class="o">&gt;</span><span class="w"> </span><span class="mi">0</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="c1">// Try to notify another instance that it&#39;s time to close</span>
<span class="w">                </span><span class="n">Socket</span><span class="w"> </span><span class="n">socket</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">Socket</span><span class="p">((</span><span class="n">String</span><span class="p">)</span><span class="w"> </span><span class="kc">null</span><span class="p">,</span><span class="w"> </span><span class="n">port</span><span class="p">);</span>
<span class="w">                </span><span class="c1">// Wait until the other instance says it has closed</span>
<span class="w">                </span><span class="n">socket</span><span class="p">.</span><span class="na">getInputStream</span><span class="p">().</span><span class="na">read</span><span class="p">();</span>
<span class="w">                </span><span class="c1">// Then tidy up</span>
<span class="w">                </span><span class="n">socket</span><span class="p">.</span><span class="na">close</span><span class="p">();</span>
<span class="w">            </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">IOException</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="c1">// Ignore if port is not open</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="c1">// Start Jetty</span>
<span class="w">        </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Starting Jetty servlet container.&quot;</span><span class="p">);</span>
<span class="w">        </span><span class="n">String</span><span class="w"> </span><span class="n">url</span><span class="p">;</span>
<span class="w">        </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">url</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">runServer</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;Development Server Mode&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="c1">// Start Browser</span>
<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;gui&quot;</span><span class="p">)</span><span class="w"> </span><span class="o">&amp;&amp;</span><span class="w"> </span><span class="n">url</span><span class="w"> </span><span class="o">!=</span><span class="w"> </span><span class="kc">null</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Starting Web Browser.&quot;</span><span class="p">);</span>

<span class="w">                </span><span class="c1">// Open browser into application URL</span>
<span class="w">                </span><span class="n">BrowserLauncher</span><span class="p">.</span><span class="na">openBrowser</span><span class="p">(</span><span class="n">url</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">Exception</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// NOP exception already on console by jetty</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="kd">private</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">assertAssertionsEnabled</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">        </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="k">assert</span><span class="w"> </span><span class="kc">false</span><span class="p">;</span>

<span class="w">            </span><span class="n">System</span><span class="p">.</span><span class="na">err</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;You should run &quot;</span>
<span class="w">                    </span><span class="o">+</span><span class="w"> </span><span class="n">DevelopmentServerLauncher</span><span class="p">.</span><span class="na">class</span><span class="p">.</span><span class="na">getSimpleName</span><span class="p">()</span>
<span class="w">                    </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; with assertions enabled. Add -ea as a VM argument.&quot;</span><span class="p">);</span>
<span class="w">        </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">AssertionError</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// All is fine</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="cm">/**</span>
<span class="cm">     * Run the server with specified arguments.</span>
<span class="cm">     *</span>
<span class="cm">     * @param serverArgs</span>
<span class="cm">     * @return</span>
<span class="cm">     * @throws Exception</span>
<span class="cm">     * @throws Exception</span>
<span class="cm">     */</span>
<span class="w">    </span><span class="kd">protected</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="n">String</span><span class="w"> </span><span class="nf">runServer</span><span class="p">(</span><span class="n">Map</span><span class="o">&lt;</span><span class="n">String</span><span class="p">,</span><span class="w"> </span><span class="n">String</span><span class="o">&gt;</span><span class="w"> </span><span class="n">serverArgs</span><span class="p">,</span>
<span class="w">            </span><span class="n">String</span><span class="w"> </span><span class="n">mode</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">Exception</span><span class="w"> </span><span class="p">{</span>

<span class="w">        </span><span class="c1">// Assign default values for some arguments</span>
<span class="w">        </span><span class="n">assignDefault</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;webroot&quot;</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;src/main/webapp&quot;</span><span class="p">);</span>
<span class="w">        </span><span class="n">assignDefault</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;httpPort&quot;</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;&quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">serverPort</span><span class="p">);</span>
<span class="w">        </span><span class="n">assignDefault</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;context&quot;</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;&quot;</span><span class="p">);</span>
<span class="w">        </span><span class="n">assignDefault</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;slowdown&quot;</span><span class="p">,</span><span class="w"> </span><span class="s">&quot;/run/APP/PUBLISHED/js_label.js&quot;</span><span class="p">);</span>

<span class="w">        </span><span class="kt">int</span><span class="w"> </span><span class="n">port</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">serverPort</span><span class="p">;</span>
<span class="w">        </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">port</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Integer</span><span class="p">.</span><span class="na">parseInt</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;httpPort&quot;</span><span class="p">));</span>
<span class="w">        </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">NumberFormatException</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// keep default value for port</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="c1">// Add help for System.out</span>
<span class="w">        </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;-------------------------------------------------\n&quot;</span>
<span class="w">                </span><span class="o">+</span><span class="w"> </span><span class="s">&quot;Starting Vaadin in &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">mode</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot;.\n&quot;</span>
<span class="w">                </span><span class="o">+</span><span class="w"> </span><span class="s">&quot;Running in http://localhost:&quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">port</span>
<span class="w">                </span><span class="o">+</span><span class="w"> </span><span class="s">&quot;\n-------------------------------------------------\n&quot;</span><span class="p">);</span>

<span class="w">        </span><span class="kd">final</span><span class="w"> </span><span class="n">Server</span><span class="w"> </span><span class="n">server</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">Server</span><span class="p">();</span>

<span class="w">        </span><span class="kd">final</span><span class="w"> </span><span class="n">ServerConnector</span><span class="w"> </span><span class="n">connector</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">ServerConnector</span><span class="p">(</span><span class="n">server</span><span class="p">);</span>

<span class="w">        </span><span class="n">connector</span><span class="p">.</span><span class="na">setPort</span><span class="p">(</span><span class="n">port</span><span class="p">);</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;withssl&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">SslContextFactory</span><span class="w"> </span><span class="n">sslFact</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">SslContextFactory</span><span class="p">();</span>
<span class="w">            </span><span class="n">sslFact</span><span class="p">.</span><span class="na">setTrustStorePath</span><span class="p">(</span><span class="n">KEYSTORE</span><span class="p">);</span>
<span class="w">            </span><span class="n">sslFact</span><span class="p">.</span><span class="na">setTrustStorePassword</span><span class="p">(</span><span class="s">&quot;password&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="n">sslFact</span><span class="p">.</span><span class="na">setKeyStorePath</span><span class="p">(</span><span class="n">KEYSTORE</span><span class="p">);</span>
<span class="w">            </span><span class="n">sslFact</span><span class="p">.</span><span class="na">setKeyManagerPassword</span><span class="p">(</span><span class="s">&quot;password&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="n">sslFact</span><span class="p">.</span><span class="na">setKeyStorePassword</span><span class="p">(</span><span class="s">&quot;password&quot;</span><span class="p">);</span>

<span class="w">            </span><span class="n">ServerConnector</span><span class="w"> </span><span class="n">sslConnector</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">ServerConnector</span><span class="p">(</span><span class="n">server</span><span class="p">,</span><span class="w"> </span><span class="n">sslFact</span><span class="p">);</span>
<span class="w">            </span><span class="n">sslConnector</span><span class="p">.</span><span class="na">setPort</span><span class="p">(</span><span class="mi">8444</span><span class="p">);</span>

<span class="w">            </span><span class="n">server</span><span class="p">.</span><span class="na">setConnectors</span><span class="p">(</span><span class="k">new</span><span class="w"> </span><span class="n">Connector</span><span class="o">[]</span><span class="w"> </span><span class="p">{</span><span class="w"> </span><span class="n">connector</span><span class="p">,</span><span class="w"> </span><span class="n">sslConnector</span><span class="w"> </span><span class="p">});</span>
<span class="w">        </span><span class="p">}</span><span class="w"> </span><span class="k">else</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">server</span><span class="p">.</span><span class="na">setConnectors</span><span class="p">(</span><span class="k">new</span><span class="w"> </span><span class="n">Connector</span><span class="o">[]</span><span class="w"> </span><span class="p">{</span><span class="w"> </span><span class="n">connector</span><span class="w"> </span><span class="p">});</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="kd">final</span><span class="w"> </span><span class="n">WebAppContext</span><span class="w"> </span><span class="n">webappcontext</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">WebAppContext</span><span class="p">();</span>
<span class="w">        </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">setContextPath</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;context&quot;</span><span class="p">));</span>
<span class="w">        </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">setWar</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;webroot&quot;</span><span class="p">));</span>
<span class="w">        </span><span class="n">server</span><span class="p">.</span><span class="na">setHandler</span><span class="p">(</span><span class="n">webappcontext</span><span class="p">);</span>

<span class="w">        </span><span class="c1">// --slowdown=/run/APP/PUBLISHED/*,/other/path/asd.jpg</span>
<span class="w">        </span><span class="c1">// slows down specified paths</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;slowdown&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">String</span><span class="o">[]</span><span class="w"> </span><span class="n">paths</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;slowdown&quot;</span><span class="p">).</span><span class="na">split</span><span class="p">(</span><span class="s">&quot;,&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">String</span><span class="w"> </span><span class="n">p</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">paths</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Slowing down: &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">p</span><span class="p">);</span>
<span class="w">                </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">addFilter</span><span class="p">(</span><span class="n">SlowFilter</span><span class="p">.</span><span class="na">class</span><span class="p">,</span><span class="w"> </span><span class="n">p</span><span class="p">,</span>
<span class="w">                        </span><span class="n">EnumSet</span><span class="p">.</span><span class="na">of</span><span class="p">(</span><span class="n">DispatcherType</span><span class="p">.</span><span class="na">REQUEST</span><span class="p">));</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">        </span><span class="c1">// --cache=/run/APP/PUBLISHED/*,/other/path/asd.jpg</span>
<span class="w">        </span><span class="c1">// caches specified paths</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;cache&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">String</span><span class="o">[]</span><span class="w"> </span><span class="n">paths</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;cache&quot;</span><span class="p">).</span><span class="na">split</span><span class="p">(</span><span class="s">&quot;,&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">String</span><span class="w"> </span><span class="n">p</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">paths</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Enabling cache for: &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">p</span><span class="p">);</span>
<span class="w">                </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">addFilter</span><span class="p">(</span><span class="n">CacheFilter</span><span class="p">.</span><span class="na">class</span><span class="p">,</span><span class="w"> </span><span class="n">p</span><span class="p">,</span>
<span class="w">                        </span><span class="n">EnumSet</span><span class="p">.</span><span class="na">of</span><span class="p">(</span><span class="n">DispatcherType</span><span class="p">.</span><span class="na">REQUEST</span><span class="p">));</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="c1">// --autoreload=all --autoreload=WebContent/classes,other/path</span>
<span class="w">        </span><span class="c1">// --scaninterval=1</span>
<span class="w">        </span><span class="c1">// Configure Jetty to auto-reload when a any class is compiled in</span>
<span class="w">        </span><span class="c1">// any folder included in the list of folders passed as arguments</span>
<span class="w">        </span><span class="c1">// or in the entire classpath if the keyworkd all is passed.</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;autoreload&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="kt">int</span><span class="w"> </span><span class="n">interval</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="mi">1</span><span class="p">;</span>
<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;scaninterval&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">interval</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Integer</span><span class="p">.</span><span class="na">parseInt</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;scaninterval&quot;</span><span class="p">));</span>
<span class="w">            </span><span class="p">}</span>

<span class="w">            </span><span class="n">List</span><span class="o">&lt;</span><span class="n">File</span><span class="o">&gt;</span><span class="w"> </span><span class="n">classFolders</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">ArrayList</span><span class="o">&lt;&gt;</span><span class="p">();</span>
<span class="w">            </span><span class="n">String</span><span class="o">[]</span><span class="w"> </span><span class="n">paths</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;autoreload&quot;</span><span class="p">).</span><span class="na">split</span><span class="p">(</span><span class="s">&quot;,&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">paths</span><span class="p">.</span><span class="na">length</span><span class="w"> </span><span class="o">==</span><span class="w"> </span><span class="mi">1</span><span class="w"> </span><span class="o">&amp;&amp;</span><span class="w"> </span><span class="s">&quot;all&quot;</span><span class="p">.</span><span class="na">equals</span><span class="p">(</span><span class="n">paths</span><span class="o">[</span><span class="mi">0</span><span class="o">]</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">ClassLoader</span><span class="w"> </span><span class="n">cl</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">server</span><span class="p">.</span><span class="na">getClass</span><span class="p">().</span><span class="na">getClassLoader</span><span class="p">();</span>
<span class="w">                </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">URL</span><span class="w"> </span><span class="n">u</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="p">((</span><span class="n">URLClassLoader</span><span class="p">)</span><span class="w"> </span><span class="n">cl</span><span class="p">).</span><span class="na">getURLs</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">                    </span><span class="n">File</span><span class="w"> </span><span class="n">f</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">File</span><span class="p">(</span><span class="n">u</span><span class="p">.</span><span class="na">getPath</span><span class="p">());</span>
<span class="w">                    </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">f</span><span class="p">.</span><span class="na">isDirectory</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">                        </span><span class="n">classFolders</span><span class="p">.</span><span class="na">add</span><span class="p">(</span><span class="n">f</span><span class="p">);</span>
<span class="w">                    </span><span class="p">}</span>
<span class="w">                </span><span class="p">}</span>
<span class="w">            </span><span class="p">}</span><span class="w"> </span><span class="k">else</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">String</span><span class="w"> </span><span class="n">p</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">paths</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                    </span><span class="n">File</span><span class="w"> </span><span class="n">f</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">File</span><span class="p">(</span><span class="n">p</span><span class="p">);</span>
<span class="w">                    </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">f</span><span class="p">.</span><span class="na">isDirectory</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">                        </span><span class="n">classFolders</span><span class="p">.</span><span class="na">add</span><span class="p">(</span><span class="n">f</span><span class="p">);</span>
<span class="w">                    </span><span class="p">}</span>
<span class="w">                </span><span class="p">}</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="o">!</span><span class="n">classFolders</span><span class="p">.</span><span class="na">isEmpty</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span>
<span class="w">                        </span><span class="s">&quot;Enabling context auto-reload.\n Scan interval: &quot;</span>
<span class="w">                                </span><span class="o">+</span><span class="w"> </span><span class="n">interval</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; secs.\n Scanned folders: &quot;</span><span class="p">);</span>
<span class="w">                </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">File</span><span class="w"> </span><span class="n">f</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">classFolders</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                    </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;  &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">f</span><span class="p">.</span><span class="na">getAbsolutePath</span><span class="p">());</span>
<span class="w">                    </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">setExtraClasspath</span><span class="p">(</span><span class="n">f</span><span class="p">.</span><span class="na">getAbsolutePath</span><span class="p">());</span>
<span class="w">                </span><span class="p">}</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;&quot;</span><span class="p">);</span>

<span class="w">                </span><span class="n">Scanner</span><span class="w"> </span><span class="n">scanner</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">Scanner</span><span class="p">();</span>
<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">setScanInterval</span><span class="p">(</span><span class="n">interval</span><span class="p">);</span>

<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">setRecursive</span><span class="p">(</span><span class="kc">true</span><span class="p">);</span>
<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">addListener</span><span class="p">((</span><span class="n">BulkListener</span><span class="p">)</span><span class="w"> </span><span class="n">e</span><span class="w"> </span><span class="o">-&gt;</span><span class="w"> </span><span class="p">{</span>
<span class="w">                    </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">stop</span><span class="p">();</span>
<span class="w">                    </span><span class="n">server</span><span class="p">.</span><span class="na">stop</span><span class="p">();</span>
<span class="w">                    </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>
<span class="w">                    </span><span class="n">server</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>
<span class="w">                </span><span class="p">});</span>
<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">setReportExistingFilesOnStartup</span><span class="p">(</span><span class="kc">false</span><span class="p">);</span>
<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">setFilenameFilter</span><span class="p">(</span>
<span class="w">                        </span><span class="p">(</span><span class="n">folder</span><span class="p">,</span><span class="w"> </span><span class="n">name</span><span class="p">)</span><span class="w"> </span><span class="o">-&gt;</span><span class="w"> </span><span class="n">name</span><span class="p">.</span><span class="na">endsWith</span><span class="p">(</span><span class="s">&quot;.class&quot;</span><span class="p">));</span>

<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">setScanDirs</span><span class="p">(</span><span class="n">classFolders</span><span class="p">);</span>
<span class="w">                </span><span class="n">scanner</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>
<span class="w">                </span><span class="n">server</span><span class="p">.</span><span class="na">addBean</span><span class="p">(</span><span class="n">scanner</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="c1">// Read web.xml to find all configured servlets</span>
<span class="w">        </span><span class="n">webappcontext</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>

<span class="w">        </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">server</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>

<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="s">&quot;shutdownPort&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="kt">int</span><span class="w"> </span><span class="n">shutdownPort</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Integer</span>
<span class="w">                        </span><span class="p">.</span><span class="na">parseInt</span><span class="p">(</span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;shutdownPort&quot;</span><span class="p">));</span>
<span class="w">                </span><span class="kd">final</span><span class="w"> </span><span class="n">ServerSocket</span><span class="w"> </span><span class="n">serverSocket</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">ServerSocket</span><span class="p">(</span><span class="n">shutdownPort</span><span class="p">,</span>
<span class="w">                        </span><span class="mi">1</span><span class="p">,</span><span class="w"> </span><span class="n">InetAddress</span><span class="p">.</span><span class="na">getByName</span><span class="p">(</span><span class="s">&quot;127.0.0.1&quot;</span><span class="p">));</span>
<span class="w">                </span><span class="k">new</span><span class="w"> </span><span class="n">Thread</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">                    </span><span class="nd">@Override</span>
<span class="w">                    </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">run</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">                        </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">                            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span>
<span class="w">                                    </span><span class="s">&quot;Waiting for shutdown signal on port &quot;</span>
<span class="w">                                            </span><span class="o">+</span><span class="w"> </span><span class="n">serverSocket</span><span class="p">.</span><span class="na">getLocalPort</span><span class="p">());</span>
<span class="w">                            </span><span class="c1">// Start waiting for a close signal</span>
<span class="w">                            </span><span class="n">Socket</span><span class="w"> </span><span class="n">accept</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">serverSocket</span><span class="p">.</span><span class="na">accept</span><span class="p">();</span>
<span class="w">                            </span><span class="c1">// First stop listening to the port</span>
<span class="w">                            </span><span class="n">serverSocket</span><span class="p">.</span><span class="na">close</span><span class="p">();</span>

<span class="w">                            </span><span class="c1">// Start a thread that kills the JVM if</span>
<span class="w">                            </span><span class="c1">// server.stop() doesn&#39;t have any effect</span>
<span class="w">                            </span><span class="n">Thread</span><span class="w"> </span><span class="n">interruptThread</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">Thread</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">                                </span><span class="nd">@Override</span>
<span class="w">                                </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">run</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">                                    </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">                                        </span><span class="n">Thread</span><span class="p">.</span><span class="na">sleep</span><span class="p">(</span><span class="mi">5000</span><span class="p">);</span>
<span class="w">                                        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="o">!</span><span class="n">server</span><span class="p">.</span><span class="na">isStopped</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">                                            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span>
<span class="w">                                                    </span><span class="s">&quot;Jetty still running. Closing JVM.&quot;</span><span class="p">);</span>
<span class="w">                                            </span><span class="n">dumpThreadStacks</span><span class="p">();</span>
<span class="w">                                            </span><span class="n">System</span><span class="p">.</span><span class="na">exit</span><span class="p">(</span><span class="o">-</span><span class="mi">1</span><span class="p">);</span>
<span class="w">                                        </span><span class="p">}</span>
<span class="w">                                    </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">InterruptedException</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                                        </span><span class="c1">// Interrupted if server.stop() was</span>
<span class="w">                                        </span><span class="c1">// successful</span>
<span class="w">                                    </span><span class="p">}</span>
<span class="w">                                </span><span class="p">}</span>
<span class="w">                            </span><span class="p">};</span>
<span class="w">                            </span><span class="n">interruptThread</span><span class="p">.</span><span class="na">setDaemon</span><span class="p">(</span><span class="kc">true</span><span class="p">);</span>
<span class="w">                            </span><span class="n">interruptThread</span><span class="p">.</span><span class="na">start</span><span class="p">();</span>

<span class="w">                            </span><span class="c1">// Then stop the jetty server</span>
<span class="w">                            </span><span class="n">server</span><span class="p">.</span><span class="na">stop</span><span class="p">();</span>

<span class="w">                            </span><span class="n">interruptThread</span><span class="p">.</span><span class="na">interrupt</span><span class="p">();</span>

<span class="w">                            </span><span class="c1">// Send a byte to tell the other process that it can</span>
<span class="w">                            </span><span class="c1">// start jetty</span>
<span class="w">                            </span><span class="n">OutputStream</span><span class="w"> </span><span class="n">outputStream</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">accept</span>
<span class="w">                                    </span><span class="p">.</span><span class="na">getOutputStream</span><span class="p">();</span>
<span class="w">                            </span><span class="n">outputStream</span><span class="p">.</span><span class="na">write</span><span class="p">(</span><span class="mi">0</span><span class="p">);</span>
<span class="w">                            </span><span class="n">outputStream</span><span class="p">.</span><span class="na">flush</span><span class="p">();</span>
<span class="w">                            </span><span class="c1">// Finally close the socket</span>
<span class="w">                            </span><span class="n">accept</span><span class="p">.</span><span class="na">close</span><span class="p">();</span>
<span class="w">                        </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">Exception</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                            </span><span class="n">e</span><span class="p">.</span><span class="na">printStackTrace</span><span class="p">();</span>
<span class="w">                        </span><span class="p">}</span>
<span class="w">                    </span><span class="p">}</span>

<span class="w">                </span><span class="p">}.</span><span class="na">start</span><span class="p">();</span>

<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">Exception</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">server</span><span class="p">.</span><span class="na">stop</span><span class="p">();</span>
<span class="w">            </span><span class="k">throw</span><span class="w"> </span><span class="n">e</span><span class="p">;</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="k">return</span><span class="w"> </span><span class="s">&quot;http://localhost:&quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">port</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">serverArgs</span><span class="p">.</span><span class="na">get</span><span class="p">(</span><span class="s">&quot;context&quot;</span><span class="p">);</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="cm">/**</span>
<span class="cm">     * Assign default value for given key.</span>
<span class="cm">     *</span>
<span class="cm">     * @param map</span>
<span class="cm">     * @param key</span>
<span class="cm">     * @param value</span>
<span class="cm">     */</span>
<span class="w">    </span><span class="kd">private</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">assignDefault</span><span class="p">(</span><span class="n">Map</span><span class="o">&lt;</span><span class="n">String</span><span class="p">,</span><span class="w"> </span><span class="n">String</span><span class="o">&gt;</span><span class="w"> </span><span class="n">map</span><span class="p">,</span><span class="w"> </span><span class="n">String</span><span class="w"> </span><span class="n">key</span><span class="p">,</span>
<span class="w">            </span><span class="n">String</span><span class="w"> </span><span class="n">value</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">        </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="o">!</span><span class="n">map</span><span class="p">.</span><span class="na">containsKey</span><span class="p">(</span><span class="n">key</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">map</span><span class="p">.</span><span class="na">put</span><span class="p">(</span><span class="n">key</span><span class="p">,</span><span class="w"> </span><span class="n">value</span><span class="p">);</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="cm">/**</span>
<span class="cm">     * Parse all command line arguments into a map.</span>
<span class="cm">     *</span>
<span class="cm">     * Arguments format &quot;key=value&quot; are put into map.</span>
<span class="cm">     *</span>
<span class="cm">     * @param args</span>
<span class="cm">     * @return map of arguments key value pairs.</span>
<span class="cm">     */</span>
<span class="w">    </span><span class="kd">protected</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="n">Map</span><span class="o">&lt;</span><span class="n">String</span><span class="p">,</span><span class="w"> </span><span class="n">String</span><span class="o">&gt;</span><span class="w"> </span><span class="nf">parseArguments</span><span class="p">(</span><span class="n">String</span><span class="o">[]</span><span class="w"> </span><span class="n">args</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">        </span><span class="kd">final</span><span class="w"> </span><span class="n">Map</span><span class="o">&lt;</span><span class="n">String</span><span class="p">,</span><span class="w"> </span><span class="n">String</span><span class="o">&gt;</span><span class="w"> </span><span class="n">map</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">HashMap</span><span class="o">&lt;&gt;</span><span class="p">();</span>
<span class="w">        </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">String</span><span class="w"> </span><span class="n">arg</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">args</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="kd">final</span><span class="w"> </span><span class="kt">int</span><span class="w"> </span><span class="n">d</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">arg</span><span class="p">.</span><span class="na">indexOf</span><span class="p">(</span><span class="s">&quot;=&quot;</span><span class="p">);</span>
<span class="w">            </span><span class="k">if</span><span class="w"> </span><span class="p">(</span><span class="n">d</span><span class="w"> </span><span class="o">&gt;</span><span class="w"> </span><span class="mi">0</span><span class="w"> </span><span class="o">&amp;&amp;</span><span class="w"> </span><span class="n">d</span><span class="w"> </span><span class="o">&lt;</span><span class="w"> </span><span class="n">arg</span><span class="p">.</span><span class="na">length</span><span class="p">()</span><span class="w"> </span><span class="o">&amp;&amp;</span><span class="w"> </span><span class="n">arg</span><span class="p">.</span><span class="na">startsWith</span><span class="p">(</span><span class="s">&quot;--&quot;</span><span class="p">))</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="kd">final</span><span class="w"> </span><span class="n">String</span><span class="w"> </span><span class="n">name</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">arg</span><span class="p">.</span><span class="na">substring</span><span class="p">(</span><span class="mi">2</span><span class="p">,</span><span class="w"> </span><span class="n">d</span><span class="p">);</span>
<span class="w">                </span><span class="kd">final</span><span class="w"> </span><span class="n">String</span><span class="w"> </span><span class="n">value</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">arg</span><span class="p">.</span><span class="na">substring</span><span class="p">(</span><span class="n">d</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="mi">1</span><span class="p">);</span>
<span class="w">                </span><span class="n">map</span><span class="p">.</span><span class="na">put</span><span class="p">(</span><span class="n">name</span><span class="p">,</span><span class="w"> </span><span class="n">value</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">        </span><span class="k">return</span><span class="w"> </span><span class="n">map</span><span class="p">;</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="cm">/**</span>
<span class="cm">     * Sleeps for 2-5 seconds when serving resources that matches given</span>
<span class="cm">     * pathSpec. --slowdown=/run/APP/PUBLISHED/*,/other/path/asd.jpg</span>
<span class="cm">     */</span>
<span class="w">    </span><span class="kd">public</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kd">class</span> <span class="nc">SlowFilter</span><span class="w"> </span><span class="kd">implements</span><span class="w"> </span><span class="n">Filter</span><span class="w"> </span><span class="p">{</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">init</span><span class="p">(</span><span class="n">FilterConfig</span><span class="w"> </span><span class="n">filterConfig</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">ServletException</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// TODO Auto-generated method stub</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">doFilter</span><span class="p">(</span><span class="n">ServletRequest</span><span class="w"> </span><span class="n">request</span><span class="p">,</span><span class="w"> </span><span class="n">ServletResponse</span><span class="w"> </span><span class="n">response</span><span class="p">,</span>
<span class="w">                </span><span class="n">FilterChain</span><span class="w"> </span><span class="n">chain</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">IOException</span><span class="p">,</span><span class="w"> </span><span class="n">ServletException</span><span class="w"> </span><span class="p">{</span>

<span class="w">            </span><span class="n">String</span><span class="w"> </span><span class="n">path</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="p">((</span><span class="n">HttpServletRequest</span><span class="p">)</span><span class="w"> </span><span class="n">request</span><span class="p">).</span><span class="na">getPathInfo</span><span class="p">();</span>
<span class="w">            </span><span class="kt">long</span><span class="w"> </span><span class="n">delay</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Math</span><span class="p">.</span><span class="na">round</span><span class="p">(</span><span class="n">Math</span><span class="p">.</span><span class="na">random</span><span class="p">()</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="mi">3000</span><span class="p">)</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="mi">2000</span><span class="p">;</span>
<span class="w">            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Delaying &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">path</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; for &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">delay</span><span class="p">);</span>

<span class="w">            </span><span class="k">try</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">Thread</span><span class="p">.</span><span class="na">sleep</span><span class="p">(</span><span class="n">delay</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span><span class="w"> </span><span class="k">catch</span><span class="w"> </span><span class="p">(</span><span class="n">InterruptedException</span><span class="w"> </span><span class="n">e</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Delay interrupted for &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">path</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span><span class="w"> </span><span class="k">finally</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;Resuming &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">path</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span>

<span class="w">            </span><span class="n">chain</span><span class="p">.</span><span class="na">doFilter</span><span class="p">(</span><span class="n">request</span><span class="p">,</span><span class="w"> </span><span class="n">response</span><span class="p">);</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">destroy</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// TODO Auto-generated method stub</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="cm">/**</span>
<span class="cm">     * Adds &quot;Expires&quot; and &quot;Cache-control&quot; headers when serving resources that</span>
<span class="cm">     * match given pathSpec, in order to cache resource for CACHE_MINUTES.</span>
<span class="cm">     * --cache=/run/APP/PUBLISHED/*,/other/path/asd.jpg</span>
<span class="cm">     */</span>
<span class="w">    </span><span class="kd">public</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kd">class</span> <span class="nc">CacheFilter</span><span class="w"> </span><span class="kd">implements</span><span class="w"> </span><span class="n">Filter</span><span class="w"> </span><span class="p">{</span>

<span class="w">        </span><span class="kd">private</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kd">final</span><span class="w"> </span><span class="kt">int</span><span class="w"> </span><span class="n">CACHE_MINUTES</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="mi">1</span><span class="p">;</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">init</span><span class="p">(</span><span class="n">FilterConfig</span><span class="w"> </span><span class="n">filterConfig</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">ServletException</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// TODO Auto-generated method stub</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">doFilter</span><span class="p">(</span><span class="n">ServletRequest</span><span class="w"> </span><span class="n">request</span><span class="p">,</span><span class="w"> </span><span class="n">ServletResponse</span><span class="w"> </span><span class="n">response</span><span class="p">,</span>
<span class="w">                </span><span class="n">FilterChain</span><span class="w"> </span><span class="n">chain</span><span class="p">)</span><span class="w"> </span><span class="kd">throws</span><span class="w"> </span><span class="n">IOException</span><span class="p">,</span><span class="w"> </span><span class="n">ServletException</span><span class="w"> </span><span class="p">{</span>

<span class="w">            </span><span class="n">String</span><span class="w"> </span><span class="n">path</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="p">((</span><span class="n">HttpServletRequest</span><span class="p">)</span><span class="w"> </span><span class="n">request</span><span class="p">).</span><span class="na">getPathInfo</span><span class="p">();</span>
<span class="w">            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span>
<span class="w">                    </span><span class="s">&quot;Caching &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">path</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; for &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">CACHE_MINUTES</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; minutes&quot;</span><span class="p">);</span>

<span class="w">            </span><span class="n">Calendar</span><span class="w"> </span><span class="n">calendar</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">Calendar</span><span class="p">.</span><span class="na">getInstance</span><span class="p">();</span>
<span class="w">            </span><span class="n">calendar</span><span class="p">.</span><span class="na">add</span><span class="p">(</span><span class="n">Calendar</span><span class="p">.</span><span class="na">MINUTE</span><span class="p">,</span><span class="w"> </span><span class="n">CACHE_MINUTES</span><span class="p">);</span>

<span class="w">            </span><span class="n">String</span><span class="w"> </span><span class="n">expires</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="k">new</span><span class="w"> </span><span class="n">SimpleDateFormat</span><span class="p">(</span><span class="s">&quot;EEE, dd MMM yyyy HH:mm:ss z&quot;</span><span class="p">)</span>
<span class="w">                    </span><span class="p">.</span><span class="na">format</span><span class="p">(</span><span class="n">calendar</span><span class="p">.</span><span class="na">getTime</span><span class="p">());</span>

<span class="w">            </span><span class="p">((</span><span class="n">HttpServletResponse</span><span class="p">)</span><span class="w"> </span><span class="n">response</span><span class="p">).</span><span class="na">setHeader</span><span class="p">(</span><span class="s">&quot;Expires&quot;</span><span class="p">,</span><span class="w"> </span><span class="n">expires</span><span class="p">);</span>
<span class="w">            </span><span class="p">((</span><span class="n">HttpServletResponse</span><span class="p">)</span><span class="w"> </span><span class="n">response</span><span class="p">).</span><span class="na">setHeader</span><span class="p">(</span><span class="s">&quot;Cache-Control&quot;</span><span class="p">,</span>
<span class="w">                    </span><span class="s">&quot;max-age=&quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="p">(</span><span class="n">CACHE_MINUTES</span><span class="w"> </span><span class="o">*</span><span class="w"> </span><span class="mi">60</span><span class="p">));</span>

<span class="w">            </span><span class="n">chain</span><span class="p">.</span><span class="na">doFilter</span><span class="p">(</span><span class="n">request</span><span class="p">,</span><span class="w"> </span><span class="n">response</span><span class="p">);</span>
<span class="w">        </span><span class="p">}</span>

<span class="w">        </span><span class="nd">@Override</span>
<span class="w">        </span><span class="kd">public</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">destroy</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="c1">// TODO Auto-generated method stub</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">    </span><span class="p">}</span>

<span class="w">    </span><span class="kd">private</span><span class="w"> </span><span class="kd">static</span><span class="w"> </span><span class="kt">void</span><span class="w"> </span><span class="nf">dumpThreadStacks</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w">        </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">Entry</span><span class="o">&lt;</span><span class="n">Thread</span><span class="p">,</span><span class="w"> </span><span class="n">StackTraceElement</span><span class="o">[]&gt;</span><span class="w"> </span><span class="n">entry</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">Thread</span>
<span class="w">                </span><span class="p">.</span><span class="na">getAllStackTraces</span><span class="p">().</span><span class="na">entrySet</span><span class="p">())</span><span class="w"> </span><span class="p">{</span>
<span class="w">            </span><span class="n">Thread</span><span class="w"> </span><span class="n">thread</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">entry</span><span class="p">.</span><span class="na">getKey</span><span class="p">();</span>
<span class="w">            </span><span class="n">StackTraceElement</span><span class="o">[]</span><span class="w"> </span><span class="n">stackTraceElements</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">entry</span><span class="p">.</span><span class="na">getValue</span><span class="p">();</span>

<span class="w">            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="n">thread</span><span class="p">.</span><span class="na">getName</span><span class="p">()</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="s">&quot; - &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">thread</span><span class="p">.</span><span class="na">getState</span><span class="p">());</span>
<span class="w">            </span><span class="k">for</span><span class="w"> </span><span class="p">(</span><span class="n">StackTraceElement</span><span class="w"> </span><span class="n">stackTraceElement</span><span class="w"> </span><span class="p">:</span><span class="w"> </span><span class="n">stackTraceElements</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w">                </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">(</span><span class="s">&quot;    at &quot;</span><span class="w"> </span><span class="o">+</span><span class="w"> </span><span class="n">stackTraceElement</span><span class="p">);</span>
<span class="w">            </span><span class="p">}</span>
<span class="w">            </span><span class="n">System</span><span class="p">.</span><span class="na">out</span><span class="p">.</span><span class="na">println</span><span class="p">();</span>
<span class="w">        </span><span class="p">}</span>
<span class="w">    </span><span class="p">}</span>

<span class="p">}</span>
</pre></div>