chrome.bluetooth API improvements.

chrome/browser/extensions/api/bluetooth/bluetooth_api.cc

 // Copyright (c) 2012 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 "chrome/browser/extensions/api/bluetooth/bluetooth_api.h"
 
 #include <string>
 
 #include "base/lazy_instance.h"
 #include "base/memory/ref_counted.h"
 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api_utils.h"
 #include "chrome/browser/extensions/api/bluetooth/bluetooth_event_router.h"
+#include "chrome/browser/extensions/api/bluetooth/bluetooth_socket_event_dispatcher.h"
 #include "chrome/browser/extensions/event_names.h"
+#include "chrome/browser/profiles/profile_manager.h"
 #include "chrome/common/extensions/api/bluetooth.h"
 #include "chrome/common/extensions/api/bluetooth/bluetooth_manifest_data.h"
 #include "content/public/browser/browser_thread.h"
 #include "device/bluetooth/bluetooth_adapter.h"
 #include "device/bluetooth/bluetooth_device.h"
 #include "device/bluetooth/bluetooth_out_of_band_pairing_data.h"
 #include "device/bluetooth/bluetooth_profile.h"
 #include "device/bluetooth/bluetooth_service_record.h"
 #include "device/bluetooth/bluetooth_socket.h"
 #include "device/bluetooth/bluetooth_utils.h"
 #include "extensions/browser/event_router.h"
 #include "extensions/browser/extension_system.h"
 #include "extensions/common/permissions/permissions_data.h"
 #include "net/base/io_buffer.h"
 
 using content::BrowserContext;
+using content::BrowserThread;
+
 using device::BluetoothAdapter;
 using device::BluetoothDevice;
 using device::BluetoothProfile;
 using device::BluetoothServiceRecord;
 using device::BluetoothSocket;
 
-namespace {
+using extensions::BluetoothApiSocket;
 
-extensions::ExtensionBluetoothEventRouter* GetEventRouter(
-    BrowserContext* context) {
-  return extensions::BluetoothAPI::Get(context)->bluetooth_event_router();
-}
-
-}  // namespace
+namespace AddProfile = extensions::api::bluetooth::AddProfile;
+namespace bluetooth = extensions::api::bluetooth;
+namespace Connect = extensions::api::bluetooth::Connect;
+namespace Disconnect = extensions::api::bluetooth::Disconnect;
+namespace GetDevices = extensions::api::bluetooth::GetDevices;
+namespace GetProfiles = extensions::api::bluetooth::GetProfiles;
+namespace RemoveProfile = extensions::api::bluetooth::RemoveProfile;
+namespace SetOutOfBandPairingData =
+    extensions::api::bluetooth::SetOutOfBandPairingData;
+namespace Send = extensions::api::bluetooth::Send;
 
 namespace {
 
 const char kCouldNotGetLocalOutOfBandPairingData[] =
     "Could not get local Out Of Band Pairing Data";
-const char kCouldNotSetOutOfBandPairingData[] =
-    "Could not set Out Of Band Pairing Data";
-const char kFailedToConnect[] = "Connection failed";
 const char kInvalidDevice[] = "Invalid device";
 const char kInvalidUuid[] = "Invalid UUID";
 const char kPermissionDenied[] = "Permission to add profile denied.";
 const char kProfileAlreadyRegistered[] =
     "This profile has already been registered";
 const char kProfileNotFound[] = "Profile not found: invalid uuid";
 const char kProfileRegistrationFailed[] = "Profile registration failed";
-const char kServiceDiscoveryFailed[] = "Service discovery failed";
 const char kSocketNotFoundError[] = "Socket not found: invalid socket id";
 const char kStartDiscoveryFailed[] = "Starting discovery failed";
 const char kStopDiscoveryFailed[] = "Failed to stop discovery";
 
+extensions::ExtensionBluetoothEventRouter* GetEventRouter(
+    BrowserContext* context) {
+  // Note: |context| is valid on UI thread only.
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  return extensions::BluetoothAPI::Get(context)->event_router();
+}
+
+linked_ptr<bluetooth::Socket> CreateSocketInfo(int socket_id,
+                                               BluetoothApiSocket* socket) {
+  DCHECK(BrowserThread::CurrentlyOn(BluetoothApiSocket::kThreadId));
+  linked_ptr<bluetooth::Socket> socket_info(new bluetooth::Socket());
+  // This represents what we know about the socket, and does not call through
+  // to the system.
+  socket_info->id = socket_id;
+  if (!socket->name().empty()) {
+    socket_info->name.reset(new std::string(socket->name()));
+  }
+  socket_info->persistent = socket->persistent();
+  if (socket->buffer_size() > 0) {
+    socket_info->buffer_size.reset(new int(socket->buffer_size()));
+  }
+  socket_info->paused = socket->paused();
+  socket_info->device.address = socket->device_address();
+  socket_info->profile.uuid = socket->profile_uuid();
+
+  return socket_info;
+}
+
+void SetSocketProperties(extensions::BluetoothApiSocket* socket,
+                         bluetooth::SocketProperties* properties) {
+  if (properties->name.get()) {
+    socket->set_name(*properties->name.get());
+  }
+  if (properties->persistent.get()) {
+    socket->set_persistent(*properties->persistent.get());
+  }
+  if (properties->buffer_size.get()) {
+    // buffer size is validated when issuing the actual Recv operation
+    // on the socket.
+    socket->set_buffer_size(*properties->buffer_size.get());
+  }
+}
+
+static void DispatchConnectionEventWorker(
+    void* browser_context_id,
+    const std::string& extension_id,
+    const std::string& profile_uuid,
+    const device::BluetoothDevice* device,
+    scoped_refptr<device::BluetoothSocket> socket) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  content::BrowserContext* context =
+      reinterpret_cast<content::BrowserContext*>(browser_context_id);
+  if (!extensions::ExtensionsBrowserClient::Get()->IsValidContext(context))
+    return;
+
+  extensions::BluetoothAPI* bluetooth_api =
+      extensions::BluetoothAPI::Get(context);
+  if (!bluetooth_api)
+    return;
+
+  bluetooth_api->DispatchConnectionEvent(
+      extension_id, profile_uuid, device, socket);
+}
+
 }  // namespace
 
