Send GCM id to DMServer

components/policy/core/common/cloud/cloud_policy_client.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/policy/core/common/cloud/cloud_policy_client.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/guid.h"
 #include "base/logging.h"
@@ skipping 359 matching lines @@
   request->set_location(location);
 
   const DeviceManagementRequestJob::Callback job_callback =
       base::Bind(&CloudPolicyClient::OnDeviceAttributeUpdated,
       base::Unretained(this), request_job.get(), callback);
 
   request_jobs_.push_back(request_job.Pass());
   request_jobs_.back()->Start(job_callback);
 }
 
+void CloudPolicyClient::UpdateGcmId(
+    const std::string& gcm_id,
+    const CloudPolicyClient::StatusCallback& callback) {
+  CHECK(is_registered());
+
+  scoped_ptr<DeviceManagementRequestJob> request_job(service_->CreateJob(
+      DeviceManagementRequestJob::TYPE_GCM_ID_UPDATE, GetRequestContext()));
+
+  request_job->SetDMToken(dm_token_);
+  request_job->SetClientID(client_id_);
+
+  em::GcmIdUpdateRequest* const request =
+      request_job->GetRequest()->mutable_gcm_id_update_request();
+
+  request->set_gcm_id(gcm_id);
+
+  const DeviceManagementRequestJob::Callback job_callback =
+      base::Bind(&CloudPolicyClient::OnGcmIdUpdated, base::Unretained(this),
+                 request_job.get(), callback);
+
+  request_jobs_.push_back(request_job.Pass());
+  request_jobs_.back()->Start(job_callback);
+}
+
 void CloudPolicyClient::AddObserver(Observer* observer) {
   observers_.AddObserver(observer);
 }
 
 void CloudPolicyClient::RemoveObserver(Observer* observer) {
   observers_.RemoveObserver(observer);
 }
 
 void CloudPolicyClient::AddPolicyTypeToFetch(
     const std::string& policy_type,
@@ skipping 268 matching lines @@
         commands.push_back(command);
     } else {
       status = DM_STATUS_RESPONSE_DECODING_ERROR;
     }
   }
   callback.Run(status, commands);
   // Must call RemoveJob() last, because it frees |callback|.
   RemoveJob(job);
 }
 
+void CloudPolicyClient::OnGcmIdUpdated(
+    const DeviceManagementRequestJob* job,
+    const StatusCallback& callback,
+    DeviceManagementStatus status,
+    int net_error,
+    const enterprise_management::DeviceManagementResponse& response) {
+  status_ = status;
+  if (status != DM_STATUS_SUCCESS)
+    NotifyClientError();
+
+  callback.Run(status == DM_STATUS_SUCCESS);
+  RemoveJob(job);
+}
+
 void CloudPolicyClient::NotifyPolicyFetched() {
   FOR_EACH_OBSERVER(Observer, observers_, OnPolicyFetched(this));
 }
 
 void CloudPolicyClient::NotifyRegistrationStateChanged() {
   FOR_EACH_OBSERVER(Observer, observers_, OnRegistrationStateChanged(this));
 }
 
 void CloudPolicyClient::NotifyRobotAuthCodesFetched() {
   FOR_EACH_OBSERVER(Observer, observers_, OnRobotAuthCodesFetched(this));
 }
 
 void CloudPolicyClient::NotifyClientError() {
   FOR_EACH_OBSERVER(Observer, observers_, OnClientError(this));
 }
 
 }  // namespace policy