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/stream/Types.hpp"
#include <privmx/endpoint/core/Events.hpp>
#include <privmx/endpoint/core/Types.hpp>
 
namespace privmx {
namespace endpoint {
namespace stream {

struct StreamRoomDeletedEventData {
    std::string streamRoomId;
};

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 StreamRoomJoinedEvent : public core::Event {

    StreamRoomJoinedEvent() : core::Event("streamRoomJoined") {}

    std::string toJSON() const override;

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

    StreamRoomParticipantEventData 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 StreamRoomLeftEvent : public core::Event {

    StreamRoomLeftEvent() : core::Event("streamRoomLeft") {}

    std::string toJSON() const override;

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

    StreamRoomParticipantEventData data;
};

struct StreamSubscribedEvent : public core::Event {

    StreamSubscribedEvent() : core::Event("streamSubscribed") {}

    std::string toJSON() const override;

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

    StreamSubscriptionEventData data;
};

struct StreamUnsubscribedEvent : public core::Event {

    StreamUnsubscribedEvent() : core::Event("streamUnsubscribed") {}

    std::string toJSON() const override;

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

    StreamSubscriptionEventData 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 isStreamRoomJoinedEvent(const core::EventHolder& eventHolder);

    static StreamRoomJoinedEvent extractStreamRoomJoinedEvent(const core::EventHolder& eventHolder);

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

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

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

    static StreamRoomLeftEvent extractStreamRoomLeftEvent(const core::EventHolder& eventHolder);

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

    static StreamSubscribedEvent extractStreamSubscribedEvent(const core::EventHolder& eventHolder);

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

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