-namespace AddProfile = extensions::api::bluetooth::AddProfile;
-namespace bluetooth = extensions::api::bluetooth;
-namespace Connect = extensions::api::bluetooth::Connect;
-namespace Disconnect = extensions::api::bluetooth::Disconnect;
-namespace GetDevices = extensions::api::bluetooth::GetDevices;
-namespace GetProfiles = extensions::api::bluetooth::GetProfiles;
-namespace GetServices = extensions::api::bluetooth::GetServices;
-namespace Read = extensions::api::bluetooth::Read;
-namespace RemoveProfile = extensions::api::bluetooth::RemoveProfile;
-namespace SetOutOfBandPairingData =
-    extensions::api::bluetooth::SetOutOfBandPairingData;
-namespace Write = extensions::api::bluetooth::Write;
-
 namespace extensions {
 
 static base::LazyInstance<BrowserContextKeyedAPIFactory<BluetoothAPI> >
     g_factory = LAZY_INSTANCE_INITIALIZER;
 
 // static
 BrowserContextKeyedAPIFactory<BluetoothAPI>*
 BluetoothAPI::GetFactoryInstance() {
   return g_factory.Pointer();
 }
 
 // static
 BluetoothAPI* BluetoothAPI::Get(BrowserContext* context) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   return GetFactoryInstance()->Get(context);
 }
 
-BluetoothAPI::BluetoothAPI(BrowserContext* context)
+BluetoothAPI::ConnectionParams::ConnectionParams() {}
+
+BluetoothAPI::ConnectionParams::~ConnectionParams() {}
+
+BluetoothAPI::BluetoothAPI(content::BrowserContext* context)
     : browser_context_(context) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   ExtensionSystem::Get(browser_context_)->event_router()->RegisterObserver(
       this, bluetooth::OnAdapterStateChanged::kEventName);
   ExtensionSystem::Get(browser_context_)->event_router()->RegisterObserver(
       this, bluetooth::OnDeviceAdded::kEventName);
   ExtensionSystem::Get(browser_context_)->event_router()->RegisterObserver(
       this, bluetooth::OnDeviceChanged::kEventName);
   ExtensionSystem::Get(browser_context_)->event_router()->RegisterObserver(
       this, bluetooth::OnDeviceRemoved::kEventName);
 }
 
-BluetoothAPI::~BluetoothAPI() {
+BluetoothAPI::~BluetoothAPI() {}
+
+ExtensionBluetoothEventRouter* BluetoothAPI::event_router() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (!event_router_) {
+    event_router_.reset(new ExtensionBluetoothEventRouter(browser_context_));
+  }
+  return event_router_.get();
 }
 
