Obfuscated Gaia ID fetcher

chrome/browser/extensions/api/push_messaging/push_messaging_api.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 "chrome/browser/extensions/api/push_messaging/push_messaging_api.h"
 
 #include "base/bind.h"
 #include "base/values.h"
 #include "chrome/browser/extensions/event_names.h"
 #include "chrome/browser/extensions/event_router.h"
 #include "chrome/browser/profiles/profile.h"
+#include "chrome/browser/profiles/profile_manager.h"
+#include "chrome/browser/signin/token_service.h"
+#include "chrome/browser/signin/token_service_factory.h"
 #include "chrome/common/extensions/api/experimental_push_messaging.h"
+#include "chrome/common/net/gaia/google_service_auth_error.h"
 #include "content/public/browser/browser_thread.h"
 #include "googleurl/src/gurl.h"
+#include "obfuscated_gaia_id_fetcher.h"
 
 namespace extensions {
 
 namespace glue = extensions::api::experimental_push_messaging;
 
 PushMessagingEventRouter::PushMessagingEventRouter(Profile* profile)
     : profile_(profile) {
 }
 
 PushMessagingEventRouter::~PushMessagingEventRouter() {}
 
+// TODO: Move these methods to be on the class that eventually creates
+// the Obfuscated Gaia ID fetcher, and pass "this" from that class for
+// the delegate.
+class GaiaFetcherDelegate : public ObfuscatedGaiaIdFetcher::Delegate {
+ public:
+  GaiaFetcherDelegate() {}
+  virtual ~GaiaFetcherDelegate() {}
+  virtual void OnObfuscatedGaiaIdFetchSuccess(
+      const std::string& access_token) {
+    LOG(INFO) << "*** Obfuscated Gaia Id fetch returned success, "
+              << access_token << " ***";
+    delete this;  // TODO: temp only, remove when part of outer class
+  }
+  virtual void OnObfuscatedGaiaIdFetchFailure(
+      const GoogleServiceAuthError& error) {
+    LOG(INFO) << "*** Obfuscated Gaia Id fetch failed, error is "
+              << (int) error.state();
+    delete this; // TODO: temp only, remove when part of outer class
+  }
+
+};

[Munjal (Google), 2012/08/09 21:44:29]

This seems like temporary code?

+
+// free function to start the fetch operation
+void StartGaiaIdFetch() {
+  // TODO: I really want to use the profile passed in, not get the last one
+  Profile* profile = ProfileManager::GetLastUsedProfile();
+  // TODO: Not for checkin, just for testing, remove all this before checkin
+  LOG(INFO) << "*** PushMessagingEventRouter::Init called ***";
+  TokenService* token_service = TokenServiceFactory::GetForProfile(profile);
+  net::URLRequestContextGetter* context = profile->GetRequestContext();
+  const std::string  refreshToken = token_service->GetOAuth2LoginRefreshToken();
+  const std::string extensionId = "joginpnpfmplidoohnmocbdijkchphdm";
+  // TODO: we really want extensionId = ExtensionFunction::GetExtension()->id();
+  // but that in only available once we have a class inheriting
+  // from ExtensionFuction, which we will likely have later on
+  ObfuscatedGaiaIdFetcher::Parameters parameters(refreshToken, extensionId);
+  GaiaFetcherDelegate* delegate = new GaiaFetcherDelegate();
+  // TODO: Don't forget to manage the lifetime of the fetcher object
+  ObfuscatedGaiaIdFetcher* fetcher =
+      new ObfuscatedGaiaIdFetcher(context, delegate, parameters);
+  fetcher->Start();
+  LOG(INFO) << "*** PushMessagingEventRouter::Init exiting ***";
+}
+
 void PushMessagingEventRouter::Init() {
   // TODO(dcheng): Add hooks into InvalidationHandler when landed.
+
+  // MessageLoop::current()->PostDelayedTask(
+  //    FROM_HERE,
+  //    base::Bind(&StartGaiaIdFetch),
+  //    base::TimeDelta::FromMilliseconds(2000));
+
+
 }

[Munjal (Google), 2012/08/09 21:44:29]

Seems like all changes ot this file are done for trying out things. So not
reviewing them.

 
 void PushMessagingEventRouter::OnMessage(const std::string& extension_id,
                                          int subchannel,
                                          const std::string& payload) {
   glue::Message message;
   message.subchannel_id = subchannel;
   message.payload = payload;
 
   scoped_ptr<base::Value> parameters(glue::OnMessage::Create(message));
   profile_->GetExtensionEventRouter()->DispatchEventToExtension(
       extension_id,
       event_names::kOnPushMessage,
       *parameters.get(),
       profile_,
       GURL());
 }
 
 }  // namespace extensions