Move sockets APIs out of src/chrome

extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.cc

 // Copyright 2013 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/sockets_tcp_server/sockets_tcp_server_api.h"
+#include "extensions/browser/api/sockets_tcp_server/sockets_tcp_server_api.h"
 
-#include "chrome/browser/extensions/api/socket/tcp_socket.h"
-#include "chrome/browser/extensions/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.h"
 #include "chrome/common/extensions/api/sockets/sockets_manifest_data.h"
 #include "chrome/common/extensions/permissions/socket_permission.h"
 #include "content/public/common/socket_permission_request.h"
+#include "extensions/browser/api/socket/tcp_socket.h"
+#include "extensions/browser/api/sockets_tcp_server/tcp_server_socket_event_dispatcher.h"
 #include "extensions/common/permissions/permissions_data.h"
 #include "net/base/net_errors.h"
 
 using content::SocketPermissionRequest;
 using extensions::ResumableTCPServerSocket;
-using extensions::api::sockets_tcp_server::SocketInfo;
-using extensions::api::sockets_tcp_server::SocketProperties;
+using extensions::core_api::sockets_tcp_server::SocketInfo;
+using extensions::core_api::sockets_tcp_server::SocketProperties;
 
 namespace {
 
 const char kSocketNotFoundError[] = "Socket not found";
 const char kPermissionError[] = "Does not have permission";
 const int kDefaultListenBacklog = SOMAXCONN;
 
 linked_ptr<SocketInfo> CreateSocketInfo(int socket_id,
                                         ResumableTCPServerSocket* socket) {
   linked_ptr<SocketInfo> socket_info(new SocketInfo());
@@ skipping 23 matching lines @@
     socket->set_name(*properties->name.get());
   }
   if (properties->persistent.get()) {
     socket->set_persistent(*properties->persistent.get());
   }
 }
 
 }  // namespace
 
 namespace extensions {
-namespace api {
+namespace core_api {
 
 TCPServerSocketAsyncApiFunction::~TCPServerSocketAsyncApiFunction() {}
 
 scoped_ptr<SocketResourceManagerInterface>
-    TCPServerSocketAsyncApiFunction::CreateSocketResourceManager() {
+TCPServerSocketAsyncApiFunction::CreateSocketResourceManager() {
   return scoped_ptr<SocketResourceManagerInterface>(
-      new SocketResourceManager<ResumableTCPServerSocket>()).Pass();
+             new SocketResourceManager<ResumableTCPServerSocket>()).Pass();
 }
 
 ResumableTCPServerSocket* TCPServerSocketAsyncApiFunction::GetTcpSocket(
     int socket_id) {
   return static_cast<ResumableTCPServerSocket*>(GetSocket(socket_id));
 }
 
 SocketsTcpServerCreateFunction::SocketsTcpServerCreateFunction() {}
 
 SocketsTcpServerCreateFunction::~SocketsTcpServerCreateFunction() {}
@@ skipping 39 matching lines @@
   SetSocketProperties(socket, &params_.get()->properties);
   results_ = sockets_tcp_server::Update::Results::Create();
 }
 
 SocketsTcpServerSetPausedFunction::SocketsTcpServerSetPausedFunction()
     : socket_event_dispatcher_(NULL) {}
 
 SocketsTcpServerSetPausedFunction::~SocketsTcpServerSetPausedFunction() {}
 
 bool SocketsTcpServerSetPausedFunction::Prepare() {
-  params_ = api::sockets_tcp_server::SetPaused::Params::Create(*args_);
+  params_ = core_api::sockets_tcp_server::SetPaused::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
 
   socket_event_dispatcher_ =
       TCPServerSocketEventDispatcher::Get(browser_context());
-  DCHECK(socket_event_dispatcher_) << "There is no socket event dispatcher. "
-    "If this assertion is failing during a test, then it is likely that "
-    "TestExtensionSystem is failing to provide an instance of "
-    "TCPServerSocketEventDispatcher.";
+  DCHECK(socket_event_dispatcher_)
+      << "There is no socket event dispatcher. "
+         "If this assertion is failing during a test, then it is likely that "
+         "TestExtensionSystem is failing to provide an instance of "
+         "TCPServerSocketEventDispatcher.";
   return socket_event_dispatcher_ != NULL;
 }
 
 void SocketsTcpServerSetPausedFunction::Work() {
   ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   if (socket->paused() != params_->paused) {
     socket->set_paused(params_->paused);
     if (socket->IsConnected() && !params_->paused) {
       socket_event_dispatcher_->OnServerSocketResume(extension_->id(),
                                                      params_->socket_id);
     }
   }
 
   results_ = sockets_tcp_server::SetPaused::Results::Create();
 }
 
 SocketsTcpServerListenFunction::SocketsTcpServerListenFunction()
-  : socket_event_dispatcher_(NULL) {}
+    : socket_event_dispatcher_(NULL) {}
 
 SocketsTcpServerListenFunction::~SocketsTcpServerListenFunction() {}
 
 bool SocketsTcpServerListenFunction::Prepare() {
-  params_ = api::sockets_tcp_server::Listen::Params::Create(*args_);
+  params_ = core_api::sockets_tcp_server::Listen::Params::Create(*args_);
   EXTENSION_FUNCTION_VALIDATE(params_.get());
 
   socket_event_dispatcher_ =
       TCPServerSocketEventDispatcher::Get(browser_context());
-  DCHECK(socket_event_dispatcher_) << "There is no socket event dispatcher. "
-    "If this assertion is failing during a test, then it is likely that "
-    "TestExtensionSystem is failing to provide an instance of "
-    "TCPServerSocketEventDispatcher.";
+  DCHECK(socket_event_dispatcher_)
+      << "There is no socket event dispatcher. "
+         "If this assertion is failing during a test, then it is likely that "
+         "TestExtensionSystem is failing to provide an instance of "
+         "TCPServerSocketEventDispatcher.";
   return socket_event_dispatcher_ != NULL;
 }
 
 void SocketsTcpServerListenFunction::Work() {
   ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id);
   if (!socket) {
     error_ = kSocketNotFoundError;
     return;
   }
 
   SocketPermissionRequest param(
-      SocketPermissionRequest::TCP_LISTEN,
-      params_->address,
-      params_->port);
+      SocketPermissionRequest::TCP_LISTEN, params_->address, params_->port);
   if (!SocketsManifestData::CheckRequest(GetExtension(), param)) {
     error_ = kPermissionError;
     return;
   }
 
   int net_result = socket->Listen(
       params_->address,
       params_->port,
       params_->backlog.get() ? *params_->backlog.get() : kDefaultListenBacklog,
       &error_);
 
   if (net_result != net::OK)
     error_ = net::ErrorToString(net_result);
 
-
   if (net_result == net::OK) {
     socket_event_dispatcher_->OnServerSocketListen(extension_->id(),
                                                    params_->socket_id);
   }
 
   results_ = sockets_tcp_server::Listen::Results::Create(net_result);
 }
 
 SocketsTcpServerDisconnectFunction::SocketsTcpServerDisconnectFunction() {}
 
