more unit tests

Author: pfeatherstone

examples/CMakeLists.txt

@@ -47,7 +47,8 @@ add_executable(tests
   unit_tests/main.cpp
   unit_tests/base64.cpp
   unit_tests/sha1.cpp
-  unit_tests/message.cpp)
+  unit_tests/message.cpp
+  unit_tests/async.cpp)
 target_link_options(tests PRIVATE $<$<CONFIG:Release>:-s>)
 target_include_directories(tests PRIVATE ${CMAKE_CURRENT_SOURCE_DIR}/extra)
 target_link_libraries(tests PRIVATE http)

examples/unit_tests/async.cpp

@@ -0,0 +1,88 @@
+#include <string_view>
+#include <vector>
+#include <boost/asio/io_context.hpp>
+#include <boost/asio/ip/basic_resolver.hpp>
+#include <boost/asio/ip/tcp.hpp>
+#include <boost/asio/connect.hpp>
+#include <http_async.h>
+#include "doctest.h"
+
+using boost::asio::ip::tcp;
+using boost::asio::ip::make_address_v4;
+using tcp_acceptor  = boost::asio::basic_socket_acceptor<tcp, boost::asio::io_context::executor_type>;
+using tcp_socket    = boost::asio::basic_stream_socket<tcp,   boost::asio::io_context::executor_type>;
+using tcp_resolver  = boost::asio::ip::basic_resolver<tcp,    boost::asio::io_context::executor_type>; 
+using tcp_endpoint  = boost::asio::ip::tcp::endpoint;
+
+TEST_SUITE("[ASYNC]")
+{
+    TEST_CASE("HTTP GET")
+    {
+        boost::asio::io_context ioc{1};
+        tcp_acceptor acceptor(ioc, {tcp::v4(), 6666});
+        tcp_socket   peer(ioc);
+        tcp_socket   client(ioc);
+        tcp_resolver resolver(ioc);
+        bool         exception_thrown{false};
+
+        http::request   req_client, req_peer;
+        http::response  resp_client, resp_peer;
+        std::string     buf_client;
+        std::string     buf_peer;
+
+        req_client.verb   = http::GET;
+        req_client.uri    = "/data?name=bane&peace=lie";
+        req_client.add_header(http::host, "hello there!");
+        req_client.add_header(http::user_agent, "Boost::asio " + std::to_string(BOOST_ASIO_VERSION)); // optional header
+
+        resp_peer.status = http::ok;
+        resp_peer.content_str = "There is only passion";
+        
+        try
+        {
+            acceptor.async_accept(peer, [&](boost::system::error_code ec) {
+                REQUIRE(!bool(ec));
+                http::async_http_read(peer, req_peer, buf_peer, [&](boost::system::error_code ec, size_t){
+                    REQUIRE(!bool(ec));
+                    http::async_http_write(peer, resp_peer, buf_peer, [&](boost::system::error_code ec, size_t){
+                        REQUIRE(!bool(ec));
+                    });
+                });
+            });
+
+            resolver.async_resolve("localhost", "6666", [&](boost::system::error_code ec, const auto& endpoints) {
+                REQUIRE(!bool(ec));
+                boost::asio::async_connect(client, endpoints, [&](boost::system::error_code ec, auto endpoint) {
+                    REQUIRE(!bool(ec));
+                    http::async_http_write(client, req_client, buf_client, [&](boost::system::error_code ec, size_t) {
+                        REQUIRE(!bool(ec));
+                        http::async_http_read(client, resp_client, buf_client, [&](boost::system::error_code ec, size_t) {
+                            REQUIRE(!bool(ec));
+                        });
+                    });
+                });
+            });
+
+            ioc.run();
+        }
+        catch(const std::exception& e)
+        {
+            exception_thrown = true;
+        }
+
+        REQUIRE(!exception_thrown);
+        REQUIRE(req_peer.verb == http::GET);
+        REQUIRE(req_peer.uri == "/data");
+        REQUIRE(req_peer.params.size() == 2);
+        REQUIRE(req_peer.params[0].key == "name");
+        REQUIRE(req_peer.params[0].val == "bane");
+        REQUIRE(req_peer.params[1].key == "peace");
+        REQUIRE(req_peer.params[1].val == "lie");
+        const auto it = req_peer.find(http::host);
+        REQUIRE(it != req_peer.headers.end());
+        REQUIRE(it->value == "hello there!");
+
+        REQUIRE(resp_client.status == http::ok);
+        REQUIRE(resp_client.content_str == "There is only passion");
+    }
+}