qhttpmessagestreamparser_p.h

Enable keyboard shortcuts

// Copyright (C) 2021 The Qt Company Ltd.

// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only

// Qt-Security score:significant

#ifndef QHTTPMESSAGESTREAMPARSER_P_H

#define QHTTPMESSAGESTREAMPARSER_P_H

//

//  W A R N I N G

//  -------------

//

// This file is not part of the Qt API.  It exists purely as an

// implementation detail.  This header file may change from version to

// version without notice, or even be removed.

//

// We mean it.

//

#include <QtJsonRpc/qtjsonrpcglobal.h>

#include <QtCore/qbytearray.h>

#include <QtCore/qstring.h>

#include <functional>

QT_BEGIN_NAMESPACE

class Q_JSONRPC_EXPORT QHttpMessageStreamParser

public:

    enum class State {

        PreHeader,

        InHeaderField,

        HeaderValueSpace,

        InHeaderValue,

        AfterCr,

        AfterCrLf,

        AfterCrLfCr,

        InBody

};

/*!

     * \internal

     * \brief Allows to run the FSM with or without keeping any buffers.

*/

    enum Mode { BUFFERED, UNBUFFERED };

    QHttpMessageStreamParser(

            std::function<void(const QByteArray &, const QByteArray &)> headerHandler,

            std::function<void(const QByteArray &body)> bodyHandler,

            std::function<void(QtMsgType, const QString &)> errorHandler, Mode mode = BUFFERED);

    void receiveData(QByteArrayView data);

    bool receiveEof();

    State state() const { return m_state; }

    void setMaxContentLength(int maxSize);

private:

    void callHasHeader();

    void callHasBody();

    void errorMessage(QtMsgType error, const QString &msg);

    std::function<void(const QByteArray &, const QByteArray &)> m_headerHandler;

    std::function<void(const QByteArray &body)> m_bodyHandler;

    std::function<void(QtMsgType error, const QString &msg)> m_errorHandler;

    QByteArray m_currentHeaderField;

    QByteArray m_currentHeaderValue;

    QByteArray m_currentPacket;

    int m_maxContentLength = std::numeric_limits<int>::max();

    State m_state = State::PreHeader;

    int m_contentSize = -1;

    int m_currentPacketSize = 0;

    Mode m_mode;

};

QT_END_NAMESPACE

#endif // QHTTPMESSAGESTREAMPARSER_P_H