-ExtensionBluetoothEventRouter* BluetoothAPI::bluetooth_event_router() {
-  if (!bluetooth_event_router_)
-    bluetooth_event_router_.reset(
-        new ExtensionBluetoothEventRouter(browser_context_));
+scoped_refptr<BluetoothAPI::SocketData> BluetoothAPI::socket_data() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (!socket_data_) {
+    ApiResourceManager<BluetoothApiSocket>* socket_manager =
+        ApiResourceManager<BluetoothApiSocket>::Get(browser_context_);
+    DCHECK(socket_manager)
+        << "There is no socket manager. "
+           "If this assertion is failing during a test, then it is likely that "
+           "TestExtensionSystem is failing to provide an instance of "
+           "ApiResourceManager<BluetoothApiSocket>.";
 
-  return bluetooth_event_router_.get();
+    socket_data_ = socket_manager->data_;
+  }
+  return socket_data_;
+}
+
+scoped_refptr<api::BluetoothSocketEventDispatcher>
+BluetoothAPI::socket_event_dispatcher() {
+  if (!socket_event_dispatcher_) {
+    socket_event_dispatcher_ = new api::BluetoothSocketEventDispatcher(
+        browser_context_, socket_data());
+  }
+  return socket_event_dispatcher_;
 }
 
 void BluetoothAPI::Shutdown() {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
   ExtensionSystem::Get(browser_context_)->event_router()->UnregisterObserver(
       this);
 }
 
 void BluetoothAPI::OnListenerAdded(const EventListenerInfo& details) {
-  if (bluetooth_event_router()->IsBluetoothSupported())
-    bluetooth_event_router()->OnListenerAdded();
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (event_router()->IsBluetoothSupported())
+    event_router()->OnListenerAdded();
 }
 
 void BluetoothAPI::OnListenerRemoved(const EventListenerInfo& details) {
-  if (bluetooth_event_router()->IsBluetoothSupported())
-    bluetooth_event_router()->OnListenerRemoved();
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+  if (event_router()->IsBluetoothSupported())
+    event_router()->OnListenerRemoved();
+}
+
+void BluetoothAPI::DispatchConnectionEvent(
+    const std::string& extension_id,
+    const std::string& profile_uuid,
+    const device::BluetoothDevice* device,
+    scoped_refptr<device::BluetoothSocket> socket) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  if (!event_router()->HasProfile(profile_uuid))
+    return;
+
+  extensions::BluetoothAPI::ConnectionParams params;
+  params.browser_context_id = browser_context_;
+  params.thread_id = BluetoothApiSocket::kThreadId;
+  params.extension_id = extension_id;
+  params.profile_uuid = profile_uuid;
+  params.device_address = device->GetAddress();
+  params.socket = socket;
+  params.socket_data = socket_data();
+  BrowserThread::PostTask(
+      params.thread_id, FROM_HERE, base::Bind(&RegisterSocket, params));
+}
+
+// static
+void BluetoothAPI::RegisterSocket(
+    const BluetoothAPI::ConnectionParams& params) {
+  DCHECK(BrowserThread::CurrentlyOn(params.thread_id));
+
+  BluetoothApiSocket* api_socket = new BluetoothApiSocket(params.extension_id,
+                                                          params.socket,
+                                                          params.device_address,
+                                                          params.profile_uuid);
+  int socket_id = params.socket_data->Add(api_socket);
+  api::bluetooth::Socket result_socket;
+  result_socket.device.address = params.device_address;
+  result_socket.profile.uuid = params.profile_uuid;
+  result_socket.id = socket_id;
+
+  scoped_ptr<base::ListValue> args =
+      bluetooth::OnConnection::Create(result_socket);
+  scoped_ptr<Event> event(
+      new Event(bluetooth::OnConnection::kEventName, args.Pass()));
+
+  PostEvent(params, event.Pass());
+}
+
+// static
+void BluetoothAPI::PostEvent(const BluetoothAPI::ConnectionParams& params,
+                             scoped_ptr<extensions::Event> event) {
+  DCHECK(BrowserThread::CurrentlyOn(params.thread_id));
+
+  BrowserThread::PostTask(BrowserThread::UI,
+                          FROM_HERE,
+                          base::Bind(&DispatchEvent,
+                                     params.browser_context_id,
+                                     params.extension_id,
+                                     base::Passed(event.Pass())));
+}
+
+// static
+void BluetoothAPI::DispatchEvent(void* browser_context_id,
+                                 const std::string& extension_id,
+                                 scoped_ptr<extensions::Event> event) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  content::BrowserContext* context =
+      reinterpret_cast<content::BrowserContext*>(browser_context_id);
+  if (!extensions::ExtensionsBrowserClient::Get()->IsValidContext(context))
+    return;
+
+  EventRouter* router = ExtensionSystem::Get(context)->event_router();
+  if (router)
+    router->DispatchEventToExtension(extension_id, event.Pass());
 }
 
 namespace api {
 
-BluetoothAddProfileFunction::BluetoothAddProfileFunction() {
+BluetoothSocketApiFunction::BluetoothSocketApiFunction() {}
+
+BluetoothSocketApiFunction::~BluetoothSocketApiFunction() {}
+
+bool BluetoothSocketApiFunction::PrePrepare() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  set_work_thread_id(BluetoothApiSocket::kThreadId);
+  socket_data_ = BluetoothAPI::Get(browser_context())->socket_data();
+  socket_event_dispatcher_ =
+      BluetoothAPI::Get(browser_context())->socket_event_dispatcher();
+  return socket_data_ && socket_event_dispatcher_;
 }
 
+bool BluetoothSocketApiFunction::Respond() { return error_.empty(); }
+
+BluetoothGetAdapterStateFunction::~BluetoothGetAdapterStateFunction() {}
+
+bool BluetoothGetAdapterStateFunction::DoWork(
+    scoped_refptr<BluetoothAdapter> adapter) {
+  bluetooth::AdapterState state;
+  PopulateAdapterState(*adapter.get(), &state);
+  results_ = bluetooth::GetAdapterState::Results::Create(state);
+  SendResponse(true);
+  return true;
+}
+
+BluetoothGetDevicesFunction::~BluetoothGetDevicesFunction() {}
+
+bool BluetoothGetDevicesFunction::DoWork(
+    scoped_refptr<BluetoothAdapter> adapter) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  base::ListValue* device_list = new base::ListValue;
+  SetResult(device_list);
+
+  BluetoothAdapter::DeviceList devices = adapter->GetDevices();
+  for (BluetoothAdapter::DeviceList::const_iterator iter = devices.begin();
+       iter != devices.end();
+       ++iter) {
+    const BluetoothDevice* device = *iter;
+    DCHECK(device);
+
+    bluetooth::Device extension_device;
+    bluetooth::BluetoothDeviceToApiDevice(*device, &extension_device);
+
+    device_list->Append(extension_device.ToValue().release());
+  }
+
+  SendResponse(true);
+
+  return true;
+}
+
+BluetoothAddProfileFunction::BluetoothAddProfileFunction() {}
+
+BluetoothAddProfileFunction::~BluetoothAddProfileFunction() {}
+
 bool BluetoothAddProfileFunction::RunImpl() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   scoped_ptr<AddProfile::Params> params(AddProfile::Params::Create(*args_));
   EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
 
   if (!BluetoothDevice::IsUUIDValid(params->profile.uuid)) {
     SetError(kInvalidUuid);
     return false;
   }
 
   BluetoothPermissionRequest param(params->profile.uuid);
   if (!BluetoothManifestData::CheckRequest(GetExtension(), param)) {
@@ skipping 33 matching lines @@
   RegisterProfile(
       options,
       base::Bind(&BluetoothAddProfileFunction::OnProfileRegistered, this));
 
   return true;
 }
 
 void BluetoothAddProfileFunction::RegisterProfile(
     const BluetoothProfile::Options& options,
     const BluetoothProfile::ProfileCallback& callback) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   BluetoothProfile::Register(uuid_, options, callback);
 }
 
 void BluetoothAddProfileFunction::OnProfileRegistered(
     BluetoothProfile* bluetooth_profile) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   if (!bluetooth_profile) {
     SetError(kProfileRegistrationFailed);
     SendResponse(false);
     return;
   }
 
   if (GetEventRouter(browser_context())->HasProfile(uuid_)) {
     bluetooth_profile->Unregister();
     SetError(kProfileAlreadyRegistered);
     SendResponse(false);
     return;
   }
 
   bluetooth_profile->SetConnectionCallback(
-      base::Bind(&ExtensionBluetoothEventRouter::DispatchConnectionEvent,
-                 base::Unretained(GetEventRouter(browser_context())),
+      base::Bind(&DispatchConnectionEventWorker,
+                 browser_context(),
                  extension_id(),
                  uuid_));
   GetEventRouter(browser_context())
       ->AddProfile(uuid_, extension_id(), bluetooth_profile);
   SendResponse(true);
 }
 
