Revert 255262 "Migrate chrome.bluetooth API backend to use devic..."

trunk/src/chrome/browser/extensions/api/bluetooth/bluetooth_event_router.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_event_router.h"
 
 #include <map>
 #include <string>
 
 #include "base/bind.h"
 #include "base/json/json_writer.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_vector.h"
 #include "base/strings/utf_string_conversions.h"
 #include "chrome/browser/chrome_notification_types.h"
 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api_utils.h"
 #include "chrome/browser/extensions/event_names.h"
 #include "chrome/common/extensions/api/bluetooth.h"
 #include "content/public/browser/notification_details.h"
 #include "content/public/browser/notification_source.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_profile.h"
 #include "device/bluetooth/bluetooth_socket.h"
 #include "extensions/browser/event_router.h"
 #include "extensions/browser/extension_system.h"
 
 namespace extensions {
 
 namespace bluetooth = api::bluetooth;
 
 // A struct storing a Bluetooth socket and the extension that added it.
 struct ExtensionBluetoothSocketRecord {
   std::string extension_id;
   scoped_refptr<device::BluetoothSocket> socket;
 };
 
 // A struct storing a Bluetooth profile and the extension that added it.
 struct ExtensionBluetoothProfileRecord {
   std::string extension_id;
   device::BluetoothProfile* profile;
 };
 
 ExtensionBluetoothEventRouter::ExtensionBluetoothEventRouter(
     content::BrowserContext* context)
-    : browser_context_(context),
+    : send_discovery_events_(false),
+      responsible_for_discovery_(false),
+      browser_context_(context),
       adapter_(NULL),
       num_event_listeners_(0),
       next_socket_id_(1),
       weak_ptr_factory_(this) {
   DCHECK(browser_context_);
   registrar_.Add(this,
                  chrome::NOTIFICATION_EXTENSION_UNLOADED,
                  content::Source<content::BrowserContext>(browser_context_));
 }
 
 ExtensionBluetoothEventRouter::~ExtensionBluetoothEventRouter() {
   if (adapter_.get()) {
     adapter_->RemoveObserver(this);
     adapter_ = NULL;
   }
   DLOG_IF(WARNING, socket_map_.size() != 0)
       << "Bluetooth sockets are still open.";
   socket_map_.clear();
 
   for (BluetoothProfileMap::iterator iter = bluetooth_profile_map_.begin();
        iter != bluetooth_profile_map_.end();
        ++iter) {
     iter->second.profile->Unregister();
   }
-  for (DiscoverySessionMap::iterator iter = discovery_session_map_.begin();
-       iter != discovery_session_map_.end();
-       ++iter) {
-    delete iter->second;
-  }
 }
 
 bool ExtensionBluetoothEventRouter::IsBluetoothSupported() const {
   return adapter_.get() ||
          device::BluetoothAdapterFactory::IsBluetoothAdapterAvailable();
 }
 
 void ExtensionBluetoothEventRouter::GetAdapter(
     const device::BluetoothAdapterFactory::AdapterCallback& callback) {
   if (adapter_.get()) {
@@ skipping 53 matching lines @@
     device::BluetoothProfile* bluetooth_profile = iter->second.profile;
     bluetooth_profile_map_.erase(iter);
     bluetooth_profile->Unregister();
   }
 }
 
 bool ExtensionBluetoothEventRouter::HasProfile(const std::string& uuid) const {
   return bluetooth_profile_map_.find(uuid) != bluetooth_profile_map_.end();
 }
 
-void ExtensionBluetoothEventRouter::StartDiscoverySession(
-    device::BluetoothAdapter* adapter,
-    const std::string& extension_id,
-    const base::Closure& callback,
-    const base::Closure& error_callback) {
-  if (adapter != adapter_.get()) {
-    error_callback.Run();
-    return;
-  }
-  DiscoverySessionMap::iterator iter =
-      discovery_session_map_.find(extension_id);
-  if (iter != discovery_session_map_.end() && iter->second->IsActive()) {
-    DVLOG(1) << "An active discovery session exists for extension.";
-    error_callback.Run();
-    return;
-  }
-  adapter->StartDiscoverySession(
-      base::Bind(&ExtensionBluetoothEventRouter::OnStartDiscoverySession,
-                 weak_ptr_factory_.GetWeakPtr(),
-                 extension_id,
-                 callback),
-      error_callback);
-}
-
-void ExtensionBluetoothEventRouter::StopDiscoverySession(
-    device::BluetoothAdapter* adapter,
-    const std::string& extension_id,
-    const base::Closure& callback,
-    const base::Closure& error_callback) {
-  if (adapter != adapter_.get()) {
-    error_callback.Run();
-    return;
-  }
-  DiscoverySessionMap::iterator iter =
-      discovery_session_map_.find(extension_id);
-  if (iter == discovery_session_map_.end() || !iter->second->IsActive()) {
-    DVLOG(1) << "No active discovery session exists for extension.";
-    error_callback.Run();
-    return;
-  }
-  device::BluetoothDiscoverySession* session = iter->second;
-  session->Stop(callback, error_callback);
-}
-
 device::BluetoothProfile* ExtensionBluetoothEventRouter::GetProfile(
     const std::string& uuid) const {
   BluetoothProfileMap::const_iterator iter = bluetooth_profile_map_.find(uuid);
   if (iter != bluetooth_profile_map_.end())
     return iter->second.profile;
 
   return NULL;
 }
 
 scoped_refptr<device::BluetoothSocket>
 ExtensionBluetoothEventRouter::GetSocket(int id) {
   SocketMap::iterator socket_entry = socket_map_.find(id);
   if (socket_entry == socket_map_.end())
     return NULL;
   return socket_entry->second.socket;
 }
 
+void ExtensionBluetoothEventRouter::SetResponsibleForDiscovery(
+    bool responsible) {
+  responsible_for_discovery_ = responsible;
+}
+
+bool ExtensionBluetoothEventRouter::IsResponsibleForDiscovery() const {
+  return responsible_for_discovery_;
+}
+
+void ExtensionBluetoothEventRouter::SetSendDiscoveryEvents(bool should_send) {
+  // At the transition into sending devices, also send past devices that
+  // were discovered as they will not be discovered again.
+  if (should_send && !send_discovery_events_) {
+    for (DeviceList::const_iterator i = discovered_devices_.begin();
+        i != discovered_devices_.end(); ++i) {
+      DispatchDeviceEvent(extensions::event_names::kBluetoothOnDeviceDiscovered,
+                          **i);
+    }
+  }
+
+  send_discovery_events_ = should_send;
+}
+
 void ExtensionBluetoothEventRouter::DispatchDeviceEvent(
     const std::string& event_name, const bluetooth::Device& device) {
   scoped_ptr<base::ListValue> args(new base::ListValue());
   args->Append(device.ToValue().release());
   scoped_ptr<Event> event(new Event(event_name, args.Pass()));
   ExtensionSystem::Get(browser_context_)->event_router()->BroadcastEvent(
       event.Pass());
 }
 
 void ExtensionBluetoothEventRouter::DispatchConnectionEvent(
@@ skipping 38 matching lines @@
 }
 
 void ExtensionBluetoothEventRouter::AdapterDiscoveringChanged(
     device::BluetoothAdapter* adapter, bool discovering) {
   if (adapter != adapter_.get()) {
     DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress();
     return;
   }
 
   if (!discovering) {
-    // If any discovery sessions are inactive, clean them up.
-    DiscoverySessionMap active_session_map;
-    for (DiscoverySessionMap::iterator iter = discovery_session_map_.begin();
-         iter != discovery_session_map_.end();
-         ++iter) {
-      device::BluetoothDiscoverySession* session = iter->second;
-      if (session->IsActive()) {
-        active_session_map[iter->first] = session;
-        continue;
-      }
-      delete session;
-    }
-    discovery_session_map_.swap(active_session_map);
+    send_discovery_events_ = false;
+    responsible_for_discovery_ = false;
+    discovered_devices_.clear();
   }
 
   DispatchAdapterStateEvent();
 }
 
 void ExtensionBluetoothEventRouter::DeviceAdded(
     device::BluetoothAdapter* adapter,
     device::BluetoothDevice* device) {
   if (adapter != adapter_.get()) {
     DVLOG(1) << "Ignoring event for adapter " << adapter->GetAddress();
     return;
   }
 
   bluetooth::Device* extension_device =
       new bluetooth::Device();
   bluetooth::BluetoothDeviceToApiDevice(
       *device, extension_device);
+  discovered_devices_.push_back(extension_device);
+
+  if (!send_discovery_events_)
+    return;
 
   DispatchDeviceEvent(extensions::event_names::kBluetoothOnDeviceDiscovered,
                       *extension_device);
 }
 
 void ExtensionBluetoothEventRouter::InitializeAdapterIfNeeded() {
   if (!adapter_.get()) {
     GetAdapter(base::Bind(&ExtensionBluetoothEventRouter::InitializeAdapter,
                           weak_ptr_factory_.GetWeakPtr()));
   }
@@ skipping 44 matching lines @@
   // Remove all sockets opened by the extension.
   SocketMap::iterator socket_iter = socket_map_.begin();
   while (socket_iter != socket_map_.end()) {
     int socket_id = socket_iter->first;
     ExtensionBluetoothSocketRecord record = socket_iter->second;
     socket_iter++;
     if (record.extension_id == extension_id) {
       ReleaseSocket(socket_id);
     }
   }
-
-  // Remove any discovery session initiated by the extension.
-  DiscoverySessionMap::iterator session_iter =
-      discovery_session_map_.find(extension_id);
-  if (session_iter == discovery_session_map_.end())
-    return;
-  delete session_iter->second;
-  discovery_session_map_.erase(session_iter);
-}
-
-void ExtensionBluetoothEventRouter::OnStartDiscoverySession(
-    const std::string& extension_id,
-    const base::Closure& callback,
-    scoped_ptr<device::BluetoothDiscoverySession> discovery_session) {
-  // Clean up any existing session instance for the extension.
-  DiscoverySessionMap::iterator iter =
-      discovery_session_map_.find(extension_id);
-  if (iter != discovery_session_map_.end())
-    delete iter->second;
-  discovery_session_map_[extension_id] = discovery_session.release();
-  callback.Run();
 }
 
 void ExtensionBluetoothEventRouter::Observe(
     int type,
     const content::NotificationSource& source,
     const content::NotificationDetails& details) {
   switch (type) {
     case chrome::NOTIFICATION_EXTENSION_UNLOADED: {
       extensions::UnloadedExtensionInfo* info =
           content::Details<extensions::UnloadedExtensionInfo>(details).ptr();
       CleanUpForExtension(info->extension->id());
       break;
     }
   }
 }
 
 }  // namespace extensions