| OLD | NEW |
| (Empty) |
| 1 // Copyright 2014 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 "chrome/browser/extensions/api/bluetooth/bluetooth_private_api.h" | |
| 6 | |
| 7 #include "base/callback.h" | |
| 8 #include "base/lazy_instance.h" | |
| 9 #include "base/strings/string_util.h" | |
| 10 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api.h" | |
| 11 #include "chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h" | |
| 12 #include "chrome/common/extensions/api/bluetooth_private.h" | |
| 13 #include "device/bluetooth/bluetooth_adapter.h" | |
| 14 #include "device/bluetooth/bluetooth_adapter_factory.h" | |
| 15 | |
| 16 namespace bt_private = extensions::api::bluetooth_private; | |
| 17 | |
| 18 namespace extensions { | |
| 19 | |
| 20 static base::LazyInstance<BrowserContextKeyedAPIFactory<BluetoothPrivateAPI> > | |
| 21 g_factory = LAZY_INSTANCE_INITIALIZER; | |
| 22 | |
| 23 // static | |
| 24 BrowserContextKeyedAPIFactory<BluetoothPrivateAPI>* | |
| 25 BluetoothPrivateAPI::GetFactoryInstance() { | |
| 26 return g_factory.Pointer(); | |
| 27 } | |
| 28 | |
| 29 BluetoothPrivateAPI::BluetoothPrivateAPI(content::BrowserContext* context) | |
| 30 : browser_context_(context) { | |
| 31 EventRouter::Get(browser_context_) | |
| 32 ->RegisterObserver(this, bt_private::OnPairing::kEventName); | |
| 33 } | |
| 34 | |
| 35 BluetoothPrivateAPI::~BluetoothPrivateAPI() {} | |
| 36 | |
| 37 void BluetoothPrivateAPI::Shutdown() { | |
| 38 EventRouter::Get(browser_context_)->UnregisterObserver(this); | |
| 39 } | |
| 40 | |
| 41 void BluetoothPrivateAPI::OnListenerAdded(const EventListenerInfo& details) { | |
| 42 // This function can be called multiple times for the same JS listener, for | |
| 43 // example, once for the addListener call and again if it is a lazy listener. | |
| 44 if (!details.browser_context) | |
| 45 return; | |
| 46 | |
| 47 BluetoothAPI::Get(browser_context_)->event_router()->AddPairingDelegate( | |
| 48 details.extension_id); | |
| 49 } | |
| 50 | |
| 51 void BluetoothPrivateAPI::OnListenerRemoved(const EventListenerInfo& details) { | |
| 52 // This function can be called multiple times for the same JS listener, for | |
| 53 // example, once for the addListener call and again if it is a lazy listener. | |
| 54 if (!details.browser_context) | |
| 55 return; | |
| 56 | |
| 57 BluetoothAPI::Get(browser_context_)->event_router()->RemovePairingDelegate( | |
| 58 details.extension_id); | |
| 59 } | |
| 60 | |
| 61 namespace api { | |
| 62 | |
| 63 namespace { | |
| 64 | |
| 65 const char kNameProperty[] = "name"; | |
| 66 const char kPoweredProperty[] = "powered"; | |
| 67 const char kDiscoverableProperty[] = "discoverable"; | |
| 68 | |
| 69 const char kSetAdapterPropertyError[] = "Error setting adapter properties: $1"; | |
| 70 | |
| 71 const char kDeviceNotFoundError[] = | |
| 72 "Given address is not a valid Bluetooth device."; | |
| 73 | |
| 74 const char kPairingNotEnabled[] = | |
| 75 "Pairing must be enabled to set a pairing response."; | |
| 76 | |
| 77 const char kInvalidPairingResponseOptions[] = | |
| 78 "Invalid pairing response options"; | |
| 79 | |
| 80 const char kAdapterNotPresent[] = | |
| 81 "Could not find a Bluetooth adapter."; | |
| 82 | |
| 83 // Returns true if the pairing response options passed into the | |
| 84 // setPairingResponse function are valid. | |
| 85 bool ValidatePairingResponseOptions( | |
| 86 const device::BluetoothDevice* device, | |
| 87 const bt_private::SetPairingResponseOptions& options) { | |
| 88 bool response = options.response != bt_private::PAIRING_RESPONSE_NONE; | |
| 89 bool pincode = options.pincode.get() != NULL; | |
| 90 bool passkey = options.passkey.get() != NULL; | |
| 91 | |
| 92 if (!response && !pincode && !passkey) | |
| 93 return false; | |
| 94 if (pincode && passkey) | |
| 95 return false; | |
| 96 if (options.response != bt_private::PAIRING_RESPONSE_CONFIRM && | |
| 97 (pincode || passkey)) | |
| 98 return false; | |
| 99 | |
| 100 // Check the BluetoothDevice is in expecting the correct response. | |
| 101 if (!device->ExpectingConfirmation() && !device->ExpectingPinCode() && | |
| 102 !device->ExpectingPasskey()) | |
| 103 return false; | |
| 104 if (pincode && !device->ExpectingPinCode()) | |
| 105 return false; | |
| 106 if (passkey && !device->ExpectingPasskey()) | |
| 107 return false; | |
| 108 if (options.response == bt_private::PAIRING_RESPONSE_CONFIRM && !pincode && | |
| 109 !passkey && !device->ExpectingConfirmation()) | |
| 110 return false; | |
| 111 | |
| 112 return true; | |
| 113 } | |
| 114 | |
| 115 } // namespace | |
| 116 | |
| 117 BluetoothPrivateSetAdapterStateFunction:: | |
| 118 BluetoothPrivateSetAdapterStateFunction() {} | |
| 119 | |
| 120 BluetoothPrivateSetAdapterStateFunction:: | |
| 121 ~BluetoothPrivateSetAdapterStateFunction() {} | |
| 122 | |
| 123 bool BluetoothPrivateSetAdapterStateFunction::DoWork( | |
| 124 scoped_refptr<device::BluetoothAdapter> adapter) { | |
| 125 scoped_ptr<bt_private::SetAdapterState::Params> params( | |
| 126 bt_private::SetAdapterState::Params::Create(*args_)); | |
| 127 EXTENSION_FUNCTION_VALIDATE(params.get()); | |
| 128 | |
| 129 if (!adapter->IsPresent()) { | |
| 130 SetError(kAdapterNotPresent); | |
| 131 SendResponse(false); | |
| 132 return true; | |
| 133 } | |
| 134 | |
| 135 const bt_private::NewAdapterState& new_state = params->adapter_state; | |
| 136 | |
| 137 // These properties are not owned. | |
| 138 std::string* name = new_state.name.get(); | |
| 139 bool* powered = new_state.powered.get(); | |
| 140 bool* discoverable = new_state.discoverable.get(); | |
| 141 | |
| 142 if (name && adapter->GetName() != *name) { | |
| 143 pending_properties_.insert(kNameProperty); | |
| 144 adapter->SetName(*name, | |
| 145 CreatePropertySetCallback(kNameProperty), | |
| 146 CreatePropertyErrorCallback(kNameProperty)); | |
| 147 } | |
| 148 | |
| 149 if (powered && adapter->IsPowered() != *powered) { | |
| 150 pending_properties_.insert(kPoweredProperty); | |
| 151 adapter->SetPowered(*powered, | |
| 152 CreatePropertySetCallback(kPoweredProperty), | |
| 153 CreatePropertyErrorCallback(kPoweredProperty)); | |
| 154 } | |
| 155 | |
| 156 if (discoverable && adapter->IsDiscoverable() != *discoverable) { | |
| 157 pending_properties_.insert(kDiscoverableProperty); | |
| 158 adapter->SetDiscoverable( | |
| 159 *discoverable, | |
| 160 CreatePropertySetCallback(kDiscoverableProperty), | |
| 161 CreatePropertyErrorCallback(kDiscoverableProperty)); | |
| 162 } | |
| 163 | |
| 164 if (pending_properties_.empty()) | |
| 165 SendResponse(true); | |
| 166 return true; | |
| 167 } | |
| 168 | |
| 169 base::Closure | |
| 170 BluetoothPrivateSetAdapterStateFunction::CreatePropertySetCallback( | |
| 171 const std::string& property_name) { | |
| 172 return base::Bind( | |
| 173 &BluetoothPrivateSetAdapterStateFunction::OnAdapterPropertySet, | |
| 174 this, | |
| 175 property_name); | |
| 176 } | |
| 177 | |
| 178 base::Closure | |
| 179 BluetoothPrivateSetAdapterStateFunction::CreatePropertyErrorCallback( | |
| 180 const std::string& property_name) { | |
| 181 return base::Bind( | |
| 182 &BluetoothPrivateSetAdapterStateFunction::OnAdapterPropertyError, | |
| 183 this, | |
| 184 property_name); | |
| 185 } | |
| 186 | |
| 187 void BluetoothPrivateSetAdapterStateFunction::OnAdapterPropertySet( | |
| 188 const std::string& property) { | |
| 189 DCHECK(pending_properties_.find(property) != pending_properties_.end()); | |
| 190 DCHECK(failed_properties_.find(property) == failed_properties_.end()); | |
| 191 | |
| 192 pending_properties_.erase(property); | |
| 193 if (pending_properties_.empty()) { | |
| 194 if (failed_properties_.empty()) | |
| 195 SendResponse(true); | |
| 196 else | |
| 197 SendError(); | |
| 198 } | |
| 199 } | |
| 200 | |
| 201 void BluetoothPrivateSetAdapterStateFunction::OnAdapterPropertyError( | |
| 202 const std::string& property) { | |
| 203 DCHECK(pending_properties_.find(property) != pending_properties_.end()); | |
| 204 DCHECK(failed_properties_.find(property) == failed_properties_.end()); | |
| 205 | |
| 206 pending_properties_.erase(property); | |
| 207 failed_properties_.insert(property); | |
| 208 if (pending_properties_.empty()) | |
| 209 SendError(); | |
| 210 } | |
| 211 | |
| 212 void BluetoothPrivateSetAdapterStateFunction::SendError() { | |
| 213 DCHECK(pending_properties_.empty()); | |
| 214 DCHECK(!failed_properties_.empty()); | |
| 215 | |
| 216 std::vector<std::string> failed_vector; | |
| 217 std::copy(failed_properties_.begin(), | |
| 218 failed_properties_.end(), | |
| 219 std::back_inserter(failed_vector)); | |
| 220 | |
| 221 std::vector<std::string> replacements(1); | |
| 222 replacements[0] = JoinString(failed_vector, ", "); | |
| 223 std::string error = | |
| 224 ReplaceStringPlaceholders(kSetAdapterPropertyError, replacements, NULL); | |
| 225 SetError(error); | |
| 226 SendResponse(false); | |
| 227 } | |
| 228 | |
| 229 BluetoothPrivateSetPairingResponseFunction:: | |
| 230 BluetoothPrivateSetPairingResponseFunction() {} | |
| 231 | |
| 232 BluetoothPrivateSetPairingResponseFunction:: | |
| 233 ~BluetoothPrivateSetPairingResponseFunction() {} | |
| 234 | |
| 235 bool BluetoothPrivateSetPairingResponseFunction::DoWork( | |
| 236 scoped_refptr<device::BluetoothAdapter> adapter) { | |
| 237 scoped_ptr<bt_private::SetPairingResponse::Params> params( | |
| 238 bt_private::SetPairingResponse::Params::Create(*args_)); | |
| 239 EXTENSION_FUNCTION_VALIDATE(params.get()); | |
| 240 const bt_private::SetPairingResponseOptions& options = params->options; | |
| 241 | |
| 242 BluetoothEventRouter* router = | |
| 243 BluetoothAPI::Get(browser_context())->event_router(); | |
| 244 if (!router->GetPairingDelegate(extension_id())) { | |
| 245 SetError(kPairingNotEnabled); | |
| 246 SendResponse(false); | |
| 247 return true; | |
| 248 } | |
| 249 | |
| 250 const std::string& device_address = options.device.address; | |
| 251 device::BluetoothDevice* device = adapter->GetDevice(device_address); | |
| 252 if (!device) { | |
| 253 SetError(kDeviceNotFoundError); | |
| 254 SendResponse(false); | |
| 255 return true; | |
| 256 } | |
| 257 | |
| 258 if (!ValidatePairingResponseOptions(device, options)) { | |
| 259 SetError(kInvalidPairingResponseOptions); | |
| 260 SendResponse(false); | |
| 261 return true; | |
| 262 } | |
| 263 | |
| 264 if (options.pincode.get()) { | |
| 265 device->SetPinCode(*options.pincode.get()); | |
| 266 } else if (options.passkey.get()) { | |
| 267 device->SetPasskey(*options.passkey.get()); | |
| 268 } else { | |
| 269 switch (options.response) { | |
| 270 case bt_private::PAIRING_RESPONSE_CONFIRM: | |
| 271 device->ConfirmPairing(); | |
| 272 break; | |
| 273 case bt_private::PAIRING_RESPONSE_REJECT: | |
| 274 device->RejectPairing(); | |
| 275 break; | |
| 276 case bt_private::PAIRING_RESPONSE_CANCEL: | |
| 277 device->CancelPairing(); | |
| 278 break; | |
| 279 default: | |
| 280 NOTREACHED(); | |
| 281 } | |
| 282 } | |
| 283 | |
| 284 SendResponse(true); | |
| 285 return true; | |
| 286 } | |
| 287 | |
| 288 } // namespace api | |
| 289 | |
| 290 } // namespace extensions | |
| OLD | NEW |