ResponseWrapper.java

Go to the documentation of this file.

package org.openkilda.security.filter;

import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.util.UUID;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpServletResponseWrapper;

public class ResponseWrapper extends HttpServletResponseWrapper {

    private UUID id;
    private ServletOutputStream outputStream;
    private PrintWriter writer;
    private ServletOutputStreamWrapper streamWrapper;

    public ResponseWrapper(UUID requestId, HttpServletResponse response) {
        super(response);
        this.id = requestId;
    }

    /*
     * (non-Javadoc)
     * 
     * @see javax.servlet.ServletResponseWrapper#getOutputStream()
     */
    @Override
    public ServletOutputStream getOutputStream() throws IOException {
        if (writer != null) {
            throw new IllegalStateException("Writer has already been read on this response.");
        }

        if (outputStream == null) {
            outputStream = getResponse().getOutputStream();
            streamWrapper = new ServletOutputStreamWrapper(outputStream);
        }
        return streamWrapper;
    }

    /*
     * (non-Javadoc)
     * 
     * @see javax.servlet.ServletResponseWrapper#getWriter()
     */
    @Override
    public PrintWriter getWriter() throws IOException {
        if (outputStream != null) {
            throw new IllegalStateException("Stream has already been read on this response.");
        }

        if (writer == null) {
            streamWrapper = new ServletOutputStreamWrapper(getResponse().getOutputStream());
            writer =
                    new PrintWriter(new OutputStreamWriter(streamWrapper, getResponse()
                            .getCharacterEncoding()), true);
        }

        return writer;
    }

    /*
     * (non-Javadoc)
     * 
     * @see javax.servlet.ServletResponseWrapper#flushBuffer()
     */
    @Override
    public void flushBuffer() throws IOException {
        if (writer != null) {
            writer.flush();
        } else if (outputStream != null) {
            streamWrapper.flush();
        }
    }

    public byte[] getData() {
        if (streamWrapper != null) {
            return streamWrapper.getData();
        }
        return new byte[0];
    }

    public UUID getId() {
        return id;
    }
}