1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CONTENT_BROWSER_PRELOADING_PREFETCH_PREFETCH_PROXY_CONFIGURATOR_H_
#define CONTENT_BROWSER_PRELOADING_PREFETCH_PREFETCH_PROXY_CONFIGURATOR_H_
#include <optional>
#include <string>
#include "base/memory/raw_ptr.h"
#include "base/sequence_checker.h"
#include "base/time/clock.h"
#include "base/time/time.h"
#include "content/common/content_export.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver_set.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "mojo/public/cpp/bindings/remote_set.h"
#include "net/base/proxy_chain.h"
#include "net/http/http_request_headers.h"
#include "services/network/public/mojom/network_context.mojom.h"
#include "url/gurl.h"
namespace content {
// Configures the use of the IP-masking CONNECT tunnel proxy for Isolated
// Prerenders, and observers their connection failures.
class CONTENT_EXPORT PrefetchProxyConfigurator
: public network::mojom::CustomProxyConnectionObserver {
public:
// Creates an instance of |PrefetchProxyConfigurator| when given a valid
// |proxy_url|.
static std::unique_ptr<PrefetchProxyConfigurator>
MaybeCreatePrefetchProxyConfigurator(const GURL& proxy_url,
const std::string& api_key);
PrefetchProxyConfigurator(const GURL& proxy_url, const std::string& api_key);
~PrefetchProxyConfigurator() override;
PrefetchProxyConfigurator(const PrefetchProxyConfigurator&) = delete;
const PrefetchProxyConfigurator operator=(const PrefetchProxyConfigurator&) =
delete;
// Adds a config client that can be used to update Data Reduction Proxy
// settings.
void AddCustomProxyConfigClient(
mojo::Remote<network::mojom::CustomProxyConfigClient> config_client,
base::OnceCallback<void()> callback);
// Updates the custom proxy config to all clients.
void UpdateCustomProxyConfig(base::OnceCallback<void()> callback);
// Creates a config that can be sent to the NetworkContext.
network::mojom::CustomProxyConfigPtr CreateCustomProxyConfig() const;
// Passes a new pending remote for the custom proxy connection observer
// implemented by this class.
mojo::PendingRemote<network::mojom::CustomProxyConnectionObserver>
NewProxyConnectionObserverRemote();
// Returns true when the prefetch proxy has not recently had any connection
// errors.
bool IsPrefetchProxyAvailable() const;
void SetClockForTesting(const base::Clock* clock);
// mojom::CustomProxyConnectionObserver:
void OnFallback(const net::ProxyChain& bad_chain, int net_error) override;
void OnTunnelHeadersReceived(
const net::ProxyChain& proxy_chain,
uint64_t chain_index,
const scoped_refptr<net::HttpResponseHeaders>& response_headers) override;
private:
// Called when an error is detected by the CustomProxyConnectionObserver
// implementation so that we can throttle requests to the proxy.
void OnTunnelProxyConnectionError(std::optional<base::TimeDelta> retry_after);
// The headers used to setup the connect tunnel.
net::HttpRequestHeaders connect_tunnel_headers_;
// The proxy chain used for prefetch requests.
const net::ProxyChain prefetch_proxy_chain_;
// The time clock used to calculate |prefetch_proxy_not_available_until_|.
raw_ptr<const base::Clock> clock_;
// If set, the prefetch proxy should not be used until this time.
std::optional<base::Time> prefetch_proxy_not_available_until_;
// The set of clients that will get updates about changes to the proxy config.
mojo::RemoteSet<network::mojom::CustomProxyConfigClient>
proxy_config_clients_;
// The set of receivers for tunnel connection observers.
mojo::ReceiverSet<network::mojom::CustomProxyConnectionObserver>
observer_receivers_;
SEQUENCE_CHECKER(sequence_checker_);
};
} // namespace content
#endif // CONTENT_BROWSER_PRELOADING_PREFETCH_PREFETCH_PROXY_CONFIGURATOR_H_
|
