String createUpgradeRequest()

in src/main/java/com/microsoft/azure/proton/transport/ws/WebSocketHandler.java [54:157]
32 lines of code
1 McCabe index (conditional complexity)

    String createUpgradeRequest(
            String hostName,
            String webSocketPath,
            String webSocketQuery,
            int webSocketPort,
            String webSocketProtocol,
            Map<String, String> additionalHeaders);

    /**
     * Validates the response.
     *
     * @param buffer ByteBuffer to read from.
     * @return True if the response is valid, otherwise, false.
     */
    Boolean validateUpgradeReply(ByteBuffer buffer);

    /**
     * Wraps the source buffer with additional contents from the web socket.
     *
     * @param srcBuffer Source buffer to wrap input.
     * @param dstBuffer Output buffer that bytes are written to.
     */
    void wrapBuffer(ByteBuffer srcBuffer, ByteBuffer dstBuffer);

    /**
     * Unwraps the layer from the buffer.
     *
     * @param srcBuffer The source buffer.
     * @return The current chunk for the web socket when reading.
     */
    WebsocketTuple unwrapBuffer(ByteBuffer srcBuffer);

    /**
     * Creates the pong for the "keep-alive", heart beat, network status probing when connecting in a web socket.
     *
     * @param srcBuffer The source buffer to read from.
     * @param dstBuffer The destination buffer with the pong.
     * @see <a href="https://html.spec.whatwg.org/multipage/web-sockets.html#ping-and-pong-frames">Ping and pong</a>
     */
    void createPong(ByteBuffer srcBuffer, ByteBuffer dstBuffer);

    /**
     * Gets the size of the header.
     *
     * @param payloadSize Size of the payload.
     * @return The size of the header.
     */
    int calculateHeaderSize(int payloadSize);

    /**
     * Represents the web socket message and its type.
     */
    class WebsocketTuple {

        private long length;
        private WebSocketMessageType type;

        /**
         * Creates an instance with the given length and type.
         *
         * @param length Length of the segment.
         * @param type Type of the socket message.
         */
        public WebsocketTuple(long length, WebSocketMessageType type) {
            this.length = length;
            this.type = type;
        }

        /**
         * Sets the length of the message.
         *
         * @param length The length of the message.
         */
        public void setLength(long length) {
            this.length = length;
        }

        /**
         * Sets the message type.
         *
         * @param type The message type.
         */
        public void setType(WebSocketMessageType type) {
            this.type = type;
        }

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

        /**
         * Gets the type of the message.
         *
         * @return The type of the message.
         */
        public WebSocketMessageType getType() {
            return this.type;
        }
    }