+BluetoothRemoveProfileFunction::~BluetoothRemoveProfileFunction() {}
+
 bool BluetoothRemoveProfileFunction::RunImpl() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   scoped_ptr<RemoveProfile::Params> params(
       RemoveProfile::Params::Create(*args_));
 
   if (!BluetoothDevice::IsUUIDValid(params->profile.uuid)) {
     SetError(kInvalidUuid);
     return false;
   }
 
   std::string uuid =
       device::bluetooth_utils::CanonicalUuid(params->profile.uuid);
 
   if (!GetEventRouter(browser_context())->HasProfile(uuid)) {
     SetError(kProfileNotFound);
     return false;
   }
 
   GetEventRouter(browser_context())->RemoveProfile(uuid);
   return true;
 }
 
-// TODO(youngki): Implement.
+BluetoothGetProfilesFunction::~BluetoothGetProfilesFunction() {}
+
 bool BluetoothGetProfilesFunction::DoWork(
     scoped_refptr<device::BluetoothAdapter> adapter) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   scoped_ptr<GetProfiles::Params> params(GetProfiles::Params::Create(*args_));
   EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
   const bluetooth::GetProfilesOptions& options = params->options;
 
   BluetoothDevice* device = adapter->GetDevice(options.device.address);
   if (!device) {
     SetError(kInvalidDevice);
     SendResponse(false);
     return false;
   }
 
   BluetoothDevice::ServiceList service_list = device->GetServices();
 
