reply.hpp

Go to the documentation of this file.

//    OpenVPN -- An application to securely tunnel IP networks
//               over a single port, with support for SSL/TLS-based
//               session authentication and key exchange,
//               packet encryption, packet authentication, and
//               packet compression.
//
//    Copyright (C) 2012- OpenVPN Inc.
//
//    SPDX-License-Identifier: MPL-2.0 OR AGPL-3.0-only WITH openvpn3-openssl-exception
//
//
// Source: pkg:github/chriskohlhoff/asio@asio-1-8-0#asio/src/examples/http
//  Adapted from code Copyright (c) 2003-2012 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
//  Distributed under the Boost Software License, Version 1.0. (See accompanying
//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
 
// Parse an HTTP reply
 
#ifndef OPENVPN_HTTP_REPLY_H
#define OPENVPN_HTTP_REPLY_H
 
#include <openvpn/http/header.hpp>
#include <openvpn/http/parseutil.hpp>
 
namespace openvpn::HTTP {
 
struct Reply
{
    Reply()
        : http_version_major(0), http_version_minor(0), status_code(0)
    {
    }
 
    void reset()
    {
        http_version_major = 0;
        http_version_minor = 0;
        status_code = 0;
        status_text = "";
        headers.clear();
    }
 
    std::string to_string() const
    {
        std::ostringstream out;
        out << "HTTP Reply" << std::endl;
        out << "version=" << http_version_major << '/' << http_version_minor << std::endl;
        out << "status_code=" << status_code << std::endl;
        out << "status_text=" << status_text << std::endl;
        out << headers.to_string();
        return out.str();
    }
 
    int http_version_major;
    int http_version_minor;
    int status_code;
    std::string status_text;
    HeaderList headers;
};
 
class ReplyParser
{
    enum state
    {
        http_version_h,
        http_version_t_1,
        http_version_t_2,
        http_version_p,
        http_version_slash,
        http_version_major_start,
        http_version_major,
        http_version_minor_start,
        http_version_minor,
        status_code_start,
        status_code,
        status_text_start,
        status_text,
        expecting_newline_1,
        header_line_start,
        header_lws,
        header_name,
        space_before_header_value,
        header_value,
        expecting_newline_2,
        expecting_newline_3
    };
 
  public:
    enum status
    {
        pending,
        fail,
        success,
    };
 
    ReplyParser()
        : state_(http_version_h)
    {
    }
 
    // Reset to initial parser state.
    void reset()
    {
        state_ = http_version_h;
    }
 
    // Parse some HTTP reply data.
    status consume(Reply &req, const unsigned char input)
    {
        switch (state_)
        {
        case http_version_h:
            if (input == 'H')
            {
                state_ = http_version_t_1;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_t_1:
            if (input == 'T')
            {
                state_ = http_version_t_2;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_t_2:
            if (input == 'T')
            {
                state_ = http_version_p;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_p:
            if (input == 'P')
            {
                state_ = http_version_slash;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_slash:
            if (input == '/')
            {
                req.http_version_major = 0;
                req.http_version_minor = 0;
                state_ = http_version_major_start;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_major_start:
            if (Util::is_digit(input))
            {
                req.http_version_major = req.http_version_major * 10 + input - '0';
                state_ = http_version_major;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_major:
            if (input == '.')
            {
                state_ = http_version_minor_start;
                return pending;
            }
            else if (Util::is_digit(input))
            {
                req.http_version_major = req.http_version_major * 10 + input - '0';
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_minor_start:
            if (Util::is_digit(input))
            {
                req.http_version_minor = req.http_version_minor * 10 + input - '0';
                state_ = http_version_minor;
                return pending;
            }
            else
            {
                return fail;
            }
        case http_version_minor:
            if (input == ' ')
            {
                state_ = status_code_start;
                return pending;
            }
            else if (Util::is_digit(input))
            {
                req.http_version_minor = req.http_version_minor * 10 + input - '0';
                return pending;
            }
            else
            {
                return fail;
            }
        case status_code_start:
            if (Util::is_digit(input))
            {
                req.status_code = req.status_code * 10 + input - '0';
                state_ = status_code;
                return pending;
            }
            else
            {
                return fail;
            }
        case status_code:
            if (input == ' ')
            {
                state_ = status_text_start;
                return pending;
            }
            else if (Util::is_digit(input))
            {
                req.status_code = req.status_code * 10 + input - '0';
                return pending;
            }
            else
            {
                return fail;
            }
        case status_text_start:
            if (input == '\r')
            {
                state_ = expecting_newline_1;
                return pending;
            }
            else if (!Util::is_char(input) || Util::is_ctl(input) || Util::is_tspecial(input))
            {
                return fail;
            }
            else
            {
                state_ = status_text;
                req.status_text.push_back(input);
                return pending;
            }
        case status_text:
            if (input == '\r')
            {
                state_ = expecting_newline_1;
                return pending;
            }
            else if (!Util::is_char(input) || Util::is_ctl(input))
            {
                return fail;
            }
            else
            {
                req.status_text.push_back(input);
                return pending;
            }
        case expecting_newline_1:
            if (input == '\n')
            {
                state_ = header_line_start;
                return pending;
            }
            else
            {
                return fail;
            }
        case header_line_start:
            if (input == '\r')
            {
                state_ = expecting_newline_3;
                return pending;
            }
            else if (!req.headers.empty() && (input == ' ' || input == '\t'))
            {
                state_ = header_lws;
                return pending;
            }
            else if (!Util::is_char(input) || Util::is_ctl(input) || Util::is_tspecial(input))
            {
                return fail;
            }
            else
            {
                req.headers.push_back(Header());
                req.headers.back().name.push_back(input);
                state_ = header_name;
                return pending;
            }
        case header_lws:
            if (input == '\r')
            {
                state_ = expecting_newline_2;
                return pending;
            }
            else if (input == ' ' || input == '\t')
            {
                return pending;
            }
            else if (Util::is_ctl(input))
            {
                return fail;
            }
            else
            {
                state_ = header_value;
                req.headers.back().value.push_back(input);
                return pending;
            }
        case header_name:
            if (input == ':')
            {
                state_ = space_before_header_value;
                return pending;
            }
            else if (!Util::is_char(input) || Util::is_ctl(input) || Util::is_tspecial(input))
            {
                return fail;
            }
            else
            {
                req.headers.back().name.push_back(input);
                return pending;
            }
        case space_before_header_value:
            if (input == ' ')
            {
                state_ = header_value;
                return pending;
            }
            else
            {
                return fail;
            }
        case header_value:
            if (input == '\r')
            {
                state_ = expecting_newline_2;
                return pending;
            }
            else if (Util::is_ctl(input))
            {
                return fail;
            }
            else
            {
                req.headers.back().value.push_back(input);
                return pending;
            }
        case expecting_newline_2:
            if (input == '\n')
            {
                state_ = header_line_start;
                return pending;
            }
            else
            {
                return fail;
            }
        case expecting_newline_3:
            if (input == '\n')
                return success;
            else
                return fail;
        default:
            return fail;
        }
    }
 
  private:
    // The current state of the parser.
    state state_;
};
 
struct ReplyType
{
    typedef Reply State;
    typedef ReplyParser Parser;
};
} // namespace openvpn::HTTP
 
#endif