feat: add HTTP server integration sample

Author: Hackerl

CMakeLists.txt

@@ -6,6 +6,7 @@ set(CMAKE_POSITION_INDEPENDENT_CODE TRUE)
 set(ASYNCIO_VERSION 1.1.0)
 
 option(BUILD_SAMPLES "Build asyncio samples" ON)
+option(BUILD_INTEGRATION_SAMPLES "Build asyncio integration samples" OFF)
 option(BUILD_SHARED_LIBS "Build using shared libraries" OFF)
 option(ASYNCIO_EMBED_CA_CERT "Use built-in CA certificates instead of system certificates" OFF)
 

sample/CMakeLists.txt

@@ -1,3 +1,7 @@
+if (BUILD_INTEGRATION_SAMPLES)
+    find_package(httplib CONFIG REQUIRED)
+endif ()
+
 add_executable(asyncio_tcp_client tcp/client.cpp)
 target_link_libraries(asyncio_tcp_client PRIVATE asyncio-main)
 
@@ -10,8 +14,13 @@ target_link_libraries(asyncio_tls_client PRIVATE asyncio-main)
 add_executable(asyncio_tls_server tls/server.cpp)
 target_link_libraries(asyncio_tls_server PRIVATE asyncio-main)
 
-add_executable(asyncio_http http/main.cpp)
-target_link_libraries(asyncio_http PRIVATE asyncio-main)
+add_executable(asyncio_http_client http/client.cpp)
+target_link_libraries(asyncio_http_client PRIVATE asyncio-main)
+
+if (BUILD_INTEGRATION_SAMPLES)
+    add_executable(asyncio_http_server http/server.cpp)
+    target_link_libraries(asyncio_http_server PRIVATE asyncio-main httplib::httplib)
+endif ()
 
 add_executable(asyncio_ws ws/main.cpp)
 target_link_libraries(asyncio_ws PRIVATE asyncio-main)

sample/http/main.cpp sample/http/client.cppsample/http/main.cpp renamed to sample/http/client.cpp

@@ -0,0 +1,49 @@
+#include <asyncio/thread.h>
+#include <asyncio/signal.h>
+#include <asyncio/error.h>
+#include <zero/cmdline.h>
+#include <httplib.h>
+
+asyncio::task::Task<void> asyncMain(const int argc, char *argv[]) {
+    zero::Cmdline cmdline;
+
+    cmdline.add<std::string>("ip", "IP address to bind");
+    cmdline.add<std::uint16_t>("port", "Port number to listen on");
+
+    cmdline.parse(argc, argv);
+
+    const auto ip = cmdline.get<std::string>("ip");
+    const auto port = cmdline.get<std::uint16_t>("port");
+
+    httplib::Server server;
+
+    server.Get(
+        "/hi",
+        [](const httplib::Request &, httplib::Response &response) {
+            response.set_content("Hello World!", "text/plain");
+        }
+    );
+
+    auto signal = asyncio::Signal::make();
+
+    co_await race(
+        asyncio::toThread(
+            [&] {
+                if (!server.listen(ip, port)) {
+#ifdef _WIN32
+                    throw std::system_error{WSAGetLastError(), std::system_category()};
+#else
+                    throw std::system_error{errno, std::system_category()};
+#endif
+                }
+            },
+            [&](std::thread::native_handle_type) -> std::expected<void, std::error_code> {
+                server.stop();
+                return {};
+            }
+        ),
+        asyncio::task::spawn([&]() -> asyncio::task::Task<void> {
+            co_await asyncio::error::guard(signal.on(SIGINT));
+        })
+    );
+}

sample/http/server.cpp

@@ -15,6 +15,12 @@
     "tests"
   ],
   "features": {
+    "integration-samples": {
+      "description": "Build integration samples",
+      "dependencies": [
+        "cpp-httplib"
+      ]
+    },
     "tests": {
       "description": "Build Tests",
       "dependencies": [