diff tests/src/libcommon/io/main.cpp @ 773:8c44bbcbbab9

Misc: style, cleanup and update
author David Demelier <markand@malikania.fr>
date Fri, 26 Oct 2018 13:01:00 +0200
parents 35c1517d705d
children
line wrap: on
line diff
--- a/tests/src/libcommon/io/main.cpp	Wed Oct 24 13:24:03 2018 +0200
+++ b/tests/src/libcommon/io/main.cpp	Fri Oct 26 13:01:00 2018 +0200
@@ -28,9 +28,9 @@
 #include <irccd/socket_stream.hpp>
 
 #if defined(IRCCD_HAVE_SSL)
-#   include <irccd/tls_acceptor.hpp>
-#   include <irccd/tls_connector.hpp>
-#   include <irccd/tls_stream.hpp>
+#	include <irccd/tls_acceptor.hpp>
+#	include <irccd/tls_connector.hpp>
+#	include <irccd/tls_stream.hpp>
 #endif // !IRCCD_HAVE_SSL
 
 using boost::asio::io_service;
@@ -50,100 +50,100 @@
 
 class io_fixture {
 public:
-    io_service service_;
+	io_service service_;
 
-    std::unique_ptr<io::acceptor> acceptor_;
-    std::unique_ptr<io::connector> connector_;
+	std::unique_ptr<acceptor> acceptor_;
+	std::unique_ptr<connector> connector_;
 
-    std::shared_ptr<io::stream> stream1_;
-    std::shared_ptr<io::stream> stream2_;
+	std::shared_ptr<stream> stream1_;
+	std::shared_ptr<stream> stream2_;
 
-    virtual auto create_acceptor() -> std::unique_ptr<io::acceptor> = 0;
+	virtual auto create_acceptor() -> std::unique_ptr<acceptor> = 0;
 
-    virtual auto create_connector() -> std::unique_ptr<io::connector> = 0;
+	virtual auto create_connector() -> std::unique_ptr<connector> = 0;
 
-    void init()
-    {
-        acceptor_ = create_acceptor();
-        connector_ = create_connector();
+	void init()
+	{
+		acceptor_ = create_acceptor();
+		connector_ = create_connector();
 
-        acceptor_->accept([this] (auto code, auto stream) {
-            if (code)
-                throw std::system_error(code);
+		acceptor_->accept([this] (auto code, auto stream) {
+			if (code)
+				throw std::system_error(code);
 
-            stream1_ = std::move(stream);
-        });
-        connector_->connect([this] (auto code, auto stream) {
-            if (code)
-                throw std::system_error(code);
+			stream1_ = std::move(stream);
+		});
+		connector_->connect([this] (auto code, auto stream) {
+			if (code)
+				throw std::system_error(code);
 
-            stream2_ = std::move(stream);
-        });
+			stream2_ = std::move(stream);
+		});
 
-        service_.run();
-        service_.reset();
-    }
+		service_.run();
+		service_.reset();
+	}
 };
 
 class ip_io_fixture : public io_fixture {
 private:
-    tcp::endpoint endpoint_;
+	tcp::endpoint endpoint_;
 
 protected:
-    /**
-     * \copydoc io_fixture::create_acceptor
-     */
-    auto create_acceptor() -> std::unique_ptr<io::acceptor> override
-    {
-        tcp::endpoint endpoint(tcp::v4(), 0U);
-        tcp::acceptor acceptor(service_, std::move(endpoint));
+	/**
+	 * \copydoc io_fixture::create_acceptor
+	 */
+	auto create_acceptor() -> std::unique_ptr<acceptor> override
+	{
+		tcp::endpoint endpoint(tcp::v4(), 0U);
+		tcp::acceptor acceptor(service_, std::move(endpoint));
 
-        endpoint_ = acceptor.local_endpoint();
+		endpoint_ = acceptor.local_endpoint();
 
-        return std::make_unique<io::ip_acceptor>(std::move(acceptor));
-    }
+		return std::make_unique<ip_acceptor>(std::move(acceptor));
+	}
 
-    /**
-     * \copydoc io_fixture::create_connector
-     */
-    auto create_connector() -> std::unique_ptr<io::connector> override
-    {
-        return std::make_unique<io::ip_connector>(service_, endpoint_);
-    }
+	/**
+	 * \copydoc io_fixture::create_connector
+	 */
+	auto create_connector() -> std::unique_ptr<connector> override
+	{
+		return std::make_unique<ip_connector>(service_, endpoint_);
+	}
 };
 
 #if defined(IRCCD_HAVE_SSL)
 
 class ssl_io_fixture : public io_fixture {
 private:
-    tcp::endpoint endpoint_;
+	tcp::endpoint endpoint_;
 
 protected:
-    /**
-     * \copydoc io_fixture::create_acceptor
-     */
-    auto create_acceptor() -> std::unique_ptr<io::acceptor> override
-    {
-        context context(context::sslv23);
+	/**
+	 * \copydoc io_fixture::create_acceptor
+	 */
+	auto create_acceptor() -> std::unique_ptr<acceptor> override
+	{
+		context context(context::sslv23);
 
-        context.use_certificate_file(TESTS_SOURCE_DIR "/data/test.crt", context::pem);
-        context.use_private_key_file(TESTS_SOURCE_DIR "/data/test.key", context::pem);
+		context.use_certificate_file(TESTS_SOURCE_DIR "/data/test.crt", context::pem);
+		context.use_private_key_file(TESTS_SOURCE_DIR "/data/test.key", context::pem);
 
-        tcp::endpoint endpoint(tcp::v4(), 0U);
-        tcp::acceptor acceptor(service_, std::move(endpoint));
+		tcp::endpoint endpoint(tcp::v4(), 0U);
+		tcp::acceptor acceptor(service_, std::move(endpoint));
 
-        endpoint_ = acceptor.local_endpoint();
+		endpoint_ = acceptor.local_endpoint();
 
-        return std::make_unique<io::tls_acceptor<>>(std::move(context), std::move(acceptor));
-    }
+		return std::make_unique<tls_acceptor<>>(std::move(context), std::move(acceptor));
+	}
 
-    /**
-     * \copydoc io_fixture::create_connector
-     */
-    auto create_connector() -> std::unique_ptr<io::connector> override
-    {
-        return std::make_unique<io::tls_connector<>>(context(context::sslv23), service_, endpoint_);
-    }
+	/**
+	 * \copydoc io_fixture::create_connector
+	 */
+	auto create_connector() -> std::unique_ptr<connector> override
+	{
+		return std::make_unique<tls_connector<>>(context(context::sslv23), service_, endpoint_);
+	}
 };
 
 #endif // !IRCCD_HAVE_SSL
