[GCM] Add app handler support for connection events

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 "base/bind.h"
 #include "base/files/file_path.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 232 matching lines @@
       new ConnectionFactoryImpl(endpoints,
                                 backoff_policy,
                                 network_session,
                                 net_log,
                                 recorder));
 }
 
 GCMClientImpl::GCMClientImpl(scoped_ptr<GCMInternalsBuilder> internals_builder)
     : internals_builder_(internals_builder.Pass()),
       state_(UNINITIALIZED),
+      delegate_(NULL),
       clock_(internals_builder_->BuildClock()),
       url_request_context_getter_(NULL),
       pending_registration_requests_deleter_(&pending_registration_requests_),
       pending_unregistration_requests_deleter_(
           &pending_unregistration_requests_),
       periodic_checkin_ptr_factory_(this),
       weak_ptr_factory_(this) {
 }
 
 GCMClientImpl::~GCMClientImpl() {
@@ skipping 236 matching lines @@
 
 void GCMClientImpl::UpdateRegistrationCallback(bool success) {
   // TODO(fgorski): This is one of the signals that store needs a rebuild.
   DCHECK(success);
 }
 
 void GCMClientImpl::Stop() {
   weak_ptr_factory_.InvalidateWeakPtrs();
   device_checkin_info_.Reset();
   connection_factory_.reset();
+  delegate_->OnDisconnected();
   mcs_client_.reset();
   checkin_request_.reset();
   pending_registration_requests_.clear();
   state_ = INITIALIZED;
   gcm_store_->Close();
 }
 
 void GCMClientImpl::CheckOut() {
   Stop();
   gcm_store_->Destroy(base::Bind(&GCMClientImpl::OnGCMStoreDestroyed,
@@ skipping 210 matching lines @@
   }
   return stats;
 }
 
 void GCMClientImpl::OnActivityRecorded() {
   delegate_->OnActivityRecorded();
 }
 
 void GCMClientImpl::OnConnected(const GURL& current_server,
                                 const net::IPEndPoint& ip_endpoint) {
-  // TODO(zea): inform GCMClient::Delegate and app handlers as well.
+  // TODO(gcm): expose current server in debug page.
   delegate_->OnActivityRecorded();
+  delegate_->OnConnected(ip_endpoint);
 }
 
 void GCMClientImpl::OnDisconnected() {
-  // TODO(zea): inform GCMClient::Delegate and app handlers as well.
   delegate_->OnActivityRecorded();
+  delegate_->OnDisconnected();
 }
 
 void GCMClientImpl::OnMessageReceivedFromMCS(const gcm::MCSMessage& message) {
   switch (message.tag()) {
     case kLoginResponseTag:
       DVLOG(1) << "Login response received by GCM Client. Ignoring.";
       return;
     case kDataMessageStanzaTag:
       DVLOG(1) << "A downstream message received. Processing...";
       HandleIncomingMessage(message);
@@ skipping 126 matching lines @@
 
   recorder_.RecordIncomingSendError(
       data_message_stanza.category(),
       data_message_stanza.to(),
       data_message_stanza.id());
   delegate_->OnMessageSendError(data_message_stanza.category(),
                                 send_error_details);
 }
 
 }  // namespace gcm