[NTP::Push] Add the classes for sending a breaking news subscription request

components/ntp_snippets/breaking_news/subscription_json_request.h

Index: components/ntp_snippets/breaking_news/subscription_json_request.h
diff --git a/components/ntp_snippets/breaking_news/subscription_json_request.h b/components/ntp_snippets/breaking_news/subscription_json_request.h
new file mode 100644
index 0000000000000000000000000000000000000000..44c39b03f1f1dc28ce09f616935742bb2070d9d6
--- /dev/null
+++ b/components/ntp_snippets/breaking_news/subscription_json_request.h
@@ -0,0 +1,98 @@
+// Copyright 2017 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_BREAKING_NEWS_SUBSCRIPTION_JSON_REQUEST_H_
+#define COMPONENTS_NTP_SNIPPETS_BREAKING_NEWS_SUBSCRIPTION_JSON_REQUEST_H_
+
+#include <memory>
+#include <string>
+#include <utility>
+
+#include "base/callback.h"
+#include "base/memory/weak_ptr.h"
+#include "base/optional.h"
+#include "base/time/time.h"
+#include "components/ntp_snippets/status.h"
+#include "components/translate/core/browser/language_model.h"
+#include "google_apis/gaia/oauth2_token_service.h"
+#include "net/http/http_request_headers.h"
+
+namespace ntp_snippets {
+
+namespace internal {
+
+// A single request to subscribe for breaking news via GCM.
+class SubscriptionJsonRequest : public net::URLFetcherDelegate {
+ public:
+  // A client can expect error_details only, if there was any error during the

[fhorschig, 2017/06/01 09:23:56]

please update the comment

[mamir, 2017/06/01 14:52:32]

Done.

+  // subscription or parsing. In successful cases, it will be an empty string.
+  using CompletedCallback =
+      base::OnceCallback<void(const ntp_snippets::Status& status)>;
+
+  // Builds authenticated and non-authenticated SubscriptionJsonRequests.

[fhorschig, 2017/06/01 09:23:56]

outdated comment?

[mamir, 2017/06/01 14:52:31]

Acknowledged.

+  class Builder {
+   public:
+    Builder();
+    Builder(Builder&&);
+    ~Builder();
+
+    // Builds a Request object that contains all data to fetch new snippets.
+    std::unique_ptr<SubscriptionJsonRequest> Build() const;
+
+    Builder& SetToken(const std::string& token);
+    Builder& SetUrl(const GURL& url);
+    Builder& SetUrlRequestContextGetter(
+        const scoped_refptr<net::URLRequestContextGetter>& context_getter);
+
+    // These preview methods allow to inspect the Request without exposing it
+    // publicly.
+    std::string PreviewRequestBodyForTesting() { return BuildBody(); }
+    std::string PreviewRequestHeadersForTesting() { return BuildHeaders(); }
+
+   private:
+    std::string BuildHeaders() const;
+    std::string BuildBody() const;
+    std::unique_ptr<net::URLFetcher> BuildURLFetcher(
+        net::URLFetcherDelegate* request,
+        const std::string& headers,
+        const std::string& body) const;
+
+    // GCM subscribtion token obtain from GCM driver (instanceID::getToken())
+    std::string token_;
+    // TODO(mamir): Additional fields to be added: country, language
+
+    GURL url_;
+    scoped_refptr<net::URLRequestContextGetter> url_request_context_getter_;
+
+    // Optional properties.
+    std::string obfuscated_gaia_id_;
+  };
+
+  ~SubscriptionJsonRequest() override;
+
+  void Start(CompletedCallback callback);
+
+ private:
+  friend class Builder;
+  SubscriptionJsonRequest();
+  // URLFetcherDelegate implementation.
+  void OnURLFetchComplete(const net::URLFetcher* source) override;
+
+  // The fetcher for subscribing. Only non-null if a subscription process is
+  // currently ongoing.

[fhorschig, 2017/06/01 09:23:56]

That comment is a lie :D
Your builder always adds a fetcher and there is no point where it is deleted.

[mamir, 2017/06/01 14:52:32]

Acknowledged.

+  std::unique_ptr<net::URLFetcher> url_fetcher_;
+
+  // The callback to notify when URLFetcher finished and results are available.
+  CompletedCallback request_completed_callback_;
+
+  base::WeakPtrFactory<SubscriptionJsonRequest> weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(SubscriptionJsonRequest);
+};
+
+}  // namespace internal
+
+}  // namespace ntp_snippets
+
+#endif  // COMPONENTS_NTP_SNIPPETS_BREAKING_NEWS_SUBSCRIPTION_JSON_REQUEST_H_