OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "chrome/browser/chromeos/settings/device_settings_service.h" | 5 #include "chrome/browser/chromeos/settings/device_settings_service.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
106 return public_key_; | 106 return public_key_; |
107 } | 107 } |
108 | 108 |
109 void DeviceSettingsService::Load() { | 109 void DeviceSettingsService::Load() { |
110 EnqueueLoad(false); | 110 EnqueueLoad(false); |
111 } | 111 } |
112 | 112 |
113 void DeviceSettingsService::SignAndStore( | 113 void DeviceSettingsService::SignAndStore( |
114 scoped_ptr<em::ChromeDeviceSettingsProto> new_settings, | 114 scoped_ptr<em::ChromeDeviceSettingsProto> new_settings, |
115 const base::Closure& callback) { | 115 const base::Closure& callback) { |
116 scoped_ptr<em::PolicyData> new_policy = AssemblePolicy(*new_settings); | 116 if (!delegate_) |
117 if (!new_policy) { | 117 HandleError(STORE_KEY_UNAVAILABLE, callback); |
118 HandleError(STORE_POLICY_ERROR, callback); | 118 else |
119 return; | 119 delegate_->SignAndStoreAsync(new_settings.Pass(), callback); |
120 } | |
121 | |
122 EnqueueSignAndStore(new_policy.Pass(), callback); | |
123 } | 120 } |
124 | 121 |
125 void DeviceSettingsService::SetManagementSettings( | 122 void DeviceSettingsService::SetManagementSettings( |
126 em::PolicyData::ManagementMode management_mode, | 123 em::PolicyData::ManagementMode management_mode, |
127 const std::string& request_token, | 124 const std::string& request_token, |
128 const std::string& device_id, | 125 const std::string& device_id, |
129 const base::Closure& callback) { | 126 const base::Closure& callback) { |
130 if (!CheckManagementModeTransition(management_mode)) { | 127 if (!delegate_) { |
131 LOG(ERROR) << "Invalid management mode transition: current mode = " | 128 HandleError(STORE_KEY_UNAVAILABLE, callback); |
132 << GetManagementMode() << ", new mode = " << management_mode; | 129 } else { |
133 HandleError(STORE_POLICY_ERROR, callback); | 130 delegate_->SetManagementSettingsAsync( |
134 return; | 131 management_mode, request_token, device_id, callback); |
135 } | 132 } |
136 | |
137 scoped_ptr<em::PolicyData> policy = AssemblePolicy(*device_settings_); | |
138 if (!policy) { | |
139 HandleError(STORE_POLICY_ERROR, callback); | |
140 return; | |
141 } | |
142 | |
143 policy->set_management_mode(management_mode); | |
144 policy->set_request_token(request_token); | |
145 policy->set_device_id(device_id); | |
146 | |
147 EnqueueSignAndStore(policy.Pass(), callback); | |
148 } | 133 } |
149 | 134 |
150 void DeviceSettingsService::Store(scoped_ptr<em::PolicyFetchResponse> policy, | 135 void DeviceSettingsService::Store(scoped_ptr<em::PolicyFetchResponse> policy, |
151 const base::Closure& callback) { | 136 const base::Closure& callback) { |
152 Enqueue( | 137 Enqueue( |
153 new StoreSettingsOperation( | 138 new StoreSettingsOperation( |
154 base::Bind(&DeviceSettingsService::HandleCompletedOperation, | 139 base::Bind(&DeviceSettingsService::HandleCompletedOperation, |
155 weak_factory_.GetWeakPtr(), | 140 weak_factory_.GetWeakPtr(), |
156 callback), | 141 callback), |
157 policy.Pass())); | 142 policy.Pass())); |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
237 new LoadSettingsOperation( | 222 new LoadSettingsOperation( |
238 base::Bind(&DeviceSettingsService::HandleCompletedOperation, | 223 base::Bind(&DeviceSettingsService::HandleCompletedOperation, |
239 weak_factory_.GetWeakPtr(), | 224 weak_factory_.GetWeakPtr(), |
240 base::Closure())); | 225 base::Closure())); |
241 operation->set_force_key_load(force_key_load); | 226 operation->set_force_key_load(force_key_load); |
242 operation->set_username(username_); | 227 operation->set_username(username_); |
243 operation->set_delegate(delegate_); | 228 operation->set_delegate(delegate_); |
244 Enqueue(operation); | 229 Enqueue(operation); |
245 } | 230 } |
246 | 231 |
247 void DeviceSettingsService::EnqueueSignAndStore( | |
248 scoped_ptr<em::PolicyData> policy, | |
249 const base::Closure& callback) { | |
250 SignAndStoreSettingsOperation* operation = new SignAndStoreSettingsOperation( | |
251 base::Bind(&DeviceSettingsService::HandleCompletedOperation, | |
252 weak_factory_.GetWeakPtr(), | |
253 callback), | |
254 policy.Pass()); | |
255 operation->set_delegate(delegate_); | |
256 Enqueue(operation); | |
257 } | |
258 | |
259 void DeviceSettingsService::EnsureReload(bool force_key_load) { | 232 void DeviceSettingsService::EnsureReload(bool force_key_load) { |
260 if (!pending_operations_.empty()) { | 233 if (!pending_operations_.empty()) { |
261 pending_operations_.front()->set_username(username_); | 234 pending_operations_.front()->set_username(username_); |
262 pending_operations_.front()->set_delegate(delegate_); | 235 pending_operations_.front()->set_delegate(delegate_); |
263 pending_operations_.front()->RestartLoad(force_key_load); | 236 pending_operations_.front()->RestartLoad(force_key_load); |
264 } else { | 237 } else { |
265 EnqueueLoad(force_key_load); | 238 EnqueueLoad(force_key_load); |
266 } | 239 } |
267 } | 240 } |
268 | 241 |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
358 LOG(ERROR) << "Session manager operation failed: " << status; | 331 LOG(ERROR) << "Session manager operation failed: " << status; |
359 | 332 |
360 FOR_EACH_OBSERVER(Observer, observers_, DeviceSettingsUpdated()); | 333 FOR_EACH_OBSERVER(Observer, observers_, DeviceSettingsUpdated()); |
361 | 334 |
362 // The completion callback happens after the notification so clients can | 335 // The completion callback happens after the notification so clients can |
363 // filter self-triggered updates. | 336 // filter self-triggered updates. |
364 if (!callback.is_null()) | 337 if (!callback.is_null()) |
365 callback.Run(); | 338 callback.Run(); |
366 } | 339 } |
367 | 340 |
368 scoped_ptr<em::PolicyData> DeviceSettingsService::AssemblePolicy( | 341 void DeviceSettingsService::OnSignAndStoreOperationCompleted(Status status) { |
369 const em::ChromeDeviceSettingsProto& settings) const { | 342 store_status_ = status; |
370 scoped_ptr<em::PolicyData> policy(new em::PolicyData()); | 343 FOR_EACH_OBSERVER(Observer, observers_, DeviceSettingsUpdated()); |
371 if (policy_data_) { | |
372 // Preserve management settings. | |
373 if (policy_data_->has_management_mode()) | |
374 policy->set_management_mode(policy_data_->management_mode()); | |
375 if (policy_data_->has_request_token()) | |
376 policy->set_request_token(policy_data_->request_token()); | |
377 if (policy_data_->has_device_id()) | |
378 policy->set_device_id(policy_data_->device_id()); | |
379 } else { | |
380 // If there's no previous policy data, this is the first time the device | |
381 // setting is set. We set the management mode to NOT_MANAGED initially. | |
382 policy->set_management_mode(em::PolicyData::NOT_MANAGED); | |
383 } | |
384 policy->set_policy_type(policy::dm_protocol::kChromeDevicePolicyType); | |
385 policy->set_timestamp((base::Time::Now() - base::Time::UnixEpoch()). | |
386 InMilliseconds()); | |
387 policy->set_username(username_); | |
388 if (!settings.SerializeToString(policy->mutable_policy_value())) | |
389 return scoped_ptr<em::PolicyData>(); | |
390 | |
391 return policy.Pass(); | |
392 } | |
393 | |
394 em::PolicyData::ManagementMode DeviceSettingsService::GetManagementMode() | |
395 const { | |
396 if (policy_data_ && policy_data_->has_management_mode()) | |
397 return policy_data_->management_mode(); | |
398 return em::PolicyData::NOT_MANAGED; | |
399 } | |
400 | |
401 bool DeviceSettingsService::CheckManagementModeTransition( | |
402 em::PolicyData::ManagementMode new_mode) const { | |
403 em::PolicyData::ManagementMode current_mode = GetManagementMode(); | |
404 | |
405 // Mode is not changed. | |
406 if (current_mode == new_mode) | |
407 return true; | |
408 | |
409 switch (current_mode) { | |
410 case em::PolicyData::NOT_MANAGED: | |
411 // For consumer management enrollment. | |
412 return new_mode == em::PolicyData::CONSUMER_MANAGED; | |
413 | |
414 case em::PolicyData::ENTERPRISE_MANAGED: | |
415 // Management mode cannot be set when it is currently ENTERPRISE_MANAGED. | |
416 return false; | |
417 | |
418 case em::PolicyData::CONSUMER_MANAGED: | |
419 // For consumer management unenrollment. | |
420 return new_mode == em::PolicyData::NOT_MANAGED; | |
421 } | |
422 | |
423 NOTREACHED(); | |
424 return false; | |
425 } | 344 } |
426 | 345 |
427 ScopedTestDeviceSettingsService::ScopedTestDeviceSettingsService() { | 346 ScopedTestDeviceSettingsService::ScopedTestDeviceSettingsService() { |
428 DeviceSettingsService::Initialize(); | 347 DeviceSettingsService::Initialize(); |
429 } | 348 } |
430 | 349 |
431 ScopedTestDeviceSettingsService::~ScopedTestDeviceSettingsService() { | 350 ScopedTestDeviceSettingsService::~ScopedTestDeviceSettingsService() { |
432 // Clean pending operations. | 351 // Clean pending operations. |
433 DeviceSettingsService::Get()->UnsetSessionManager(); | 352 DeviceSettingsService::Get()->UnsetSessionManager(); |
434 DeviceSettingsService::Shutdown(); | 353 DeviceSettingsService::Shutdown(); |
435 } | 354 } |
436 | 355 |
437 } // namespace chromeos | 356 } // namespace chromeos |
OLD | NEW |