arc-bridge: Move most methods to Mojo interfaces

components/arc/arc_bridge_service_impl.cc

 // Copyright 2015 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 "components/arc/arc_bridge_service_impl.h"
 
 #include <string>
 #include <utility>
 
 #include "base/command_line.h"
 #include "base/prefs/pref_registry_simple.h"
 #include "base/prefs/pref_service.h"
 #include "base/sequenced_task_runner.h"
 #include "base/task_runner_util.h"
 #include "base/thread_task_runner_handle.h"
 #include "chromeos/chromeos_switches.h"
 #include "chromeos/dbus/dbus_method_call_status.h"
 #include "chromeos/dbus/dbus_thread_manager.h"
 #include "chromeos/dbus/session_manager_client.h"
-#include "mojo/public/cpp/bindings/array.h"
-#include "third_party/mojo/src/mojo/edk/embedder/embedder.h"
-
-namespace mojo {
-
-template <>
-struct TypeConverter<arc::AppInfo, arc::AppInfoPtr> {
-  static arc::AppInfo Convert(const arc::AppInfoPtr& app_info_ptr) {
-    return *app_info_ptr;
-  }
-};
-
-template <>
-struct TypeConverter<arc::RunningAppProcessInfo,
-                     arc::RunningAppProcessInfoPtr> {
-  static arc::RunningAppProcessInfo Convert(
-      const arc::RunningAppProcessInfoPtr& process_ptr) {
-    return *process_ptr;
-  }
-};
-
-}  // namespace mojo
 
 namespace arc {
 
 ArcBridgeServiceImpl::ArcBridgeServiceImpl(
     scoped_ptr<ArcBridgeBootstrap> bootstrap)
     : bootstrap_(std::move(bootstrap)),
       binding_(this),
       session_started_(false),
       weak_factory_(this) {
   bootstrap_->set_delegate(this);
@@ skipping 39 matching lines @@
   DCHECK(CalledOnValidThread());
   if (state() == State::STOPPED || state() == State::STOPPING) {
     VLOG(1) << "StopInstance() called when ARC is not running";
     return;
   }
 
   SetState(State::STOPPING);
   bootstrap_->Stop();
 }
 
-bool ArcBridgeServiceImpl::RegisterInputDevice(const std::string& name,
-                                               const std::string& device_type,
-                                               base::ScopedFD fd) {
+void ArcBridgeServiceImpl::OnAppInstanceReady(AppInstancePtr app_ptr) {
   DCHECK(CalledOnValidThread());
   if (state() != State::READY) {
-    LOG(ERROR) << "Called RegisterInputDevice when the service is not ready";
-    return false;
+    VLOG(1) << "StopInstance() called";
+    return;
   }
-  MojoHandle wrapped_handle;
-  MojoResult wrap_result = mojo::embedder::CreatePlatformHandleWrapper(
-      mojo::embedder::ScopedPlatformHandle(
-          mojo::embedder::PlatformHandle(fd.release())),
-      &wrapped_handle);
-  if (wrap_result != MOJO_RESULT_OK) {
-    LOG(WARNING) << "Pipe failed to wrap handles. Closing: " << wrap_result;
-    return false;
-  }
-  instance_ptr_->RegisterInputDevice(
-      name, device_type, mojo::ScopedHandle(mojo::Handle(wrapped_handle)));
-  return true;
+  app_ptr_ = std::move(app_ptr);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnAppInstanceReady());
 }
 
-bool ArcBridgeServiceImpl::SendNotificationEventToAndroid(
-    const std::string& key, ArcNotificationEvent event) {
+void ArcBridgeServiceImpl::OnInputInstanceReady(InputInstancePtr input_ptr) {
   DCHECK(CalledOnValidThread());
-  if (key.empty()) {
-    LOG(ERROR) << "SendNotificationToAndroid failed: Wrong parameter";
-    return false;
+  if (state() != State::READY) {
+    VLOG(1) << "StopInstance() called";
+    return;
   }
-  if (state() != State::READY) {
-    LOG(ERROR) << "Called SendNotificationEventToAndroid when the service is"
-      << "not ready";
-    return false;
-  }
-  instance_ptr_->SendNotificationEventToAndroid(key, event);
-  return true;
+  input_ptr_ = std::move(input_ptr);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnInputInstanceReady());
 }
 
-bool ArcBridgeServiceImpl::RefreshAppList() {
+void ArcBridgeServiceImpl::OnNotificationsInstanceReady(
+    NotificationsInstancePtr notifications_ptr) {
   DCHECK(CalledOnValidThread());
   if (state() != State::READY) {
-    LOG(ERROR) << "Called RefreshAppList when the service is not ready";
-    return false;
+    VLOG(1) << "StopInstance() called";
+    return;
   }
-  instance_ptr_->RefreshAppList();
-  return true;
+  notifications_ptr_ = std::move(notifications_ptr);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnNotificationsInstanceReady());
 }
 
-bool ArcBridgeServiceImpl::LaunchApp(const std::string& package,
-                                     const std::string& activity) {
+void ArcBridgeServiceImpl::OnPowerInstanceReady(PowerInstancePtr power_ptr) {
   DCHECK(CalledOnValidThread());
   if (state() != State::READY) {
-    LOG(ERROR) << "Called LaunchApp when the service is not ready";
-    return false;
+    VLOG(1) << "StopInstance() called";
+    return;
   }
-  instance_ptr_->LaunchApp(package, activity);
-  return true;
+  power_ptr_ = std::move(power_ptr);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnPowerInstanceReady());
 }
 
-bool ArcBridgeServiceImpl::RequestAppIcon(const std::string& package,
-                                          const std::string& activity,
-                                          ScaleFactor scale_factor) {
+void ArcBridgeServiceImpl::OnProcessListInstanceReady(
+    ProcessListInstancePtr process_list_ptr) {
   DCHECK(CalledOnValidThread());
   if (state() != State::READY) {
-    LOG(ERROR) << "Called RequestAppIcon when the service is not ready";
-    return false;
-  }
-  instance_ptr_->RequestAppIcon(package, activity, scale_factor);
-  return true;
-}
-
-bool ArcBridgeServiceImpl::RequestProcessList() {
-  DCHECK(CalledOnValidThread());
-  if (state() != State::READY) {
-    LOG(ERROR) << "Called RequestProcessList when the service is not ready";
-    return false;
-  }
-  instance_ptr_->RequestProcessList();
-  return true;
-}
-
-void ArcBridgeServiceImpl::OnInstanceBootPhase(InstanceBootPhase phase) {
-  DCHECK(CalledOnValidThread());
-  // The state can be CONNECTED the first time this is called, and will then
-  // transition to READY after BRIDGE_READY has been passed.
-  if (state() != State::CONNECTED && state() != State::READY) {
-    VLOG(1) << "StopInstance() called while connecting";
+    VLOG(1) << "StopInstance() called";
     return;
   }
-  if (phase == INSTANCE_BOOT_PHASE_BRIDGE_READY) {
-    SetState(State::READY);
-  }
-  FOR_EACH_OBSERVER(Observer, observer_list(), OnInstanceBootPhase(phase));
-}
-
-void ArcBridgeServiceImpl::OnNotificationPosted(ArcNotificationDataPtr data) {
-  DCHECK(CalledOnValidThread());
-  FOR_EACH_OBSERVER(NotificationObserver, notification_observer_list(),
-                    OnNotificationPostedFromAndroid(*data.get()));
-}
-
-void ArcBridgeServiceImpl::OnNotificationRemoved(const mojo::String& key) {
-  DCHECK(CalledOnValidThread());
-  FOR_EACH_OBSERVER(NotificationObserver, notification_observer_list(),
-                    OnNotificationRemovedFromAndroid(key));
-}
-
-void ArcBridgeServiceImpl::OnAppListRefreshed(
-    mojo::Array<arc::AppInfoPtr> apps_ptr) {
-  DCHECK(CalledOnValidThread());
-  std::vector<arc::AppInfo> apps(apps_ptr.To<std::vector<arc::AppInfo>>());
-  FOR_EACH_OBSERVER(AppObserver, app_observer_list(), OnAppListRefreshed(apps));
-}
-
-void ArcBridgeServiceImpl::OnAppIcon(const mojo::String& package,
-                                     const mojo::String& activity,
-                                     ScaleFactor scale_factor,
-                                     mojo::Array<uint8_t> icon_png_data) {
-  DCHECK(CalledOnValidThread());
-  FOR_EACH_OBSERVER(
-      AppObserver, app_observer_list(),
-      OnAppIcon(package, activity, scale_factor, icon_png_data.storage()));
-}
-
-void ArcBridgeServiceImpl::OnUpdateProcessList(
-    mojo::Array<RunningAppProcessInfoPtr> processes_ptr) {
-  DCHECK(CalledOnValidThread());
-  std::vector<RunningAppProcessInfo> processes(
-      processes_ptr.To<std::vector<RunningAppProcessInfo>>());
-  FOR_EACH_OBSERVER(
-      ProcessObserver,
-      process_observer_list(),
-      OnUpdateProcessList(processes));
-}
-
-void ArcBridgeServiceImpl::OnAcquireDisplayWakeLock(DisplayWakeLockType type) {
-  DCHECK(CalledOnValidThread());
-  // TODO(ejcaruso): Implement.
-  VLOG(1) << "OnAcquireDisplayWakeLock";
-}
-
-void ArcBridgeServiceImpl::OnReleaseDisplayWakeLock(DisplayWakeLockType type) {
-  DCHECK(CalledOnValidThread());
-  // TODO(ejcaruso): Implement.
-  VLOG(1) << "OnReleaseDisplayWakeLock";
+  process_list_ptr_ = std::move(process_list_ptr);
+  FOR_EACH_OBSERVER(Observer, observer_list(), OnProcessListInstanceReady());
 }
 
 void ArcBridgeServiceImpl::OnArcAvailable(bool arc_available) {
   DCHECK(CalledOnValidThread());
   if (available() == arc_available)
     return;
   SetAvailable(arc_available);
   PrerequisitesChanged();
 }
 
 void ArcBridgeServiceImpl::OnConnectionEstablished(
     ArcBridgeInstancePtr instance) {
   DCHECK(CalledOnValidThread());
   if (state() != State::CONNECTING) {
     VLOG(1) << "StopInstance() called while connecting";
     return;
   }
 
   instance_ptr_ = std::move(instance);
 
   ArcBridgeHostPtr host;
   binding_.Bind(GetProxy(&host));
   instance_ptr_->Init(std::move(host));
 
-  SetState(State::CONNECTED);
+  SetState(State::READY);
 }
 
 void ArcBridgeServiceImpl::OnStopped() {
   DCHECK(CalledOnValidThread());
   SetState(State::STOPPED);
 }
 
 }  // namespace arc