| 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/scoped_cros_settings_test_helper.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 17 matching lines...) Expand all Loading... |
| 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 { |
| 48 public: | 47 public: |
| 49 StatusUploaderTest() | 48 StatusUploaderTest() : task_runner_(new base::TestSimpleTaskRunner()) { |
| 50 : task_runner_(new base::TestSimpleTaskRunner()), | |
| 51 device_settings_provider_(nullptr) { | |
| 52 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); | 49 DeviceStatusCollector::RegisterPrefs(prefs_.registry()); |
| 53 } | 50 } |
| 54 | 51 |
| 55 void SetUp() override { | 52 void SetUp() override { |
| 56 client_.SetDMToken("dm_token"); | 53 client_.SetDMToken("dm_token"); |
| 57 collector_.reset(new MockDeviceStatusCollector(&prefs_)); | 54 collector_.reset(new MockDeviceStatusCollector(&prefs_)); |
| 58 | 55 settings_helper_.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 } | 56 } |
| 70 | 57 |
| 71 void TearDown() override { | 58 void TearDown() override { |
| 72 content::RunAllBlockingPoolTasksUntilIdle(); | 59 content::RunAllBlockingPoolTasksUntilIdle(); |
| 73 // Restore the real DeviceSettingsProvider. | |
| 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 } | 60 } |
| 79 | 61 |
| 80 // Given a pending task to upload status, mocks out a server response. | 62 // Given a pending task to upload status, mocks out a server response. |
| 81 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, | 63 void RunPendingUploadTaskAndCheckNext(const StatusUploader& uploader, |
| 82 base::TimeDelta expected_delay) { | 64 base::TimeDelta expected_delay) { |
| 83 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); | 65 EXPECT_FALSE(task_runner_->GetPendingTasks().empty()); |
| 84 CloudPolicyClient::StatusCallback callback; | 66 CloudPolicyClient::StatusCallback callback; |
| 85 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) | 67 EXPECT_CALL(client_, UploadDeviceStatus(_, _, _)) |
| 86 .WillOnce(SaveArg<2>(&callback)); | 68 .WillOnce(SaveArg<2>(&callback)); |
| 87 task_runner_->RunPendingTasks(); | 69 task_runner_->RunPendingTasks(); |
| (...skipping 19 matching lines...) Expand all Loading... |
| 107 // |expected_delay| and |now| + |expected_delay|. | 89 // |expected_delay| and |now| + |expected_delay|. |
| 108 base::Time now = base::Time::NowFromSystemTime(); | 90 base::Time now = base::Time::NowFromSystemTime(); |
| 109 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); | 91 base::Time next_task = now + task_runner_->NextPendingTaskDelay(); |
| 110 | 92 |
| 111 EXPECT_LE(next_task, now + expected_delay); | 93 EXPECT_LE(next_task, now + expected_delay); |
| 112 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); | 94 EXPECT_GE(next_task, uploader.last_upload() + expected_delay); |
| 113 } | 95 } |
| 114 | 96 |
| 115 base::MessageLoop loop_; | 97 base::MessageLoop loop_; |
| 116 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; | 98 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; |
| 117 chromeos::ScopedTestDeviceSettingsService test_device_settings_service_; | 99 chromeos::ScopedCrosSettingsTestHelper settings_helper_; |
| 118 chromeos::ScopedTestCrosSettings test_cros_settings_; | |
| 119 scoped_ptr<MockDeviceStatusCollector> collector_; | 100 scoped_ptr<MockDeviceStatusCollector> collector_; |
| 120 chromeos::CrosSettingsProvider* device_settings_provider_; | |
| 121 chromeos::StubCrosSettingsProvider stub_settings_provider_; | |
| 122 MockCloudPolicyClient client_; | 101 MockCloudPolicyClient client_; |
| 123 MockDeviceManagementService device_management_service_; | 102 MockDeviceManagementService device_management_service_; |
| 124 TestingPrefServiceSimple prefs_; | 103 TestingPrefServiceSimple prefs_; |
| 125 }; | 104 }; |
| 126 | 105 |
| 127 TEST_F(StatusUploaderTest, BasicTest) { | 106 TEST_F(StatusUploaderTest, BasicTest) { |
| 128 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); | 107 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); |
| 129 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 108 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 130 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); | 109 EXPECT_EQ(1U, task_runner_->GetPendingTasks().size()); |
| 131 // On startup, first update should happen immediately. | 110 // On startup, first update should happen immediately. |
| 132 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); | 111 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); |
| 133 } | 112 } |
| 134 | 113 |
| 135 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { | 114 TEST_F(StatusUploaderTest, DifferentFrequencyAtStart) { |
| 136 // Keep a pointer to the mock collector because collector_ gets cleared | 115 // Keep a pointer to the mock collector because collector_ gets cleared |
| 137 // when it is passed to the StatusUploader constructor below. | 116 // when it is passed to the StatusUploader constructor below. |
| 138 MockDeviceStatusCollector* const mock_collector = collector_.get(); | 117 MockDeviceStatusCollector* const mock_collector = collector_.get(); |
| 139 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; | 118 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; |
| 140 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, | 119 settings_helper_.SetInteger(chromeos::kReportUploadFrequency, new_delay); |
| 141 new_delay); | |
| 142 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( | 120 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( |
| 143 new_delay); | 121 new_delay); |
| 144 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); | 122 EXPECT_TRUE(task_runner_->GetPendingTasks().empty()); |
| 145 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 123 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 146 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); | 124 ASSERT_EQ(1U, task_runner_->GetPendingTasks().size()); |
| 147 // On startup, first update should happen immediately. | 125 // On startup, first update should happen immediately. |
| 148 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); | 126 EXPECT_EQ(base::TimeDelta(), task_runner_->NextPendingTaskDelay()); |
| 149 | 127 |
| 150 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); | 128 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); |
| 151 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( | 129 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 | 173 // Keep a pointer to the mock collector because collector_ gets cleared |
| 196 // when it is passed to the StatusUploader constructor below. | 174 // when it is passed to the StatusUploader constructor below. |
| 197 MockDeviceStatusCollector* const mock_collector = collector_.get(); | 175 MockDeviceStatusCollector* const mock_collector = collector_.get(); |
| 198 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); | 176 StatusUploader uploader(&client_, collector_.Pass(), task_runner_); |
| 199 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); | 177 EXPECT_CALL(*mock_collector, GetDeviceStatus(_)).WillRepeatedly(Return(true)); |
| 200 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( | 178 EXPECT_CALL(*mock_collector, GetDeviceSessionStatus(_)).WillRepeatedly( |
| 201 Return(true)); | 179 Return(true)); |
| 202 // Change the frequency. The new frequency should be reflected in the timing | 180 // Change the frequency. The new frequency should be reflected in the timing |
| 203 // used for the next callback. | 181 // used for the next callback. |
| 204 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; | 182 const int new_delay = StatusUploader::kDefaultUploadDelayMs * 2; |
| 205 chromeos::CrosSettings::Get()->SetInteger(chromeos::kReportUploadFrequency, | 183 settings_helper_.SetInteger(chromeos::kReportUploadFrequency, new_delay); |
| 206 new_delay); | |
| 207 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( | 184 const base::TimeDelta expected_delay = base::TimeDelta::FromMilliseconds( |
| 208 new_delay); | 185 new_delay); |
| 209 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); | 186 RunPendingUploadTaskAndCheckNext(uploader, expected_delay); |
| 210 } | 187 } |
| 211 | 188 |
| 212 } // namespace policy | 189 } // namespace policy |
| OLD | NEW |