Events.hpp

#ifndef _PRIVMXLIB_ENDPOINT_KVDB_EVENTS_HPP_
#define _PRIVMXLIB_ENDPOINT_KVDB_EVENTS_HPP_
 
#include "privmx/endpoint/core/Events.hpp"
#include "privmx/endpoint/core/Types.hpp"
#include "privmx/endpoint/kvdb/Types.hpp"
 
namespace privmx {
namespace endpoint {
namespace kvdb {

struct KvdbDeletedEventData {
    
    std::string kvdbId;
};

struct  KvdbStatsEventData {

    std::string kvdbId;

    int64_t lastEntryDate;

    int64_t entries;
};

struct KvdbDeletedEntryEventData {

    std::string kvdbId;

    std::string kvdbEntryKey;
};
 
struct KvdbCreatedEvent : public core::Event {

    KvdbCreatedEvent() : core::Event("kvdbCreated") {}

    std::string toJSON() const override;

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

struct KvdbUpdatedEvent : public core::Event {
    
    KvdbUpdatedEvent() : core::Event("kvdbUpdated") {}

    std::string toJSON() const override;

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

struct KvdbDeletedEvent : public core::Event {
    
    KvdbDeletedEvent() : core::Event("kvdbDeleted") {}

    std::string toJSON() const override;

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

struct KvdbStatsChangedEvent : public core::Event {
    
    KvdbStatsChangedEvent() : core::Event("kvdbStatsChanged") {}

    std::string toJSON() const override;

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

struct KvdbNewEntryEvent : public core::Event {
    
    KvdbNewEntryEvent() : core::Event("kvdbNewEntry") {}

    std::string toJSON() const override;

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

struct KvdbEntryUpdatedEvent : public core::Event {
    
    KvdbEntryUpdatedEvent() : core::Event("kvdbEntryUpdated") {}

    std::string toJSON() const override;

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

struct KvdbEntryDeletedEvent : public core::Event {
    
    KvdbEntryDeletedEvent() : core::Event("kvdbEntryDeleted") {}

    std::string toJSON() const override;

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

class Events {
public:

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

    static KvdbCreatedEvent extractKvdbCreatedEvent(const core::EventHolder& eventHolder);

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

    static KvdbUpdatedEvent extractKvdbUpdatedEvent(const core::EventHolder& eventHolder);

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

    static KvdbDeletedEvent extractKvdbDeletedEvent(const core::EventHolder& eventHolder);

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

    static KvdbStatsChangedEvent extractKvdbStatsEvent(const core::EventHolder& eventHolder);

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

    static KvdbNewEntryEvent extractKvdbNewEntryEvent(const core::EventHolder& eventHolder);

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

    static KvdbEntryUpdatedEvent extractKvdbEntryUpdatedEvent(const core::EventHolder& eventHolder);

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

    static KvdbEntryDeletedEvent extractKvdbEntryDeletedEvent(const core::EventHolder& eventHolder);
};
 
}  // namespace kvdb
}  // namespace endpoint
}  // namespace privmx
 
#endif