This commit is contained in:
k1988 2017-11-16 10:40:51 +08:00
commit c5f8e73277
9 changed files with 249 additions and 112 deletions

View file

@ -16,7 +16,7 @@ script:
make && make &&
CTEST_OUTPUT_ON_FAILURE=1 make test && CTEST_OUTPUT_ON_FAILURE=1 make test &&
rm -r * && rm -r * &&
CXX=g++ cmake -DCMAKE_CXX_FLAGS=\"-Werror -O3 -DUSE_STANDALONE_ASIO\" .. && CXX=g++ cmake -DUSE_STANDALONE_ASIO=ON -DCMAKE_CXX_FLAGS=\"-Werror -O3\" .. &&
make && make &&
CTEST_OUTPUT_ON_FAILURE=1 make test CTEST_OUTPUT_ON_FAILURE=1 make test
" "

View file

@ -1,52 +1,77 @@
cmake_minimum_required (VERSION 2.8.8) cmake_minimum_required (VERSION 2.8.8)
project (Simple-Web-Server)
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -std=c++11 -Wall -Wextra -Wsign-conversion")
include_directories(.) project (Simple-Web-Server)
option(USE_STANDALONE_ASIO "set ON to use standalone Asio instead of Boost.Asio" OFF)
option(BUILD_TESTING "set ON to build library tests" OFF)
if(NOT MSVC)
add_compile_options(-std=c++11 -Wall -Wextra -Wsign-conversion)
else()
add_compile_options(/W1)
endif()
add_library(simple-web-server INTERFACE)
target_include_directories(simple-web-server INTERFACE ${CMAKE_CURRENT_SOURCE_DIR})
find_package(Threads REQUIRED) find_package(Threads REQUIRED)
target_link_libraries(simple-web-server INTERFACE ${CMAKE_THREAD_LIBS_INIT})
set(BOOST_COMPONENTS system filesystem thread) # TODO 2020 when Debian Jessie LTS ends:
# Late 2017 TODO: remove the following checks and always use std::regex # Remove Boost system, thread, regex components; use Boost::<component> aliases; remove Boost target_include_directories
if("${CMAKE_CXX_COMPILER_ID}" STREQUAL "GNU") if(USE_STANDALONE_ASIO)
if (CMAKE_CXX_COMPILER_VERSION VERSION_LESS 4.9) target_compile_definitions(simple-web-server INTERFACE USE_STANDALONE_ASIO)
set(BOOST_COMPONENTS ${BOOST_COMPONENTS} regex) include(CheckIncludeFileCXX)
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -DUSE_BOOST_REGEX") CHECK_INCLUDE_FILE_CXX(asio.hpp HAVE_ASIO)
if(NOT HAVE_ASIO)
message(FATAL_ERROR "Standalone Asio not found")
endif()
else()
find_package(Boost 1.53.0 COMPONENTS system thread REQUIRED)
target_link_libraries(simple-web-server INTERFACE ${Boost_LIBRARIES})
target_include_directories(simple-web-server INTERFACE ${Boost_INCLUDE_DIR})
if("${CMAKE_CXX_COMPILER_ID}" STREQUAL "GNU" AND CMAKE_CXX_COMPILER_VERSION VERSION_LESS 4.9)
target_compile_definitions(simple-web-server INTERFACE USE_BOOST_REGEX)
find_package(Boost 1.53.0 COMPONENTS regex REQUIRED)
target_link_libraries(simple-web-server INTERFACE ${Boost_LIBRARIES})
target_include_directories(simple-web-server INTERFACE ${Boost_INCLUDE_DIR})
endif() endif()
endif() endif()
find_package(Boost 1.53.0 COMPONENTS ${BOOST_COMPONENTS} REQUIRED) if(WIN32)
include_directories(SYSTEM ${Boost_INCLUDE_DIR}) target_link_libraries(simple-web-server INTERFACE ws2_32 wsock32)
endif()
if(APPLE) if(APPLE)
set(OPENSSL_ROOT_DIR "/usr/local/opt/openssl") set(OPENSSL_ROOT_DIR "/usr/local/opt/openssl")
endif() endif()
add_executable(http_examples http_examples.cpp)
target_link_libraries(http_examples ${Boost_LIBRARIES})
target_link_libraries(http_examples ${CMAKE_THREAD_LIBS_INIT})
#TODO: add requirement for version 1.0.1g (can it be done in one line?)
find_package(OpenSSL) find_package(OpenSSL)
if(OPENSSL_FOUND) if(OPENSSL_FOUND)
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -DHAVE_OPENSSL") target_compile_definitions(simple-web-server INTERFACE HAVE_OPENSSL)
target_link_libraries(http_examples ${OPENSSL_LIBRARIES}) target_link_libraries(simple-web-server INTERFACE ${OPENSSL_LIBRARIES})
include_directories(SYSTEM ${OPENSSL_INCLUDE_DIR}) target_include_directories(simple-web-server INTERFACE ${OPENSSL_INCLUDE_DIR})
add_executable(https_examples https_examples.cpp)
target_link_libraries(https_examples ${Boost_LIBRARIES})
target_link_libraries(https_examples ${OPENSSL_LIBRARIES})
target_link_libraries(https_examples ${CMAKE_THREAD_LIBS_INIT})
endif() endif()
if(MSYS) #TODO: Is MSYS true when MSVC is true? # If Simple-Web-Server is not a sub-project:
target_link_libraries(http_examples ws2_32 wsock32) if("${CMAKE_SOURCE_DIR}" STREQUAL "${CMAKE_CURRENT_SOURCE_DIR}")
add_executable(http_examples http_examples.cpp)
target_link_libraries(http_examples simple-web-server)
find_package(Boost 1.53.0 COMPONENTS system thread filesystem REQUIRED)
target_link_libraries(http_examples ${Boost_LIBRARIES})
target_include_directories(http_examples PRIVATE ${Boost_INCLUDE_DIR})
if(OPENSSL_FOUND) if(OPENSSL_FOUND)
target_link_libraries(https_examples ws2_32 wsock32) add_executable(https_examples https_examples.cpp)
target_link_libraries(https_examples simple-web-server)
target_link_libraries(https_examples ${Boost_LIBRARIES})
target_include_directories(https_examples PRIVATE ${Boost_INCLUDE_DIR})
endif() endif()
set(BUILD_TESTING ON)
install(FILES server_http.hpp client_http.hpp server_https.hpp client_https.hpp crypto.hpp utility.hpp status_code.hpp DESTINATION include/simple-web-server)
endif() endif()
enable_testing() if(BUILD_TESTING)
add_subdirectory(tests) enable_testing()
add_subdirectory(tests)
install(FILES server_http.hpp client_http.hpp server_https.hpp client_https.hpp crypto.hpp utility.hpp status_code.hpp DESTINATION include/simple-web-server) endif()

