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
5 #include "device/bluetooth/dbus/fake_bluetooth_le_advertising_manager_client.h"
6
7 #include "base/location.h"
8 #include "base/logging.h"
9 #include "base/single_thread_task_runner.h"
10 #include "base/threading/thread_task_runner_handle.h"
11 #include "dbus/bus.h"
12 #include "dbus/message.h"
13 #include "dbus/object_proxy.h"
14 #include "device/bluetooth/dbus/fake_bluetooth_le_advertisement_service_provider.h"
15 #include "third_party/cros_system_api/dbus/service_constants.h"
16
17 namespace bluez {
18
19 namespace {
20
21 constexpr char kAdvertisingManagerPath[] = "/fake/hci0";
22 // According to the Bluetooth spec, these are the min and max values possible
23 // for advertising interval. Core 4.2 Spec, Vol 2, Part E, Section 7.8.5.
24 constexpr uint16_t kMinIntervalMs = 20;
25 constexpr uint16_t kMaxIntervalMs = 10240;
26
27 } // namespace
28
29 FakeBluetoothLEAdvertisingManagerClient::
30 FakeBluetoothLEAdvertisingManagerClient() = default;
31
32 FakeBluetoothLEAdvertisingManagerClient::
33 ~FakeBluetoothLEAdvertisingManagerClient() = default;
34
Init(dbus::Bus * bus,const std::string & bluetooth_service_name)35 void FakeBluetoothLEAdvertisingManagerClient::Init(
36 dbus::Bus* bus,
37 const std::string& bluetooth_service_name) {}
38
AddObserver(Observer * observer)39 void FakeBluetoothLEAdvertisingManagerClient::AddObserver(Observer* observer) {}
40
RemoveObserver(Observer * observer)41 void FakeBluetoothLEAdvertisingManagerClient::RemoveObserver(
42 Observer* observer) {}
43
RegisterAdvertisement(const dbus::ObjectPath & manager_object_path,const dbus::ObjectPath & advertisement_object_path,base::OnceClosure callback,ErrorCallback error_callback)44 void FakeBluetoothLEAdvertisingManagerClient::RegisterAdvertisement(
45 const dbus::ObjectPath& manager_object_path,
46 const dbus::ObjectPath& advertisement_object_path,
47 base::OnceClosure callback,
48 ErrorCallback error_callback) {
49 DVLOG(1) << "RegisterAdvertisment: " << advertisement_object_path.value();
50
51 if (manager_object_path != dbus::ObjectPath(kAdvertisingManagerPath)) {
52 std::move(error_callback)
53 .Run(kNoResponseError, "Invalid Advertising Manager path.");
54 return;
55 }
56
57 auto iter = service_provider_map_.find(advertisement_object_path);
58 if (iter == service_provider_map_.end()) {
59 std::move(error_callback)
60 .Run(bluetooth_advertising_manager::kErrorInvalidArguments,
61 "Advertisement object not registered");
62 } else if (currently_registered_.size() >= kMaxBluezAdvertisements) {
63 std::move(error_callback)
64 .Run(bluetooth_advertising_manager::kErrorFailed,
65 "Maximum advertisements reached");
66 } else {
67 currently_registered_.push_back(advertisement_object_path);
68 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
69 std::move(callback));
70 }
71 }
72
UnregisterAdvertisement(const dbus::ObjectPath & manager_object_path,const dbus::ObjectPath & advertisement_object_path,base::OnceClosure callback,ErrorCallback error_callback)73 void FakeBluetoothLEAdvertisingManagerClient::UnregisterAdvertisement(
74 const dbus::ObjectPath& manager_object_path,
75 const dbus::ObjectPath& advertisement_object_path,
76 base::OnceClosure callback,
77 ErrorCallback error_callback) {
78 DVLOG(1) << "UnregisterAdvertisment: " << advertisement_object_path.value();
79
80 if (manager_object_path != dbus::ObjectPath(kAdvertisingManagerPath)) {
81 std::move(error_callback)
82 .Run(kNoResponseError, "Invalid Advertising Manager path.");
83 return;
84 }
85
86 auto service_iter = service_provider_map_.find(advertisement_object_path);
87 auto reg_iter =
88 std::find(currently_registered_.begin(), currently_registered_.end(),
89 advertisement_object_path);
90
91 if (service_iter == service_provider_map_.end()) {
92 std::move(error_callback)
93 .Run(bluetooth_advertising_manager::kErrorDoesNotExist,
94 "Advertisement not registered");
95 } else if (reg_iter == currently_registered_.end()) {
96 std::move(error_callback)
97 .Run(bluetooth_advertising_manager::kErrorDoesNotExist,
98 "Does not exist");
99 } else {
100 currently_registered_.erase(reg_iter);
101 base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
102 std::move(callback));
103 }
104 }
105
SetAdvertisingInterval(const dbus::ObjectPath & object_path,uint16_t min_interval_ms,uint16_t max_interval_ms,base::OnceClosure callback,ErrorCallback error_callback)106 void FakeBluetoothLEAdvertisingManagerClient::SetAdvertisingInterval(
107 const dbus::ObjectPath& object_path,
108 uint16_t min_interval_ms,
109 uint16_t max_interval_ms,
110 base::OnceClosure callback,
111 ErrorCallback error_callback) {
112 if (min_interval_ms < kMinIntervalMs || max_interval_ms > kMaxIntervalMs ||
113 min_interval_ms > max_interval_ms) {
114 std::move(error_callback)
115 .Run(bluetooth_advertising_manager::kErrorInvalidArguments,
116 "Invalid interval.");
117 return;
118 }
119 std::move(callback).Run();
120 }
121
ResetAdvertising(const dbus::ObjectPath & object_path,base::OnceClosure callback,ErrorCallback error_callback)122 void FakeBluetoothLEAdvertisingManagerClient::ResetAdvertising(
123 const dbus::ObjectPath& object_path,
124 base::OnceClosure callback,
125 ErrorCallback error_callback) {
126 currently_registered_.clear();
127 service_provider_map_.clear();
128 std::move(callback).Run();
129 }
130
131 void FakeBluetoothLEAdvertisingManagerClient::
RegisterAdvertisementServiceProvider(FakeBluetoothLEAdvertisementServiceProvider * service_provider)132 RegisterAdvertisementServiceProvider(
133 FakeBluetoothLEAdvertisementServiceProvider* service_provider) {
134 service_provider_map_[service_provider->object_path_] = service_provider;
135 }
136
137 void FakeBluetoothLEAdvertisingManagerClient::
UnregisterAdvertisementServiceProvider(FakeBluetoothLEAdvertisementServiceProvider * service_provider)138 UnregisterAdvertisementServiceProvider(
139 FakeBluetoothLEAdvertisementServiceProvider* service_provider) {
140 auto iter = service_provider_map_.find(service_provider->object_path_);
141 if (iter != service_provider_map_.end() && iter->second == service_provider)
142 service_provider_map_.erase(iter);
143 }
144
145 } // namespace bluez
146