mirror of
https://github.com/boostorg/mqtt5.git
synced 2026-01-19 16:32: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
134 lines
3.7 KiB
C++
134 lines
3.7 KiB
C++
//
|
|
// Copyright (c) 2023-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)
|
|
//
|
|
|
|
#include "test_common/extra_deps.hpp"
|
|
#include "test_common/preconditions.hpp"
|
|
|
|
#include <boost/mqtt5/logger.hpp>
|
|
#include <boost/mqtt5/logger_traits.hpp>
|
|
#include <boost/mqtt5/mqtt_client.hpp>
|
|
|
|
#include <boost/mqtt5/detail/log_invoke.hpp>
|
|
|
|
#include <boost/asio/detached.hpp>
|
|
#include <boost/asio/io_context.hpp>
|
|
#include <boost/asio/ip/tcp.hpp>
|
|
#include <boost/system/error_code.hpp>
|
|
#include <boost/test/tools/output_test_stream.hpp>
|
|
#include <boost/test/unit_test.hpp>
|
|
|
|
#include <chrono>
|
|
#include <iostream>
|
|
#include <sstream>
|
|
#include <string>
|
|
#include <type_traits>
|
|
|
|
using namespace boost::mqtt5;
|
|
namespace asio = boost::asio;
|
|
|
|
void logger_test() {
|
|
BOOST_STATIC_ASSERT(has_at_resolve<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_tcp_connect<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_tls_handshake<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_ws_handshake<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_connack<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_disconnect<logger>);
|
|
BOOST_STATIC_ASSERT(has_at_transport_error<logger>);
|
|
}
|
|
|
|
BOOST_AUTO_TEST_SUITE(logger_tests)
|
|
|
|
using error_code = boost::system::error_code;
|
|
|
|
class clog_redirect {
|
|
std::streambuf* _old_buffer;
|
|
|
|
public:
|
|
clog_redirect(std::streambuf* new_buffer) :
|
|
_old_buffer(std::clog.rdbuf(new_buffer))
|
|
{}
|
|
|
|
~clog_redirect() {
|
|
std::clog.rdbuf(_old_buffer);
|
|
}
|
|
|
|
};
|
|
|
|
bool contains(const std::string& str, const std::string& substr) {
|
|
return str.find(substr) != std::string::npos;
|
|
}
|
|
|
|
#ifdef BOOST_MQTT5_EXTRA_DEPS
|
|
using stream_type = boost::beast::websocket::stream<
|
|
asio::ssl::stream<asio::ip::tcp::socket>
|
|
>;
|
|
using context_type = asio::ssl::context;
|
|
using logger_type = logger;
|
|
using client_type = mqtt_client<stream_type, context_type, logger_type>;
|
|
|
|
BOOST_AUTO_TEST_CASE(client_successful_connect_debug,
|
|
* boost::unit_test::precondition(test::public_broker_cond))
|
|
{
|
|
boost::test_tools::output_test_stream output;
|
|
|
|
{
|
|
clog_redirect guard(output.rdbuf());
|
|
asio::io_context ioc;
|
|
|
|
asio::ssl::context tls_context(asio::ssl::context::tls_client);
|
|
client_type c(
|
|
ioc, std::move(tls_context), logger(log_level::debug)
|
|
);
|
|
|
|
c.brokers("broker.hivemq.com/mqtt", 8884)
|
|
.async_run(asio::detached);
|
|
|
|
c.async_disconnect([](error_code) {});
|
|
|
|
ioc.run();
|
|
}
|
|
|
|
std::string log = output.rdbuf()->str();
|
|
BOOST_TEST_MESSAGE(log);
|
|
BOOST_TEST_WARN(contains(log, "resolve"));
|
|
BOOST_TEST_WARN(contains(log, "TCP connect"));
|
|
BOOST_TEST_WARN(contains(log, "TLS handshake"));
|
|
BOOST_TEST_WARN(contains(log, "WebSocket handshake"));
|
|
BOOST_TEST_WARN(contains(log, "connack"));
|
|
}
|
|
|
|
BOOST_AUTO_TEST_CASE(client_successful_connect_warning,
|
|
* boost::unit_test::precondition(test::public_broker_cond))
|
|
{
|
|
boost::test_tools::output_test_stream output;
|
|
|
|
{
|
|
clog_redirect guard(output.rdbuf());
|
|
|
|
asio::io_context ioc;
|
|
asio::ssl::context tls_context(asio::ssl::context::tls_client);
|
|
client_type c(
|
|
ioc, std::move(tls_context), logger(log_level::warning)
|
|
);
|
|
|
|
c.brokers("broker.hivemq.com/mqtt", 8884)
|
|
.async_run(asio::detached);
|
|
|
|
c.async_disconnect([](error_code) {});
|
|
|
|
ioc.run();
|
|
}
|
|
|
|
// If connection is successful, nothing should be printed.
|
|
// However if the Broker is down or overloaded, this will cause logs to be printed.
|
|
// We should not fail the test because of it.
|
|
BOOST_TEST_WARN(output.is_empty());
|
|
}
|
|
#endif // BOOST_MQTT5_EXTRA_DEPS
|
|
|
|
BOOST_AUTO_TEST_SUITE_END();
|