fake_dlcservice_client.cc 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. // Copyright (c) 2012 The Chromium Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file.
  4. #include "chromeos/dbus/dlcservice/fake_dlcservice_client.h"
  5. #include "base/bind.h"
  6. #include "base/logging.h"
  7. #include "base/threading/thread_task_runner_handle.h"
  8. namespace chromeos {
  9. FakeDlcserviceClient::FakeDlcserviceClient() = default;
  10. FakeDlcserviceClient::~FakeDlcserviceClient() = default;
  11. void FakeDlcserviceClient::Install(
  12. const dlcservice::InstallRequest& install_request,
  13. InstallCallback callback,
  14. ProgressCallback progress_callback) {
  15. VLOG(1) << "Requesting to install DLC(s).";
  16. const std::string& id = install_request.id();
  17. InstallResult install_result{
  18. .error = install_err_,
  19. .dlc_id = id,
  20. .root_path = install_root_path_,
  21. };
  22. dlcs_with_content_.add_dlc_infos()->set_id(id);
  23. base::ThreadTaskRunnerHandle::Get()->PostTask(
  24. FROM_HERE,
  25. base::BindOnce(std::move(callback), std::move(install_result)));
  26. }
  27. void FakeDlcserviceClient::Uninstall(const std::string& dlc_id,
  28. UninstallCallback callback) {
  29. VLOG(1) << "Requesting to uninstall DLC=" << dlc_id;
  30. for (auto iter = dlcs_with_content_.dlc_infos().begin();
  31. iter != dlcs_with_content_.dlc_infos().end();) {
  32. if (iter->id() != dlc_id) {
  33. iter++;
  34. continue;
  35. }
  36. iter = dlcs_with_content_.mutable_dlc_infos()->erase(iter);
  37. }
  38. base::ThreadTaskRunnerHandle::Get()->PostTask(
  39. FROM_HERE, base::BindOnce(std::move(callback), uninstall_err_));
  40. }
  41. void FakeDlcserviceClient::Purge(const std::string& dlc_id,
  42. PurgeCallback callback) {
  43. VLOG(1) << "Requesting to purge DLC=" << dlc_id;
  44. base::ThreadTaskRunnerHandle::Get()->PostTask(
  45. FROM_HERE, base::BindOnce(std::move(callback), purge_err_));
  46. }
  47. void FakeDlcserviceClient::GetDlcState(const std::string& dlc_id,
  48. GetDlcStateCallback callback) {
  49. VLOG(1) << "Requesting to get DLC state of" << dlc_id;
  50. base::ThreadTaskRunnerHandle::Get()->PostTask(
  51. FROM_HERE,
  52. base::BindOnce(std::move(callback), get_dlc_state_err_, dlc_state_));
  53. }
  54. void FakeDlcserviceClient::GetExistingDlcs(GetExistingDlcsCallback callback) {
  55. VLOG(1) << "Requesting to get existing DLC(s).";
  56. base::ThreadTaskRunnerHandle::Get()->PostTask(
  57. FROM_HERE, base::BindOnce(std::move(callback), get_existing_dlcs_err_,
  58. dlcs_with_content_));
  59. }
  60. void FakeDlcserviceClient::DlcStateChangedForTest(dbus::Signal* signal) {
  61. NOTREACHED();
  62. }
  63. void FakeDlcserviceClient::NotifyObserversForTest(
  64. const dlcservice::DlcState& dlc_state) {
  65. // Notify all observers with the state change |dlc_state|.
  66. for (Observer& observer : observers_) {
  67. observer.OnDlcStateChanged(dlc_state);
  68. }
  69. }
  70. void FakeDlcserviceClient::AddObserver(Observer* observer) {
  71. observers_.AddObserver(observer);
  72. }
  73. void FakeDlcserviceClient::RemoveObserver(Observer* observer) {
  74. observers_.RemoveObserver(observer);
  75. }
  76. } // namespace chromeos