room.hpp

#ifndef SKYWAY_ROOM_ROOM_HPP
#define SKYWAY_ROOM_ROOM_HPP
 
#include <skyway/plugin/sfu_bot_plugin/sfu_bot.hpp>
 
#include "skyway/room/abstract/room.hpp"
#include "skyway/room/local_room_member.hpp"
#include "skyway/room/room_domain_factory.hpp"
 
namespace skyway {
namespace room {
 
class RoomFactory : public interface::RoomFactory {
public:
    std::shared_ptr<interface::Room> Create(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomDomainFactory> domain_factory) override;
    std::shared_ptr<interface::Room> Find(
        interface::RoomQuery query,
        std::unique_ptr<interface::RoomDomainFactory> domain_factory) override;
    std::shared_ptr<interface::Room> FindOrCreate(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomDomainFactory> domain_factory) override;
};
 
class Room : public abstract::Room, public std::enable_shared_from_this<Room> {
public:
    Room(std::shared_ptr<core::interface::Channel> channel,
         std::unique_ptr<interface::RoomDomainFactory> factory);
 
    ~Room() override;
    RoomType Type() override;
 
    std::vector<std::shared_ptr<interface::RoomPublication>> Publications() override;
 
    std::vector<std::shared_ptr<interface::RoomSubscription>> Subscriptions() override;
 
    std::vector<std::shared_ptr<interface::RoomMember>> Members() override;
 
    static std::shared_ptr<Room> Create(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<RoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    static std::shared_ptr<Room> Create();
 
    static std::shared_ptr<Room> Find(
        interface::RoomQuery query,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<RoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    static std::shared_ptr<Room> FindOrCreate(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<RoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    std::shared_ptr<LocalRoomMember> Join(interface::RoomMemberInitOptions options);
 
    std::shared_ptr<plugin::sfu_bot::SfuBot> GetSfuBot();
 
protected:
    // core::interface::Channel::EventListener
    void OnMemberListChanged() override;
    void OnMemberJoined(std::shared_ptr<core::interface::Member> member) override;
    void OnMemberLeft(std::shared_ptr<core::interface::Member> member) override;
    void OnMemberMetadataUpdated(std::shared_ptr<core::interface::Member> member,
                                 const std::string& metadata) override;
    void OnPublicationMetadataUpdated(std::shared_ptr<core::interface::Publication> publication,
                                      const std::string& metadata) override;
    void OnPublicationListChanged() override;
    void OnStreamPublished(std::shared_ptr<core::interface::Publication> publication) override;
    void OnStreamUnpublished(std::shared_ptr<core::interface::Publication> publication) override;
    void OnPublicationEnabled(std::shared_ptr<core::interface::Publication> publication) override;
    void OnPublicationDisabled(std::shared_ptr<core::interface::Publication> publication) override;
    void OnSubscriptionListChanged() override;
    void OnPublicationSubscribed(
        std::shared_ptr<core::interface::Subscription> subscription) override;
    void OnPublicationUnsubscribed(
        std::shared_ptr<core::interface::Subscription> subscription) override;
 
private:
    static std::shared_ptr<Room> CreateShared(
        std::shared_ptr<core::interface::Channel> channel,
        std::unique_ptr<interface::RoomDomainFactory> factory);
 
    bool IsSfuOriginPublication(std::shared_ptr<core::interface::Publication> publication);
 
public:
    friend class RoomFactory;
};
 
}  // namespace room
}  // namespace skyway
 
#endif /* SKYWAY_ROOM_ROOM_HPP */