Added implementation of RemoteMediaStreams.

content/renderer/media/mock_media_stream_dependency_factory.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/renderer/media/mock_media_stream_dependency_factory.h"
 
 #include "base/logging.h"
 #include "content/renderer/media/mock_peer_connection_impl.h"
 #include "third_party/libjingle/source/talk/app/webrtc/mediastreaminterface.h"
 #include "third_party/libjingle/source/talk/base/scoped_ref_ptr.h"
@@ skipping 21 matching lines @@
     if ((*it)->id() == track_id) {
       break;
     }
   }
   return it;
 };
 
 class MockMediaStream : public webrtc::MediaStreamInterface {
  public:
   explicit MockMediaStream(const std::string& label)
-      : label_(label) {
+      : label_(label),
+        observer_(NULL) {
   }
   virtual bool AddTrack(AudioTrackInterface* track) OVERRIDE {
     audio_track_vector_.push_back(track);
+    if (observer_)
+      observer_->OnChanged();
     return true;
   }
   virtual bool AddTrack(VideoTrackInterface* track) OVERRIDE {
     video_track_vector_.push_back(track);
+    if (observer_)
+      observer_->OnChanged();
     return true;
   }
   virtual bool RemoveTrack(AudioTrackInterface* track) OVERRIDE {
     AudioTrackVector::iterator it = FindTrack(&audio_track_vector_,
                                               track->id());
     if (it == audio_track_vector_.end())
       return false;
     audio_track_vector_.erase(it);
+    if (observer_)
+      observer_->OnChanged();
     return true;
   }
   virtual bool RemoveTrack(VideoTrackInterface* track) OVERRIDE {
     VideoTrackVector::iterator it = FindTrack(&video_track_vector_,
                                               track->id());
     if (it == video_track_vector_.end())
       return false;
     video_track_vector_.erase(it);
+    if (observer_)
+      observer_->OnChanged();
     return true;
   }
   virtual std::string label() const OVERRIDE { return label_; }
   virtual AudioTrackVector GetAudioTracks() OVERRIDE {
     return audio_track_vector_;
   }
   virtual VideoTrackVector GetVideoTracks() OVERRIDE {
     return video_track_vector_;
   }
   virtual talk_base::scoped_refptr<AudioTrackInterface>
       FindAudioTrack(const std::string& track_id) OVERRIDE {
     AudioTrackVector::iterator it = FindTrack(&audio_track_vector_, track_id);
     return it == audio_track_vector_.end() ? NULL : *it;
   }
   virtual talk_base::scoped_refptr<VideoTrackInterface>
       FindVideoTrack(const std::string& track_id) OVERRIDE {
     VideoTrackVector::iterator it = FindTrack(&video_track_vector_, track_id);
     return it == video_track_vector_.end() ? NULL : *it;
   }
   virtual void RegisterObserver(ObserverInterface* observer) OVERRIDE {
-    NOTIMPLEMENTED();
+    observer_ = observer;

[tommi (sloooow) - chröme, 2013/04/16 15:59:59]

first DCHECK(!observer_)?

[perkj_chrome, 2013/04/18 14:46:58]

Done.

   }
   virtual void UnregisterObserver(ObserverInterface* observer) OVERRIDE {
-    NOTIMPLEMENTED();
+    DCHECK(observer_ == observer);
+    observer_ = NULL;
   }
 
  protected:
   virtual ~MockMediaStream() {}
 
  private:
   std::string label_;
   AudioTrackVector audio_track_vector_;
   VideoTrackVector video_track_vector_;
+  webrtc::ObserverInterface* observer_;
 };
 
 MockAudioSource::MockAudioSource(
     const webrtc::MediaConstraintsInterface* constraints)
     : observer_(NULL),
       state_(MediaSourceInterface::kInitializing),
       optional_constraints_(constraints->GetOptional()),
       mandatory_constraints_(constraints->GetMandatory()) {
 }
 
@@ skipping 75 matching lines @@
 
 const cricket::VideoOptions* MockVideoSource::options() const {
   NOTIMPLEMENTED();
   return NULL;
 }
 
 MockLocalVideoTrack::MockLocalVideoTrack(std::string id,
                                          webrtc::VideoSourceInterface* source)
     : enabled_(false),
       id_(id),
-      source_(source) {
+      state_(MediaStreamTrackInterface::kLive),
+      source_(source),
+      observer_(NULL) {
 }
 
 MockLocalVideoTrack::~MockLocalVideoTrack() {}
 
 void MockLocalVideoTrack::AddRenderer(VideoRendererInterface* renderer) {
   NOTIMPLEMENTED();
 }
 
 void MockLocalVideoTrack::RemoveRenderer(VideoRendererInterface* renderer) {
   NOTIMPLEMENTED();
 }
 
 cricket::VideoRenderer* MockLocalVideoTrack::FrameInput() {
   NOTIMPLEMENTED();
   return NULL;
 }
 
 std::string MockLocalVideoTrack::kind() const {
   NOTIMPLEMENTED();
   return std::string();
 }
 
 std::string MockLocalVideoTrack::id() const { return id_; }
 
 bool MockLocalVideoTrack::enabled() const { return enabled_; }
 
 MockLocalVideoTrack::TrackState MockLocalVideoTrack::state() const {
-  NOTIMPLEMENTED();
-  return kInitializing;
+  return state_;
 }
 
 bool MockLocalVideoTrack::set_enabled(bool enable) {
   enabled_ = enable;
   return true;
 }
 
 bool MockLocalVideoTrack::set_state(TrackState new_state) {
-  NOTIMPLEMENTED();
-  return false;
+  state_ = new_state;
+  if (observer_)
+    observer_->OnChanged();
+  return true;
 }
 
 void MockLocalVideoTrack::RegisterObserver(ObserverInterface* observer) {
-  NOTIMPLEMENTED();
+  observer_ = observer;
 }
 
 void MockLocalVideoTrack::UnregisterObserver(ObserverInterface* observer) {
-  NOTIMPLEMENTED();
+  DCHECK(observer_ == observer);
+  observer_ = NULL;
 }
 
 VideoSourceInterface* MockLocalVideoTrack::GetSource() const {
   return source_;
 }
 
 std::string MockLocalAudioTrack::kind() const {
   NOTIMPLEMENTED();
   return std::string();
 }
 
 std::string MockLocalAudioTrack::id() const { return id_; }
 
 bool MockLocalAudioTrack::enabled() const { return enabled_; }
 
-MockLocalVideoTrack::TrackState MockLocalAudioTrack::state() const {
-  NOTIMPLEMENTED();
-  return kInitializing;
+MockLocalAudioTrack::TrackState MockLocalAudioTrack::state() const {
+  return state_;
 }
 
 bool MockLocalAudioTrack::set_enabled(bool enable) {
   enabled_ = enable;
   return true;
 }
 
 bool MockLocalAudioTrack::set_state(TrackState new_state) {
-  NOTIMPLEMENTED();
-  return false;
+  state_ = new_state;
+  if (observer_)
+    observer_->OnChanged();
+  return true;
 }
 
 void MockLocalAudioTrack::RegisterObserver(ObserverInterface* observer) {
-  NOTIMPLEMENTED();
+  observer_ = observer;
 }
 
 void MockLocalAudioTrack::UnregisterObserver(ObserverInterface* observer) {
-  NOTIMPLEMENTED();
+  DCHECK(observer_ == observer);
+  observer_ = NULL;
 }
 
 AudioSourceInterface* MockLocalAudioTrack::GetSource() const {
   NOTIMPLEMENTED();
   return NULL;
 }
 
 class MockSessionDescription : public SessionDescriptionInterface {
  public:
   MockSessionDescription(const std::string& type,
@@ skipping 170 matching lines @@
 
 webrtc::IceCandidateInterface*
 MockMediaStreamDependencyFactory::CreateIceCandidate(
     const std::string& sdp_mid,
     int sdp_mline_index,
     const std::string& sdp) {
   return new MockIceCandidate(sdp_mid, sdp_mline_index, sdp);
 }
 
 }  // namespace content