local_sfu_room_member.hpp

#ifndef SKYWAY_ROOM_SFU_LOCAL_SFU_ROOM_MEMBER_HPP
#define SKYWAY_ROOM_SFU_LOCAL_SFU_ROOM_MEMBER_HPP
 
#include <skyway/plugin/sfu_bot_plugin/sfu_bot.hpp>
 
#include "skyway/room/abstract/local_room_member.hpp"
 
namespace skyway {
namespace room {
namespace sfu {
 
class LocalSFURoomMember : public abstract::LocalRoomMember {
public:
    LocalSFURoomMember(std::shared_ptr<core::interface::LocalPerson> core,
                       std::shared_ptr<interface::Room> room,
                       interface::RoomDomainFactory* factory);
 
    ~LocalSFURoomMember();
    std::shared_ptr<interface::RoomPublication> Publish(
        std::shared_ptr<media::stream::interface::local::LocalStream> stream,
        interface::LocalRoomMember::PublicationOptions options) override;
    std::shared_ptr<interface::RoomSubscription> Subscribe(
        const std::string& publication_id,
        interface::LocalRoomMember::SubscriptionOptions options) override;
    bool Unpublish(const std::string& publication_id) override;
    bool Unsubscribe(const std::string& subscription_id) override;
    std::vector<std::shared_ptr<interface::RoomPublication>> Publications() override;
 
private:
    std::shared_ptr<core::interface::LocalPerson> LocalPerson();
    void CleanupOnPublishFailure(
        const std::shared_ptr<core::interface::Publication>& origin_publication,
        const std::shared_ptr<plugin::sfu_bot::SfuBot>& sfu_bot,
        plugin::sfu_bot::Forwarding* forwarding);
};
 
}  // namespace sfu
}  // namespace room
}  // namespace skyway
 
#endif /* SKYWAY_ROOM_SFU_LOCAL_SFU_ROOM_MEMBER_HPP */