| 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 "components/policy/core/common/cloud/cloud_policy_service.h" | 5 #include "components/policy/core/common/cloud/cloud_policy_service.h" |
| 6 | 6 |
| 7 #include "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "policy/proto/device_management_backend.pb.h" | 8 #include "policy/proto/device_management_backend.pb.h" |
| 9 | 9 |
| 10 namespace em = enterprise_management; | 10 namespace em = enterprise_management; |
| 11 | 11 |
| 12 namespace policy { | 12 namespace policy { |
| 13 | 13 |
| 14 CloudPolicyService::CloudPolicyService(const PolicyNamespaceKey& policy_ns_key, | 14 CloudPolicyService::CloudPolicyService(const std::string& policy_type, |
| 15 const std::string& settings_entity_id, |
| 15 CloudPolicyClient* client, | 16 CloudPolicyClient* client, |
| 16 CloudPolicyStore* store) | 17 CloudPolicyStore* store) |
| 17 : policy_ns_key_(policy_ns_key), | 18 : policy_type_(policy_type), |
| 19 settings_entity_id_(settings_entity_id), |
| 18 client_(client), | 20 client_(client), |
| 19 store_(store), | 21 store_(store), |
| 20 refresh_state_(REFRESH_NONE), | 22 refresh_state_(REFRESH_NONE), |
| 21 initialization_complete_(false) { | 23 initialization_complete_(false) { |
| 22 client_->AddNamespaceToFetch(policy_ns_key_); | 24 client_->AddPolicyTypeToFetch(policy_type_, settings_entity_id_); |
| 23 client_->AddObserver(this); | 25 client_->AddObserver(this); |
| 24 store_->AddObserver(this); | 26 store_->AddObserver(this); |
| 25 | 27 |
| 26 // Make sure we initialize |client_| from the policy data that might be | 28 // Make sure we initialize |client_| from the policy data that might be |
| 27 // already present in |store_|. | 29 // already present in |store_|. |
| 28 OnStoreLoaded(store_); | 30 OnStoreLoaded(store_); |
| 29 } | 31 } |
| 30 | 32 |
| 31 CloudPolicyService::~CloudPolicyService() { | 33 CloudPolicyService::~CloudPolicyService() { |
| 32 client_->RemoveNamespaceToFetch(policy_ns_key_); | 34 client_->RemovePolicyTypeToFetch(policy_type_, settings_entity_id_); |
| 33 client_->RemoveObserver(this); | 35 client_->RemoveObserver(this); |
| 34 store_->RemoveObserver(this); | 36 store_->RemoveObserver(this); |
| 35 } | 37 } |
| 36 | 38 |
| 37 std::string CloudPolicyService::ManagedBy() const { | 39 std::string CloudPolicyService::ManagedBy() const { |
| 38 const em::PolicyData* policy = store_->policy(); | 40 const em::PolicyData* policy = store_->policy(); |
| 39 if (policy) { | 41 if (policy) { |
| 40 std::string username = policy->username(); | 42 std::string username = policy->username(); |
| 41 std::size_t pos = username.find('@'); | 43 std::size_t pos = username.find('@'); |
| 42 if (pos != std::string::npos) | 44 if (pos != std::string::npos) |
| (...skipping 14 matching lines...) Expand all Loading... |
| 57 refresh_state_ = REFRESH_POLICY_FETCH; | 59 refresh_state_ = REFRESH_POLICY_FETCH; |
| 58 client_->FetchPolicy(); | 60 client_->FetchPolicy(); |
| 59 } | 61 } |
| 60 | 62 |
| 61 void CloudPolicyService::OnPolicyFetched(CloudPolicyClient* client) { | 63 void CloudPolicyService::OnPolicyFetched(CloudPolicyClient* client) { |
| 62 if (client_->status() != DM_STATUS_SUCCESS) { | 64 if (client_->status() != DM_STATUS_SUCCESS) { |
| 63 RefreshCompleted(false); | 65 RefreshCompleted(false); |
| 64 return; | 66 return; |
| 65 } | 67 } |
| 66 | 68 |
| 67 const em::PolicyFetchResponse* policy = client_->GetPolicyFor(policy_ns_key_); | 69 const em::PolicyFetchResponse* policy = |
| 70 client_->GetPolicyFor(policy_type_, settings_entity_id_); |
| 68 if (policy) { | 71 if (policy) { |
| 69 if (refresh_state_ != REFRESH_NONE) | 72 if (refresh_state_ != REFRESH_NONE) |
| 70 refresh_state_ = REFRESH_POLICY_STORE; | 73 refresh_state_ = REFRESH_POLICY_STORE; |
| 71 store_->Store(*policy, client->fetched_invalidation_version()); | 74 store_->Store(*policy, client->fetched_invalidation_version()); |
| 72 } else { | 75 } else { |
| 73 RefreshCompleted(false); | 76 RefreshCompleted(false); |
| 74 } | 77 } |
| 75 } | 78 } |
| 76 | 79 |
| 77 void CloudPolicyService::OnRegistrationStateChanged(CloudPolicyClient* client) { | 80 void CloudPolicyService::OnRegistrationStateChanged(CloudPolicyClient* client) { |
| (...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 151 | 154 |
| 152 void CloudPolicyService::AddObserver(Observer* observer) { | 155 void CloudPolicyService::AddObserver(Observer* observer) { |
| 153 observers_.AddObserver(observer); | 156 observers_.AddObserver(observer); |
| 154 } | 157 } |
| 155 | 158 |
| 156 void CloudPolicyService::RemoveObserver(Observer* observer) { | 159 void CloudPolicyService::RemoveObserver(Observer* observer) { |
| 157 observers_.RemoveObserver(observer); | 160 observers_.RemoveObserver(observer); |
| 158 } | 161 } |
| 159 | 162 |
| 160 } // namespace policy | 163 } // namespace policy |
| OLD | NEW |