Refactor IT2Me-specific functions into a HostObserver subclass.

remoting/host/chromoting_host_unittest.cc

 // Copyright (c) 2011 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 "base/bind.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop_proxy.h"
 #include "base/task.h"
 #include "remoting/host/capturer_fake.h"
 #include "remoting/host/chromoting_host.h"
 #include "remoting/host/chromoting_host_context.h"
 #include "remoting/host/host_mock_objects.h"
 #include "remoting/host/in_memory_host_config.h"
+#include "remoting/host/it2me_observer.h"
 #include "remoting/proto/video.pb.h"
 #include "remoting/protocol/protocol_mock_objects.h"
 #include "remoting/protocol/session_config.h"
 #include "testing/gmock_mutant.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using ::remoting::protocol::MockClientStub;
 using ::remoting::protocol::MockConnectionToClient;
 using ::remoting::protocol::MockConnectionToClientEventHandler;
@@ skipping 59 matching lines @@
     EXPECT_CALL(context_, encode_message_loop())
         .Times(AnyNumber());
     EXPECT_CALL(context_, network_message_loop())
         .Times(AnyNumber());
     EXPECT_CALL(context_, ui_message_loop())
         .Times(AnyNumber());
 
     Capturer* capturer = new CapturerFake();
     event_executor_ = new MockEventExecutor();
     curtain_ = new MockCurtain();
-    disconnect_window_ = new MockDisconnectWindow();
-    continue_window_ = new MockContinueWindow();
-    local_input_monitor_ = new MockLocalInputMonitor();
     desktop_environment_.reset(
-        new DesktopEnvironment(&context_, capturer, event_executor_, curtain_,
-                               disconnect_window_, continue_window_,
-                               local_input_monitor_));
+        new DesktopEnvironment(&context_, capturer, event_executor_, curtain_));
     MockAccessVerifier* access_verifier = new MockAccessVerifier();
 
     host_ = ChromotingHost::Create(&context_, config_,
                                    desktop_environment_.get(),
                                    access_verifier, false);
+
+    disconnect_window_ = new MockDisconnectWindow();
+    continue_window_ = new MockContinueWindow();
+    local_input_monitor_ = new MockLocalInputMonitor();
+    it2me_observer_.reset(new It2MeObserver(host_, &context_));
+    it2me_observer_->InitFrom(disconnect_window_, continue_window_,
+                              local_input_monitor_);
+    host_->AddStatusObserver(it2me_observer_.get());
+
     session_ = new MockSession();
     session2_ = new MockSession();
     session_config_ = SessionConfig::GetDefault();
     session_jid_ = "user@domain/rest-of-jid";
     session_config2_ = SessionConfig::GetDefault();
     session2_jid_ = "user2@domain/rest-of-jid";
     EXPECT_CALL(*session_, jid())
         .WillRepeatedly(ReturnRef(session_jid_));
     EXPECT_CALL(*session2_, jid())
         .WillRepeatedly(ReturnRef(session2_jid_));
@@ skipping 95 matching lines @@
     message_loop_.PostTask(
         FROM_HERE, base::Bind(&ChromotingHost::Shutdown, host_,
                               base::Bind(&PostQuitTask, &message_loop_)));
   }
 
  protected:
   MessageLoop message_loop_;
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy_;
   MockConnectionToClientEventHandler handler_;
   scoped_ptr<DesktopEnvironment> desktop_environment_;
+  scoped_ptr<It2MeObserver> it2me_observer_;
   scoped_refptr<ChromotingHost> host_;
   scoped_refptr<InMemoryHostConfig> config_;
   MockChromotingHostContext context_;
   MockConnectionToClient* connection_;
   scoped_ptr<MockConnectionToClient> owned_connection_;
   ClientSession* client_;
   std::string session_jid_;
   MockSession* session_;  // Owned by |connection_|.
   SessionConfig session_config_;
   MockVideoStub video_stub_;
@@ skipping 268 matching lines @@
         .Times(1)
         .InSequence(s2);
   }
   SimulateClientConnection(0, true);
   message_loop_.Run();
   host_->set_it2me(false);
   EXPECT_THAT(curtain_activated, false);
 }
 
 }  // namespace remoting