sfu_room.hpp

#ifndef SKYWAY_ROOM_SFU_SFU_ROOM_HPP
#define SKYWAY_ROOM_SFU_SFU_ROOM_HPP
 
#include <skyway/plugin/sfu_bot_plugin/sfu_bot.hpp>
 
#include "skyway/room/abstract/room.hpp"
#include "skyway/room/sfu/local_sfu_room_member.hpp"
#include "skyway/room/sfu/room_domain_factory.hpp"
 
namespace skyway {
namespace room {
namespace sfu {
 
class SFURoomFactory : 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 SFURoom : public abstract::Room, public std::enable_shared_from_this<SFURoom> {
public:
    SFURoom(std::shared_ptr<core::interface::Channel> channel,
            std::unique_ptr<interface::RoomDomainFactory> factory);
 
    ~SFURoom() 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<SFURoom> Create(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<SFURoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    static std::shared_ptr<SFURoom> Create();
 
    static std::shared_ptr<SFURoom> Find(
        interface::RoomQuery query,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<SFURoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    static std::shared_ptr<SFURoom> FindOrCreate(
        interface::RoomInitOptions options,
        std::unique_ptr<interface::RoomFactory> room_factory = std::make_unique<SFURoomFactory>(),
        std::unique_ptr<interface::RoomDomainFactory> domain_factory =
            std::make_unique<RoomDomainFactory>());
 
    std::shared_ptr<LocalSFURoomMember> 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<SFURoom> CreateShared(
        std::shared_ptr<core::interface::Channel> channel,
        std::unique_ptr<interface::RoomDomainFactory> factory);
 
public:
    friend class SFURoomFactory;
    friend class SFURoomTest;
    friend class LocalSFURoomMemberTest;
};
 
}  // namespace sfu
}  // namespace room
}  // namespace skyway
 
#endif /* SKYWAY_ROOM_SFU_SFU_ROOM_HPP */