@@ skipping 56 matching lines @@
 
   linked_ptr<sockets_tcp_server::SocketInfo> socket_info =
       CreateSocketInfo(params_->socket_id, socket);
   results_ = sockets_tcp_server::GetInfo::Results::Create(*socket_info);
 }
 
 SocketsTcpServerGetSocketsFunction::SocketsTcpServerGetSocketsFunction() {}
 
 SocketsTcpServerGetSocketsFunction::~SocketsTcpServerGetSocketsFunction() {}
 
-bool SocketsTcpServerGetSocketsFunction::Prepare() {
-  return true;
-}
+bool SocketsTcpServerGetSocketsFunction::Prepare() { return true; }
 
 void SocketsTcpServerGetSocketsFunction::Work() {
   std::vector<linked_ptr<sockets_tcp_server::SocketInfo> > socket_infos;
   base::hash_set<int>* resource_ids = GetSocketIds();
   if (resource_ids != NULL) {
     for (base::hash_set<int>::iterator it = resource_ids->begin();
-             it != resource_ids->end(); ++it) {
+         it != resource_ids->end();
+         ++it) {
       int socket_id = *it;
       ResumableTCPServerSocket* socket = GetTcpSocket(socket_id);
       if (socket) {
         socket_infos.push_back(CreateSocketInfo(socket_id, socket));
       }
     }
   }
   results_ = sockets_tcp_server::GetSockets::Results::Create(socket_infos);
 }
 
-}  // namespace api
+}  // namespace core_api
 }  // namespace extensions