bluetooth_le_advertising_manager_client.cc 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232
  1. // Copyright 2015 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 "device/bluetooth/dbus/bluetooth_le_advertising_manager_client.h"
  5. #include "base/bind.h"
  6. #include "base/check.h"
  7. #include "base/memory/raw_ptr.h"
  8. #include "base/observer_list.h"
  9. #include "dbus/bus.h"
  10. #include "dbus/message.h"
  11. #include "dbus/object_manager.h"
  12. #include "dbus/object_proxy.h"
  13. #include "third_party/cros_system_api/dbus/service_constants.h"
  14. namespace bluez {
  15. const char BluetoothLEAdvertisingManagerClient::kNoResponseError[] =
  16. "org.chromium.Error.NoResponse";
  17. // The BluetoothAdvertisementManagerClient implementation used in production.
  18. class BluetoothAdvertisementManagerClientImpl
  19. : public BluetoothLEAdvertisingManagerClient,
  20. public dbus::ObjectManager::Interface {
  21. public:
  22. BluetoothAdvertisementManagerClientImpl() : object_manager_(nullptr) {}
  23. BluetoothAdvertisementManagerClientImpl(
  24. const BluetoothAdvertisementManagerClientImpl&) = delete;
  25. BluetoothAdvertisementManagerClientImpl& operator=(
  26. const BluetoothAdvertisementManagerClientImpl&) = delete;
  27. ~BluetoothAdvertisementManagerClientImpl() override {
  28. if (object_manager_) {
  29. object_manager_->UnregisterInterface(
  30. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface);
  31. }
  32. }
  33. // BluetoothAdapterClient override.
  34. void AddObserver(
  35. BluetoothLEAdvertisingManagerClient::Observer* observer) override {
  36. DCHECK(observer);
  37. observers_.AddObserver(observer);
  38. }
  39. // BluetoothAdapterClient override.
  40. void RemoveObserver(
  41. BluetoothLEAdvertisingManagerClient::Observer* observer) override {
  42. DCHECK(observer);
  43. observers_.RemoveObserver(observer);
  44. }
  45. // dbus::ObjectManager::Interface override.
  46. dbus::PropertySet* CreateProperties(
  47. dbus::ObjectProxy* object_proxy,
  48. const dbus::ObjectPath& object_path,
  49. const std::string& interface_name) override {
  50. return new dbus::PropertySet(object_proxy, interface_name,
  51. dbus::PropertySet::PropertyChangedCallback());
  52. }
  53. // BluetoothAdvertisementManagerClient override.
  54. void RegisterAdvertisement(const dbus::ObjectPath& manager_object_path,
  55. const dbus::ObjectPath& advertisement_object_path,
  56. base::OnceClosure callback,
  57. ErrorCallback error_callback) override {
  58. dbus::MethodCall method_call(
  59. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface,
  60. bluetooth_advertising_manager::kRegisterAdvertisement);
  61. dbus::MessageWriter writer(&method_call);
  62. writer.AppendObjectPath(advertisement_object_path);
  63. // Empty dictionary for options.
  64. dbus::MessageWriter array_writer(NULL);
  65. writer.OpenArray("{sv}", &array_writer);
  66. writer.CloseContainer(&array_writer);
  67. CallObjectProxyMethod(manager_object_path, &method_call,
  68. std::move(callback), std::move(error_callback));
  69. }
  70. // BluetoothAdvertisementManagerClient override.
  71. void UnregisterAdvertisement(
  72. const dbus::ObjectPath& manager_object_path,
  73. const dbus::ObjectPath& advertisement_object_path,
  74. base::OnceClosure callback,
  75. ErrorCallback error_callback) override {
  76. dbus::MethodCall method_call(
  77. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface,
  78. bluetooth_advertising_manager::kUnregisterAdvertisement);
  79. dbus::MessageWriter writer(&method_call);
  80. writer.AppendObjectPath(advertisement_object_path);
  81. CallObjectProxyMethod(manager_object_path, &method_call,
  82. std::move(callback), std::move(error_callback));
  83. }
  84. void SetAdvertisingInterval(const dbus::ObjectPath& manager_object_path,
  85. uint16_t min_interval_ms,
  86. uint16_t max_interval_ms,
  87. base::OnceClosure callback,
  88. ErrorCallback error_callback) override {
  89. dbus::MethodCall method_call(
  90. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface,
  91. bluetooth_advertising_manager::kSetAdvertisingIntervals);
  92. dbus::MessageWriter writer(&method_call);
  93. writer.AppendUint16(min_interval_ms);
  94. writer.AppendUint16(max_interval_ms);
  95. CallObjectProxyMethod(manager_object_path, &method_call,
  96. std::move(callback), std::move(error_callback));
  97. }
  98. void ResetAdvertising(const dbus::ObjectPath& manager_object_path,
  99. base::OnceClosure callback,
  100. ErrorCallback error_callback) override {
  101. dbus::MethodCall method_call(
  102. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface,
  103. bluetooth_advertising_manager::kResetAdvertising);
  104. CallObjectProxyMethod(manager_object_path, &method_call,
  105. std::move(callback), std::move(error_callback));
  106. }
  107. protected:
  108. void Init(dbus::Bus* bus,
  109. const std::string& bluetooth_service_name) override {
  110. DCHECK(bus);
  111. object_manager_ = bus->GetObjectManager(
  112. bluetooth_service_name,
  113. dbus::ObjectPath(
  114. bluetooth_object_manager::kBluetoothObjectManagerServicePath));
  115. object_manager_->RegisterInterface(
  116. bluetooth_advertising_manager::kBluetoothAdvertisingManagerInterface,
  117. this);
  118. }
  119. private:
  120. // Unified function to call object proxy method. This includes checking
  121. // if the bluetooth adapter exists and run error callback if it doesn't.
  122. void CallObjectProxyMethod(const dbus::ObjectPath& manager_object_path,
  123. dbus::MethodCall* method_call,
  124. base::OnceClosure callback,
  125. ErrorCallback error_callback) {
  126. DCHECK(object_manager_);
  127. dbus::ObjectProxy* object_proxy =
  128. object_manager_->GetObjectProxy(manager_object_path);
  129. if (!object_proxy) {
  130. std::move(error_callback)
  131. .Run(bluetooth_advertising_manager::kErrorFailed,
  132. "Adapter does not exist.");
  133. return;
  134. }
  135. object_proxy->CallMethodWithErrorCallback(
  136. method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
  137. base::BindOnce(&BluetoothAdvertisementManagerClientImpl::OnSuccess,
  138. weak_ptr_factory_.GetWeakPtr(), std::move(callback)),
  139. base::BindOnce(&BluetoothAdvertisementManagerClientImpl::OnError,
  140. weak_ptr_factory_.GetWeakPtr(),
  141. std::move(error_callback)));
  142. }
  143. // Called by dbus::ObjectManager when an object with the advertising manager
  144. // interface is created. Informs observers.
  145. void ObjectAdded(const dbus::ObjectPath& object_path,
  146. const std::string& interface_name) override {
  147. for (auto& observer : observers_)
  148. observer.AdvertisingManagerAdded(object_path);
  149. }
  150. // Called by dbus::ObjectManager when an object with the advertising manager
  151. // interface is removed. Informs observers.
  152. void ObjectRemoved(const dbus::ObjectPath& object_path,
  153. const std::string& interface_name) override {
  154. for (auto& observer : observers_)
  155. observer.AdvertisingManagerRemoved(object_path);
  156. }
  157. // Called when a response for successful method call is received.
  158. void OnSuccess(base::OnceClosure callback, dbus::Response* response) {
  159. DCHECK(response);
  160. std::move(callback).Run();
  161. }
  162. // Called when a response for a failed method call is received.
  163. void OnError(ErrorCallback error_callback, dbus::ErrorResponse* response) {
  164. // Error response has optional error message argument.
  165. std::string error_name;
  166. std::string error_message;
  167. if (response) {
  168. dbus::MessageReader reader(response);
  169. error_name = response->GetErrorName();
  170. reader.PopString(&error_message);
  171. } else {
  172. error_name = kNoResponseError;
  173. error_message = "";
  174. }
  175. std::move(error_callback).Run(error_name, error_message);
  176. }
  177. raw_ptr<dbus::ObjectManager> object_manager_;
  178. // List of observers interested in event notifications from us.
  179. base::ObserverList<BluetoothLEAdvertisingManagerClient::Observer>::Unchecked
  180. observers_;
  181. // Weak pointer factory for generating 'this' pointers that might live longer
  182. // than we do.
  183. // Note: This should remain the last member so it'll be destroyed and
  184. // invalidate its weak pointers before any other members are destroyed.
  185. base::WeakPtrFactory<BluetoothAdvertisementManagerClientImpl>
  186. weak_ptr_factory_{this};
  187. };
  188. BluetoothLEAdvertisingManagerClient::BluetoothLEAdvertisingManagerClient() =
  189. default;
  190. BluetoothLEAdvertisingManagerClient::~BluetoothLEAdvertisingManagerClient() =
  191. default;
  192. BluetoothLEAdvertisingManagerClient*
  193. BluetoothLEAdvertisingManagerClient::Create() {
  194. return new BluetoothAdvertisementManagerClientImpl();
  195. }
  196. } // namespace bluez