StreamManager refactoring

[platform/core/ml/aitt.git] / modules / webrtc / SrcStreamManager.h

diff --git a/modules/webrtc/SrcStreamManager.h b/modules/webrtc/SrcStreamManager.h
index aca572a..e87d063 100644 (file)
--- a/modules/webrtc/SrcStreamManager.h
+++ b/modules/webrtc/SrcStreamManager.h
@@ -27,40 +27,22 @@ class SrcStreamManager : public StreamManager {
     explicit SrcStreamManager(const std::string &topic, const std::string &aitt_id,
           const std::string &thread_id);
     virtual ~SrcStreamManager();
-    void Start(void) override;
-    // TODO: What's the best way to shutdown all?
-    void Stop(void) override;
-    void SetIceCandidateAddedCallback(IceCandidateAddedCallback cb) override;
-    void SetStreamReadyCallback(StreamReadyCallback cb) override;
-    void SetStreamStartCallback(StreamStartCallback cb) override;
-    void SetStreamStopCallback(StreamStopCallback cb) override;
     std::vector<uint8_t> GetDiscoveryMessage(void) override;
-    std::string GetWatchingTopic(void) override;
-    void HandleRemovedClient(const std::string &discovery_id) override;
-    void HandleMsg(const std::string &discovery_id, const std::vector<uint8_t> &message) override;
 
   private:
     void SetWebRtcStreamCallbacks(WebRtcStream &stream) override;
-    void OnStreamStateChanged(WebRtcState::Stream state, WebRtcStream &stream);
+    void OnStreamStateChanged(WebRtcState::Stream state);
     void OnAnswerCreated(std::string sdp, WebRtcStream &stream);
-    void OnIceCandidate(const std::string &candidate, WebRtcStream &stream);
+    void OnIceCandidate(void);
     void OnSignalingStateNotify(WebRtcState::Signaling state, WebRtcStream &stream);
-    void OnIceGatheringStateNotify(WebRtcState::IceGathering state, WebRtcStream &stream);
-    void HandleStreamState(const std::string &discovery_id, const std::vector<uint8_t> &message);
-    void HandleStreamInfo(const std::string &discovery_id, const std::vector<uint8_t> &message);
+    void HandleStreamState(const std::string &discovery_id,
+          const std::vector<uint8_t> &message) override;
+    void HandleStreamInfo(const std::string &discovery_id,
+          const std::vector<uint8_t> &message) override;
     void AddStream(const std::string &discovery_id, const std::string &id, const std::string &sdp,
           const std::vector<std::string> &ice_candidates);
     void UpdateStreamInfo(const std::string &discovery_id, const std::string &id,
           const std::string &peer_id, const std::string &sdp,
           const std::vector<std::string> &ice_candidates);
-
-    std::string watching_topic_;
-    // TODO: What if user copies the module?
-    // Think about that case with destructor
-    std::map<std::string /* Peer Aitt Discovery ID */, WebRtcStream *> sink_streams_;
-    IceCandidateAddedCallback ice_candidate_added_cb_;
-    StreamReadyCallback stream_ready_cb_;
-    StreamStartCallback stream_start_cb_;
-    StreamStopCallback stream_stop_cb_;
 };
 }  // namespace AittWebRTCNamespace