Move data reduction proxy logic out of chrome and android webview network delegate

components/data_reduction_proxy/core/browser/data_reduction_proxy_network_delegate.h

Index: components/data_reduction_proxy/core/browser/data_reduction_proxy_network_delegate.h
diff --git a/components/data_reduction_proxy/core/browser/data_reduction_proxy_network_delegate.h b/components/data_reduction_proxy/core/browser/data_reduction_proxy_network_delegate.h
new file mode 100644
index 0000000000000000000000000000000000000000..ce889023a110bf9b414f481324b55f08d3442efc
--- /dev/null
+++ b/components/data_reduction_proxy/core/browser/data_reduction_proxy_network_delegate.h
@@ -0,0 +1,169 @@
+// 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.
+
+#ifndef COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_NETWORK_DELEGATE_H_
+#define COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_NETWORK_DELEGATE_H_
+
+#include "base/basictypes.h"
+#include "base/memory/ref_counted.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/values.h"
+#include "components/data_reduction_proxy/core/browser/data_reduction_proxy_metrics.h"
+#include "net/base/layered_network_delegate.h"
+#include "net/proxy/proxy_retry_info.h"
+
+template<class T> class PrefMember;
+
+typedef PrefMember<bool> BooleanPrefMember;
+
+class GURL;
+class PrefService;
+
+namespace base {
+class SingleThreadTaskRunner;
+}
+
+namespace net {
+class HttpResponseHeaders;
+class HttpRequestHeaders;
+class NetworkDelegate;
+class ProxyConfig;
+class ProxyInfo;
+class ProxyServer;
+class ProxyService;
+class URLRequest;
+}
+
+namespace data_reduction_proxy {
+
+class DataReductionProxyAuthRequestHandler;
+class DataReductionProxyParams;
+class DataReductionProxyStatisticsPrefs;
+class DataReductionProxyUsageStats;
+
+// DataReductionProxyNetworkDelegate is a LayeredNetworkDelegate that takes a
+// NetworkDelegate and adds data reduction proxy specific logic.
+class DataReductionProxyNetworkDelegate : public net::LayeredNetworkDelegate {
+ public:
+  // Provides an opportunity to interpose on proxy resolution. Called before
+  // ProxyService.ResolveProxy() returns. Two proxy configurations are provided
+  // that specify the data reduction proxy's configuration and the effective
+  // configuration according to the proxy service, respectively. Retry info is
+  // presumed to be from the proxy service.
+  typedef base::Callback<void(
+      const GURL& url,
+      int load_flags,
+      const net::ProxyConfig& data_reduction_proxy_config,
+      const net::ProxyConfig& proxy_service_proxy_config,
+      const net::ProxyRetryInfoMap& proxy_retry_info_map,
+      const DataReductionProxyParams* params,
+      net::ProxyInfo* result)> OnResolveProxyHandler;
+
+  // Provides an additional proxy configuration that can be consulted after
+  // proxy resolution.
+  typedef base::Callback<const net::ProxyConfig&()> ProxyConfigGetter;
+
+  // DataReductionProxyNetworkDelegate takes a |network_delegate| and extends
+  // it. When On*() is called, the On*Internal() method of this is first called
+  // and then the On*() of |network_delegate| is called.
+  DataReductionProxyNetworkDelegate(
+      scoped_ptr<net::NetworkDelegate> network_delegate);
+  ~DataReductionProxyNetworkDelegate() override;
+
+  // Initializes this with the given parameters. If a parameter is null, it is
+  // not assigned.
+  void Init(PrefService* profile_prefs,
+            scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner,
+            BooleanPrefMember* data_reduction_proxy_enabled,
+            DataReductionProxyParams* params,
+            DataReductionProxyUsageStats* usage_stats,
+            DataReductionProxyAuthRequestHandler* handler,
+            DataReductionProxyStatisticsPrefs* statistics_prefs,
+            const OnResolveProxyHandler& proxy_handler,
+            const ProxyConfigGetter& getter);
+
+  // Creates a Value summary of the persistent state of the network session.
+  // The caller is responsible for deleting the returned value.
+  // Must be called on the UI thread.
+  static base::Value* HistoricNetworkStatsInfoToValue(
+      PrefService* profile_prefs);
+
+  // Creates a Value summary of the state of the network session. The caller is
+  // responsible for deleting the returned value.
+  base::Value* SessionNetworkStatsInfoToValue() const;
+
+ private:
+  // Called as the proxy is being resolved for |url|. Allows the delegate to
+  // override the proxy resolution decision made by ProxyService. The delegate
+  // may override the decision by modifying the ProxyInfo |result|.
+  void OnResolveProxyInternal(const GURL& url,
+                              int load_flags,
+                              const net::ProxyService& proxy_service,
+                              net::ProxyInfo* result) override;
+
+  // Called when use of |bad_proxy| fails due to |net_error|. |net_error| is
+  // the network error encountered, if any, and OK if the fallback was
+  // for a reason other than a network error (e.g. the proxy service was
+  // explicitly directed to skip a proxy).
+  void OnProxyFallbackInternal(const net::ProxyServer& bad_proxy,
+                               int net_error) override;
+
+  // Called after a proxy connection. Allows the delegate to read/write
+  // |headers| before they get sent out. |headers| is valid only until
+  // OnCompleted or OnURLRequestDestroyed is called for this request.
+  void OnBeforeSendProxyHeadersInternal(
+      net::URLRequest* request,
+      const net::ProxyInfo& proxy_info,
+      net::HttpRequestHeaders* headers) override;
+
+  // Indicates that the URL request has been completed or failed.
+  // |started| indicates whether the request has been started. If false,
+  // some information like the socket address is not available.
+  void OnCompletedInternal(net::URLRequest* request,
+                           bool started) override;
+
+  // Posts to the UI thread to UpdateContentLengthPrefs in the data reduction
+  // proxy metrics and updates |received_content_length_| and
+  // |original_content_length_|.
+  void AccumulateContentLength(int64 received_content_length,
+                               int64 original_content_length,
+                               DataReductionProxyRequestType request_type);
+
+  PrefService* profile_prefs_;
+
+  scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner_;
+
+  // Total size of all content (excluding headers) that has been received
+  // over the network.
+  int64 received_content_length_;
+
+  // Total original size of all content before it was transferred.
+  int64 original_content_length_;
+
+  //Weak, owned by our owner.

[bengr, 2014/12/02 17:20:00]

space

[megjablon, 2014/12/02 22:33:21]

Done.

+  BooleanPrefMember* data_reduction_proxy_enabled_;
+
+  // |data_reduction_proxy_params_| must outlive this

[bengr, 2014/12/02 17:20:01]

Must outlive this...

[megjablon, 2014/12/02 22:33:21]

Done.

+  // DataReductionProxyNetworkDelegate.
+  DataReductionProxyParams* data_reduction_proxy_params_;
+
+  // |data_reduction_proxy_usage_stats_| must outlive this

[bengr, 2014/12/02 17:20:00]

Must outlive this...

[megjablon, 2014/12/02 22:33:21]

Done.

+  // DataReductionProxyNetworkDelegate.
+  DataReductionProxyUsageStats* data_reduction_proxy_usage_stats_;
+
+  DataReductionProxyAuthRequestHandler*
+      data_reduction_proxy_auth_request_handler_;
+
+  DataReductionProxyStatisticsPrefs* data_reduction_proxy_statistics_prefs_;
+
+  OnResolveProxyHandler on_resolve_proxy_handler_;
+
+  ProxyConfigGetter proxy_config_getter_;
+
+  DISALLOW_COPY_AND_ASSIGN(DataReductionProxyNetworkDelegate);
+};
+
+}  // namespace data_reduction_proxy
+
+#endif  // COMPONENTS_DATA_REDUCTION_PROXY_CORE_BROWSER_DATA_REDUCTION_PROXY_NETWORK_DELEGATE_H_