DBus MediaAnalyticsClient and media_perception pb.

chromeos/dbus/fake_media_analytics_client.cc

+// Copyright 2017 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 "chromeos/dbus/fake_media_analytics_client.h"
+
+#include "base/bind.h"
+#include "base/logging.h"
+#include "base/threading/thread_task_runner_handle.h"
+
+namespace chromeos {
+
+FakeMediaAnalyticsClient::FakeMediaAnalyticsClient()
+    : process_running_(false), fake_frame_id_(0), weak_ptr_factory_(this) {
+  current_state_.set_status(mri::State::UNINITIALIZED);
+}
+
+FakeMediaAnalyticsClient::~FakeMediaAnalyticsClient() {}
+
+void FakeMediaAnalyticsClient::FireMediaPerceptionEvent() {
+  if (!process_running_) {
+    LOG(ERROR) << "Mocked media analytics process not running.";

[tbarzic, 2017/05/10 23:59:29]

s/Mocked/Fake/

[Luke Sorenson, 2017/05/11 15:50:29]

Done.

+    return;
+  }
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&FakeMediaAnalyticsClient::OnMediaPerception,
+                            weak_ptr_factory_.GetWeakPtr()));
+}
+
+void FakeMediaAnalyticsClient::SetFrameId(int frame_id) {
+  fake_frame_id_ = frame_id;
+}
+
+void FakeMediaAnalyticsClient::Init(dbus::Bus* bus) {}
+
+void FakeMediaAnalyticsClient::SetMediaPerceptionSignalHandler(
+    const MediaPerceptionSignalHandler& handler) {
+  media_perception_signal_handler_ = handler;
+}
+
+void FakeMediaAnalyticsClient::ClearMediaPerceptionSignalHandler() {
+  media_perception_signal_handler_.Reset();
+}
+
+void FakeMediaAnalyticsClient::GetState(const StateCallback& callback) {
+  if (!process_running_) {
+    LOG(ERROR) << "Mocked media analytics process not running.";
+    callback.Run(false, current_state_);
+    return;
+  }
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&FakeMediaAnalyticsClient::OnState,
+                            weak_ptr_factory_.GetWeakPtr(), callback));
+}
+
+void FakeMediaAnalyticsClient::SetState(const mri::State& state,
+                                        const StateCallback& callback) {
+  if (!process_running_) {
+    LOG(ERROR) << "Mocked media analytics process not running.";
+    callback.Run(false, current_state_);
+    return;
+  }
+  DCHECK(state.has_status()) << "Trying to set state without status.";
+  DCHECK(state.status() == mri::State::SUSPENDED ||
+         state.status() == mri::State::RUNNING)
+      << "Trying set state to something other than RUNNING or SUSPENDED.";
+  current_state_ = state;
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&FakeMediaAnalyticsClient::OnState,
+                            weak_ptr_factory_.GetWeakPtr(), callback));
+}
+
+void FakeMediaAnalyticsClient::OnState(const StateCallback& callback) {
+  callback.Run(true, current_state_);
+}
+
+void FakeMediaAnalyticsClient::GetDiagnostics(
+    const DiagnosticsCallback& callback) {
+  if (!process_running_) {
+    LOG(ERROR) << "Mocked media analytics process not running.";
+    callback.Run(false, mri::Diagnostics());
+    return;
+  }
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&FakeMediaAnalyticsClient::OnGetDiagnostics,
+                            weak_ptr_factory_.GetWeakPtr(), callback));
+}
+
+void FakeMediaAnalyticsClient::OnGetDiagnostics(
+    const DiagnosticsCallback& callback) {
+  mri::Diagnostics diagnostics;
+  diagnostics.add_perception_sample()->mutable_frame_perception()->set_frame_id(
+      fake_frame_id_);
+  callback.Run(true, diagnostics);
+}
+
+void FakeMediaAnalyticsClient::OnMediaPerception() {
+  if (media_perception_signal_handler_.is_null()) {
+    return;
+  }
+  mri::MediaPerception media_perception;
+  media_perception.add_frame_perception()->set_frame_id(fake_frame_id_);
+  media_perception_signal_handler_.Run(media_perception);
+}
+
+}  // namespace chromeos