EventApi.hpp

#ifndef _PRIVMXLIB_ENDPOINT_EVENT_EVENTAPI_HPP_
#define _PRIVMXLIB_ENDPOINT_EVENT_EVENTAPI_HPP_
 
#include "privmx/endpoint/core/Buffer.hpp"
#include "privmx/endpoint/core/Connection.hpp"
#include "privmx/endpoint/event/Types.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_