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