listener.hpp

/*********************************************************************/
// webdar - a web server and interface program to libdar
// Copyright (C) 2013-2025 Denis Corbin
//
// This file is part of Webdar
//
//  Webdar is free software: you can redistribute it and/or modify
//  it under the terms of the GNU General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  (at your option) any later version.
//
//  Webdar is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with Webdar.  If not, see <http://www.gnu.org/licenses/>
//
//----
//  to contact the author: dar.linux@free.fr
/*********************************************************************/
 
#ifndef LISTENER_HPP
#define LISTENER_HPP
 
#include "my_config.h"
 
    // C++ system header files
#include <libthreadar/libthreadar.hpp>
#include <memory>
 
    // webdar headers
#include "central_report.hpp"
#include "exceptions.hpp"
#include "authentication.hpp"
#include "ssl_context.hpp"
#include "server_pool.hpp"
 
 
 
 
class listener : public libthreadar::thread_signal
{
public:
    listener(const std::shared_ptr<central_report> & log,        
         const std::shared_ptr<const authentication> & auth, 
         std::unique_ptr<ssl_context> & ciphering,           
         std::shared_ptr<server_pool> & pool,                
         unsigned int port                                   
    );
    listener(const std::shared_ptr<central_report> & log,        
         const std::shared_ptr<const authentication> & auth, 
         std::unique_ptr<ssl_context> & ciphering,           
         std::shared_ptr<server_pool> & pool,                
         const std::string & ip,                             
         unsigned int port                                   
    );
    listener(const listener & ref) = delete;
    listener(listener && ref) noexcept = delete;
    listener & operator = (const listener & ref) = delete;
    listener & operator = (listener && ref) noexcept = delete;
    ~listener() { close(sockfd); cancel(); join(); };
 
protected:
    // inherited from libthreadar::thread;
    virtual void inherited_run() override;
 
    // no need to override thread::signaled_inherited_cancel()
    // we rely on the cancellation_checkpoint() mechanism
    // in inherited_run()
 
private:
    std::shared_ptr<central_report> rep;       
    std::shared_ptr<const authentication> src; 
    int sockfd;                                
    int famille;                               
    std::string l_ip;                          
    std::string l_port;                        
    std::unique_ptr<ssl_context> ssl_ctx;      
    std::shared_ptr<server_pool> srv;          
 
    void set_sockfd(int domain);
    void init(const std::shared_ptr<central_report> & log,
          const std::shared_ptr<const authentication> & auth,
          std::unique_ptr<ssl_context> & ciphering,
          std::shared_ptr<server_pool> & pool,
          const std::string & ip,
          unsigned int port);
};
 
 
#endif