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 |