Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ | 5 #ifndef COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ |
| 6 #define COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ | 6 #define COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| 11 #include <string> | 11 #include <string> |
| 12 #include <vector> | 12 #include <vector> |
| 13 | 13 |
| 14 #include "base/macros.h" | 14 #include "base/macros.h" |
| 15 #include "base/strings/string_piece.h" | 15 #include "base/strings/string_piece.h" |
| 16 #include "net/dns/dns_client.h" | 16 #include "net/dns/dns_client.h" |
| 17 #include "net/dns/dns_config_service.h" | 17 #include "net/dns/dns_config_service.h" |
| 18 #include "net/socket/socket_test_util.h" | 18 #include "net/socket/socket_test_util.h" |
| 19 | 19 |
| 20 namespace certificate_transparency { | 20 namespace certificate_transparency { |
| 21 | 21 |
| 22 namespace internal { | |
| 23 | |
| 24 // A container for all of the data we need to keep alive for a mock socket. | |
| 25 // This is useful because Mock{Read,Write}, SequencedSocketData and | |
| 26 // MockClientSocketFactory all do not take ownership of or copy their arguments, | |
| 27 // so we have to manage the lifetime of those arguments ourselves. Wrapping all | |
| 28 // of that up in a single class simplifies this. | |
| 29 // This cannot be forward declared because MockLogDnsTraffic has a | |
| 30 // vector<unique_ptr<MockSocketData>> member, which requires MockSocketData be | |
| 31 // defined. | |
| 32 class MockSocketData { | |
| 33 public: | |
| 34 // A socket that expects one write and one read operation. | |
| 35 MockSocketData(const std::vector<char>& write, const std::vector<char>& read); | |
| 36 // A socket that expects one write and a read error. | |
| 37 MockSocketData(const std::vector<char>& write, int net_error); | |
| 38 // A socket that expects one write and no response. | |
| 39 explicit MockSocketData(const std::vector<char>& write); | |
| 40 | |
| 41 ~MockSocketData(); | |
| 42 | |
| 43 void SetWriteMode(net::IoMode mode) { expected_write_.mode = mode; } | |
| 44 void SetReadMode(net::IoMode mode) { expected_reads_[0].mode = mode; } | |
| 45 | |
| 46 void AddToFactory(net::MockClientSocketFactory* socket_factory); | |
| 47 | |
| 48 private: | |
| 49 // Prevents read overruns and makes a socket timeout the default behaviour. | |
| 50 static const net::MockRead no_more_data_; | |
| 51 | |
| 52 // This class only supports one write and one read, so just need to store one | |
| 53 // payload each. | |
| 54 const std::vector<char> expected_write_payload_; | |
| 55 const std::vector<char> expected_read_payload_; | |
| 56 // Encapsulates the data that is expected to be written to a socket. | |
| 57 net::MockWrite expected_write_; | |
| 58 // Encapsulates the data/error that should be returned when reading from a | |
| 59 // socket. The second "expected" read is always |no_more_data_|, which | |
| 60 // causes the socket read to hang until it times out. This results in better | |
| 61 // test failure messages (rather than a CHECK-fail due to a socket read | |
| 62 // overrunning the MockRead array) and behaviour more like a real socket when | |
| 63 // an unexpected second socket read occurs. | |
| 64 net::MockRead expected_reads_[2]; | |
| 65 // Holds pointers to |expected_write_| and |expected_reads_|. This is what is | |
| 66 // added to net::MockClientSocketFactory to prepare a mock socket. | |
| 67 net::SequencedSocketData socket_data_; | |
| 68 | |
| 69 DISALLOW_COPY_AND_ASSIGN(MockSocketData); | |
| 70 }; | |
| 71 | |
| 72 } // namespace internal | |
| 73 | |
| 74 // Mocks DNS requests and responses for a Certificate Transparency (CT) log. | 22 // Mocks DNS requests and responses for a Certificate Transparency (CT) log. |
| 75 // This is implemented using mock sockets. Call the CreateDnsClient() method to | 23 // This is implemented using mock sockets. Call the CreateDnsClient() method to |
| 76 // get a net::DnsClient wired up to these mock sockets. | 24 // get a net::DnsClient wired up to these mock sockets. |
| 77 // The Expect*() methods must be called from within a GTest test case. | 25 // The Expect*() methods must be called from within a GTest test case. |
| 26 // | |
| 27 // Example Usage: | |
| 28 // // Create a mock NetworkChangeNotifier to propagate DNS config. | |
| 29 // std::unique_ptr<net::NetworkChangeNotifier> net_change_notifier( | |
| 30 // net::NetworkChangeNotifier::CreateMock()); | |
| 31 // | |
| 32 // // net::DnsClient requires an I/O message loop for async operations. | |
| 33 // base::MessageLoopForIO message_loop; | |
| 34 // | |
| 35 // MockLogDnsTraffic mock_dns; | |
| 36 // mock_dns.InitializeDnsConfig(); | |
| 37 // // Use the Expect* methods to define expected DNS requests and responses. | |
| 38 // mock_dns.ExpectLeafIndexRequestAndResponse( | |
| 39 // "D4S6DSV2J743QJZEQMH4UYHEYK7KRQ5JIQOCPMFUHZVJNFGHXACA.hash.ct.test.", | |
| 40 // "123456"); | |
| 41 // | |
| 42 // LogDnsClient log_client(mock_dns.CreateDnsClient(), ...); | |
| 43 // log_client.QueryAuditProof("ct.test", ..., base::Bind(...)); | |
| 78 class MockLogDnsTraffic { | 44 class MockLogDnsTraffic { |
| 79 public: | 45 public: |
| 80 MockLogDnsTraffic(); | 46 MockLogDnsTraffic(); |
| 81 ~MockLogDnsTraffic(); | 47 ~MockLogDnsTraffic(); |
| 82 | 48 |
| 83 // Expect a CT DNS request for the domain |qname|. | 49 // Expect a CT DNS request for the domain |qname|. |
| 84 // Such a request will receive a DNS response indicating that the error | 50 // Such a request will receive a DNS response indicating that the error |
| 85 // specified by |rcode| occurred. See RFC1035, Section 4.1.1 for |rcode| | 51 // specified by |rcode| occurred. See RFC1035, Section 4.1.1 for |rcode| |
| 86 // values. | 52 // values. |
| 87 void ExpectRequestAndErrorResponse(base::StringPiece qname, uint8_t rcode); | 53 void ExpectRequestAndErrorResponse(base::StringPiece qname, uint8_t rcode); |
| 54 | |
| 88 // Expect a CT DNS request for the domain |qname|. | 55 // Expect a CT DNS request for the domain |qname|. |
| 89 // Such a request will trigger a socket error of type |net_error|. | 56 // Such a request will trigger a socket error of type |error|. |
| 90 // |net_error| can be any net:Error value. | 57 void ExpectRequestAndSocketError(base::StringPiece qname, net::Error error); |
| 91 void ExpectRequestAndSocketError(base::StringPiece qname, int net_error); | 58 |
| 92 // Expect a CT DNS request for the domain |qname|. | 59 // Expect a CT DNS request for the domain |qname|. |
| 93 // Such a request will timeout. | 60 // Such a request will timeout. |
| 94 // This will reduce the DNS timeout to minimize test duration. | 61 // This will reduce the DNS timeout to minimize test duration. |
| 95 void ExpectRequestAndTimeout(base::StringPiece qname); | 62 void ExpectRequestAndTimeout(base::StringPiece qname); |
| 63 | |
| 96 // Expect a CT DNS request for the domain |qname|. | 64 // Expect a CT DNS request for the domain |qname|. |
| 97 // Such a request will receive a DNS response containing |leaf_index|. | 65 // Such a request will receive a DNS response containing |leaf_index|. |
| 98 // A description of such a request and response can be seen here: | 66 // A description of such a request and response can be seen here: |
| 99 // https://github.com/google/certificate-transparency-rfcs/blob/c8844de6bd0b5d 3d16bac79865e6edef533d760b/dns/draft-ct-over-dns.md#hash-query-hashquery | 67 // https://github.com/google/certificate-transparency-rfcs/blob/c8844de6bd0b5d 3d16bac79865e6edef533d760b/dns/draft-ct-over-dns.md#hash-query-hashquery |
| 100 void ExpectLeafIndexRequestAndResponse(base::StringPiece qname, | 68 void ExpectLeafIndexRequestAndResponse(base::StringPiece qname, |
| 101 base::StringPiece leaf_index); | 69 base::StringPiece leaf_index); |
| 102 // Expect a CT DNS request for the domain |qname|. | 70 // Expect a CT DNS request for the domain |qname|. |
| 103 // Such a request will receive a DNS response containing the inclusion proof | 71 // Such a request will receive a DNS response containing the inclusion proof |
| 104 // nodes between |audit_path_start| and |audit_path_end|. | 72 // nodes between |audit_path_start| and |audit_path_end|. |
| 105 // A description of such a request and response can be seen here: | 73 // A description of such a request and response can be seen here: |
| (...skipping 12 matching lines...) Expand all Loading... | |
| 118 // Sets the DNS config to |config|. | 86 // Sets the DNS config to |config|. |
| 119 // Requires that net::NetworkChangeNotifier is initialized first. | 87 // Requires that net::NetworkChangeNotifier is initialized first. |
| 120 // The DNS config is propogated to NetworkChangeNotifier::DNSObservers | 88 // The DNS config is propogated to NetworkChangeNotifier::DNSObservers |
| 121 // asynchronously. | 89 // asynchronously. |
| 122 void SetDnsConfig(const net::DnsConfig& config); | 90 void SetDnsConfig(const net::DnsConfig& config); |
| 123 | 91 |
| 124 // Creates a DNS client that uses mock sockets. | 92 // Creates a DNS client that uses mock sockets. |
| 125 // It is this DNS client that the expectations will be tested against. | 93 // It is this DNS client that the expectations will be tested against. |
| 126 std::unique_ptr<net::DnsClient> CreateDnsClient(); | 94 std::unique_ptr<net::DnsClient> CreateDnsClient(); |
| 127 | 95 |
| 96 private: | |
| 97 // Allows tests to change socket read mode. Only the LogDnsClient tests should | |
| 98 // need to do so, to ensure consistent behaviour regardless of mode. | |
| 99 friend class LogDnsClientTest; | |
| 100 | |
| 101 // Forward declaration of a class that encapsulates socket simulation data. | |
|
Ryan Sleevi
2016/10/03 23:44:52
I would say this is an unnecessary comment, but I
Rob Percival
2016/10/05 15:42:00
Done.
| |
| 102 class MockSocketData; | |
| 103 | |
| 128 // Sets whether mock reads should complete synchronously or asynchronously. | 104 // Sets whether mock reads should complete synchronously or asynchronously. |
| 105 // By default, they complete asynchronously. | |
| 129 void SetSocketReadMode(net::IoMode read_mode) { | 106 void SetSocketReadMode(net::IoMode read_mode) { |
| 130 socket_read_mode_ = read_mode; | 107 socket_read_mode_ = read_mode; |
| 131 } | 108 } |
| 132 | 109 |
| 133 private: | |
| 134 // Expect A CT DNS request for the domain |qname|. | 110 // Expect A CT DNS request for the domain |qname|. |
| 135 // Such a request will receive a DNS response containing |answer|. | 111 // Such a request will receive a DNS response containing |answer|. |
| 136 void ExpectRequestAndResponse(base::StringPiece qname, | 112 void ExpectRequestAndResponse(base::StringPiece qname, |
| 137 base::StringPiece answer); | 113 base::StringPiece answer); |
| 138 | 114 |
| 139 // Constructs MockSocketData from |args| and adds it to |socket_factory_|. | 115 // Constructs MockSocketData from |args| and adds it to |socket_factory_|. |
| 140 template <typename... Args> | 116 template <typename... Args> |
| 141 void EmplaceMockSocketData(Args&&... args); | 117 void EmplaceMockSocketData(Args&&... args); |
| 142 | 118 |
| 143 // Sets the timeout used for DNS queries. | 119 // Sets the timeout used for DNS queries. |
| 144 // Requires that net::NetworkChangeNotifier is initialized first. | 120 // Requires that net::NetworkChangeNotifier is initialized first. |
| 145 // The new timeout is propogated to NetworkChangeNotifier::DNSObservers | 121 // The new timeout is propogated to NetworkChangeNotifier::DNSObservers |
| 146 // asynchronously. | 122 // asynchronously. |
| 147 void SetDnsTimeout(const base::TimeDelta& timeout); | 123 void SetDnsTimeout(const base::TimeDelta& timeout); |
| 148 | 124 |
| 149 // One MockSocketData for each socket that is created. This corresponds to one | 125 // One MockSocketData for each socket that is created. This corresponds to one |
| 150 // for each DNS request sent. | 126 // for each DNS request sent. |
| 151 std::vector<std::unique_ptr<internal::MockSocketData>> mock_socket_data_; | 127 std::vector<std::unique_ptr<MockSocketData>> mock_socket_data_; |
| 152 // Provides as many mock sockets as there are entries in |mock_socket_data_|. | 128 // Provides as many mock sockets as there are entries in |mock_socket_data_|. |
| 153 net::MockClientSocketFactory socket_factory_; | 129 net::MockClientSocketFactory socket_factory_; |
| 154 // Controls whether mock socket reads are asynchronous. | 130 // Controls whether mock socket reads are asynchronous. |
| 155 net::IoMode socket_read_mode_; | 131 net::IoMode socket_read_mode_; |
| 156 | 132 |
| 157 DISALLOW_COPY_AND_ASSIGN(MockLogDnsTraffic); | 133 DISALLOW_COPY_AND_ASSIGN(MockLogDnsTraffic); |
| 158 }; | 134 }; |
| 159 | 135 |
| 160 } // namespace certificate_transparency | 136 } // namespace certificate_transparency |
| 161 | 137 |
| 162 #endif // COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ | 138 #endif // COMPONENTS_CERTIFICATE_TRANSPARENCY_MOCK_LOG_DNS_TRAFFIC_H_ |
| OLD | NEW |