Refactor Clank cast connect logic

chrome/browser/media/android/remote/remote_media_player_bridge.cc

 // Copyright 2013 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 "chrome/browser/media/android/remote/remote_media_player_bridge.h"
 
 #include "base/android/jni_android.h"
 #include "base/android/jni_string.h"
 #include "chrome/browser/media/android/remote/record_cast_action.h"
 #include "chrome/browser/media/android/remote/remote_media_player_manager.h"
 #include "content/public/browser/android/content_view_core.h"
 #include "content/public/browser/web_contents.h"
 #include "jni/RemoteMediaPlayerBridge_jni.h"
 #include "media/base/android/media_common_android.h"
 #include "media/base/android/media_resource_getter.h"
 #include "media/base/timestamp_constants.h"
 #include "third_party/skia/include/core/SkBitmap.h"
 #include "ui/gfx/android/java_bitmap.h"
 
 using base::android::ConvertUTF8ToJavaString;
+using base::android::ConvertJavaStringToUTF8;
 using base::android::ScopedJavaLocalRef;
 using base::android::AttachCurrentThread;
 
 namespace {
 /*
  * Dummy function for RequestMediaResources callback. The callback is never
  * actually called by MediaPlayerAndroid or RemoteMediaPlayer but is needed
  * to compile the constructor call.
  */
 void DoNothing(int /*i*/) {}
 }
 
 namespace remote_media {
 
 RemoteMediaPlayerBridge::RemoteMediaPlayerBridge(
     MediaPlayerAndroid* local_player, const std::string& user_agent,
     bool hide_url_log, RemoteMediaPlayerManager* manager)
     : MediaPlayerAndroid(local_player->player_id(), manager,
                          base::Bind(&DoNothing),
                          local_player->frame_url()),
       start_position_millis_(0),
       local_player_(local_player),
-      in_use_(false),
-      prepared_(false),
-      pending_play_(false),
       width_(0),
       height_(0),
-      should_seek_on_prepare_(false),
       hide_url_log_(hide_url_log),
       volume_(-1.0),
       url_(local_player->GetUrl()),
       first_party_for_cookies_(local_player->GetFirstPartyForCookies()),
       user_agent_(user_agent),
       weak_factory_(this) {
   if (local_player->GetCurrentTime().InMilliseconds() > 0)
     start_position_millis_ = local_player->GetCurrentTime().InMilliseconds();
   JNIEnv* env = base::android::AttachCurrentThread();
   CHECK(env);
   ScopedJavaLocalRef<jstring> j_url_string;
   if (url_.is_valid()) {
     // Create a Java String for the URL.
     j_url_string = ConvertUTF8ToJavaString(env, url_.spec());
   }
   ScopedJavaLocalRef<jstring> j_frame_url_string;
   if (local_player->frame_url().is_valid()) {
     // Create a Java String for the URL.
     j_frame_url_string = ConvertUTF8ToJavaString(
         env, local_player->frame_url().spec());
   }
-  java_bridge_.Reset(
-      Java_RemoteMediaPlayerBridge_create(env, reinterpret_cast<intptr_t>(this),
-                                          start_position_millis_,
-                                          j_url_string.obj(),
-                                          j_frame_url_string.obj()));
+  java_bridge_.Reset(Java_RemoteMediaPlayerBridge_create(
+      env, reinterpret_cast<intptr_t>(this), start_position_millis_,
+      j_url_string.obj(), j_frame_url_string.obj(),
+      ConvertUTF8ToJavaString(env, user_agent).obj()));
 }
 
 RemoteMediaPlayerBridge::~RemoteMediaPlayerBridge() {
   JNIEnv* env = base::android::AttachCurrentThread();
   CHECK(env);
   Java_RemoteMediaPlayerBridge_destroy(env, java_bridge_.obj());
   Release();
 }
 
 int RemoteMediaPlayerBridge::GetVideoWidth() {
@@ skipping 10 matching lines @@
   MediaPlayerAndroid::OnVideoSizeChanged(width, height);
 }
 
 void RemoteMediaPlayerBridge::OnPlaybackComplete() {
   time_update_timer_.Stop();
   MediaPlayerAndroid::OnPlaybackComplete();
 }
 
 void RemoteMediaPlayerBridge::OnMediaInterrupted() {}
 
-void RemoteMediaPlayerBridge::OnMediaPrepared() {
-  if (!in_use_)
-    return;
-
-  prepared_ = true;
-  duration_ = GetDuration();
-
-  // If media player was recovered from a saved state, consume all the pending
-  // events.
-  if (should_seek_on_prepare_) {
-    PendingSeekInternal(pending_seek_);
-    pending_seek_ = base::TimeDelta::FromMilliseconds(0);
-    should_seek_on_prepare_ = false;
-  }
-
-  if (pending_play_) {
-    StartInternal();
-    pending_play_ = false;
-  }
-
-  manager()->OnMediaMetadataChanged(
-      player_id(), duration_, width_, height_, true);
-}
-
 void RemoteMediaPlayerBridge::StartInternal() {
   JNIEnv* env = AttachCurrentThread();
   Java_RemoteMediaPlayerBridge_start(env, java_bridge_.obj());
   if (!time_update_timer_.IsRunning()) {
     time_update_timer_.Start(
         FROM_HERE,
         base::TimeDelta::FromMilliseconds(media::kTimeUpdateInterval),
         this, &RemoteMediaPlayerBridge::OnTimeUpdateTimerFired);
   }
 }
 
 void RemoteMediaPlayerBridge::PauseInternal() {
   JNIEnv* env = AttachCurrentThread();
   Java_RemoteMediaPlayerBridge_pause(env, java_bridge_.obj());
   time_update_timer_.Stop();
 }
 
-void RemoteMediaPlayerBridge::SeekInternal(base::TimeDelta time) {
-  if (time > duration_)
-    time = duration_;
-
-  // Seeking to an invalid position may cause media player to stuck in an
-  // error state.
-  if (time < base::TimeDelta()) {
-    DCHECK_EQ(-1.0, time.InMillisecondsF());
-    return;
-  }
-
-  JNIEnv* env = AttachCurrentThread();
-  CHECK(env);
-  int time_msec = static_cast<int>(time.InMilliseconds());
-  Java_RemoteMediaPlayerBridge_seekTo(
-      env, java_bridge_.obj(), time_msec);
-}
-
 void RemoteMediaPlayerBridge::OnTimeUpdateTimerFired() {
   manager()->OnTimeUpdate(
       player_id(), GetCurrentTime(), base::TimeTicks::Now());
 }
 
-void RemoteMediaPlayerBridge::PendingSeekInternal(const base::TimeDelta& time) {
-  SeekInternal(time);
+void RemoteMediaPlayerBridge::PauseLocal(JNIEnv* env, jobject obj) {
+  local_player_->Pause(true);
+  static_cast<RemoteMediaPlayerManager*>(manager())->OnPaused(player_id());
 }
 
-void RemoteMediaPlayerBridge::Prepare() {
-  DCHECK(!in_use_);
-  DCHECK(IsMediaPlayableRemotely());
-  in_use_ = true;
-  AttachListener(java_bridge_.obj());
-  JNIEnv* env = AttachCurrentThread();
-  CHECK(env);
+jint RemoteMediaPlayerBridge::GetLocalPosition(JNIEnv* env, jobject obj) {
+  base::TimeDelta time = local_player_->GetCurrentTime();
+  return static_cast<jint>(time.InMilliseconds());
+}
 
-  if (url_.is_valid()) {
-    // Create a Java String for the URL.
-    ScopedJavaLocalRef<jstring> j_url_string =
-        ConvertUTF8ToJavaString(env, url_.spec());
+void RemoteMediaPlayerBridge::OnCastStarting(JNIEnv* env,
+                                             jobject obj,
+                                             jstring casting_message) {
+  static_cast<RemoteMediaPlayerManager*>(manager())->SwitchToRemotePlayer(
+      player_id(), ConvertJavaStringToUTF8(env, casting_message));
+  if (!time_update_timer_.IsRunning()) {
+    time_update_timer_.Start(
+        FROM_HERE,
+        base::TimeDelta::FromMilliseconds(media::kTimeUpdateInterval), this,
+        &RemoteMediaPlayerBridge::OnTimeUpdateTimerFired);
+  }
+}
 
-    jobject j_context = base::android::GetApplicationContext();
-    DCHECK(j_context);
-
-    ScopedJavaLocalRef<jstring> j_cookies = ConvertUTF8ToJavaString(
-        env, cookies_);
-    ScopedJavaLocalRef<jstring> j_user_agent = ConvertUTF8ToJavaString(
-        env, user_agent_);
-
-    if (!Java_RemoteMediaPlayerBridge_setDataSource(
-        env, java_bridge_.obj(), j_context, j_url_string.obj(),
-        j_cookies.obj(), j_user_agent.obj(), hide_url_log_)) {
-      OnMediaError(MEDIA_ERROR_FORMAT);
-      return;
-    }
-  }
-
-  if (!Java_RemoteMediaPlayerBridge_prepareAsync(env, java_bridge_.obj()))
-    OnMediaError(MEDIA_ERROR_FORMAT);
+void RemoteMediaPlayerBridge::OnCastStopping(JNIEnv* env, jobject obj) {
+  static_cast<RemoteMediaPlayerManager*>(manager())
+      ->SwitchToLocalPlayer(player_id());
 }
 
 void RemoteMediaPlayerBridge::Pause(bool is_media_related_action) {
   // Ignore the pause if it's not from an event that is explicitly telling
   // the video to pause. It's possible for Pause() to be called for other
   // reasons, such as freeing resources, etc. and during those times, the
   // remote video playback should not be paused.
   if (is_media_related_action) {
-    if (!in_use_) {
-      pending_play_ = false;
-    } else {
-      if (prepared_ && IsPlaying())
-        PauseInternal();
-      else
-        pending_play_ = false;
-    }
+    JNIEnv* env = AttachCurrentThread();
+    Java_RemoteMediaPlayerBridge_pause(env, java_bridge_.obj());
+    time_update_timer_.Stop();
   }
 }
 
 void RemoteMediaPlayerBridge::SetVideoSurface(gfx::ScopedJavaSurface surface) {
   // The surface is reset whenever the fullscreen view is destroyed or created.
   // Since the remote player doesn't use it, we forward it to the local player
   // for the time when user disconnects and resumes local playback
   // (see crbug.com/420690).
   local_player_->SetVideoSurface(surface.Pass());
 }
 
 base::android::ScopedJavaLocalRef<jstring> RemoteMediaPlayerBridge::GetFrameUrl(
     JNIEnv* env, jobject obj) {
   return ConvertUTF8ToJavaString(env, frame_url().spec());
 }
 
 void RemoteMediaPlayerBridge::OnPlaying(JNIEnv* env, jobject obj) {
   static_cast<RemoteMediaPlayerManager *>(manager())->OnPlaying(player_id());
 }
 
 void RemoteMediaPlayerBridge::OnPaused(JNIEnv* env, jobject obj) {
   static_cast<RemoteMediaPlayerManager *>(manager())->OnPaused(player_id());
 }
 
-void RemoteMediaPlayerBridge::OnRouteSelected(JNIEnv* env, jobject obj,
-                                              jstring castingMessage) {
-  casting_message_.reset(
-      new std::string(
-          base::android::ConvertJavaStringToUTF8(env, castingMessage)));
-  static_cast<RemoteMediaPlayerManager *>(manager())->OnRemoteDeviceSelected(
-      player_id());
-}
-
 void RemoteMediaPlayerBridge::OnRouteUnselected(JNIEnv* env, jobject obj) {
   casting_message_.reset();
   static_cast<RemoteMediaPlayerManager *>(manager())->OnRemoteDeviceUnselected(
       player_id());
 }
 
 void RemoteMediaPlayerBridge::OnPlaybackFinished(JNIEnv* env, jobject obj) {
   static_cast<RemoteMediaPlayerManager *>(manager())->OnRemotePlaybackFinished(
       player_id());
 }
@@ skipping 45 matching lines @@
 }
 
 void RemoteMediaPlayerBridge::OnPlayerDestroyed() {
   JNIEnv* env = AttachCurrentThread();
   CHECK(env);
 
   Java_RemoteMediaPlayerBridge_onPlayerDestroyed(
       env, java_bridge_.obj());
 }
 
-bool RemoteMediaPlayerBridge::IsRemotePlaybackAvailable() const {
-  JNIEnv* env = AttachCurrentThread();
-  CHECK(env);
-
-  jboolean result = Java_RemoteMediaPlayerBridge_isRemotePlaybackAvailable(
-      env, java_bridge_.obj());
-
-  return result;
-}
-
-bool RemoteMediaPlayerBridge::IsRemotePlaybackPreferredForFrame() const {
-  if (in_use_) {
-    // We have already decided to use remote playback
-    return true;
-  }
-  JNIEnv* env = AttachCurrentThread();
-  CHECK(env);
-
-  jboolean result =
-      Java_RemoteMediaPlayerBridge_isRemotePlaybackPreferredForFrame(
-          env, java_bridge_.obj());
-  return result;
-}
-
 std::string RemoteMediaPlayerBridge::GetCastingMessage() {
   return casting_message_ ?
       *casting_message_ : std::string();
 }
 
 void RemoteMediaPlayerBridge::SetPosterBitmap(
     const std::vector<SkBitmap>& bitmaps) {
   JNIEnv* env = AttachCurrentThread();
   CHECK(env);
 
   if (bitmaps.empty()) {
     Java_RemoteMediaPlayerBridge_setPosterBitmap(env, java_bridge_.obj(), NULL);
   } else {
     ScopedJavaLocalRef<jobject> j_poster_bitmap;
     j_poster_bitmap = gfx::ConvertToJavaBitmap(&(bitmaps[0]));
 
     Java_RemoteMediaPlayerBridge_setPosterBitmap(env, java_bridge_.obj(),
                                                  j_poster_bitmap.obj());
   }
 }
 
 void RemoteMediaPlayerBridge::Start() {
-  if (!in_use_) {
-    pending_play_ = true;
-    Prepare();
-  } else {
-    if (prepared_)
-      StartInternal();
-    else
-      pending_play_ = true;
-  }
+  StartInternal();
 }
 
-void RemoteMediaPlayerBridge::SeekTo(base::TimeDelta timestamp) {
-  // Record the time to seek when OnMediaPrepared() is called.
-  pending_seek_ = timestamp;
-  should_seek_on_prepare_ = true;
+void RemoteMediaPlayerBridge::SeekTo(base::TimeDelta time) {
+  // TODO(aberent) Move the checks to the Java side.
+  base::TimeDelta duration = GetDuration();
 
-  if (!in_use_)
-    Prepare();
-  else if (prepared_)
-    SeekInternal(timestamp);
-}
+  if (time > duration)
+    time = duration;
 
-void RemoteMediaPlayerBridge::Release() {
-  if (!in_use_)
-    return;
-  time_update_timer_.Stop();
-  if (prepared_) {
-    pending_seek_ = GetCurrentTime();
-    should_seek_on_prepare_ = true;
-  }
-
-  prepared_ = false;
-  pending_play_ = false;
-  JNIEnv* env = AttachCurrentThread();
-  Java_RemoteMediaPlayerBridge_release(env, java_bridge_.obj());
-  DetachListener();
-  in_use_ = false;
-}
-
-void RemoteMediaPlayerBridge::SetVolume(double volume) {
-  if (!in_use_) {
-    volume_ = volume;
+  // Seeking to an invalid position may cause media player to stuck in an
+  // error state.
+  if (time < base::TimeDelta()) {
+    DCHECK_EQ(-1.0, time.InMillisecondsF());
     return;
   }
 
   JNIEnv* env = AttachCurrentThread();
   CHECK(env);
+  int time_msec = static_cast<int>(time.InMilliseconds());
+  Java_RemoteMediaPlayerBridge_seekTo(env, java_bridge_.obj(), time_msec);
+}
+
+void RemoteMediaPlayerBridge::Release() {
+  time_update_timer_.Stop();
+  JNIEnv* env = AttachCurrentThread();
+  Java_RemoteMediaPlayerBridge_release(env, java_bridge_.obj());
+  DetachListener();
+}
+
+void RemoteMediaPlayerBridge::SetVolume(double volume) {
+  JNIEnv* env = AttachCurrentThread();
+  CHECK(env);
   Java_RemoteMediaPlayerBridge_setVolume(
       env, java_bridge_.obj(), volume);
 }
 
 base::TimeDelta RemoteMediaPlayerBridge::GetCurrentTime() {
-  if (!prepared_)
-    return pending_seek_;
   JNIEnv* env = AttachCurrentThread();
   return base::TimeDelta::FromMilliseconds(
       Java_RemoteMediaPlayerBridge_getCurrentPosition(
           env, java_bridge_.obj()));
 }
 
 base::TimeDelta RemoteMediaPlayerBridge::GetDuration() {
-  if (!prepared_)
-    return duration_;
   JNIEnv* env = AttachCurrentThread();
   const int duration_ms =
       Java_RemoteMediaPlayerBridge_getDuration(env, java_bridge_.obj());
   // Sometimes we can't get the duration remotely, but the local media player
   // knows it.
   // TODO (aberent) This is for YouTube. Remove it when the YouTube receiver is
   // fixed.
   if (duration_ms == 0) {
     return local_player_->GetDuration();
   }
   return duration_ms < 0 ? media::kInfiniteDuration()
                          : base::TimeDelta::FromMilliseconds(duration_ms);
 }
 
 bool RemoteMediaPlayerBridge::IsPlaying() {
-  if (!prepared_)
-    return pending_play_;
-
   JNIEnv* env = AttachCurrentThread();
   CHECK(env);
   jboolean result = Java_RemoteMediaPlayerBridge_isPlaying(
       env, java_bridge_.obj());
   return result;
 }
 
 bool RemoteMediaPlayerBridge::CanPause() {
   return true;
 }
 
 bool RemoteMediaPlayerBridge::CanSeekForward() {
   return true;
 }
 
 bool RemoteMediaPlayerBridge::CanSeekBackward() {
   return true;
 }
 
 bool RemoteMediaPlayerBridge::IsPlayerReady() {
-  return prepared_;
+  return true;
 }
 
 GURL RemoteMediaPlayerBridge::GetUrl() {
   return url_;
 }
 
 GURL RemoteMediaPlayerBridge::GetFirstPartyForCookies() {
   return first_party_for_cookies_;
 }
 
 void RemoteMediaPlayerBridge::Initialize() {
   cookies_.clear();
   media::MediaResourceGetter* resource_getter =
       manager()->GetMediaResourceGetter();
   resource_getter->GetCookies(
       url_, first_party_for_cookies_,
       base::Bind(&RemoteMediaPlayerBridge::OnCookiesRetrieved,
                  weak_factory_.GetWeakPtr()));
 }
 
-bool RemoteMediaPlayerBridge::IsMediaPlayableRemotely() const {
-  JNIEnv* env = AttachCurrentThread();
-  CHECK(env);
-
-  return Java_RemoteMediaPlayerBridge_isMediaPlayableRemotely(
-      env, java_bridge_.obj());
-}
-
 base::android::ScopedJavaLocalRef<jstring> RemoteMediaPlayerBridge::GetTitle(
     JNIEnv* env, jobject obj) {
   base::string16 title;
   content::ContentViewCore* core =
       static_cast<RemoteMediaPlayerManager*>(manager())->GetContentViewCore();
   if (core) {
     content::WebContents* contents = core->GetWebContents();
     if (contents) {
       title = contents->GetTitle();
     }
   }
   return base::android::ConvertUTF16ToJavaString(env, title);
 }
 
 void RemoteMediaPlayerBridge::OnCookiesRetrieved(const std::string& cookies) {
   // TODO(aberent) Do we need to retrieve auth credentials for basic
   // authentication? MediaPlayerBridge does.
   cookies_ = cookies;
+  JNIEnv* env = AttachCurrentThread();
+  CHECK(env);
+  Java_RemoteMediaPlayerBridge_setCookies(
+      env, java_bridge_.obj(), ConvertUTF8ToJavaString(env, cookies).obj());
 }
 
-} // namespace remote_media
+bool RemoteMediaPlayerBridge::TakesOverCastDevice() {
+  JNIEnv* env = AttachCurrentThread();
+  CHECK(env);
+  jboolean result =
+      Java_RemoteMediaPlayerBridge_takesOverCastDevice(env, java_bridge_.obj());
+  return result;
+}
+
+}  // namespace remote_media