Push API: Validate storage before returning cached subscriptions

components/gcm_driver/gcm_client_impl.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 "components/gcm_driver/gcm_client_impl.h"
 
 #include <stddef.h>
 
 #include <memory>
 #include <utility>
@@ skipping 860 matching lines @@
 
     // For GCM registration, we also match the sender IDs since multiple
     // registrations are not supported.
     const GCMRegistrationInfo* gcm_registration_info =
         GCMRegistrationInfo::FromRegistrationInfo(registration_info.get());
     if (gcm_registration_info) {
       const GCMRegistrationInfo* cached_gcm_registration_info =
           GCMRegistrationInfo::FromRegistrationInfo(
               registrations_iter->first.get());
       DCHECK(cached_gcm_registration_info);
-      if (cached_gcm_registration_info &&
-          gcm_registration_info->sender_ids !=
-              cached_gcm_registration_info->sender_ids) {
+      if (gcm_registration_info->sender_ids !=
+          cached_gcm_registration_info->sender_ids) {
         matched = false;
       }
     }
 
     if (matched) {
       delegate_->OnRegisterFinished(
           registration_info, registrations_iter->second, SUCCESS);
       return;
     }
   }
@@ skipping 98 matching lines @@
 
   delegate_->OnRegisterFinished(
       registration_info,
       result == SUCCESS ? registration_id : std::string(),
       result);
 
   if (iter != pending_registration_requests_.end())
     pending_registration_requests_.erase(iter);
 }
 
+bool GCMClientImpl::ValidateRegistration(
+    const linked_ptr<RegistrationInfo>& registration_info,
+    const std::string& registration_id) {
+  DCHECK_EQ(state_, READY);
+
+  // Must have a cached registration.
+  RegistrationInfoMap::const_iterator registrations_iter =
+      registrations_.find(registration_info);
+  if (registrations_iter == registrations_.end())
+    return false;
+
+  // Cached registration ID must match.
+  const std::string& cached_registration_id = registrations_iter->second;
+  if (registration_id != cached_registration_id)
+    return false;
+
+  // For GCM registration, we also match the sender IDs since multiple
+  // registrations are not supported.
+  const GCMRegistrationInfo* gcm_registration_info =
+      GCMRegistrationInfo::FromRegistrationInfo(registration_info.get());
+  if (gcm_registration_info) {
+    const GCMRegistrationInfo* cached_gcm_registration_info =
+        GCMRegistrationInfo::FromRegistrationInfo(
+            registrations_iter->first.get());
+    DCHECK(cached_gcm_registration_info);
+    if (gcm_registration_info->sender_ids !=
+        cached_gcm_registration_info->sender_ids) {
+      return false;
+    }
+  }
+
+  return true;
+}
+
 void GCMClientImpl::Unregister(
     const linked_ptr<RegistrationInfo>& registration_info) {
   DCHECK_EQ(state_, READY);
 
   std::unique_ptr<UnregistrationRequest::CustomRequestHandler> request_handler;
   std::string source_to_record;
 
   const GCMRegistrationInfo* gcm_registration_info =
       GCMRegistrationInfo::FromRegistrationInfo(registration_info.get());
   if (gcm_registration_info) {
@@ skipping 457 matching lines @@
 bool GCMClientImpl::HasStandaloneRegisteredApp() const {
   if (registrations_.empty())
     return false;
   // Note that account mapper is not counted as a standalone app since it is
   // automatically started when other app uses GCM.
   return registrations_.size() > 1 ||
          !ExistsGCMRegistrationInMap(registrations_, kGCMAccountMapperAppId);
 }
 
 }  // namespace gcm