@@ -152,25 +152,25 @@
 
 class local_io_fixture : public io_fixture {
 public:
-    /**
-     * \copydoc io_fixture::create_acceptor
-     */
-    auto create_acceptor() -> std::unique_ptr<io::acceptor> override
-    {
-        std::remove(CMAKE_BINARY_DIR "/tmp/io-test.sock");
+	/**
+	 * \copydoc io_fixture::create_acceptor
+	 */
+	auto create_acceptor() -> std::unique_ptr<acceptor> override
+	{
+		std::remove(CMAKE_BINARY_DIR "/tmp/io-test.sock");
 
-        stream_protocol::acceptor acceptor(service_, CMAKE_BINARY_DIR "/tmp/io-test.sock");
+		stream_protocol::acceptor acceptor(service_, CMAKE_BINARY_DIR "/tmp/io-test.sock");
 
-        return std::make_unique<io::local_acceptor>(std::move(acceptor));
-    }
+		return std::make_unique<local_acceptor>(std::move(acceptor));
+	}
 
-    /**
-     * \copydoc io_fixture::create_connector
-     */
-    auto create_connector() -> std::unique_ptr<io::connector> override
-    {
-        return std::make_unique<io::local_connector>(service_, CMAKE_BINARY_DIR "/tmp/io-test.sock");
-    }
+	/**
+	 * \copydoc io_fixture::create_connector
+	 */
+	auto create_connector() -> std::unique_ptr<connector> override
+	{
+		return std::make_unique<local_connector>(service_, CMAKE_BINARY_DIR "/tmp/io-test.sock");
+	}
 };
 
 #endif // !BOOST_OS_WINDOWS
@@ -179,48 +179,48 @@
  * List of fixtures to tests.
  */
 using list = boost::mpl::list<
-    ip_io_fixture
+	ip_io_fixture
 #if defined(IRCCD_HAVE_SSL)
-    , ssl_io_fixture
+	, ssl_io_fixture
 #endif
 #if !BOOST_OS_WINDOWS
-    , local_io_fixture
+	, local_io_fixture
 #endif
 >;
 
 BOOST_AUTO_TEST_CASE_TEMPLATE(invalid_argument, Test, list)
 {
-    Test fixture;
+	Test fixture;
 
-    const nlohmann::json message{
-        { "abc", 123 },
-        { "def", 456 }
-    };
+	const nlohmann::json message{
+		{ "abc", 123 },
+		{ "def", 456 }
+	};
 
-    fixture.init();
-    fixture.stream1_->read([] (auto code, auto message) {
-        BOOST_TEST(!code);
-        BOOST_TEST(message.is_object());
-        BOOST_TEST(message["abc"].template get<int>() == 123);
-        BOOST_TEST(message["def"].template get<int>() == 456);
-    });
-    fixture.stream2_->write(message, [] (auto code) {
-        BOOST_TEST(!code);
-    });
-    fixture.service_.run();
+	fixture.init();
+	fixture.stream1_->read([] (auto code, auto message) {
+		BOOST_TEST(!code);
+		BOOST_TEST(message.is_object());
+		BOOST_TEST(message["abc"].template get<int>() == 123);
+		BOOST_TEST(message["def"].template get<int>() == 456);
+	});
+	fixture.stream2_->write(message, [] (auto code) {
+		BOOST_TEST(!code);
+	});
+	fixture.service_.run();
 }
 
 BOOST_AUTO_TEST_CASE_TEMPLATE(network_down, Test, list)
 {
-    Test fixture;
+	Test fixture;
 
-    fixture.init();
-    fixture.stream1_->read([] (auto code, auto message) {
-        BOOST_TEST(code.value() == static_cast<int>(std::errc::not_connected));
-        BOOST_TEST(message.is_null());
-    });
-    fixture.stream2_ = nullptr;
-    fixture.service_.run();
+	fixture.init();
+	fixture.stream1_->read([] (auto code, auto message) {
+		BOOST_TEST(code.value() == static_cast<int>(std::errc::not_connected));
+		BOOST_TEST(message.is_null());
+	});
+	fixture.stream2_ = nullptr;
+	fixture.service_.run();
 }
 
 } // !namespace