Implement chrome.bluetoothSocket.listenUsing*()

chrome/browser/extensions/api/bluetooth_socket/bluetooth_socket_event_dispatcher.h

 // 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.
 
 #ifndef CHROME_BROWSER_EXTENSIONS_API_BLUETOOTH_SOCKET_BLUETOOTH_SOCKET_EVENT_DISPATCHER_H_
 #define CHROME_BROWSER_EXTENSIONS_API_BLUETOOTH_SOCKET_BLUETOOTH_SOCKET_EVENT_DISPATCHER_H_
 
 #include "chrome/browser/extensions/api/bluetooth/bluetooth_api_socket.h"
 #include "extensions/browser/api/api_resource_manager.h"
 #include "extensions/browser/browser_context_keyed_api_factory.h"
 
 namespace content {
 class BrowserContext;
 }
 
+namespace device {
+class BluetoothDevice;
+class BluetoothSocket;
+}
+
 namespace extensions {
 struct Event;
 class BluetoothApiSocket;
 }
 
 namespace extensions {
 namespace api {
 
 // Dispatch events related to "bluetooth" sockets from callback on native socket
 // instances. There is one instance per browser context.
 class BluetoothSocketEventDispatcher
     : public BrowserContextKeyedAPI,
       public base::SupportsWeakPtr<BluetoothSocketEventDispatcher> {
  public:
   explicit BluetoothSocketEventDispatcher(content::BrowserContext* context);
   virtual ~BluetoothSocketEventDispatcher();
 
   // Socket is active, start receiving data from it.
   void OnSocketConnect(const std::string& extension_id, int socket_id);
 
+  // Socket is active again, start accepting connections from it.
+  void OnSocketListen(const std::string& extension_id, int socket_id);
+
   // Socket is active again, start receiving data from it.
   void OnSocketResume(const std::string& extension_id, int socket_id);
 
   // BrowserContextKeyedAPI implementation.
   static BrowserContextKeyedAPIFactory<BluetoothSocketEventDispatcher>*
       GetFactoryInstance();
 
   // Convenience method to get the SocketEventDispatcher for a profile.
   static BluetoothSocketEventDispatcher* Get(content::BrowserContext* context);
 
  private:
   typedef ApiResourceManager<BluetoothApiSocket>::ApiResourceData SocketData;
   friend class BrowserContextKeyedAPIFactory<BluetoothSocketEventDispatcher>;
   // BrowserContextKeyedAPI implementation.
   static const char* service_name() { return "BluetoothSocketEventDispatcher"; }
   static const bool kServiceHasOwnInstanceInIncognito = true;
   static const bool kServiceIsNULLWhileTesting = true;
 
-  // base::Bind supports methods with up to 6 parameters. ReceiveParams is used
-  // as a workaround that limitation for invoking StartReceive.
-  struct ReceiveParams {
-    ReceiveParams();
-    ~ReceiveParams();
+  // base::Bind supports methods with up to 6 parameters. SocketParams is used
+  // as a workaround that limitation for invoking StartReceive() and
+  // StartAccept().
+  struct SocketParams {
+    SocketParams();
+    ~SocketParams();
 
     content::BrowserThread::ID thread_id;
     void* browser_context_id;
     std::string extension_id;
     scoped_refptr<SocketData> sockets;
     int socket_id;
   };
 
   // Start a receive and register a callback.
-  void StartSocketReceive(const std::string& extension_id, int socket_id);
-  static void StartReceive(const ReceiveParams& params);
+  static void StartReceive(const SocketParams& params);
 
   // Called when socket receive data.
-  static void ReceiveCallback(const ReceiveParams& params,
+  static void ReceiveCallback(const SocketParams& params,
                               int bytes_read,
                               scoped_refptr<net::IOBuffer> io_buffer);
 
   // Called when socket receive data.
-  static void ReceiveErrorCallback(const ReceiveParams& params,
+  static void ReceiveErrorCallback(const SocketParams& params,
                                    BluetoothApiSocket::ErrorReason error_reason,
                                    const std::string& error);
 
+  // Start an accept and register a callback.
+  static void StartAccept(const SocketParams& params);
+
+  // Called when socket accepts a client connection.
+  static void AcceptCallback(const SocketParams& params,
+                             const device::BluetoothDevice* device,
+                             scoped_refptr<device::BluetoothSocket> socket);
+
+  // Called when socket encounters an error while accepting a client connection.
+  static void AcceptErrorCallback(const SocketParams& params,
+                                  BluetoothApiSocket::ErrorReason error_reason,
+                                  const std::string& error);
+
   // Post an extension event from IO to UI thread
-  static void PostEvent(const ReceiveParams& params, scoped_ptr<Event> event);
+  static void PostEvent(const SocketParams& params, scoped_ptr<Event> event);
 
   // Dispatch an extension event on to EventRouter instance on UI thread.
   static void DispatchEvent(void* browser_context_id,
                             const std::string& extension_id,
                             scoped_ptr<Event> event);
 
   // Usually FILE thread (except for unit testing).
   content::BrowserThread::ID thread_id_;
   content::BrowserContext* const browser_context_;
   scoped_refptr<SocketData> sockets_;
 };
 
 }  // namespace api
 }  // namespace extensions
 
 #endif  // CHROME_BROWSER_EXTENSIONS_API_BLUETOOTH_SOCKET_BLUETOOTH_SOCKET_EVENT_DISPATCHER_H_