mirror of
https://github.com/boostorg/mqtt5.git
synced 2026-01-19 04:22:11 +00:00
6198b0e44a
Summary: * Removed all usage of real timers and resolvers in unit tests * Moved most of the tests to test/unit folder * cmake: split boost_mqtt5_tests into boost_mqtt5_unittests and boost_mqtt5_integrationtests Reviewers: ivica Reviewed By: ivica Subscribers: miljen Differential Revision: https://repo.mireo.local/D38186
60 lines
1.6 KiB
C++
60 lines
1.6 KiB
C++
//
|
|
// Copyright (c) 2025 Ivica Siladic, Bruno Iljazovic, Korina Simicevic
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0.
|
|
// (See accompanying file LICENSE or copy at http://www.boost.org/LICENSE_1_0.txt)
|
|
//
|
|
|
|
#ifndef BOOST_MQTT5_TEST_RESOLVER_HPP
|
|
#define BOOST_MQTT5_TEST_RESOLVER_HPP
|
|
|
|
#include <boost/asio/any_io_executor.hpp>
|
|
#include <boost/asio/ip/tcp.hpp>
|
|
#include <boost/asio/prepend.hpp>
|
|
|
|
namespace boost::mqtt5::test {
|
|
|
|
class test_resolver {
|
|
public:
|
|
using executor_type = asio::any_io_executor;
|
|
using results_type = asio::ip::tcp::resolver::results_type;
|
|
|
|
private:
|
|
executor_type _ex;
|
|
|
|
public:
|
|
static constexpr std::string_view invalid_host = "example.invalid";
|
|
|
|
explicit test_resolver(executor_type ex) : _ex(std::move(ex)) {}
|
|
|
|
executor_type get_executor() const noexcept { return _ex; }
|
|
|
|
template <typename CompletionToken>
|
|
decltype(auto) async_resolve(
|
|
std::string_view host, std::string_view port, CompletionToken&& token
|
|
) {
|
|
results_type results;
|
|
boost::system::error_code ec;
|
|
|
|
if (host == invalid_host)
|
|
ec = asio::error::host_not_found;
|
|
else
|
|
results = results_type::create(
|
|
asio::ip::tcp::endpoint(asio::ip::make_address_v4("127.0.0.1"), 1883),
|
|
std::string(host), std::string(port)
|
|
);
|
|
|
|
return asio::post(
|
|
get_executor(),
|
|
asio::prepend(
|
|
std::forward<CompletionToken>(token),
|
|
ec, results
|
|
)
|
|
);
|
|
}
|
|
};
|
|
|
|
} // namespace boost::mqtt5::test
|
|
|
|
#endif // !BOOST_MQTT5_TEST_RESOLVER_HPP
|