Use ChannelMojo for remote security key channels.

remoting/host/security_key/fake_security_key_ipc_server.cc

 // Copyright 2016 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 "remoting/host/security_key/fake_security_key_ipc_server.h"
 
 #include <cstdint>
 #include <memory>
 #include <string>
 
 #include "base/callback.h"
 #include "base/macros.h"
 #include "base/memory/ptr_util.h"
 #include "ipc/ipc_channel.h"
 #include "ipc/ipc_message.h"
 #include "ipc/ipc_message_macros.h"
+#include "mojo/edk/embedder/embedder.h"
+#include "mojo/edk/embedder/named_platform_handle.h"
+#include "mojo/edk/embedder/named_platform_handle_utils.h"
 #include "remoting/host/chromoting_messages.h"
 #include "remoting/host/security_key/security_key_auth_handler.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace remoting {
 
 FakeSecurityKeyIpcServer::FakeSecurityKeyIpcServer(
     int connection_id,
     ClientSessionDetails* client_session_details,
     base::TimeDelta initial_connect_timeout,
     const SecurityKeyAuthHandler::SendMessageCallback& send_message_callback,
+    const base::Closure& connect_callback,
     const base::Closure& channel_closed_callback)
     : connection_id_(connection_id),
       send_message_callback_(send_message_callback),
+      connect_callback_(connect_callback),
       channel_closed_callback_(channel_closed_callback),
       weak_factory_(this) {}
 
 FakeSecurityKeyIpcServer::~FakeSecurityKeyIpcServer() {}
 
 void FakeSecurityKeyIpcServer::SendRequest(const std::string& message_data) {
   send_message_callback_.Run(connection_id_, message_data);
 }
 
 void FakeSecurityKeyIpcServer::CloseChannel() {
@@ skipping 10 matching lines @@
   IPC_BEGIN_MESSAGE_MAP(FakeSecurityKeyIpcServer, message)
     IPC_MESSAGE_HANDLER(ChromotingRemoteSecurityKeyToNetworkMsg_Request,
                         SendRequest)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
 
   EXPECT_TRUE(handled);
   return handled;
 }
 
-void FakeSecurityKeyIpcServer::OnChannelConnected(int32_t peer_pid) {}
+void FakeSecurityKeyIpcServer::OnChannelConnected(int32_t peer_pid) {
+  connect_callback_.Run();
+}
 
-void FakeSecurityKeyIpcServer::OnChannelError() {}
-
-bool FakeSecurityKeyIpcServer::CreateChannel(const std::string& channel_name,
-                                             base::TimeDelta request_timeout) {
-  channel_name_ = channel_name;
-
-  ipc_channel_ =
-      IPC::Channel::CreateNamedServer(IPC::ChannelHandle(channel_name_), this);
+bool FakeSecurityKeyIpcServer::CreateChannel(
+    const mojo::edk::NamedPlatformHandle& channel_handle,
+    base::TimeDelta request_timeout) {
+  mojo::edk::CreateServerHandleOptions options;
+#if defined(OS_WIN)
+  options.enforce_uniqueness = false;
+#endif
+  ipc_channel_ = IPC::Channel::CreateServer(
+      mojo::edk::ConnectToPeerProcess(
+          mojo::edk::CreateServerHandle(channel_handle, options))
+          .release(),
+      this);
   EXPECT_NE(nullptr, ipc_channel_);
   return ipc_channel_->Connect();
 }
 
 bool FakeSecurityKeyIpcServer::SendResponse(const std::string& message_data) {
   last_message_received_ = message_data;
 
   // This class works in two modes: one in which the test wants the IPC channel
   // to be created and used for notification and the second mode where the test
   // wants to notified of a response via a callback.  If a callback is set then
@@ skipping 13 matching lines @@
 
 FakeSecurityKeyIpcServerFactory::~FakeSecurityKeyIpcServerFactory() {
   SecurityKeyIpcServer::SetFactoryForTest(nullptr);
 }
 
 std::unique_ptr<SecurityKeyIpcServer> FakeSecurityKeyIpcServerFactory::Create(
     int connection_id,
     ClientSessionDetails* client_session_details,
     base::TimeDelta initial_connect_timeout,
     const SecurityKeyAuthHandler::SendMessageCallback& send_message_callback,
+    const base::Closure& connect_callback,
     const base::Closure& done_callback) {
   std::unique_ptr<FakeSecurityKeyIpcServer> fake_ipc_server(
-      new FakeSecurityKeyIpcServer(connection_id, client_session_details,
-                                   initial_connect_timeout,
-                                   send_message_callback, done_callback));
+      new FakeSecurityKeyIpcServer(
+          connection_id, client_session_details, initial_connect_timeout,
+          send_message_callback, connect_callback, done_callback));
 
   ipc_server_map_[connection_id] = fake_ipc_server->AsWeakPtr();
 
   return base::WrapUnique(fake_ipc_server.release());
 }
 
 base::WeakPtr<FakeSecurityKeyIpcServer>
 FakeSecurityKeyIpcServerFactory::GetIpcServerObject(int connection_id) {
   return ipc_server_map_[connection_id];
 }
 
 }  // namespace remoting