-  base::ListValue* profiles = new base::ListValue;
+  std::vector<linked_ptr<bluetooth::Profile> > profiles;
   for (BluetoothDevice::ServiceList::const_iterator iter = service_list.begin();
        iter != service_list.end();
        ++iter) {
-    bluetooth::Profile api_profile;
-    api_profile.uuid = *iter;
-    profiles->Append(api_profile.ToValue().release());
+    linked_ptr<bluetooth::Profile> api_profile(new bluetooth::Profile());
+    api_profile->uuid = *iter;
+    // TODO(rpaquay): Add other fields.
+    profiles.push_back(api_profile);
   }
 
-  SetResult(profiles);
+  results_ = bluetooth::GetProfiles::Results::Create(profiles);
   SendResponse(true);
 
   return true;
 }
 
-bool BluetoothGetAdapterStateFunction::DoWork(
-    scoped_refptr<BluetoothAdapter> adapter) {
-  bluetooth::AdapterState state;
-  PopulateAdapterState(*adapter.get(), &state);
-  SetResult(state.ToValue().release());
-  SendResponse(true);
-  return true;
-}
-
-bool BluetoothGetDevicesFunction::DoWork(
-    scoped_refptr<BluetoothAdapter> adapter) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
-
-  base::ListValue* device_list = new base::ListValue;
-  SetResult(device_list);
-
-  BluetoothAdapter::DeviceList devices = adapter->GetDevices();
-  for (BluetoothAdapter::DeviceList::const_iterator iter = devices.begin();
-       iter != devices.end();
-       ++iter) {
-    const BluetoothDevice* device = *iter;
-    DCHECK(device);
-
-    bluetooth::Device extension_device;
-    bluetooth::BluetoothDeviceToApiDevice(*device, &extension_device);
-
-    device_list->Append(extension_device.ToValue().release());
-  }
-
-  SendResponse(true);
-
-  return true;
-}
-
-void BluetoothGetServicesFunction::GetServiceRecordsCallback(
-    base::ListValue* services,
-    const BluetoothDevice::ServiceRecordList& records) {
-  for (BluetoothDevice::ServiceRecordList::const_iterator i = records.begin();
-      i != records.end(); ++i) {
-    const BluetoothServiceRecord& record = **i;
-    bluetooth::ServiceRecord api_record;
-    api_record.name = record.name();
-    if (!record.uuid().empty())
-      api_record.uuid.reset(new std::string(record.uuid()));
-    services->Append(api_record.ToValue().release());
-  }
-
-  SendResponse(true);
-}
-
-void BluetoothGetServicesFunction::OnErrorCallback() {
-  SetError(kServiceDiscoveryFailed);
-  SendResponse(false);
-}
-
-bool BluetoothGetServicesFunction::DoWork(
-    scoped_refptr<BluetoothAdapter> adapter) {
-  scoped_ptr<GetServices::Params> params(GetServices::Params::Create(*args_));
-  EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
-  const bluetooth::GetServicesOptions& options = params->options;
-
-  BluetoothDevice* device = adapter->GetDevice(options.device_address);
-  if (!device) {
-    SetError(kInvalidDevice);
-    SendResponse(false);
-    return false;
-  }
-
-  base::ListValue* services = new base::ListValue;
-  SetResult(services);
-
-  device->GetServiceRecords(
-      base::Bind(&BluetoothGetServicesFunction::GetServiceRecordsCallback,
-                 this,
-                 services),
-      base::Bind(&BluetoothGetServicesFunction::OnErrorCallback,
-                 this));
-
-  return true;
-}
-
-void BluetoothConnectFunction::OnSuccessCallback() {
-  SendResponse(true);
-}
-
-void BluetoothConnectFunction::OnErrorCallback() {
-  SetError(kFailedToConnect);
-  SendResponse(false);
-}
+BluetoothConnectFunction::~BluetoothConnectFunction() {}
 
 bool BluetoothConnectFunction::DoWork(scoped_refptr<BluetoothAdapter> adapter) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   scoped_ptr<Connect::Params> params(Connect::Params::Create(*args_));
   EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
   const bluetooth::ConnectOptions& options = params->options;
 
   if (!BluetoothDevice::IsUUIDValid(options.profile.uuid)) {
     SetError(kInvalidUuid);
     SendResponse(false);
     return false;
   }
 
