Connecting UserClassifier to NtpSnippetsFetcher

components/ntp_snippets/remote/ntp_snippets_fetcher.h

 // Copyright 2016 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 COMPONENTS_NTP_SNIPPETS_REMOTE_NTP_SNIPPETS_FETCHER_H_
 #define COMPONENTS_NTP_SNIPPETS_REMOTE_NTP_SNIPPETS_FETCHER_H_
 
 #include <memory>
 #include <set>
 #include <string>
@@ skipping 15 matching lines @@
 class PrefService;
 class SigninManagerBase;
 
 namespace base {
 class ListValue;
 class Value;
 }  // namespace base
 
 namespace ntp_snippets {
 
+class UserClassifier;
+
 // Fetches snippet data for the NTP from the server.
 class NTPSnippetsFetcher : public OAuth2TokenService::Consumer,
                            public OAuth2TokenService::Observer,
                            public net::URLFetcherDelegate {
  public:
   // Callbacks for JSON parsing, needed because the parsing is platform-
   // dependent.
   using SuccessCallback = base::Callback<void(std::unique_ptr<base::Value>)>;
   using ErrorCallback = base::Callback<void(const std::string&)>;
   using ParseJSONCallback = base::Callback<
@@ skipping 42 matching lines @@
   };
 
   NTPSnippetsFetcher(
       SigninManagerBase* signin_manager,
       OAuth2TokenService* token_service,
       scoped_refptr<net::URLRequestContextGetter> url_request_context_getter,
       PrefService* pref_service,
       CategoryFactory* category_factory,
       translate::LanguageModel* language_model,
       const ParseJSONCallback& parse_json_callback,
-      const std::string& api_key);
+      const std::string& api_key,
+      const UserClassifier* user_classifier);
   ~NTPSnippetsFetcher() override;
 
   // Set a callback that is called when a new set of snippets are downloaded,
   // overriding any previously set callback.
   void SetCallback(const SnippetsAvailableCallback& callback);
 
   // Fetches snippets from the server. |hosts| restricts the results to a set of
   // hosts, e.g. "www.google.com". If |hosts| is empty, no host restrictions are
   // applied.
   //
@@ skipping 35 matching lines @@
   }
 
   void SetPersonalizationForTesting(Personalization personalization) {
     personalization_ = personalization;
   }
 
  private:
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest, BuildRequestAuthenticated);
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest, BuildRequestUnauthenticated);
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest, BuildRequestExcludedIds);
+  FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest, BuildRequestNoUserClass);
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest,
                            BuildRequestWithTwoLanguages);
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest,
                            BuildRequestWithUILanguageOnly);
   FRIEND_TEST_ALL_PREFIXES(NTPSnippetsFetcherTest,
                            BuildRequestWithOtherLanguageOnly);
 
   enum FetchAPI {
     CHROME_READER_API,
     CHROME_CONTENT_SUGGESTIONS_API,
   };
 
   struct RequestParams {
     FetchAPI fetch_api;
     std::string obfuscated_gaia_id;
     bool only_return_personalized_results;
     std::string user_locale;
     std::set<std::string> host_restricts;
     std::set<std::string> excluded_ids;
     int count_to_fetch;
     bool interactive_request;
+    std::string user_class;
     translate::LanguageModel::LanguageInfo ui_language;
     translate::LanguageModel::LanguageInfo other_top_language;
 
     RequestParams();
     ~RequestParams();
 
     std::string BuildRequest();
   };
 
   void FetchSnippetsImpl(const GURL& url,
@@ skipping 19 matching lines @@
   void OnURLFetchComplete(const net::URLFetcher* source) override;
 
   bool JsonToSnippets(const base::Value& parsed,
                       FetchedCategoriesVector* categories);
   void OnJsonParsed(std::unique_ptr<base::Value> parsed);
   void OnJsonError(const std::string& error);
   void FetchFinished(OptionalFetchedCategories fetched_categories,
                      FetchResult result,
                      const std::string& extra_message);
 
+  bool DemandQuotaForRequest(bool interactive_request);
+
   // Authorization for signed-in users.
   SigninManagerBase* signin_manager_;
   OAuth2TokenService* token_service_;
   std::unique_ptr<OAuth2TokenService::Request> oauth_request_;
   bool waiting_for_refresh_token_;
 
   // Holds the URL request context.
   scoped_refptr<net::URLRequestContextGetter> url_request_context_getter_;
 
   // Weak references, not owned.
@@ skipping 33 matching lines @@
 
   // The variant of the fetching to use, loaded from variation parameters.
   Personalization personalization_;
 
   // Is the request user initiated?
   bool interactive_request_;
 
   // Allow for an injectable tick clock for testing.
   std::unique_ptr<base::TickClock> tick_clock_;
 
-  // Request throttler for limiting requests.
-  RequestThrottler request_throttler_;
+  // Classifier that tells us how active the user is. Not owned.
+  const UserClassifier* user_classifier_;
+
+  // Request throttlers for limiting requests for different classes of users.
+  RequestThrottler request_throttler_rare_ntp_user_;
+  RequestThrottler request_throttler_active_ntp_user_;
+  RequestThrottler request_throttler_active_suggestions_consumer_;
 
   // When a token request gets canceled, we want to retry once.
   bool oauth_token_retried_;
 
   base::WeakPtrFactory<NTPSnippetsFetcher> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(NTPSnippetsFetcher);
 };
 }  // namespace ntp_snippets
 
 #endif  // COMPONENTS_NTP_SNIPPETS_REMOTE_NTP_SNIPPETS_FETCHER_H_