| OLD | NEW |
| 1 // Copyright (c) 2015 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/prefs/testing_pref_service.h" | 5 #include "base/prefs/testing_pref_service.h" |
| 6 #include "base/test/test_simple_task_runner.h" | 6 #include "base/test/test_simple_task_runner.h" |
| 7 #include "base/time/time.h" | 7 #include "base/time/time.h" |
| 8 #include "chrome/browser/chromeos/policy/device_status_collector.h" | 8 #include "chrome/browser/chromeos/policy/device_status_collector.h" |
| 9 #include "chrome/browser/chromeos/policy/status_uploader.h" | 9 #include "chrome/browser/chromeos/policy/status_uploader.h" |
| 10 #include "chrome/browser/chromeos/settings/device_settings_service.h" | 10 #include "chrome/browser/chromeos/settings/settings_provider_test_base.h" |
| 11 #include "chrome/browser/chromeos/settings/stub_cros_settings_provider.h" | |
| 12 #include "chromeos/settings/cros_settings_names.h" | 11 #include "chromeos/settings/cros_settings_names.h" |
| 13 #include "components/policy/core/common/cloud/cloud_policy_client.h" | 12 #include "components/policy/core/common/cloud/cloud_policy_client.h" |
| 14 #include "components/policy/core/common/cloud/mock_cloud_policy_client.h" | 13 #include "components/policy/core/common/cloud/mock_cloud_policy_client.h" |
| 15 #include "components/policy/core/common/cloud/mock_device_management_service.h" | 14 #include "components/policy/core/common/cloud/mock_device_management_service.h" |
| 16 #include "content/public/test/test_utils.h" | 15 #include "content/public/test/test_utils.h" |
| 17 #include "net/url_request/url_request_context_getter.h" | 16 #include "net/url_request/url_request_context_getter.h" |
| 18 #include "testing/gmock/include/gmock/gmock.h" | 17 #include "testing/gmock/include/gmock/gmock.h" |
| 19 #include "testing/gtest/include/gtest/gtest.h" | 18 #include "testing/gtest/include/gtest/gtest.h" |
| 20 | 19 |
| 21 using ::testing::_; | 20 using ::testing::_; |
| (...skipping 15 matching lines...) Expand all Loading... |
| 37 policy::DeviceStatusCollector::VolumeInfoFetcher()) { | 36 policy::DeviceStatusCollector::VolumeInfoFetcher()) { |
| 38 } | 37 } |
| 39 | 38 |
| 40 MOCK_METHOD1(GetDeviceStatus, bool(em::DeviceStatusReportRequest*)); | 39 MOCK_METHOD1(GetDeviceStatus, bool(em::DeviceStatusReportRequest*)); |
| 41 MOCK_METHOD1(GetDeviceSessionStatus, bool(em::SessionStatusReportRequest*)); | 40 MOCK_METHOD1(GetDeviceSessionStatus, bool(em::SessionStatusReportRequest*)); |
| 42 }; | 41 }; |
| 43 | 42 |
| 44 } // namespace | 43 } // namespace |
| 45 | 44 |
| 46 namespace policy { | 45 namespace policy { |
| 47 class StatusUploaderTest : public testing::Test { | 46 class StatusUploaderTest : public testing::Test, |
| 47 public chromeos::SettingsProviderTestBase { |
| 48 public: | 48 public: |
| 49 StatusUploaderTest() | 49 StatusUploaderTest() : task_runner_(new base::TestSimpleTaskRunner()) { |
| 50 : task_runner_(new base::TestSimpleTaskRunner()), | |
| 51 device_settings_provider_(nullptr) { | |
| 52 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); | 50 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); |
| 53 } | 51 } |
| 54 | 52 |
| 55 void SetUp() override { | 53 void SetUp() override { |
| 56 client_.SetDMToken("dm_token"); | 54 client_.SetDMToken("dm_token"); |
| 57 collector_.reset(new MockDeviceStatusCollector(&prefs_)); | 55 collector_.reset(new MockDeviceStatusCollector(&prefs_)); |
| 58 | 56 ReplaceProvider(chromeos::kReportUploadFrequency); |
| 59 // Swap out the DeviceSettingsProvider with our stub settings provider | |
| 60 // so we can set values for the upload frequency. | |
| 61 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get(); | |
| 62 device_settings_provider_ = | |
| 63 cros_settings->GetProvider(chromeos::kReportDeviceVersionInfo); | |
| 64 EXPECT_TRUE(device_settings_provider_); | |
| 65 EXPECT_TRUE( | |
| 66 cros_settings->RemoveSettingsProvider(device_settings_provider_)); | |
| 67 cros_settings->AddSettingsProvider(&stub_settings_provider_); | |
| 68 | |
| 69 } | 57 } |
| 70 | 58 |
| 71 void TearDown() override { | 59 void TearDown() override { |
| 72 content::RunAllBlockingPoolTasksUntilIdle(); | 60 content::RunAllBlockingPoolTasksUntilIdle(); |
| 73 // Restore the real DeviceSettingsProvider. | 61 RestoreProvider(); |
| 74 chromeos::CrosSettings* cros_settings = chromeos::CrosSettings::Get(); | |
| 75 EXPECT_TRUE(cros_settings->RemoveSettingsProvider( | |
| 76 &stub_settings_provider_)); | |
| 77 cros_settings->AddSettingsProvider(device_settings_provider_); | |
| 78 } | 62 } |
| 79 | 63 |
| 80 // Given a pending task to upload status, mocks out a server response. | 64 // Given a pending task to upload status, mocks out a server response. |
| 81 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, | 65 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, |
| 82 base::TimeDelta expected_delay) { | 66 base::TimeDelta expected_delay) { |
| 83 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); | 67 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); |
| 84 CloudPolicyClient::StatusCallback callback; | 68 CloudPolicyClient::StatusCallback callback; |
| 85 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) | 69 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) |
| 86 .WillOnce(SaveArg<2>(&callback)); | 70 .WillOnce(SaveArg<2>(&callback)); |
| 87 task_runner_->RunPendingTasks(); | 71 task_runner_->RunPendingTasks(); |
| (...skipping 19 matching lines...) Expand all Loading... |
| 107 // |expected_delay| and |now| + |expected_delay|. | 91 // |expected_delay| and |now| + |expected_delay|. |
| 108 base::Time now = base::Time::NowFromSystemTime(); | 92 base::Time now = base::Time::NowFromSystemTime(); |
| 109 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); | 93 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); |
| 110 | 94 |
| 111 EXPECT_LE(next_task, now + expected_delay); | 95 EXPECT_LE(next_task, now + expected_delay); |
| 112 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); | 96 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); |
| 113 } | 97 } |
| 114 | 98 |
| 115 base::MessageLoop loop_; | 99 base::MessageLoop loop_; |
| 116 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; | 100 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; |
| 117 chromeos::ScopedTestDeviceSettingsService test_device_settings_service_; | |
| 118 chromeos::ScopedTestCrosSettings test_cros_settings_; | |
| 119 scoped_ptr<MockDeviceStatusCollector> collector_; | 101 scoped_ptr<MockDeviceStatusCollector> collector_; |
| 120 chromeos::CrosSettingsProvider* device_settings_provider_; | |
| 121 chromeos::StubCrosSettingsProvider stub_settings_provider_; | |
| 122 MockCloudPolicyClient client_; | 102 MockCloudPolicyClient client_; |
| 123 MockDeviceManagementService device_management_service_; | 103 MockDeviceManagementService device_management_service_; |
| 124 TestingPrefServiceSimple prefs_; | 104 TestingPrefServiceSimple prefs_; |
| 125 }; | 105 }; |
| 126 | 106 |
| 127 TEST_F(StatusUploaderTest, BasicTest) { | 107 TEST_F(StatusUploaderTest, BasicTest) { |
| 128 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); | 108 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); |
| 129 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 109 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 130 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); | 110 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); |
| 131 // On startup, first update should happen immediately. | 111 // On startup, first update should happen immediately. |
| 132 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); | 112 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); |
| 133 } | 113 } |
| 134 | 114 |
| 135 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { | 115 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { |
| 136 // Keep a pointer to the mock collector because collector_ gets cleared | 116 // Keep a pointer to the mock collector because collector_ gets cleared |
| 137 // when it is passed to the StatusUploader constructor below. | 117 // when it is passed to the StatusUploader constructor below. |
| 138 MockDeviceStatusCollector* const mock_collector = collector_.get(); | 118 MockDeviceStatusCollector* const mock_collector = collector_.get(); |
| 139 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; | 119 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; |
| 140 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, | 120 stub_settings_provider_.SetInteger(chromeos::kReportUploadFrequency, |
| 141 new_delay); | 121 new_delay); |
| 142 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( | 122 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( |
| 143 new_delay); | 123 new_delay); |
| 144 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); | 124 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); |
| 145 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 125 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 146 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); | 126 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); |
| 147 // On startup, first update should happen immediately. | 127 // On startup, first update should happen immediately. |
| 148 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); | 128 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); |
| 149 | 129 |
| 150 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); | 130 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); |
| 151 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( | 131 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 195 // Keep a pointer to the mock collector because collector_ gets cleared | 175 // Keep a pointer to the mock collector because collector_ gets cleared |
| 196 // when it is passed to the StatusUploader constructor below. | 176 // when it is passed to the StatusUploader constructor below. |
| 197 MockDeviceStatusCollector* const mock_collector = collector_.get(); | 177 MockDeviceStatusCollector* const mock_collector = collector_.get(); |
| 198 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 178 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 199 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); | 179 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); |
| 200 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( | 180 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( |
| 201 Return(true)); | 181 Return(true)); |
| 202 // Change the frequency. The new frequency should be reflected in the timing | 182 // Change the frequency. The new frequency should be reflected in the timing |
| 203 // used for the next callback. | 183 // used for the next callback. |
| 204 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; | 184 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; |
| 205 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, | 185 stub_settings_provider_.SetInteger(chromeos::kReportUploadFrequency, |
| 206 new_delay); | 186 new_delay); |
| 207 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( | 187 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( |
| 208 new_delay); | 188 new_delay); |
| 209 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); | 189 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); |
| 210 } | 190 } |
| 211 | 191 |
| 212 } // namespace policy | 192 } // namespace policy |
| OLD | NEW |