listener.hpp

#pragma once
 
#include <boost/asio/ip/tcp.hpp>
#include <boost/beast/core/error.hpp>
 
#include <filesystem>
#include <memory>
#include <string>
 
namespace boost::asio
{
    class io_context;
}
 
namespace boost::asio::ssl
{
    class context;
}
 
namespace spdlog
{
    class logger;
}
 
namespace malloy::server
{
    class router;

    class listener :
        public std::enable_shared_from_this<listener>
    {
    public:
        listener(
            std::shared_ptr<spdlog::logger> logger,
            std::shared_ptr<spdlog::logger> connection_logger,
            boost::asio::io_context& ioc,
            std::shared_ptr<boost::asio::ssl::context> tls_ctx,
            const boost::asio::ip::tcp::endpoint& endpoint,
            std::shared_ptr<malloy::server::router> router,
            std::shared_ptr<const std::filesystem::path> http_doc_root,
            std::string agent_string
        );

        listener(const listener& other) = delete;

        listener(listener&& other) noexcept = delete;

        virtual
        ~listener() = default;

        listener&
        operator=(const listener& rhs) = delete;

        listener&
        operator=(listener&& rhs) noexcept = delete;

        void
        run();

        [[nodiscard]]
        std::shared_ptr<malloy::server::router>
        router() const noexcept
        {
            return m_router;
        }
 
    private:
        std::shared_ptr<spdlog::logger> m_logger;
        std::shared_ptr<spdlog::logger> m_connection_logger;
        boost::asio::io_context& m_io_ctx;
        std::shared_ptr<boost::asio::ssl::context> m_tls_ctx;
        boost::asio::ip::tcp::acceptor m_acceptor;
        std::shared_ptr<malloy::server::router> m_router;
        std::shared_ptr<const std::filesystem::path> m_doc_root;
        std::string m_agent_string;

        void
        do_accept();

        void
        on_accept(boost::beast::error_code ec, boost::asio::ip::tcp::socket socket);
    };
 
}