publication.hpp

//
//  publication.hpp
//  skyway
//
//  Created by sandabu on 2022/01/12.
//  Copyright © 2022 NTT Communications. All rights reserved.
//
 
#ifndef SKYWAY_CORE_PUBLICATION_HPP_
#define SKYWAY_CORE_PUBLICATION_HPP_
 
#include "skyway/core/interface/channel.hpp"
#include "skyway/core/interface/local_stream.hpp"
 
namespace skyway {
namespace core {
 
class Publication : public interface::Publication {
public:
    Publication(std::shared_ptr<interface::Channel> channel, const model::Publication& initial_dto);
    ~Publication();
 
    void AddEventListener(interface::Publication::EventListener* listener) override;
    void RemoveEventListener(interface::Publication::EventListener* listener) override;
 
    void AddInternalListener(InternalListener* listener) override;
    void RemoveInternalListener(InternalListener* listener) override;
 
    std::string Id() const override;
    std::shared_ptr<interface::Member> Publisher() const override;
    std::vector<std::shared_ptr<interface::Subscription>> Subscriptions() const override;
    model::ContentType ContentType() const override;
    std::optional<std::string> Metadata() const override;
    std::shared_ptr<interface::Publication> Origin() const override;
    std::vector<model::Codec> CodecCapabilities() const override;
    std::vector<model::Encoding> Encodings() const override;
    interface::PublicationState State() override;
 
    std::shared_ptr<interface::LocalStream> Stream() const override;
 
    bool UpdateMetadata(const std::string& metadata) override;
    bool UpdateEncodings(std::vector<model::Encoding> encodings) override;
    bool ReplaceStream(std::shared_ptr<interface::LocalStream> stream) override;
    bool Cancel() const override;
    bool Enable() override;
    bool Disable() const override;
 
    std::optional<model::WebRTCStats> GetStats(const std::string& selector) override;
    void AddGetStatsCallback(const std::string& remote_member_id, Callback* callback) override;
    void RemoveGetStatsCallback(const std::string& remote_member_id) override;
 
    void SetCodecCapabilities(std::vector<model::Codec> codec_capabilities) override;
    void SetEncodings(std::vector<model::Encoding> encodings) override;
    void SetStream(std::shared_ptr<interface::LocalStream> stream) override;
    bool IsEnabling() override;
    void Dispose() override;
 
    void OnUnpublished() override;
    void OnSubscribed(std::shared_ptr<interface::Subscription> subscription) override;
    void OnUnsubscribed(std::shared_ptr<interface::Subscription> subscription) override;
    void OnMetadataUpdated(const std::string& metadata) override;
    void OnEnabled() override;
    void OnDisabled() override;
    void OnConnectionStateChanged(const ConnectionState new_state) override;
 
private:
    std::weak_ptr<interface::Channel> channel_;
    model::Publication initial_dto_;
    std::atomic<interface::PublicationState> state_;
    std::vector<model::Codec> codec_capabilities_;
    std::vector<model::Encoding> encodings_;
 
    std::weak_ptr<interface::Member> publisher_;
    std::shared_ptr<interface::LocalStream> stream_;
 
    std::mutex listeners_mtx_;
    std::mutex internal_listeners_mtx_;
    std::unordered_set<interface::Publication::EventListener*> listeners_;
    std::unordered_set<interface::Publication::InternalListener*> internal_listeners_;
    std::atomic<bool> metadata_updated_;
    bool is_enabling_;
    std::mutex get_stats_callback_mutex_;
    std::unordered_map<std::string, Callback*> get_stats_callbacks_;
};
 
}  // namespace core
}  // namespace skyway
 
#endif /* SKYWAY_CORE_PUBLICATION_HPP_ */