OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include <utility> | 5 #include <utility> |
| 6 #include <vector> |
6 | 7 |
7 #include "base/strings/utf_string_conversions.h" | 8 #include "base/strings/utf_string_conversions.h" |
8 #include "device/bluetooth/device.h" | 9 #include "device/bluetooth/device.h" |
9 #include "mojo/public/cpp/bindings/strong_binding.h" | 10 #include "mojo/public/cpp/bindings/strong_binding.h" |
10 | 11 |
11 namespace bluetooth { | 12 namespace bluetooth { |
| 13 Device::~Device() { |
| 14 adapter_->RemoveObserver(this); |
| 15 } |
12 | 16 |
13 Device::Device(const std::string& address, | 17 // static |
14 scoped_refptr<device::BluetoothAdapter> adapter) | 18 void Device::Create(scoped_refptr<device::BluetoothAdapter> adapter, |
15 : address_(address), adapter_(std::move(adapter)) {} | 19 std::unique_ptr<device::BluetoothGattConnection> connection, |
16 | 20 mojom::DeviceRequest request) { |
17 Device::~Device() {} | 21 auto device_impl = |
| 22 base::WrapUnique(new Device(adapter, std::move(connection))); |
| 23 auto* device_ptr = device_impl.get(); |
| 24 device_ptr->binding_ = |
| 25 mojo::MakeStrongBinding(std::move(device_impl), std::move(request)); |
| 26 } |
18 | 27 |
19 // static | 28 // static |
20 mojom::DeviceInfoPtr Device::ConstructDeviceInfoStruct( | 29 mojom::DeviceInfoPtr Device::ConstructDeviceInfoStruct( |
21 const device::BluetoothDevice* device) { | 30 const device::BluetoothDevice* device) { |
22 mojom::DeviceInfoPtr device_info = mojom::DeviceInfo::New(); | 31 mojom::DeviceInfoPtr device_info = mojom::DeviceInfo::New(); |
23 | 32 |
24 device_info->name = device->GetName(); | 33 device_info->name = device->GetName(); |
25 device_info->name_for_display = | 34 device_info->name_for_display = |
26 base::UTF16ToUTF8(device->GetNameForDisplay()); | 35 base::UTF16ToUTF8(device->GetNameForDisplay()); |
27 device_info->address = device->GetAddress(); | 36 device_info->address = device->GetAddress(); |
| 37 device_info->is_gatt_connected = device->IsGattConnected(); |
28 | 38 |
29 if (device->GetInquiryRSSI()) { | 39 if (device->GetInquiryRSSI()) { |
30 device_info->rssi = mojom::RSSIWrapper::New(); | 40 device_info->rssi = mojom::RSSIWrapper::New(); |
31 device_info->rssi->value = device->GetInquiryRSSI().value(); | 41 device_info->rssi->value = device->GetInquiryRSSI().value(); |
32 } | 42 } |
33 | 43 |
34 return device_info; | 44 return device_info; |
35 } | 45 } |
36 | 46 |
37 void Device::GetInfo(const GetInfoCallback& callback) { | 47 void Device::DeviceChanged(device::BluetoothAdapter* adapter, |
38 device::BluetoothDevice* device = adapter_->GetDevice(address_); | 48 device::BluetoothDevice* device) { |
39 if (device) { | 49 if (device->GetAddress() != GetAddress()) { |
40 mojom::DeviceInfoPtr device_info = ConstructDeviceInfoStruct(device); | 50 return; |
41 callback.Run(std::move(device_info)); | 51 } |
42 } else { | 52 |
43 callback.Run(nullptr); | 53 if (!device->IsGattConnected()) { |
| 54 binding_->Close(); |
44 } | 55 } |
45 } | 56 } |
46 | 57 |
| 58 void Device::GattServicesDiscovered(device::BluetoothAdapter* adapter, |
| 59 device::BluetoothDevice* device) { |
| 60 if (device->GetAddress() != GetAddress()) { |
| 61 return; |
| 62 } |
| 63 |
| 64 std::vector<base::Closure> requests; |
| 65 requests.swap(pending_services_requests_); |
| 66 for (const base::Closure& request : requests) { |
| 67 request.Run(); |
| 68 } |
| 69 } |
| 70 |
| 71 void Device::Disconnect() { |
| 72 binding_->Close(); |
| 73 } |
| 74 |
| 75 void Device::GetInfo(const GetInfoCallback& callback) { |
| 76 device::BluetoothDevice* device = adapter_->GetDevice(GetAddress()); |
| 77 DCHECK(device); |
| 78 |
| 79 callback.Run(ConstructDeviceInfoStruct(device)); |
| 80 } |
| 81 |
| 82 void Device::GetServices(const GetServicesCallback& callback) { |
| 83 device::BluetoothDevice* device = adapter_->GetDevice(GetAddress()); |
| 84 DCHECK(device); |
| 85 |
| 86 if (device->IsGattServicesDiscoveryComplete()) { |
| 87 GetServicesImpl(callback); |
| 88 return; |
| 89 } |
| 90 |
| 91 // pending_services_requests_ is owned by Device, so base::Unretained is |
| 92 // safe. |
| 93 pending_services_requests_.push_back( |
| 94 base::Bind(&Device::GetServicesImpl, base::Unretained(this), callback)); |
| 95 } |
| 96 |
| 97 Device::Device(scoped_refptr<device::BluetoothAdapter> adapter, |
| 98 std::unique_ptr<device::BluetoothGattConnection> connection) |
| 99 : adapter_(std::move(adapter)), connection_(std::move(connection)) { |
| 100 adapter_->AddObserver(this); |
| 101 } |
| 102 |
| 103 void Device::GetServicesImpl(const GetServicesCallback& callback) { |
| 104 device::BluetoothDevice* device = adapter_->GetDevice(GetAddress()); |
| 105 DCHECK(device); |
| 106 |
| 107 std::vector<mojom::ServiceInfoPtr> services; |
| 108 |
| 109 for (const device::BluetoothRemoteGattService* service : |
| 110 device->GetGattServices()) { |
| 111 services.push_back(ConstructServiceInfoStruct(*service)); |
| 112 } |
| 113 |
| 114 callback.Run(std::move(services)); |
| 115 } |
| 116 |
| 117 mojom::ServiceInfoPtr Device::ConstructServiceInfoStruct( |
| 118 const device::BluetoothRemoteGattService& service) { |
| 119 mojom::ServiceInfoPtr service_info = mojom::ServiceInfo::New(); |
| 120 |
| 121 service_info->uuid = service.GetUUID(); |
| 122 service_info->is_primary = service.IsPrimary(); |
| 123 |
| 124 return service_info; |
| 125 } |
| 126 |
| 127 const std::string& Device::GetAddress() { |
| 128 return connection_->GetDeviceAddress(); |
| 129 } |
| 130 |
47 } // namespace bluetooth | 131 } // namespace bluetooth |
OLD | NEW |