Events.hpp

/*
PrivMX Endpoint.
Copyright © 2024 Simplito sp. z o.o.
 
This file is part of the PrivMX Platform (https://privmx.dev).
This software is Licensed under the PrivMX Free License.
 
See the License for the specific language governing permissions and
limitations under the License.
*/
 
#ifndef _PRIVMXLIB_ENDPOINT_STREAM_EVENTS_HPP_
#define _PRIVMXLIB_ENDPOINT_STREAM_EVENTS_HPP_
 
#include <privmx/endpoint/core/Events.hpp>
#include <privmx/endpoint/core/Types.hpp>
#include "privmx/endpoint/stream/Types.hpp"
 
namespace privmx {
namespace endpoint {
namespace stream {
 
 
struct StreamRoomDeletedEventData {
    std::string streamRoomId;
};
 
struct StreamEventData {
    std::string streamRoomId;

    std::vector<int64_t> streamIds;

    std::string userId;
};
 
struct StreamLeftEventData {
    std::string streamRoomId;

    int64_t streamId;

    std::string userId;
};
 
struct StreamUnpublishedEventData {
    std::string streamRoomId;

    int64_t streamId;
};
using StreamPublishedEventData = PublishedStreamData;

struct StreamRoomCreatedEvent : public core::Event {

    StreamRoomCreatedEvent() : core::Event("streamRoomCreated") {}

    std::string toJSON() const override;

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

struct StreamRoomUpdatedEvent : public core::Event {

    StreamRoomUpdatedEvent() : core::Event("streamRoomUpdated") {}

    std::string toJSON() const override;

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

struct StreamRoomDeletedEvent : public core::Event {

    StreamRoomDeletedEvent() : core::Event("streamRoomDeleted") {}

    std::string toJSON() const override;

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

struct StreamPublishedEvent : public core::Event {

    StreamPublishedEvent() : core::Event("streamPublished") {}

    std::string toJSON() const override;

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

struct StreamUpdatedEvent : public core::Event {

    StreamUpdatedEvent() : core::Event("streamUpdated") {}

    std::string toJSON() const override;

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

    StreamUpdatedEventData data;
};
 

struct StreamJoinedEvent : public core::Event {

    StreamJoinedEvent() : core::Event("streamJoined") {}

    std::string toJSON() const override;

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

struct StreamUnpublishedEvent : public core::Event {

    StreamUnpublishedEvent() : core::Event("streamUnpublished") {}

    std::string toJSON() const override;

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

struct StreamLeftEvent : public core::Event {

    StreamLeftEvent() : core::Event("streamLeft") {}

    std::string toJSON() const override;

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

struct StreamNewStreamsEvent : public core::Event {

    StreamNewStreamsEvent() : core::Event("StreamNewStreams") {}

    std::string toJSON() const override;

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

    NewStreams data;
};
 

struct StreamsUpdatedEvent : public core::Event {

    StreamsUpdatedEvent() : core::Event("streamsUpdated") {}

    std::string toJSON() const override;

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

    StreamsUpdatedData data;
};
 

class Events {
public:

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

    static StreamRoomCreatedEvent extractStreamRoomCreatedEvent(const core::EventHolder& eventHolder);

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

    static StreamRoomUpdatedEvent extractStreamRoomUpdatedEvent(const core::EventHolder& eventHolder);

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

    static StreamRoomDeletedEvent extractStreamRoomDeletedEvent(const core::EventHolder& eventHolder);

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

    static StreamPublishedEvent extractStreamPublishedEvent(const core::EventHolder& eventHolder);

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

    static StreamUpdatedEvent extractStreamUpdatedEvent(const core::EventHolder& eventHolder);

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

    static StreamJoinedEvent extractStreamJoinedEvent(const core::EventHolder& eventHolder);

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

    static StreamUnpublishedEvent extractStreamUnpublishedEvent(const core::EventHolder& eventHolder);

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

    static StreamLeftEvent extractStreamLeftEvent(const core::EventHolder& eventHolder);

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

    static StreamNewStreamsEvent extractStreamNewStreamsEvent(const core::EventHolder& eventHolder);
 

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

    static StreamsUpdatedEvent extractStreamsUpdatedEvent(const core::EventHolder& eventHolder);
};
 
}  // namespace stream
}  // namespace endpoint
}  // namespace privmx
 
#endif // _PRIVMXLIB_ENDPOINT_STREAM_EVENTS_HPP_