EventApi.hpp

#ifndef _PRIVMXLIB_ENDPOINT_EVENT_EVENTAPI_HPP_
#define _PRIVMXLIB_ENDPOINT_EVENT_EVENTAPI_HPP_
 
#include "privmx/endpoint/core/Connection.hpp"
#include "privmx/endpoint/event/Types.hpp"
#include "privmx/endpoint/core/Buffer.hpp"
#include <privmx/endpoint/core/ExtendedPointer.hpp>
 
namespace privmx {
namespace endpoint {
namespace event {
 
class EventApiImpl;

class EventApi : public privmx::endpoint::core::ExtendedPointer<EventApiImpl> {
public:

    static EventApi create(core::Connection& connection);

    EventApi();
    EventApi(const EventApi& obj);
    EventApi& operator=(const EventApi& obj);
    EventApi(EventApi&& obj);
    ~EventApi();

    void emitEvent(const std::string& contextId, const std::vector<core::UserWithPubKey>& users, const std::string& channelName, const core::Buffer& eventData);

    std::vector<std::string> subscribeFor(const std::vector<std::string>& subscriptionQueries);

    void unsubscribeFrom(const std::vector<std::string>& subscriptionIds);

    std::string buildSubscriptionQuery(const std::string& channelName, EventSelectorType selectorType, const std::string& selectorId);
 
private:
    EventApi(const std::shared_ptr<EventApiImpl>& impl);
};
 
}  // namespace event
}  // namespace endpoint
}  // namespace privmx
 
#endif  // _PRIVMXLIB_ENDPOINT_EVENT_EVENTAPI_HPP_