@@ skipping 10 matching lines @@
   BluetoothProfile* bluetooth_profile =
       GetEventRouter(browser_context())->GetProfile(uuid);
   if (!bluetooth_profile) {
     SetError(kProfileNotFound);
     SendResponse(false);
     return false;
   }
 
   device->ConnectToProfile(
       bluetooth_profile,
+      BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI),
+      BrowserThread::GetMessageLoopProxyForThread(
+          BluetoothApiSocket::kThreadId),
+      NULL,
+      net::NetLog::Source(),
       base::Bind(&BluetoothConnectFunction::OnSuccessCallback, this),
       base::Bind(&BluetoothConnectFunction::OnErrorCallback, this));
 
   return true;
 }
 
-bool BluetoothDisconnectFunction::RunImpl() {
-  scoped_ptr<Disconnect::Params> params(Disconnect::Params::Create(*args_));
-  EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
-  const bluetooth::DisconnectOptions& options = params->options;
-  return GetEventRouter(browser_context())->ReleaseSocket(options.socket.id);
-}
-
-BluetoothReadFunction::BluetoothReadFunction() : success_(false) {}
-BluetoothReadFunction::~BluetoothReadFunction() {}
-
-bool BluetoothReadFunction::Prepare() {
-  scoped_ptr<Read::Params> params(Read::Params::Create(*args_));
-  EXTENSION_FUNCTION_VALIDATE(params.get() != NULL);
-  const bluetooth::ReadOptions& options = params->options;
-
-  socket_ = GetEventRouter(browser_context())->GetSocket(options.socket.id);
-  if (socket_.get() == NULL) {
-    SetError(kSocketNotFoundError);
-    return false;
-  }
-
-  success_ = false;
-  return true;
-}
-
-void BluetoothReadFunction::Work() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
-
-  if (!socket_.get())
-    return;
-
-  scoped_refptr<net::GrowableIOBuffer> buffer(new net::GrowableIOBuffer);
-  success_ = socket_->Receive(buffer.get());
-  if (success_)
-    SetResult(base::BinaryValue::CreateWithCopiedBuffer(buffer->StartOfBuffer(),
-                                                        buffer->offset()));
-  else
-    SetError(socket_->GetLastErrorMessage());
-}
-
-bool BluetoothReadFunction::Respond() {
-  return success_;
-}
-
-BluetoothWriteFunction::BluetoothWriteFunction()
-    : success_(false),
-      data_to_write_(NULL) {
-}
-
-BluetoothWriteFunction::~BluetoothWriteFunction() {}
-
-bool BluetoothWriteFunction::Prepare() {
-  // TODO(bryeung): update to new-style parameter passing when ArrayBuffer
-  // support is added
-  base::DictionaryValue* options;
-  EXTENSION_FUNCTION_VALIDATE(args_->GetDictionary(0, &options));
-
-  base::DictionaryValue* socket;
-  EXTENSION_FUNCTION_VALIDATE(options->GetDictionary("socket", &socket));
-
-  int socket_id;
-  EXTENSION_FUNCTION_VALIDATE(socket->GetInteger("id", &socket_id));
-
-  socket_ = GetEventRouter(browser_context())->GetSocket(socket_id);
-  if (socket_.get() == NULL) {
-    SetError(kSocketNotFoundError);
-    return false;
-  }
-
-  base::BinaryValue* tmp_data;
-  EXTENSION_FUNCTION_VALIDATE(options->GetBinary("data", &tmp_data));
-  data_to_write_ = tmp_data;
-
-  success_ = false;
-  return socket_.get() != NULL;
-}
-
-void BluetoothWriteFunction::Work() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
-
-  if (socket_.get() == NULL)
-    return;
-
-  scoped_refptr<net::WrappedIOBuffer> wrapped_io_buffer(
-      new net::WrappedIOBuffer(data_to_write_->GetBuffer()));
+void BluetoothConnectFunction::OnSuccessCallback() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  SendResponse(true);
+}
+
+void BluetoothConnectFunction::OnErrorCallback(const std::string& error) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  SetError(error);
+  SendResponse(false);
+}
+
+BluetoothDisconnectFunction::BluetoothDisconnectFunction() {}
+
+BluetoothDisconnectFunction::~BluetoothDisconnectFunction() {}
+
+bool BluetoothDisconnectFunction::Prepare() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  params_ = Disconnect::Params::Create(*args_);
+  EXTENSION_FUNCTION_VALIDATE(params_.get() != NULL);
+  return true;
+}
+
+void BluetoothDisconnectFunction::AsyncWorkStart() {
+  DCHECK(BrowserThread::CurrentlyOn(work_thread_id()));
+  BluetoothApiSocket* socket =
+      socket_data_->Get(extension_id(), params_->options.socket_id);
+  if (!socket) {
+    error_ = kSocketNotFoundError;
+    return;
+  }
+  socket->Disconnect(base::Bind(&BluetoothDisconnectFunction::OnSuccess, this));
+}
+
+void BluetoothDisconnectFunction::OnSuccess() {
+  DCHECK(BrowserThread::CurrentlyOn(work_thread_id()));
+  socket_data_->Remove(extension_id(), params_->options.socket_id);
+  results_ = bluetooth::Disconnect::Results::Create();
+  AsyncWorkCompleted();
+}
+
+BluetoothSendFunction::BluetoothSendFunction() : io_buffer_size_(0) {}
+
+BluetoothSendFunction::~BluetoothSendFunction() {}
+
+bool BluetoothSendFunction::Prepare() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  params_ = Send::Params::Create(*args_);
+  EXTENSION_FUNCTION_VALIDATE(params_.get() != NULL);
+  io_buffer_size_ = params_->options.data.size();
+  io_buffer_ = new net::WrappedIOBuffer(params_->options.data.data());
+  return true;
+}
+
+void BluetoothSendFunction::AsyncWorkStart() {
+  DCHECK(BrowserThread::CurrentlyOn(work_thread_id()));
+  BluetoothApiSocket* socket =
+      socket_data_->Get(extension_id(), params_->options.socket_id);
+  if (!socket) {
+    error_ = kSocketNotFoundError;
+    return;
+  }
   scoped_refptr<net::DrainableIOBuffer> drainable_io_buffer(
-      new net::DrainableIOBuffer(wrapped_io_buffer.get(),
-                                 data_to_write_->GetSize()));
-  success_ = socket_->Send(drainable_io_buffer.get());
-  if (success_) {
-    if (drainable_io_buffer->BytesConsumed() > 0)
-      SetResult(new base::FundamentalValue(
-          drainable_io_buffer->BytesConsumed()));
-    else
-      results_.reset();
-  } else {
-    SetError(socket_->GetLastErrorMessage());
-  }
-}
-
-bool BluetoothWriteFunction::Respond() {
-  return success_;
+      new net::DrainableIOBuffer(io_buffer_.get(), io_buffer_size_));
+  socket->Send(drainable_io_buffer,
+               base::Bind(&BluetoothSendFunction::OnSendSuccess, this),
+               base::Bind(&BluetoothSendFunction::OnSendError, this));
+}
+
+void BluetoothSendFunction::OnSendSuccess(int bytes_sent) {
+  DCHECK(BrowserThread::CurrentlyOn(work_thread_id()));
+  results_ = Send::Results::Create(bytes_sent);
+  AsyncWorkCompleted();
+}
+
+void BluetoothSendFunction::OnSendError(const std::string& message) {
+  DCHECK(BrowserThread::CurrentlyOn(work_thread_id()));
+  error_ = message;
+  AsyncWorkCompleted();
+}
+
+BluetoothUpdateSocketFunction::BluetoothUpdateSocketFunction() {}
+
+BluetoothUpdateSocketFunction::~BluetoothUpdateSocketFunction() {}
+
+bool BluetoothUpdateSocketFunction::Prepare() {
+  params_ = bluetooth::UpdateSocket::Params::Create(*args_);
+  EXTENSION_FUNCTION_VALIDATE(params_.get());
+  return true;
+}
+
+void BluetoothUpdateSocketFunction::Work() {
+  BluetoothApiSocket* socket =
+      socket_data_->Get(extension_id(), params_->socket_id);
+  if (!socket) {
+    error_ = kSocketNotFoundError;
+    return;
+  }
+
+  SetSocketProperties(socket, &params_.get()->properties);
+  results_ = bluetooth::UpdateSocket::Results::Create();
+}
+
+BluetoothSetSocketPausedFunction::BluetoothSetSocketPausedFunction() {}
+
+BluetoothSetSocketPausedFunction::~BluetoothSetSocketPausedFunction() {}
+
+bool BluetoothSetSocketPausedFunction::Prepare() {
+  params_ = bluetooth::SetSocketPaused::Params::Create(*args_);
+  EXTENSION_FUNCTION_VALIDATE(params_.get());
+  return true;
+}
+
+void BluetoothSetSocketPausedFunction::Work() {
+  BluetoothApiSocket* socket =
+      socket_data_->Get(extension_id(), params_->socket_id);
+  if (!socket) {
+    error_ = kSocketNotFoundError;
+    return;
+  }
+
+  if (socket->paused() != params_->paused) {
+    socket->set_paused(params_->paused);
+    if (!params_->paused) {
+      socket_event_dispatcher_->OnSocketResume(extension_->id(),
+                                               params_->socket_id);
+    }
+  }
+
+  results_ = bluetooth::SetSocketPaused::Results::Create();
+}
+
+BluetoothGetSocketFunction::BluetoothGetSocketFunction() {}
+
+BluetoothGetSocketFunction::~BluetoothGetSocketFunction() {}
+
+bool BluetoothGetSocketFunction::Prepare() {
+  params_ = bluetooth::GetSocket::Params::Create(*args_);
+  EXTENSION_FUNCTION_VALIDATE(params_.get());
+  return true;
+}
+
+void BluetoothGetSocketFunction::Work() {
+  BluetoothApiSocket* socket =
+      socket_data_->Get(extension_id(), params_->socket_id);
+  if (!socket) {
+    error_ = kSocketNotFoundError;
+    return;
+  }
+
+  linked_ptr<bluetooth::Socket> socket_info =
+      CreateSocketInfo(params_->socket_id, socket);
+  results_ = bluetooth::GetSocket::Results::Create(*socket_info);
+}
+
+BluetoothGetSocketsFunction::BluetoothGetSocketsFunction() {}
+
+BluetoothGetSocketsFunction::~BluetoothGetSocketsFunction() {}
+
+bool BluetoothGetSocketsFunction::Prepare() { return true; }
+
+void BluetoothGetSocketsFunction::Work() {
+  std::vector<linked_ptr<bluetooth::Socket> > socket_infos;
+  base::hash_set<int>* resource_ids =
+      socket_data_->GetResourceIds(extension_id());
+  if (resource_ids != NULL) {
+    for (base::hash_set<int>::iterator it = resource_ids->begin();
+         it != resource_ids->end();
+         ++it) {
+      int socket_id = *it;
+      BluetoothApiSocket* socket = socket_data_->Get(extension_id(), socket_id);
+      if (socket) {
+        socket_infos.push_back(CreateSocketInfo(socket_id, socket));
+      }
+    }
+  }
+  results_ = bluetooth::GetSockets::Results::Create(socket_infos);
 }
 
 void BluetoothSetOutOfBandPairingDataFunction::OnSuccessCallback() {
   SendResponse(true);
 }
 
-void BluetoothSetOutOfBandPairingDataFunction::OnErrorCallback() {
-  SetError(kCouldNotSetOutOfBandPairingData);
+void BluetoothSetOutOfBandPairingDataFunction::OnErrorCallback(
+    const std::string& error) {
+  SetError(error);
   SendResponse(false);
 }
 
 bool BluetoothSetOutOfBandPairingDataFunction::DoWork(
     scoped_refptr<BluetoothAdapter> adapter) {
   // TODO(bryeung): update to new-style parameter passing when ArrayBuffer
   // support is added
   base::DictionaryValue* options;
   EXTENSION_FUNCTION_VALIDATE(args_->GetDictionary(0, &options));
   std::string address;
@@ skipping 115 matching lines @@
       adapter,
       extension_id(),
       base::Bind(&BluetoothStopDiscoveryFunction::OnSuccessCallback, this),
       base::Bind(&BluetoothStopDiscoveryFunction::OnErrorCallback, this));
 
   return true;
 }
 
 }  // namespace api
 }  // namespace extensions