Adding handling of MCS Endpoints to GServicesSettings

google_apis/gcm/engine/gservices_settings.cc

 // Copyright 2014 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/engine/gservices_settings.h"
 
 #include "base/bind.h"
 #include "base/strings/string_number_conversions.h"
+#include "base/strings/stringprintf.h"
 
 namespace {
 // The expected time in seconds between periodic checkins.
 const char kCheckinIntervalKey[] = "checkin_interval";
 // The override URL to the checkin server.
 const char kCheckinURLKey[] = "checkin_url";
 // The MCS machine name to connect to.
 const char kMCSHostnameKey[] = "gcm_hostname";
 // The MCS port to connect to.
 const char kMCSSecurePortKey[] = "gcm_secure_port";
 // The URL to get MCS registration IDs.
 const char kRegistrationURLKey[] = "gcm_registration_url";
 
 const int64 kDefaultCheckinInterval = 2 * 24 * 60 * 60;  // seconds = 2 days.
 const int64 kMinimumCheckinInterval = 12 * 60 * 60;      // seconds = 12 hours.
 const char kDefaultCheckinURL[] = "https://android.clients.google.com/checkin";
-const char kDefaultMCSHostname[] = "https://mtalk.google.com";
+const char kDefaultMCSHostname[] = "mtalk.google.com";
 const int kDefaultMCSSecurePort = 5228;

[jianli, 2014/05/08 18:59:37]

nit: kDefaultMCSMainSecurePort

[fgorski, 2014/05/08 19:21:03]

Done.

+const int kDefaultMCSFallbackPort = 443;

[jianli, 2014/05/08 18:59:37]

nit: better to add "Secure" into the name, like kDefaultMCSFallbackSecurePort

[fgorski, 2014/05/08 19:21:03]

Done.

 const char kDefaultRegistrationURL[] =
     "https://android.clients.google.com/c2dm/register3";
+const char kMCSEnpointTemplate[] = "https://%s:%d";
+
+std::string MakeMCSEndpoint(const std::string& mcs_hostname, int port) {
+  return base::StringPrintf(kMCSEnpointTemplate, mcs_hostname.c_str(), port);
+}
 
 }  // namespace
 
 namespace gcm {
 
 // static
 const base::TimeDelta GServicesSettings::MinimumCheckinInterval() {
   return base::TimeDelta::FromSeconds(kMinimumCheckinInterval);
 }
 
 // static
 const GURL GServicesSettings::DefaultCheckinURL() {
   return GURL(kDefaultCheckinURL);
 }
 
 GServicesSettings::GServicesSettings()
     : checkin_interval_(base::TimeDelta::FromSeconds(kDefaultCheckinInterval)),
       checkin_url_(kDefaultCheckinURL),
-      mcs_hostname_(kDefaultMCSHostname),
-      mcs_secure_port_(kDefaultMCSSecurePort),
+      mcs_main_endpoint_(MakeMCSEndpoint(kDefaultMCSHostname,
+                                         kDefaultMCSSecurePort)),
+      mcs_fallback_endpoint_(MakeMCSEndpoint(kDefaultMCSHostname,
+                                             kDefaultMCSFallbackPort)),
       registration_url_(kDefaultRegistrationURL),
       weak_ptr_factory_(this) {
 }
 
 GServicesSettings::~GServicesSettings() {}
 
 bool GServicesSettings::UpdateFromCheckinResponse(
   const checkin_proto::AndroidCheckinResponse& checkin_response) {
   if (!checkin_response.has_digest() ||
       checkin_response.digest() == digest_) {
@@ skipping 22 matching lines @@
     const GCMStore::LoadResult& load_result) {
   if (UpdateSettings(load_result.gservices_settings))
     digest_ = load_result.gservices_digest;
 }
 
 std::map<std::string, std::string> GServicesSettings::GetSettingsMap() const {
   std::map<std::string, std::string> settings;
   settings[kCheckinIntervalKey] =
       base::Int64ToString(checkin_interval_.InSeconds());
   settings[kCheckinURLKey] = checkin_url_.spec();
-  settings[kMCSHostnameKey] = mcs_hostname_;
-  settings[kMCSSecurePortKey] = base::IntToString(mcs_secure_port_);
+  settings[kMCSHostnameKey] = mcs_main_endpoint_.host();
+  settings[kMCSSecurePortKey] = mcs_main_endpoint_.port();
   settings[kRegistrationURLKey] = registration_url_.spec();
   return settings;
 }
 
 bool GServicesSettings::UpdateSettings(
     const std::map<std::string, std::string>& settings) {
   int64 new_checkin_interval = kMinimumCheckinInterval;
   std::map<std::string, std::string>::const_iterator iter =
       settings.find(kCheckinIntervalKey);
   if (iter == settings.end()) {
@@ skipping 62 matching lines @@
   }
   new_registration_url = GURL(iter->second);
   if (!new_registration_url.is_valid()) {
     LOG(ERROR) << "Invalid registration URL provided: "
                << new_registration_url.possibly_invalid_spec();
     return false;
   }
 
   // We only update the settings once all of them are correct.
   checkin_interval_ = base::TimeDelta::FromSeconds(new_checkin_interval);
-  mcs_hostname_ = new_mcs_hostname;
-  mcs_secure_port_ = new_mcs_secure_port;
+  mcs_main_endpoint_ = GURL(MakeMCSEndpoint(new_mcs_hostname,

[jianli, 2014/05/08 18:59:37]

Can you validate the URL?

[fgorski, 2014/05/08 19:21:03]

Done.

+                                            new_mcs_secure_port));
+  mcs_fallback_endpoint_ = GURL(MakeMCSEndpoint(new_mcs_hostname,
+                                                kDefaultMCSFallbackPort));
   checkin_url_ = new_checkin_url;
   registration_url_ = new_registration_url;
   return true;
 }
 
 }  // namespace gcm