GroupManager.h

Go to the documentation of this file.

 
 
#ifndef _GROUPMANAGER_H
#define _GROUPMANAGER_H
 
#include <functional>
#include <unordered_map>
#include <shared_mutex>
#include <memory>
#include <vector>
#include <string>
#include <sstream>

template <typename T>
auto createCallback(T* ptr, void (T::* method)(const std::string&)) {
    return [ptr, method](const std::string& s) {
        (ptr->*method)(s);
        };
}
 
class GroupManager {
public: 
    static GroupManager& getInstance();
    
    void subscribe(const std::string& groupName, std::function<void(const std::string&)> callback, const std::string& CUID);
    
    void unsubscribe(const std::string& groupName , const std::string& CUID);
    
    void send(const std::string& groupName, const std::string& message);
 
protected: 
    std::unordered_map<std::string, std::vector<std::pair<std::function<void(const std::string&)>, std::string>>> groups;
 
private: 
    
    GroupManager() = default;
    ~GroupManager() = default;
 
    // Design to be used by multiple threads =>
    std::shared_mutex mtx;
 
    // We block the different way to copy or deplace it
    GroupManager(const GroupManager&) = delete;
    GroupManager& operator=(const GroupManager&) = delete;
    GroupManager(GroupManager&&) = delete;
    GroupManager& operator=(GroupManager&&) = delete;
};
 
#endif //_GROUPMANAGER_H