http has a copy of run_sync

Author: vinniefalco

CMakePresets.json

@@ -0,0 +1,10 @@
+{
+    "version": 6,
+    "cmakeMinimumRequired": {
+        "major": 3,
+        "minor": 25,
+        "patch": 0
+    },
+    "configurePresets": [],
+    "buildPresets": []
+}

src/server/route_handler.cpp

@@ -9,7 +9,6 @@
 
 #include <boost/http/server/route_handler.hpp>
 #include <boost/http/string_body.hpp>
-#include <boost/capy/ex/run_sync.hpp>
 
 namespace boost {
 namespace http {

test/unit/run_sync.hpp

@@ -0,0 +1,108 @@
+//
+// Copyright (c) 2025 Vinnie Falco (vinnie dot falco at gmail 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)
+//
+// Official repository: https://github.com/cppalliance/http
+//
+
+#ifndef BOOST_HTTP_TEST_RUN_SYNC_HPP
+#define BOOST_HTTP_TEST_RUN_SYNC_HPP
+
+#include <boost/capy/coro.hpp>
+#include <boost/capy/ex/execution_context.hpp>
+#include <boost/capy/task.hpp>
+
+#include <coroutine>
+#include <exception>
+#include <type_traits>
+#include <utility>
+
+namespace boost {
+namespace http {
+
+// Trivial execution context for synchronous execution.
+class sync_context : public capy::execution_context
+{
+};
+
+// Trivial executor for synchronous execution.
+struct sync_executor
+{
+    static sync_context ctx_;
+
+    bool operator==(sync_executor const&) const noexcept { return true; }
+    capy::execution_context& context() const noexcept { return ctx_; }
+    void on_work_started() const noexcept {}
+    void on_work_finished() const noexcept {}
+
+    capy::coro dispatch(capy::coro h) const
+    {
+        return h;
+    }
+
+    void post(capy::coro h) const
+    {
+        h.resume();
+    }
+};
+
+inline sync_context sync_executor::ctx_;
+
+// Synchronous task runner for tests.
+class sync_runner
+{
+public:
+    sync_runner() = default;
+
+    sync_runner(sync_runner const&) = delete;
+    sync_runner& operator=(sync_runner const&) = delete;
+    sync_runner(sync_runner&&) = default;
+    sync_runner& operator=(sync_runner&&) = default;
+
+    template<typename T>
+    T operator()(capy::task<T> t) &&
+    {
+        auto h = t.handle();
+        t.release();
+        sync_executor ex;
+
+        h.promise().set_continuation(std::noop_coroutine(), ex);
+        h.promise().set_executor(ex);
+
+        ex.dispatch(capy::coro{h}).resume();
+
+        std::exception_ptr ep = h.promise().exception();
+
+        if constexpr (std::is_void_v<T>)
+        {
+            h.destroy();
+            if (ep)
+                std::rethrow_exception(ep);
+        }
+        else
+        {
+            if (ep)
+            {
+                h.destroy();
+                std::rethrow_exception(ep);
+            }
+            auto result = std::move(h.promise().result());
+            h.destroy();
+            return result;
+        }
+    }
+};
+
+inline
+sync_runner
+run_sync()
+{
+    return sync_runner{};
+}
+
+} // namespace http
+} // namespace boost
+
+#endif

test/unit/server/flat_router.cpp

@@ -13,8 +13,8 @@
 // Full functional tests are in beast2/test/unit/server/router.cpp
 
 #include <boost/http/server/router.hpp>
-#include <boost/capy/ex/run_sync.hpp>
 
+#include "run_sync.hpp"
 #include "test_suite.hpp"
 
 namespace boost {
@@ -39,11 +39,11 @@ struct flat_router_test
         flat_router fr2(fr1);
 
         params req;
-        capy::run_sync()(fr1.dispatch(
+        run_sync()(fr1.dispatch(
             http::method::get, urls::url_view("/"), req));
         BOOST_TEST_EQ(*counter, 1);
 
-        capy::run_sync()(fr2.dispatch(
+        run_sync()(fr2.dispatch(
             http::method::get, urls::url_view("/"), req));
         BOOST_TEST_EQ(*counter, 2);
     }
@@ -70,11 +70,11 @@ struct flat_router_test
         fr2 = fr1;
 
         params req;
-        capy::run_sync()(fr1.dispatch(
+        run_sync()(fr1.dispatch(
             http::method::get, urls::url_view("/"), req));
         BOOST_TEST_EQ(*counter, 1);
 
-        capy::run_sync()(fr2.dispatch(
+        run_sync()(fr2.dispatch(
             http::method::get, urls::url_view("/"), req));
         BOOST_TEST_EQ(*counter, 2);
     }

test/unit/server/route_handler.cpp

@@ -13,14 +13,21 @@
 #include <boost/http/server/router.hpp>
 #include <boost/http/server/flat_router.hpp>
 #include <boost/http/request.hpp>
-#include <boost/capy/ex/run_sync.hpp>
 
+#include "run_sync.hpp"
 #include "test_route_handler.hpp"
 #include "test_suite.hpp"
 
+#include <array>
+
 namespace boost {
 namespace http {
 
+struct any_write_buffers
+{
+    std::array<capy::const_buffer, 16> v_;
+};
+
 struct route_handler_test
 {
     using test_router = router<route_params>;
@@ -33,7 +40,7 @@ struct route_handler_test
     {
         flat_router fr(std::move(r));
         test_route_params p;
-        auto rv = capy::run_sync()(fr.dispatch(
+        auto rv = run_sync()(fr.dispatch(
             verb, urls::url_view(url), p));
         if(BOOST_TEST_EQ(rv.message(), rv0.message()))
             BOOST_TEST(rv == rv0);

test/unit/server/router.cpp

@@ -12,8 +12,7 @@
 #include <boost/http/server/flat_router.hpp>
 #include <boost/http/server/detail/router_base.hpp>
 
-#include <boost/capy/ex/run_sync.hpp>
-
+#include "run_sync.hpp"
 #include "test_suite.hpp"
 
 namespace boost {
@@ -108,7 +107,7 @@ struct router_test
     {
         flat_router fr(std::move(r));
         params req;
-        auto rv = capy::run_sync()(fr.dispatch(
+        auto rv = run_sync()(fr.dispatch(
             http::method::get, urls::url_view(url), req));
         BOOST_TEST_EQ(rv.message(), rv0.message());
     }
@@ -121,7 +120,7 @@ struct router_test
     {
         flat_router fr(std::move(r));
         params req;
-        auto rv = capy::run_sync()(fr.dispatch(
+        auto rv = run_sync()(fr.dispatch(
             verb, urls::url_view(url), req));
         BOOST_TEST_EQ(rv.message(), rv0.message());
     }
@@ -134,7 +133,7 @@ struct router_test
     {
         flat_router fr(std::move(r));
         params req;
-        auto rv = capy::run_sync()(fr.dispatch(
+        auto rv = run_sync()(fr.dispatch(
             verb, urls::url_view(url), req));
         BOOST_TEST_EQ(rv.message(), rv0.message());
     }
@@ -411,7 +410,7 @@ struct router_test
             flat_router fr(std::move(r));
             params req;
             BOOST_TEST_THROWS(
-                capy::run_sync()(fr.dispatch(
+                run_sync()(fr.dispatch(
                     http::method::unknown, urls::url_view("/"), req)),
                 std::invalid_argument);
         }
@@ -423,7 +422,7 @@ struct router_test
             flat_router fr(std::move(r));
             params req;
             BOOST_TEST_THROWS(
-                capy::run_sync()(fr.dispatch(
+                run_sync()(fr.dispatch(
                     "", urls::url_view("/"), req)),
                 std::invalid_argument);
         }