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" | |
bartfab (slow)
2015/03/31 14:12:40
Nit: Still used in line 120 and others.
| |
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 |