local_p2p_room_member.hpp

//
//  local_p2p_room_member.hpp
//  skyway
//
//  Created by Naoto Takahashi on 2023/11/22.
//  Copyright © 2023 NTT Communications. All rights reserved.
//
#ifndef SKYWAY_ROOM_P2P_LOCAL_P2P_ROOM_MEMBER_HPP
#define SKYWAY_ROOM_P2P_LOCAL_P2P_ROOM_MEMBER_HPP
 
#include "skyway/room/abstract/local_room_member.hpp"
 
namespace skyway {
namespace room {
namespace p2p {
 
class LocalP2PRoomMember : public abstract::LocalRoomMember {
public:
    LocalP2PRoomMember(core::interface::LocalPerson* core,
                       std::shared_ptr<interface::Room> room,
                       interface::RoomDomainFactory* factory);
    ~LocalP2PRoomMember();
    std::unique_ptr<interface::RoomPublication> Publish(
        std::shared_ptr<core::interface::LocalStream> stream,
        interface::LocalRoomMember::PublicationOptions options) override;
    std::unique_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;
 
private:
    core::interface::LocalPerson* LocalPerson();
};
 
}  // namespace p2p
}  // namespace room
}  // namespace skyway
 
#endif /* SKYWAY_ROOM_P2P_LOCAL_P2P_ROOM_MEMBER_HPP */