OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 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 "chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h" | 5 #include "chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/json/json_writer.h" | 11 #include "base/json/json_writer.h" |
12 #include "base/logging.h" | 12 #include "base/logging.h" |
13 #include "base/memory/ref_counted.h" | 13 #include "base/memory/ref_counted.h" |
14 #include "base/memory/scoped_vector.h" | 14 #include "base/memory/scoped_vector.h" |
15 #include "base/strings/utf_string_conversions.h" | 15 #include "base/strings/utf_string_conversions.h" |
16 #include "chrome/browser/chrome_notification_types.h" | 16 #include "chrome/browser/chrome_notification_types.h" |
17 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api_utils.h" | 17 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api_utils.h" |
18 #include "chrome/browser/extensions/event_names.h" | |
19 #include "chrome/common/extensions/api/bluetooth.h" | 18 #include "chrome/common/extensions/api/bluetooth.h" |
20 #include "content/public/browser/notification_details.h" | 19 #include "content/public/browser/notification_details.h" |
21 #include "content/public/browser/notification_source.h" | 20 #include "content/public/browser/notification_source.h" |
22 #include "device/bluetooth/bluetooth_adapter.h" | 21 #include "device/bluetooth/bluetooth_adapter.h" |
23 #include "device/bluetooth/bluetooth_adapter_factory.h" | 22 #include "device/bluetooth/bluetooth_adapter_factory.h" |
24 #include "device/bluetooth/bluetooth_device.h" | 23 #include "device/bluetooth/bluetooth_device.h" |
25 #include "device/bluetooth/bluetooth_discovery_session.h" | 24 #include "device/bluetooth/bluetooth_discovery_session.h" |
26 #include "device/bluetooth/bluetooth_profile.h" | 25 #include "device/bluetooth/bluetooth_profile.h" |
27 #include "device/bluetooth/bluetooth_socket.h" | 26 #include "device/bluetooth/bluetooth_socket.h" |
28 #include "extensions/browser/event_router.h" | 27 #include "extensions/browser/event_router.h" |
(...skipping 174 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
203 } | 202 } |
204 | 203 |
205 scoped_refptr<device::BluetoothSocket> | 204 scoped_refptr<device::BluetoothSocket> |
206 ExtensionBluetoothEventRouter::GetSocket(int id) { | 205 ExtensionBluetoothEventRouter::GetSocket(int id) { |
207 SocketMap::iterator socket_entry = socket_map_.find(id); | 206 SocketMap::iterator socket_entry = socket_map_.find(id); |
208 if (socket_entry == socket_map_.end()) | 207 if (socket_entry == socket_map_.end()) |
209 return NULL; | 208 return NULL; |
210 return socket_entry->second.socket; | 209 return socket_entry->second.socket; |
211 } | 210 } |
212 | 211 |
213 void ExtensionBluetoothEventRouter::DispatchDeviceEvent( | |
214 const std::string& event_name, const bluetooth::Device& device) { | |
215 scoped_ptr<base::ListValue> args(new base::ListValue()); | |
216 args->Append(device.ToValue().release()); | |
217 scoped_ptr<Event> event(new Event(event_name, args.Pass())); | |
218 ExtensionSystem::Get(browser_context_)->event_router()->BroadcastEvent( | |
219 event.Pass()); | |
220 } | |
221 | |
222 void ExtensionBluetoothEventRouter::DispatchConnectionEvent( | 212 void ExtensionBluetoothEventRouter::DispatchConnectionEvent( |
223 const std::string& extension_id, | 213 const std::string& extension_id, |
224 const std::string& uuid, | 214 const std::string& uuid, |
225 const device::BluetoothDevice* device, | 215 const device::BluetoothDevice* device, |
226 scoped_refptr<device::BluetoothSocket> socket) { | 216 scoped_refptr<device::BluetoothSocket> socket) { |
227 if (!HasProfile(uuid)) | 217 if (!HasProfile(uuid)) |
228 return; | 218 return; |
229 | 219 |
230 int socket_id = RegisterSocket(extension_id, socket); | 220 int socket_id = RegisterSocket(extension_id, socket); |
231 api::bluetooth::Socket result_socket; | 221 bluetooth::Socket result_socket; |
232 api::bluetooth::BluetoothDeviceToApiDevice(*device, &result_socket.device); | 222 bluetooth::BluetoothDeviceToApiDevice(*device, &result_socket.device); |
233 result_socket.profile.uuid = uuid; | 223 result_socket.profile.uuid = uuid; |
234 result_socket.id = socket_id; | 224 result_socket.id = socket_id; |
235 | 225 |
236 scoped_ptr<base::ListValue> args(new base::ListValue()); | 226 scoped_ptr<base::ListValue> args = |
237 args->Append(result_socket.ToValue().release()); | 227 bluetooth::OnConnection::Create(result_socket); |
238 scoped_ptr<Event> event(new Event( | 228 scoped_ptr<Event> event(new Event( |
239 bluetooth::OnConnection::kEventName, args.Pass())); | 229 bluetooth::OnConnection::kEventName, args.Pass())); |
240 ExtensionSystem::Get(browser_context_) | 230 ExtensionSystem::Get(browser_context_) |
241 ->event_router() | 231 ->event_router() |
242 ->DispatchEventToExtension(extension_id, event.Pass()); | 232 ->DispatchEventToExtension(extension_id, event.Pass()); |
243 } | 233 } |
244 | 234 |
245 void ExtensionBluetoothEventRouter::AdapterPresentChanged( | 235 void ExtensionBluetoothEventRouter::AdapterPresentChanged( |
246 device::BluetoothAdapter* adapter, bool present) { | 236 device::BluetoothAdapter* adapter, bool present) { |
247 if (adapter != adapter_.get()) { | 237 if (adapter != adapter_.get()) { |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
287 } | 277 } |
288 | 278 |
289 void ExtensionBluetoothEventRouter::DeviceAdded( | 279 void ExtensionBluetoothEventRouter::DeviceAdded( |
290 device::BluetoothAdapter* adapter, | 280 device::BluetoothAdapter* adapter, |
291 device::BluetoothDevice* device) { | 281 device::BluetoothDevice* device) { |
292 if (adapter != adapter_.get()) { | 282 if (adapter != adapter_.get()) { |
293 DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress(); | 283 DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress(); |
294 return; | 284 return; |
295 } | 285 } |
296 | 286 |
297 bluetooth::Device extension_device; | 287 DispatchDeviceEvent(bluetooth::OnDeviceAdded::kEventName, device); |
298 bluetooth::BluetoothDeviceToApiDevice(*device, &extension_device); | 288 } |
299 | 289 |
300 DispatchDeviceEvent(extensions::event_names::kBluetoothOnDeviceDiscovered, | 290 void ExtensionBluetoothEventRouter::DeviceChanged( |
301 extension_device); | 291 device::BluetoothAdapter* adapter, |
| 292 device::BluetoothDevice* device) { |
| 293 if (adapter != adapter_.get()) { |
| 294 DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress(); |
| 295 return; |
| 296 } |
| 297 |
| 298 DispatchDeviceEvent(bluetooth::OnDeviceChanged::kEventName, device); |
| 299 } |
| 300 |
| 301 void ExtensionBluetoothEventRouter::DeviceRemoved( |
| 302 device::BluetoothAdapter* adapter, |
| 303 device::BluetoothDevice* device) { |
| 304 if (adapter != adapter_.get()) { |
| 305 DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress(); |
| 306 return; |
| 307 } |
| 308 |
| 309 DispatchDeviceEvent(bluetooth::OnDeviceRemoved::kEventName, device); |
302 } | 310 } |
303 | 311 |
304 void ExtensionBluetoothEventRouter::InitializeAdapterIfNeeded() { | 312 void ExtensionBluetoothEventRouter::InitializeAdapterIfNeeded() { |
305 if (!adapter_.get()) { | 313 if (!adapter_.get()) { |
306 GetAdapter(base::Bind(&ExtensionBluetoothEventRouter::InitializeAdapter, | 314 GetAdapter(base::Bind(&ExtensionBluetoothEventRouter::InitializeAdapter, |
307 weak_ptr_factory_.GetWeakPtr())); | 315 weak_ptr_factory_.GetWeakPtr())); |
308 } | 316 } |
309 } | 317 } |
310 | 318 |
311 void ExtensionBluetoothEventRouter::InitializeAdapter( | 319 void ExtensionBluetoothEventRouter::InitializeAdapter( |
312 scoped_refptr<device::BluetoothAdapter> adapter) { | 320 scoped_refptr<device::BluetoothAdapter> adapter) { |
313 if (!adapter_.get()) { | 321 if (!adapter_.get()) { |
314 adapter_ = adapter; | 322 adapter_ = adapter; |
315 adapter_->AddObserver(this); | 323 adapter_->AddObserver(this); |
316 } | 324 } |
317 } | 325 } |
318 | 326 |
319 void ExtensionBluetoothEventRouter::MaybeReleaseAdapter() { | 327 void ExtensionBluetoothEventRouter::MaybeReleaseAdapter() { |
320 if (adapter_.get() && num_event_listeners_ == 0) { | 328 if (adapter_.get() && num_event_listeners_ == 0) { |
321 adapter_->RemoveObserver(this); | 329 adapter_->RemoveObserver(this); |
322 adapter_ = NULL; | 330 adapter_ = NULL; |
323 } | 331 } |
324 } | 332 } |
325 | 333 |
326 void ExtensionBluetoothEventRouter::DispatchAdapterStateEvent() { | 334 void ExtensionBluetoothEventRouter::DispatchAdapterStateEvent() { |
327 api::bluetooth::AdapterState state; | 335 bluetooth::AdapterState state; |
328 PopulateAdapterState(*adapter_.get(), &state); | 336 PopulateAdapterState(*adapter_.get(), &state); |
329 | 337 |
330 scoped_ptr<base::ListValue> args(new base::ListValue()); | 338 scoped_ptr<base::ListValue> args = |
331 args->Append(state.ToValue().release()); | 339 bluetooth::OnAdapterStateChanged::Create(state); |
332 scoped_ptr<Event> event(new Event( | 340 scoped_ptr<Event> event(new Event( |
333 bluetooth::OnAdapterStateChanged::kEventName, | 341 bluetooth::OnAdapterStateChanged::kEventName, |
334 args.Pass())); | 342 args.Pass())); |
335 ExtensionSystem::Get(browser_context_)->event_router()->BroadcastEvent( | 343 ExtensionSystem::Get(browser_context_)->event_router()->BroadcastEvent( |
336 event.Pass()); | 344 event.Pass()); |
337 } | 345 } |
338 | 346 |
| 347 void ExtensionBluetoothEventRouter::DispatchDeviceEvent( |
| 348 const std::string& event_name, |
| 349 device::BluetoothDevice* device) { |
| 350 bluetooth::Device extension_device; |
| 351 bluetooth::BluetoothDeviceToApiDevice(*device, &extension_device); |
| 352 |
| 353 scoped_ptr<base::ListValue> args = |
| 354 bluetooth::OnDeviceAdded::Create(extension_device); |
| 355 scoped_ptr<Event> event(new Event(event_name, args.Pass())); |
| 356 ExtensionSystem::Get(browser_context_)->event_router()->BroadcastEvent( |
| 357 event.Pass()); |
| 358 } |
| 359 |
339 void ExtensionBluetoothEventRouter::CleanUpForExtension( | 360 void ExtensionBluetoothEventRouter::CleanUpForExtension( |
340 const std::string& extension_id) { | 361 const std::string& extension_id) { |
341 // Remove all profiles added by the extension. | 362 // Remove all profiles added by the extension. |
342 BluetoothProfileMap::iterator profile_iter = bluetooth_profile_map_.begin(); | 363 BluetoothProfileMap::iterator profile_iter = bluetooth_profile_map_.begin(); |
343 while (profile_iter != bluetooth_profile_map_.end()) { | 364 while (profile_iter != bluetooth_profile_map_.end()) { |
344 ExtensionBluetoothProfileRecord record = profile_iter->second; | 365 ExtensionBluetoothProfileRecord record = profile_iter->second; |
345 if (record.extension_id == extension_id) { | 366 if (record.extension_id == extension_id) { |
346 bluetooth_profile_map_.erase(profile_iter++); | 367 bluetooth_profile_map_.erase(profile_iter++); |
347 record.profile->Unregister(); | 368 record.profile->Unregister(); |
348 } else { | 369 } else { |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
391 case chrome::NOTIFICATION_EXTENSION_UNLOADED: { | 412 case chrome::NOTIFICATION_EXTENSION_UNLOADED: { |
392 extensions::UnloadedExtensionInfo* info = | 413 extensions::UnloadedExtensionInfo* info = |
393 content::Details<extensions::UnloadedExtensionInfo>(details).ptr(); | 414 content::Details<extensions::UnloadedExtensionInfo>(details).ptr(); |
394 CleanUpForExtension(info->extension->id()); | 415 CleanUpForExtension(info->extension->id()); |
395 break; | 416 break; |
396 } | 417 } |
397 } | 418 } |
398 } | 419 } |
399 | 420 |
400 } // namespace extensions | 421 } // namespace extensions |
OLD | NEW |