[GCM] Adding basic G-services handling

google_apis/gcm/gcm_client_impl.cc

 // Copyright 2013 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 "google_apis/gcm/gcm_client_impl.h"
 
 #include "base/bind.h"
 #include "base/files/file_path.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/metrics/histogram.h"
 #include "base/sequenced_task_runner.h"
+#include "base/strings/string_number_conversions.h"
 #include "base/time/default_clock.h"
 #include "google_apis/gcm/base/mcs_message.h"
 #include "google_apis/gcm/base/mcs_util.h"
 #include "google_apis/gcm/engine/checkin_request.h"
 #include "google_apis/gcm/engine/connection_factory_impl.h"
 #include "google_apis/gcm/engine/gcm_store_impl.h"
 #include "google_apis/gcm/engine/mcs_client.h"
 #include "google_apis/gcm/protocol/mcs.pb.h"
 #include "net/http/http_network_session.h"
 #include "net/url_request/url_request_context.h"
@@ skipping 43 matching lines @@
   SEND_ERROR,        // Error sending a message.
 };
 
 // MCS endpoints. SSL Key pinning is done automatically due to the *.google.com
 // pinning rule.
 // Note: modifying the endpoints will affect the ability to compare the
 // GCM.CurrentEnpoint histogram across versions.
 const char kMCSEndpointMain[] = "https://mtalk.google.com:5228";
 const char kMCSEndpointFallback[] = "https://mtalk.google.com:443";
 
+const char kCheckinIntervalKey[] = "checkin_interval";
 const int kMaxRegistrationRetries = 5;
 const char kMessageTypeDataMessage[] = "gcm";
 const char kMessageTypeDeletedMessagesKey[] = "deleted_messages";
 const char kMessageTypeKey[] = "message_type";
 const char kMessageTypeSendErrorKey[] = "send_error";
 const char kSendErrorMessageIdKey[] = "google.message_id";
 const char kSendMessageFromValue[] = "gcm@chrome.com";
 const int64 kDefaultUserSerialNumber = 0LL;
 
 GCMClient::Result ToGCMClientResult(MCSClient::MessageSendStatus status) {
@@ skipping 118 matching lines @@
 
   if (!result->success) {
     ResetState();
     return;
   }
 
   registrations_ = result->registrations;
 
   device_checkin_info_.android_id = result->device_android_id;
   device_checkin_info_.secret = result->device_security_token;
+  g_services_settings_ = result->g_services_settings;
   InitializeMCSClient(result.Pass());
   if (!device_checkin_info_.IsValid()) {
     device_checkin_info_.Reset();
     state_ = INITIAL_DEVICE_CHECKIN;
     StartCheckin(device_checkin_info_);
     return;
+  } else {

[fgorski, 2014/03/28 14:30:51]

remove

[fgorski, 2014/03/29 01:09:32]

Done.

   }
 
   OnReady();
 }
 
 void GCMClientImpl::InitializeMCSClient(
     scoped_ptr<GCMStore::LoadResult> result) {
   std::vector<GURL> endpoints;
   endpoints.push_back(GURL(kMCSEndpointMain));
   endpoints.push_back(GURL(kMCSEndpointFallback));
@@ skipping 56 matching lines @@
                                     weak_ptr_factory_.GetWeakPtr()),
                          kDefaultBackoffPolicy,
                          chrome_build_proto_,
                          checkin_info.android_id,
                          checkin_info.secret,
                          account_ids_,
                          url_request_context_getter_));
   checkin_request_->Start();
 }
 
