bluetooth: Browser side partial implementation of getPrimaryService.

content/browser/bluetooth/bluetooth_dispatcher_host.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/bluetooth/bluetooth_dispatcher_host.h"
 
 #include "base/strings/utf_string_conversions.h"
 #include "content/common/bluetooth/bluetooth_messages.h"
 #include "device/bluetooth/bluetooth_adapter.h"
 #include "device/bluetooth/bluetooth_adapter_factory.h"
 #include "device/bluetooth/bluetooth_device.h"
 #include "device/bluetooth/bluetooth_discovery_session.h"
+#include "device/bluetooth/bluetooth_gatt_service.h"
 
 using device::BluetoothAdapter;
 using device::BluetoothAdapterFactory;
+using device::BluetoothGattService;
 
 namespace content {
 
-const int kScanTime = 5;  // 5 seconds of scan time
-const int kTestingScanTime = 0;  // No need to scan for tests
+// TODO(ortuno): Once we have a chooser for scanning and the right
+// callback for discovered services we should delete these constants.
+// https://crbug.com/436280 and https://crbug.com/484504
+const int kDelayTime = 5;         // 5 seconds for scanning and discovering
+const int kTestingDelayTime = 0;  // No need to wait during tests
 
 BluetoothDispatcherHost::BluetoothDispatcherHost()
     : BrowserMessageFilter(BluetoothMsgStart),
       weak_ptr_factory_(this) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  current_scan_time_ = kScanTime;
+  current_delay_time_ = kDelayTime;
   if (BluetoothAdapterFactory::IsBluetoothAdapterAvailable())
     BluetoothAdapterFactory::GetAdapter(
         base::Bind(&BluetoothDispatcherHost::set_adapter,
                    weak_ptr_factory_.GetWeakPtr()));
 }
 
 void BluetoothDispatcherHost::OnDestruct() const {
   // See class comment: UI Thread Note.
   BrowserThread::DeleteOnUIThread::Destruct(this);
 }
 
 void BluetoothDispatcherHost::OverrideThreadForMessage(
     const IPC::Message& message,
     content::BrowserThread::ID* thread) {
   // See class comment: UI Thread Note.
   *thread = BrowserThread::UI;
 }
 
 bool BluetoothDispatcherHost::OnMessageReceived(const IPC::Message& message) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   bool handled = true;
   IPC_BEGIN_MESSAGE_MAP(BluetoothDispatcherHost, message)
   IPC_MESSAGE_HANDLER(BluetoothHostMsg_RequestDevice, OnRequestDevice)
   IPC_MESSAGE_HANDLER(BluetoothHostMsg_ConnectGATT, OnConnectGATT)
+  IPC_MESSAGE_HANDLER(BluetoothHostMsg_GetPrimaryService, OnGetPrimaryService)
   IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 void BluetoothDispatcherHost::SetBluetoothAdapterForTesting(
     scoped_refptr<device::BluetoothAdapter> mock_adapter) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  current_scan_time_ = kTestingScanTime;
+  current_delay_time_ = kTestingDelayTime;
   set_adapter(mock_adapter.Pass());
 }
 
 BluetoothDispatcherHost::~BluetoothDispatcherHost() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   // Clear adapter, releasing observer references.
   set_adapter(scoped_refptr<device::BluetoothAdapter>());
 }
 
 void BluetoothDispatcherHost::set_adapter(
@@ skipping 46 matching lines @@
   }
   device->CreateGattConnection(
       base::Bind(&BluetoothDispatcherHost::OnGATTConnectionCreated,
                  weak_ptr_factory_.GetWeakPtr(), thread_id, request_id,
                  device_instance_id),
       base::Bind(&BluetoothDispatcherHost::OnCreateGATTConnectionError,
                  weak_ptr_factory_.GetWeakPtr(), thread_id, request_id,
                  device_instance_id));
 }
 
+void BluetoothDispatcherHost::OnGetPrimaryService(
+    int thread_id,
+    int request_id,
+    const std::string& device_instance_id,
+    const std::string& service_uuid) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+  // TODO(ortuno): Right now it's pointless to check if the domain has access to

