WIP for integration between Chrome and Google Web History.

chrome/browser/history/web_history_service.h

+// 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.
+
+#ifndef CHROME_BROWSER_HISTORY_WEB_HISTORY_SERVICE_H_
+#define CHROME_BROWSER_HISTORY_WEB_HISTORY_SERVICE_H_
+#pragma once
+
+#include <map>
+#include <set>
+#include <string>
+#include <vector>
+
+#include "base/file_path.h"
+#include "base/memory/scoped_vector.h"
+#include "base/memory/weak_ptr.h"
+#include "base/string16.h"
+#include "base/timer.h"
+#include "chrome/browser/cancelable_request.h"
+#include "chrome/browser/history/history_types.h"
+#include "chrome/browser/profiles/profile_keyed_service.h"
+#include "chrome/common/net/gaia/oauth2_access_token_consumer.h"
+#include "content/public/browser/notification_observer.h"
+#include "content/public/browser/notification_registrar.h"
+#include "content/public/common/url_fetcher_delegate.h"
+#include "googleurl/src/gurl.h"
+
+class OAuth2AccessTokenFetcher;
+class Profile;
+
+namespace base {
+class DictionaryValue;
+}
+
+namespace history {
+
+class WebHistoryService : public ProfileKeyedService,
+                          public content::URLFetcherDelegate,
+                          public content::NotificationObserver,
+                          public OAuth2AccessTokenConsumer {
+ public:
+  // Returns the WebHistoryService for |profile|, creating a new one if needed.
+  static WebHistoryService* GetForProfile(Profile* profile);
+
+  explicit WebHistoryService(Profile* profile);
+  virtual ~WebHistoryService();
+
+  typedef base::Callback<void()> QueryWebHistoryCallback;
+
+  // content::URLFetcherDelegate method.
+  virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE;
+
+  // content::NotificationObserver method.
+  virtual void Observe(int type,
+                       const content::NotificationSource& source,
+                       const content::NotificationDetails& details) OVERRIDE;
+
+  // OAuth2AccessTokenConsumer methods.
+  virtual void OnGetTokenSuccess(const std::string& access_token) OVERRIDE;
+  virtual void OnGetTokenFailure(const GoogleServiceAuthError& error) OVERRIDE;
+
+  void QueryHistory(const string16& text_query,
+                    const QueryOptions& options,
+                    CancelableRequestConsumerBase* consumer,
+                    const QueryWebHistoryCallback& callback);
+
+ private:
+  // Send the OAuth2AccessTokenFetcher request.
+  void RefreshAccessToken();
+  void GetHistory();
+
+  Profile* profile_;
+
+  // Used to recieve TokenService notifications for GaiaOAuth2LoginRefreshToken.
+  content::NotificationRegistrar registrar_;
+
+  std::string access_token_;
+
+  scoped_ptr<content::URLFetcher> url_fetcher_;
+
+  QueryWebHistoryCallback query_history_callback_;
+
+  // The pending OAuth access token request and a timer for retrying on failure.
+  scoped_ptr<OAuth2AccessTokenFetcher> access_token_fetcher_;
+  base::OneShotTimer<WebHistoryService> auth_retry_timer_;
+
+  DISALLOW_COPY_AND_ASSIGN(WebHistoryService);
+};
+
+}  // namespace history
+
+#endif  // CHROME_BROWSER_HISTORY_WEB_HISTORY_SERVICE_H_