remote_registry.hpp

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

#ifndef LIBFORB_REMOTE_REGISTRY_HPP
#define LIBFORB_REMOTE_REGISTRY_HPP

#include <map>

#include <forb/base_stub.hpp>

namespace forb {

    class remote_registry {
        /* ********************************************** CUSTOM TYPES ********************************************** */
    private:
        // Forward declaration, see implementation file.
        struct remote_obj_entry;

        /* ************************************************ ALIASES ************************************************* */

        using obj_map_t = std::map<std::string, remote_obj_entry>;

        /* *********************************************** ATTRIBUTES *********************************************** */

        obj_map_t remote_objects;

        /* ********************************************** CONSTRUCTORS ********************************************** */
    public:
        explicit remote_registry(std::string conf_file_name);

        /**************************************************************************************************************/
    public:
        ~remote_registry() noexcept;

        remote_registry(const remote_registry &other);

        remote_registry &operator=(const remote_registry &other);

        remote_registry(remote_registry &&other) noexcept;

        remote_registry &operator=(remote_registry &&other) noexcept;

        /**************************************************************************************************************/
    public:
        remote_var get(const std::string &obj_name) const {
            return get(obj_name, false, 0);
        };

        remote_var get(const std::string &obj_name, base_stub::buffer_size_t buffer_size) {
            return get(obj_name, false, buffer_size);
        };

        remote_var get_force_socket(const std::string &obj_name) const {
            return get(obj_name, true, 0);
        };

    private:
        remote_var get(const std::string &obj_name, bool force_socket, base_stub::buffer_size_t buffer_size) const;
    };

} // namespace forb


#endif //LIBFORB_REMOTE_REGISTRY_HPP