-void GCMClientImpl::OnCheckinCompleted(uint64 android_id,
-                                       uint64 security_token) {
+void GCMClientImpl::ScheduleNextCheckin(

[fgorski, 2014/03/28 14:30:51]

Consider renaming to SchedulePeriodicCheckin

[fgorski, 2014/03/29 01:09:32]

Done.

+    const base::Time& last_checkin_time,
+    const CheckinInfo& checkin_info) {
+  GServicesSettingsMap::const_iterator iter =
+      g_services_settings_.find(kCheckinIntervalKey);
+  // If we don't have the setting or string parsing fails, 0 is a reasonable

[fgorski, 2014/03/28 14:30:51]

consider 2 days as should be the current default for the service.

[fgorski, 2014/03/29 01:09:32]

Done.

+  // value.
+  int64 checkin_interval_sec = 0LL;
+  if (iter != g_services_settings_.end())
+    base::StringToInt64(iter->second, &checkin_interval_sec);
+  base::TimeDelta checkin_interval =
+      base::TimeDelta::FromSeconds(checkin_interval_sec);
+  base::TimeDelta time_to_next_checkin =
+      last_checkin_time + checkin_interval - base::Time::Now();
+  base::MessageLoop::current()->PostDelayedTask(
+      FROM_HERE,
+      base::Bind(&GCMClientImpl::StartCheckin,
+                 weak_ptr_factory_.GetWeakPtr(),
+                 checkin_info),
+      time_to_next_checkin);
+}
+
+void GCMClientImpl::OnCheckinCompleted(
+    const checkin_proto::AndroidCheckinResponse& checkin_response) {
   checkin_request_.reset();
 
-  CheckinInfo checkin_info;
-  checkin_info.android_id = android_id;
-  checkin_info.secret = security_token;
-
-  if (!checkin_info.IsValid()) {
+  if (!checkin_response.has_android_id() ||
+      !checkin_response.has_security_token()) {
     // TODO(fgorski): I don't think a retry here will help, we should probalby
     // start over. By checking in with (0, 0).
     return;
   }
 
+  CheckinInfo checkin_info;
+  checkin_info.android_id = checkin_response.android_id();
+  checkin_info.secret = checkin_response.security_token();
+
+  // Process the gservices to get the checkin_interval here.
+  UpdateGServicesSettings(checkin_response);
+
   if (state_ == INITIAL_DEVICE_CHECKIN) {
     OnFirstTimeDeviceCheckinCompleted(checkin_info);
   } else {
     DCHECK_EQ(READY, state_);
     if (device_checkin_info_.android_id != checkin_info.android_id ||
         device_checkin_info_.secret != checkin_info.secret) {
       ResetState();
-    } else {
-      // TODO(fgorski): Reset the checkin timer.
     }
   }
+
+  if (device_checkin_info_.IsValid())
+    ScheduleNextCheckin(base::Time::Now(), device_checkin_info_);
 }
 
 void GCMClientImpl::SetDeviceCredentialsCallback(bool success) {
   // TODO(fgorski): This is one of the signals that store needs a rebuild.
   DCHECK(success);
 }
 
 void GCMClientImpl::UpdateRegistrationCallback(bool success) {
   // TODO(fgorski): This is one of the signals that store needs a rebuild.
   DCHECK(success);
@@ skipping 325 matching lines @@
       send_error_details.additional_data.find(kSendErrorMessageIdKey);
   if (iter != send_error_details.additional_data.end()) {
     send_error_details.message_id = iter->second;
     send_error_details.additional_data.erase(iter);
   }
 
   delegate_->OnMessageSendError(data_message_stanza.category(),
                                 send_error_details);
 }
 
+void GCMClientImpl::UpdateGServicesSettings(
+    const checkin_proto::AndroidCheckinResponse& checkin_response) {
+  std::vector<std::string> settings_to_remove;
+  std::map<std::string, std::string> settings_to_add;
+
+  // Check if we are only dealing with a diff of settings or full update.
+  if (checkin_response.has_settings_diff() &&
+      !checkin_response.settings_diff()) {
+    for (GServicesSettingsMap::const_iterator it = g_services_settings_.begin();
+         it != g_services_settings_.end(); ++it) {
+      settings_to_remove.push_back(it->first);
+    }
+    g_services_settings_.clear();
+  }
+
+  for (int i = 0; i < checkin_response.setting_size(); ++i) {
+    std::string name = checkin_response.setting(i).name();

[fgorski, 2014/03/28 14:30:51]

add a comment explaining what the if statement does.

[fgorski, 2014/03/29 01:09:32]

Done.

+    if (name.find("delete_") == 0) {

[fgorski, 2014/03/28 14:30:51]

use const 

[fgorski, 2014/03/29 01:09:32]

Done.

+      name = name.substr(7);

[fgorski, 2014/03/28 14:30:51]

use arraysize with the const above.

[fgorski, 2014/03/29 01:09:32]

Done.

+      GServicesSettingsMap::iterator iter = g_services_settings_.find(name);
+      if (iter != g_services_settings_.end()) {
+        settings_to_remove.push_back(name);
+        g_services_settings_.erase(iter);
+      }
+    } else {
+      std::string value = checkin_response.setting(i).value();
+      g_services_settings_[name] = value;
+      settings_to_add[name] = value;
+    }
+  }
+
+  gcm_store_->UpdateGServicesSettings(

[fgorski, 2014/03/28 14:30:51]

Pass the current time based on the clock_

clock_->Now().ToInternalValue()

[fgorski, 2014/03/29 01:09:32]

Done.

+      settings_to_remove,
+      settings_to_add,
+      base::Bind(&GCMClientImpl::UpdateGServicesSettingsCallback,
+                 weak_ptr_factory_.GetWeakPtr()));
+}
+
+void GCMClientImpl::UpdateGServicesSettingsCallback(bool success) {
+  DCHECK(success);
+}
+
 }  // namespace gcm