[scheib, 2015/05/28 23:09:16]

TODO: Check if device_instance_id is in "allowed devices". crbug.com/00000
TODO: Check if service__uuid is in "allowed services". crbug.com/00000 (This
implies also that service_uuid is well-formed).

[ortuno, 2015/05/29 17:53:54]

Done.

+  // the device, because any domain can connect to any device. But once
+  // permissions are implemented we should check that the domain has access to
+  // the device. https://crbug.com/484745
+  // For now just wait two seconds and call OnServiceDiscovered.

[scheib, 2015/05/28 23:09:16]

s/wait two seconds/wait a fixed time/. The constant is already changed to 5 and
may likely change again.

[ortuno, 2015/05/29 17:53:54]

Done.

+  // TODO(ortuno): Use callback once it's implemented http://crbug.com/484504
+  BrowserThread::PostDelayedTask(
+      BrowserThread::UI, FROM_HERE,
+      base::Bind(&BluetoothDispatcherHost::OnServicesDiscovered,
+                 weak_ptr_factory_.GetWeakPtr(), thread_id, request_id,
+                 device_instance_id, service_uuid),
+      base::TimeDelta::FromSeconds(current_delay_time_));
+}
+
 void BluetoothDispatcherHost::OnDiscoverySessionStarted(
     int thread_id,
     int request_id,
     scoped_ptr<device::BluetoothDiscoverySession> discovery_session) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   BrowserThread::PostDelayedTask(
       BrowserThread::UI, FROM_HERE,
       base::Bind(&BluetoothDispatcherHost::StopDiscoverySession,
                  weak_ptr_factory_.GetWeakPtr(), thread_id, request_id,
                  base::Passed(&discovery_session)),
-      base::TimeDelta::FromSeconds(current_scan_time_));
+      base::TimeDelta::FromSeconds(current_delay_time_));
 }
 
 void BluetoothDispatcherHost::OnDiscoverySessionStartedError(int thread_id,
                                                              int request_id) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   DLOG(WARNING) << "BluetoothDispatcherHost::OnDiscoverySessionStartedError";
   Send(new BluetoothMsg_RequestDeviceError(thread_id, request_id,
                                            BluetoothError::NOT_FOUND));
 }
 
@@ skipping 58 matching lines @@
     int request_id,
     const std::string& device_instance_id,
     device::BluetoothDevice::ConnectErrorCode error_code) {
   // There was an error creating the ATT Bearer so we reject with
   // NetworkError.
   // https://webbluetoothcg.github.io/web-bluetooth/#dom-bluetoothdevice-connectgatt
   Send(new BluetoothMsg_ConnectGATTError(thread_id, request_id,
                                          BluetoothError::NETWORK_ERROR));
 }
 
+void BluetoothDispatcherHost::OnServicesDiscovered(
+    int thread_id,
+    int request_id,
+    const std::string& device_instance_id,
+    const std::string& service_uuid) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  device::BluetoothDevice* device = adapter_->GetDevice(device_instance_id);
+  if (device == NULL) {
+    Send(new BluetoothMsg_GetPrimaryServiceError(
+        thread_id, request_id, BluetoothError::NETWORK_ERROR));

[scheib, 2015/05/28 23:09:16]

We should get the error messages returning error strings before adding more
error responses. Let's do it before landing any future patch with error
messages.

[ortuno, 2015/05/29 17:53:54]

Ack.

+    return;
+  }
+  for (BluetoothGattService* service : device->GetGattServices()) {
+    if (service->GetUUID().canonical_value() == service_uuid) {
+      Send(new BluetoothMsg_GetPrimaryServiceSuccess(
+          thread_id, request_id, device_instance_id, service->GetIdentifier(),
+          service->GetUUID().canonical_value()));
+      return;
+    }
+  }
+  Send(new BluetoothMsg_GetPrimaryServiceError(thread_id, request_id,
+                                               BluetoothError::NOT_FOUND));
+}
+
 }  // namespace content