subscription.hpp

//
//  subscription.hpp
//  skyway
//
//  Created by sandabu on 2022/01/13.
//  Copyright © 2022 NTT Communications. All rights reserved.
//
 
#ifndef SKYWAY_CORE_INTERFACE_SUBSCRIPTION_HPP_
#define SKYWAY_CORE_INTERFACE_SUBSCRIPTION_HPP_
 
#include "skyway/core/connection_state.hpp"
#include "skyway/core/interface/member.hpp"
#include "skyway/core/interface/remote_stream.hpp"
#include "skyway/model/domain.hpp"
 
namespace skyway {
namespace core {
namespace interface {
 
class Publication;
 
enum class SubscriptionState { kEnabled, kDisabled, kCanceled };
 
// `std::enable_shared_from_this<T>` is supposed to be inherited by concrete classes.
// (e.g. skyway/core/subscription.hpp)
// however if so, compile failed on the Android SDK that includes interfaces.
class Subscription : public std::enable_shared_from_this<Subscription>,
                     public ConnectionStateChangeNotifiable {
public:
    class EventListener {
    public:
        [[deprecated]] virtual void OnCanceled() {}
        virtual void OnConnectionStateChanged(const ConnectionState state) {}
    };
    class InternalListener {
    public:
        virtual void OnChangePreferredEncoding(std::shared_ptr<Subscription> subscription) = 0;
    };
    class Callback {
    public:
        virtual const std::optional<nlohmann::json> GetStatsReport(
            std::shared_ptr<Subscription> subscription) = 0;
    };
    virtual ~Subscription() = default;
 
    virtual void AddEventListener(EventListener* listener) = 0;
    virtual void RemoveEventListener(EventListener* listener) = 0;
    virtual void AddInternalListener(InternalListener* listener)    = 0;
    virtual void RemoveInternalListener(InternalListener* listener) = 0;
 
    virtual std::string Id() const = 0;
    virtual model::ContentType ContentType() const = 0;
    virtual std::shared_ptr<interface::Publication> Publication() const = 0;
    virtual std::shared_ptr<interface::Member> Subscriber() const = 0;
    virtual SubscriptionState State() = 0;
    virtual std::shared_ptr<RemoteStream> Stream() = 0;
    virtual std::optional<std::string> PreferredEncodingId() const = 0;
    virtual bool ChangePreferredEncoding(const std::string& id) = 0;
    [[deprecated]] virtual bool Cancel() const = 0;
    [[deprecated]] virtual std::optional<model::WebRTCStats> GetStats() = 0;
    virtual void AddGetStatsCallback(Callback* callback) = 0;
    virtual void RemoveGetStatsCallback()                = 0;
 
    virtual void SetStream(std::shared_ptr<RemoteStream> stream) = 0;
    virtual void SetPreferredEncodingId(const std::string& id)   = 0;
 
    virtual void OnCanceled() = 0;
};
 
}  // namespace interface
}  // namespace core
}  // namespace skyway
 
#endif /* SKYWAY_CORE_INTERFACE_SUBSCRIPTION_HPP_ */