base_skeleton.hpp

//
// Created by gabriele on 04/11/18.
//

#ifndef LIBFORB_BASE_SKELETON_HPP
#define LIBFORB_BASE_SKELETON_HPP

#include <mutex>
#include <thread>
#include <vector>

#include <forb/stream/socket.hpp>


namespace forb {

    class base_skeleton {
        /* ************************************* ALIASES AND STATIC ATTRIBUTES ************************************** */
    private:
        using thread_list_t = std::vector<std::thread>;

        /* *********************************************** ATTRIBUTES *********************************************** */
    private:
        int _port = 0;

        int _queue_size = 0;

        std::thread _server_thread;

        forb::streams::socket _incoming_calls;

        /* ********************************************** CONSTRUCTORS ********************************************** */
    public:
        explicit base_skeleton(int port, int queue_size = 10) : _port(port), _queue_size(queue_size) {};

        /**************************************************************************************************************/

        virtual ~base_skeleton() = default;

        base_skeleton(const base_skeleton &other) = delete;

        base_skeleton &operator=(const base_skeleton &other) = delete;

        base_skeleton(base_skeleton &&other) noexcept = default;

        base_skeleton &operator=(base_skeleton &&other) noexcept = default;

        /**************************************************************************************************************/
    protected:
        static void listen_thread_body(base_skeleton *impl);

        static void call_thread_body(base_skeleton *impl, forb::streams::socket call_socket);

        /**************************************************************************************************************/
    public:
        void start_server();

        void join_server();

    protected:
        virtual void execute_call(call_id_t code,
                                  forb::streams::stream *callstream,
                                  forb::streams::stream *datastream) = 0;

    private:
        void accept_connection();
    };
}


#endif //LIBFORB_BASE_SKELETON_HPP