Events.hpp

#ifndef _PRIVMXLIB_ENDPOINT_THREAD_EVENTS_HPP_
#define _PRIVMXLIB_ENDPOINT_THREAD_EVENTS_HPP_
 
#include "privmx/endpoint/core/Events.hpp"
#include "privmx/endpoint/core/Types.hpp"
#include "privmx/endpoint/thread/Types.hpp"
 
namespace privmx {
namespace endpoint {
namespace thread {
 
struct ThreadDeletedEventData {
    
    std::string threadId;
};

struct ThreadDeletedMessageEventData {

    std::string threadId;

    std::string messageId;
};

struct  ThreadStatsEventData {

    std::string threadId;

    int64_t lastMsgDate;

    int64_t messagesCount;
};

struct ThreadCreatedEvent : public core::Event {

    ThreadCreatedEvent() : core::Event("threadCreated") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    Thread data;
};

struct ThreadUpdatedEvent : public core::Event {
    
    ThreadUpdatedEvent() : core::Event("threadUpdated") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    Thread data;
};

struct ThreadDeletedEvent : public core::Event {
    
    ThreadDeletedEvent() : core::Event("threadDeleted") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    ThreadDeletedEventData data;
};

struct ThreadNewMessageEvent : public core::Event {
    
    ThreadNewMessageEvent() : core::Event("threadNewMessage") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    thread::Message data;
};

struct ThreadMessageUpdatedEvent : public core::Event {
    
    ThreadMessageUpdatedEvent() : core::Event("threadUpdatedMessage") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    thread::Message data;
};

struct ThreadMessageDeletedEvent : public core::Event {
    
    ThreadMessageDeletedEvent() : core::Event("threadMessageDeleted") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    ThreadDeletedMessageEventData data;
};

struct ThreadStatsChangedEvent : public core::Event {
    
    ThreadStatsChangedEvent() : core::Event("threadStatsChanged") {}

    std::string toJSON() const override;

    std::shared_ptr<core::SerializedEvent> serialize() const override;
    
    ThreadStatsEventData data;
};

class Events {
public:

    static bool isThreadCreatedEvent(const core::EventHolder& eventHolder);

    static ThreadCreatedEvent extractThreadCreatedEvent(const core::EventHolder& eventHolder);

    static bool isThreadUpdatedEvent(const core::EventHolder& eventHolder);

    static ThreadUpdatedEvent extractThreadUpdatedEvent(const core::EventHolder& eventHolder);

    static bool isThreadDeletedEvent(const core::EventHolder& eventHolder);

    static ThreadDeletedEvent extractThreadDeletedEvent(const core::EventHolder& eventHolder);

    static bool isThreadStatsEvent(const core::EventHolder& eventHolder);

    static ThreadStatsChangedEvent extractThreadStatsEvent(const core::EventHolder& eventHolder);

    static bool isThreadNewMessageEvent(const core::EventHolder& eventHolder);

    static ThreadNewMessageEvent extractThreadNewMessageEvent(const core::EventHolder& eventHolder);

    static bool isThreadMessageUpdatedEvent(const core::EventHolder& eventHolder);

    static ThreadMessageUpdatedEvent extractThreadMessageUpdatedEvent(const core::EventHolder& eventHolder);

 
    [[deprecated("Use isThreadMessageDeletedEvent(const core::EventHolder& eventHolder).")]]
    static bool isThreadDeletedMessageEvent(const core::EventHolder& eventHolder);

 
    static bool isThreadMessageDeletedEvent(const core::EventHolder& eventHolder);

    static ThreadMessageDeletedEvent extractThreadMessageDeletedEvent(const core::EventHolder& eventHolder);
};
 
}  // namespace thread
}  // namespace endpoint
}  // namespace privmx
 
#endif