View file

@ -68,7 +68,12 @@ namespace SimpleWeb {
b64 = BIO_new(BIO_f_base64()); b64 = BIO_new(BIO_f_base64());
BIO_set_flags(b64, BIO_FLAGS_BASE64_NO_NL); BIO_set_flags(b64, BIO_FLAGS_BASE64_NO_NL);
// TODO: Cannot find the exact version this change happended. Remove in 2020
#if OPENSSL_VERSION_NUMBER <= 0x1000114fL
bio = BIO_new_mem_buf((char *)&base64[0], static_cast<int>(base64.size()));
#else
bio = BIO_new_mem_buf(&base64[0], static_cast<int>(base64.size())); bio = BIO_new_mem_buf(&base64[0], static_cast<int>(base64.size()));
#endif
bio = BIO_push(b64, bio); bio = BIO_push(b64, bio);
auto decoded_length = BIO_read(bio, &ascii[0], static_cast<int>(ascii.size())); auto decoded_length = BIO_read(bio, &ascii[0], static_cast<int>(ascii.size()));

View file

@ -183,10 +183,9 @@ namespace SimpleWeb {
friend class Session; friend class Session;
asio::streambuf streambuf; asio::streambuf streambuf;
std::shared_ptr<asio::ip::tcp::endpoint> remote_endpoint;
Request(std::size_t max_request_streambuf_size, std::shared_ptr<asio::ip::tcp::endpoint> remote_endpoint) noexcept Request(std::size_t max_request_streambuf_size, std::shared_ptr<asio::ip::tcp::endpoint> remote_endpoint) noexcept
: streambuf(max_request_streambuf_size), remote_endpoint(std::move(remote_endpoint)), content(streambuf) {} : streambuf(max_request_streambuf_size), content(streambuf), remote_endpoint(std::move(remote_endpoint)) {}
public: public:
std::string method, path, query_string, http_version; std::string method, path, query_string, http_version;
@ -197,6 +196,8 @@ namespace SimpleWeb {
regex::smatch path_match; regex::smatch path_match;
std::shared_ptr<asio::ip::tcp::endpoint> remote_endpoint;
std::string remote_endpoint_address() noexcept { std::string remote_endpoint_address() noexcept {
try { try {
return remote_endpoint->address().to_string(); return remote_endpoint->address().to_string();

View file

@ -1,7 +1,9 @@
#ifndef SIMPLE_WEB_STATUS_CODE_HPP #ifndef SIMPLE_WEB_STATUS_CODE_HPP
#define SIMPLE_WEB_STATUS_CODE_HPP #define SIMPLE_WEB_STATUS_CODE_HPP
#include <map>
#include <string> #include <string>
#include <unordered_map>
#include <vector> #include <vector>
namespace SimpleWeb { namespace SimpleWeb {
@ -138,19 +140,33 @@ namespace SimpleWeb {
} }
inline StatusCode status_code(const std::string &status_code_str) noexcept { inline StatusCode status_code(const std::string &status_code_str) noexcept {
for(auto &status_code : status_codes()) { class StringToStatusCode : public std::unordered_map<std::string, SimpleWeb::StatusCode> {
if(status_code.second == status_code_str) public:
return status_code.first; StringToStatusCode() {
} for(auto &status_code : SimpleWeb::status_codes())
return StatusCode::unknown; emplace(status_code.second, status_code.first);
}
};
static StringToStatusCode string_to_status_code;
auto pos = string_to_status_code.find(status_code_str);
if(pos == string_to_status_code.end())
return StatusCode::unknown;
return pos->second;
} }
const inline std::string &status_code(StatusCode status_code_enum) noexcept { const inline std::string &status_code(StatusCode status_code_enum) noexcept {
for(auto &status_code : status_codes()) { class StatusCodeToString : public std::map<SimpleWeb::StatusCode, std::string> {
if(status_code.first == status_code_enum) public:
return status_code.second; StatusCodeToString() {
} for(auto &status_code : SimpleWeb::status_codes())
return status_codes()[0].second; emplace(status_code.first, status_code.second);
}
};
static StatusCodeToString status_code_to_string;
auto pos = status_code_to_string.find(status_code_enum);
if(pos == status_code_to_string.end())
return status_codes()[0].second;
return pos->second;
} }
} // namespace SimpleWeb } // namespace SimpleWeb

View file

@ -1,26 +1,21 @@
set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -fno-access-control") if(NOT MSVC)
add_compile_options(-fno-access-control)
add_executable(io_test io_test.cpp)
target_link_libraries(io_test simple-web-server)
add_test(io_test io_test)
add_executable(io_test io_test.cpp) add_executable(parse_test parse_test.cpp)
target_link_libraries(io_test ${Boost_LIBRARIES}) target_link_libraries(parse_test simple-web-server)
target_link_libraries(io_test ${CMAKE_THREAD_LIBS_INIT}) add_test(parse_test parse_test)
add_executable(parse_test parse_test.cpp)
target_link_libraries(parse_test ${Boost_LIBRARIES})
target_link_libraries(parse_test ${CMAKE_THREAD_LIBS_INIT})
if(MSYS) #TODO: Is MSYS true when MSVC is true?
target_link_libraries(io_test ws2_32 wsock32)
target_link_libraries(parse_test ws2_32 wsock32)
endif() endif()
add_test(io_test io_test)
add_test(parse_test parse_test)
if(OPENSSL_FOUND) if(OPENSSL_FOUND)
add_executable(crypto_test crypto_test.cpp) add_executable(crypto_test crypto_test.cpp)
target_link_libraries(crypto_test ${OPENSSL_CRYPTO_LIBRARY}) target_link_libraries(crypto_test simple-web-server)
add_test(crypto_test crypto_test) add_test(crypto_test crypto_test)
endif() endif()
add_executable(status_code_test status_code_test.cpp) add_executable(status_code_test status_code_test.cpp)
target_link_libraries(status_code_test simple-web-server)
add_test(status_code_test status_code_test) add_test(status_code_test status_code_test)

View file

@ -64,6 +64,9 @@ int main() {
*response << "HTTP/1.1 200 OK\r\nContent-Length: " << content.length() << "\r\n\r\n" *response << "HTTP/1.1 200 OK\r\nContent-Length: " << content.length() << "\r\n\r\n"
<< content; << content;
assert(!request->remote_endpoint_address().empty());
assert(request->remote_endpoint_port() != 0);
}; };
server.resource["^/string2$"]["POST"] = [](shared_ptr<HttpServer::Response> response, shared_ptr<HttpServer::Request> request) { server.resource["^/string2$"]["POST"] = [](shared_ptr<HttpServer::Response> response, shared_ptr<HttpServer::Request> request) {

View file

@ -195,19 +195,97 @@ int main() {
{ {
{ {
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}}; SimpleWeb::CaseInsensitiveMultimap solution;
auto parsed = SimpleWeb::ContentDisposition::parse("form-data"); auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("");
assert(parsed == solution); assert(parsed == solution);
} }
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"a", ""}};
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("a");
assert(parsed == solution);
}
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"a", ""}, {"b", ""}};
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("a; b");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("a;b");
assert(parsed == solution);
}
}
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"a", ""}, {"b", "c"}};
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("a; b=c");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("a;b=c");
assert(parsed == solution);
}
}
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}};
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data");
assert(parsed == solution);
}
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"test", ""}};
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; test");
assert(parsed == solution);
}
}
{ {
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"name", "file"}}; SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"name", "file"}};
auto parsed = SimpleWeb::ContentDisposition::parse("form-data; name=\"file\""); {
assert(parsed == solution); auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=\"file\"");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=file");
assert(parsed == solution);
}
} }
{ {
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"name", "file"}, {"filename", "filename.png"}}; SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"name", "file"}, {"filename", "filename.png"}};
auto parsed = SimpleWeb::ContentDisposition::parse("form-data; name=\"file\"; filename=\"filename.png\""); {
assert(parsed == solution); auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=\"file\"; filename=\"filename.png\"");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data;name=\"file\";filename=\"filename.png\"");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=file; filename=filename.png");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data;name=file;filename=filename.png");
assert(parsed == solution);
}
}
{
SimpleWeb::CaseInsensitiveMultimap solution = {{"form-data", ""}, {"name", "fi le"}, {"filename", "file name.png"}};
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=\"fi le\"; filename=\"file name.png\"");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=\"fi%20le\"; filename=\"file%20name.png\"");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=fi le; filename=file name.png");
assert(parsed == solution);
}
{
auto parsed = SimpleWeb::HttpHeader::FieldValue::SemicolonSeparatedAttributes::parse("form-data; name=fi%20le; filename=file%20name.png");
assert(parsed == solution);
}
} }
} }
} }

