Using PolicyServiceWatcher instead of PolicyWatcherLinux/Win/Mac.

remoting/host/policy_hack/policy_watcher_unittest.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 <iostream>
+
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "base/synchronization/waitable_event.h"
 #include "remoting/host/dns_blackhole_checker.h"
 #include "remoting/host/policy_hack/fake_policy_watcher.h"
 #include "remoting/host/policy_hack/mock_policy_callback.h"
 #include "remoting/host/policy_hack/policy_watcher.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace remoting {
 namespace policy_hack {
 
 class PolicyWatcherTest : public testing::Test {
  public:
-  PolicyWatcherTest() {
-  }
+  PolicyWatcherTest() : message_loop_(base::MessageLoop::TYPE_IO) {}
 
   void SetUp() override {
     message_loop_proxy_ = base::MessageLoopProxy::current();
     policy_updated_callback_ = base::Bind(
         &MockPolicyCallback::OnPolicyUpdate,
         base::Unretained(&mock_policy_callback_));
     policy_error_callback_ = base::Bind(
         &MockPolicyCallback::OnPolicyError,
         base::Unretained(&mock_policy_callback_));
     policy_watcher_.reset(new FakePolicyWatcher(message_loop_proxy_));
@@ skipping 407 matching lines @@
   for (int i = 0; i < (kMaxTransientErrorRetries - 1); i++) {
     policy_watcher_->SignalTransientErrorForTest();
   }
   policy_watcher_->SetPolicies(&nat_true_);
   for (int i = 0; i < (kMaxTransientErrorRetries - 1); i++) {
     policy_watcher_->SignalTransientErrorForTest();
   }
   StopWatching();
 }
 
+// Unit tests cannot instantiate PolicyWatcher on ChromeOS
+// (as this requires running inside a browser process).
+#ifndef OS_CHROMEOS
+
+namespace {
+
+void OnPolicyUpdatedDumpPolicy(scoped_ptr<base::DictionaryValue> policies) {
+  if (!VLOG_IS_ON(1)) {

[Sergey Ulanov, 2015/01/13 01:17:04]

You won't need this if you use VLOG() instead of std::cout

[Łukasz Anforowicz, 2015/01/13 18:28:29]

Advantage of using VLOG_IS_ON + std::cout:
- Output fits in a terminal window (otherwise prefix added by VLOG makes it
rather ugly and difficult to read) (comparison below - (*))

Why I thought std::cout is still okay:
- std::cout won't be used at runtime unless -v=1 cmdline param is used

On second thought, the arguments above are not very compelling - it is probably
easier going forward to have logging consistent with the rest of the code + 
Please shout if you think I should still change std::cout to VLOG.

(*) Nice output via std::cout:

OnPolicyUpdated callback received the following policies:
RemoteAccessHostAllowClientPairing = boolean: True
RemoteAccessHostAllowGnubbyAuth = boolean: True
RemoteAccessHostAllowRelayedConnection = boolean: True
RemoteAccessHostDebugOverridePolicies = string: ""
RemoteAccessHostDomain = string: "google.com"
RemoteAccessHostFirewallTraversal = boolean: False
RemoteAccessHostMatchUsername = boolean: True
RemoteAccessHostRequireCurtain = boolean: True
RemoteAccessHostRequireTwoFactor = boolean: False
RemoteAccessHostTalkGadgetPrefix = string: "chromoting-host"
RemoteAccessHostTokenUrl = string: ""
RemoteAccessHostTokenValidationCertificateIssuer = string: ""
RemoteAccessHostTokenValidationUrl = string: ""
RemoteAccessHostUdpPortRange = string: "12400-12408"

Ugly output via VLOG(1):

[20460:20460:0113/093712:2416686358115:VERBOSE1:policy_watcher_unittest.cc(459)]
OnPolicyUpdated callback received the following policies:
[20460:20460:0113/093712:2416686358159:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostAllowClientPairing = boolean: True
[20460:20460:0113/093712:2416686358175:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostAllowGnubbyAuth = boolean: True
[20460:20460:0113/093712:2416686358190:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostAllowRelayedConnection = boolean: True
[20460:20460:0113/093712:2416686358210:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostDebugOverridePolicies = string: ""
[20460:20460:0113/093712:2416686358225:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostDomain = string: "google.com"
[20460:20460:0113/093712:2416686358240:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostFirewallTraversal = boolean: False
[20460:20460:0113/093712:2416686358254:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostMatchUsername = boolean: True
[20460:20460:0113/093712:2416686358273:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostRequireCurtain = boolean: True
[20460:20460:0113/093712:2416686358288:VERBOSE1:policy_watcher_unittest.cc(473)]
RemoteAccessHostRequireTwoFactor = boolean: False
[20460:20460:0113/093712:2416686358303:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostTalkGadgetPrefix = string: "chromoting-host"
[20460:20460:0113/093712:2416686358321:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostTokenUrl = string: ""
[20460:20460:0113/093712:2416686358336:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostTokenValidationCertificateIssuer = string: ""
[20460:20460:0113/093712:2416686358351:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostTokenValidationUrl = string: ""
[20460:20460:0113/093712:2416686358368:VERBOSE1:policy_watcher_unittest.cc(467)]
RemoteAccessHostUdpPortRange = string: "12400-12408"

+    return;
+  }
+
+  std::cout << "OnPolicyUpdated callback received the following policies:"

[Sergey Ulanov, 2015/01/13 01:17:04]

please use LOG() or VLOG() for logging, instead of std::cout.

[Łukasz Anforowicz, 2015/01/13 18:28:29]

Done.

+            << std::endl;
+
+  for (base::DictionaryValue::Iterator iter(*policies); !iter.IsAtEnd();
+       iter.Advance()) {
+    std::cout << iter.key() << " = ";
+    switch (iter.value().GetType()) {
+      case base::Value::Type::TYPE_STRING: {
+        std::string value;
+        CHECK(iter.value().GetAsString(&value));
+        std::cout << "string: " << '"' << value << '"';
+        break;
+      }
+      case base::Value::Type::TYPE_BOOLEAN: {
+        bool value;
+        CHECK(iter.value().GetAsBoolean(&value));
+        std::cout << "boolean: " << (value ? "True" : "False");
+        break;
+      }
+      default: {
+        std::cout << "unrecognized type";
+        break;
+      }
+    }
+    std::cout << std::endl;
+  }
+}
+
+}  // anonymous namespace
+
+// To dump policy contents, run unit tests with the following flags:
+// out/Debug/remoting_unittests --gtest_filter=*TestRealChromotingPolicy* -v=1
+TEST_F(PolicyWatcherTest, TestRealChromotingPolicy) {
+  scoped_refptr<base::SingleThreadTaskRunner> task_runner =
+      base::MessageLoop::current()->task_runner();
+  scoped_ptr<PolicyWatcher> policy_watcher(
+      PolicyWatcher::Create(nullptr, task_runner));
+
+  {
+    base::RunLoop run_loop;
+    policy_watcher->StartWatching(base::Bind(OnPolicyUpdatedDumpPolicy),
+                                  base::Bind(base::DoNothing));
+    run_loop.RunUntilIdle();
+  }
+
+  {
+    base::RunLoop run_loop;
+    PolicyWatcher* raw_policy_watcher = policy_watcher.release();
+    raw_policy_watcher->StopWatching(
+        base::Bind(base::IgnoreResult(
+                       &base::SequencedTaskRunner::DeleteSoon<PolicyWatcher>),
+                   task_runner, FROM_HERE, raw_policy_watcher));
+    run_loop.RunUntilIdle();
+  }
+
+  // Today, the only verification offered by this test is:
+  // - Manual verification of policy values dumped by OnPolicyUpdatedDumpPolicy
+  // - Automated verification that nothing crashed
+}
+
+#endif
+
+// TODO(lukasza): We should consider adding a test against a
+// MockConfigurationPolicyProvider.
+
 }  // namespace policy_hack
 }  // namespace remoting