View file

@ -155,7 +155,64 @@ namespace SimpleWeb {
} }
return result; return result;
} }
};
class FieldValue {
public:
class SemicolonSeparatedAttributes {
public:
/// Parse Set-Cookie or Content-Disposition header field value. Attribute values are percent-decoded.
static CaseInsensitiveMultimap parse(const std::string &str) {
CaseInsensitiveMultimap result;
std::size_t name_start_pos = std::string::npos;
std::size_t name_end_pos = std::string::npos;
std::size_t value_start_pos = std::string::npos;
for(std::size_t c = 0; c < str.size(); ++c) {
if(name_start_pos == std::string::npos) {
if(str[c] != ' ' && str[c] != ';')
name_start_pos = c;
}
else {
if(name_end_pos == std::string::npos) {
if(str[c] == ';') {
result.emplace(str.substr(name_start_pos, c - name_start_pos), std::string());
name_start_pos = std::string::npos;
}
else if(str[c] == '=')
name_end_pos = c;
}
else {
if(value_start_pos == std::string::npos) {
if(str[c] == '"' && c + 1 < str.size())
value_start_pos = c + 1;
else
value_start_pos = c;
}
else if(str[c] == '"' || str[c] == ';') {
result.emplace(str.substr(name_start_pos, name_end_pos - name_start_pos), Percent::decode(str.substr(value_start_pos, c - value_start_pos)));
name_start_pos = std::string::npos;
name_end_pos = std::string::npos;
value_start_pos = std::string::npos;
}
}
}
}
if(name_start_pos != std::string::npos) {
if(name_end_pos == std::string::npos)
result.emplace(str.substr(name_start_pos), std::string());
else if(value_start_pos != std::string::npos) {
if(str.back() == '"')
result.emplace(str.substr(name_start_pos, name_end_pos - name_start_pos), Percent::decode(str.substr(value_start_pos, str.size() - 1)));
else
result.emplace(str.substr(name_start_pos, name_end_pos - name_start_pos), Percent::decode(str.substr(value_start_pos)));
}
}
return result;
}
};
};
}; // namespace SimpleWeb
class RequestMessage { class RequestMessage {
public: public:
@ -231,49 +288,6 @@ namespace SimpleWeb {
return true; return true;
} }
}; };
class ContentDisposition {
public:
/// Can be used to parse the Content-Disposition header field value when
/// clients are posting requests with enctype="multipart/form-data"
static CaseInsensitiveMultimap parse(const std::string &line) {
CaseInsensitiveMultimap result;
std::size_t para_start_pos = 0;
std::size_t para_end_pos = std::string::npos;
std::size_t value_start_pos = std::string::npos;
for(std::size_t c = 0; c < line.size(); ++c) {
if(para_start_pos != std::string::npos) {
if(para_end_pos == std::string::npos) {
if(line[c] == ';') {
result.emplace(line.substr(para_start_pos, c - para_start_pos), std::string());
para_start_pos = std::string::npos;
}
else if(line[c] == '=')
para_end_pos = c;
}
else {
if(value_start_pos == std::string::npos) {
if(line[c] == '"' && c + 1 < line.size())
value_start_pos = c + 1;
}
else if(line[c] == '"') {
result.emplace(line.substr(para_start_pos, para_end_pos - para_start_pos), line.substr(value_start_pos, c - value_start_pos));
para_start_pos = std::string::npos;
para_end_pos = std::string::npos;
value_start_pos = std::string::npos;
}
}
}
else if(line[c] != ' ' && line[c] != ';')
para_start_pos = c;
}
if(para_start_pos != std::string::npos && para_end_pos == std::string::npos)
result.emplace(line.substr(para_start_pos), std::string());
return result;
}
};
} // namespace SimpleWeb } // namespace SimpleWeb
#ifdef __SSE2__ #ifdef __SSE2__