Index: net/websockets/websocket_stream_create_test_base.cc |
diff --git a/net/websockets/websocket_stream_create_test_base.cc b/net/websockets/websocket_stream_create_test_base.cc |
deleted file mode 100644 |
index 900b1aff09b48d0f7fc98f61c945c7f2dc816abe..0000000000000000000000000000000000000000 |
--- a/net/websockets/websocket_stream_create_test_base.cc |
+++ /dev/null |
@@ -1,150 +0,0 @@ |
-// Copyright 2015 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. |
- |
-#include "net/websockets/websocket_stream_create_test_base.h" |
- |
-#include "base/callback.h" |
-#include "net/http/http_request_headers.h" |
-#include "net/http/http_response_headers.h" |
-#include "net/websockets/websocket_basic_handshake_stream.h" |
-#include "net/websockets/websocket_handshake_request_info.h" |
-#include "net/websockets/websocket_handshake_response_info.h" |
-#include "net/websockets/websocket_handshake_stream_create_helper.h" |
-#include "net/websockets/websocket_stream.h" |
-#include "url/gurl.h" |
-#include "url/origin.h" |
- |
-namespace net { |
- |
-using HeaderKeyValuePair = WebSocketStreamCreateTestBase::HeaderKeyValuePair; |
- |
-// A sub-class of WebSocketHandshakeStreamCreateHelper which always sets a |
-// deterministic key to use in the WebSocket handshake. |
-class DeterministicKeyWebSocketHandshakeStreamCreateHelper |
- : public WebSocketHandshakeStreamCreateHelper { |
- public: |
- DeterministicKeyWebSocketHandshakeStreamCreateHelper( |
- WebSocketStream::ConnectDelegate* connect_delegate, |
- const std::vector<std::string>& requested_subprotocols) |
- : WebSocketHandshakeStreamCreateHelper(connect_delegate, |
- requested_subprotocols) {} |
- |
- void OnStreamCreated(WebSocketBasicHandshakeStream* stream) override { |
- stream->SetWebSocketKeyForTesting("dGhlIHNhbXBsZSBub25jZQ=="); |
- } |
- |
- private: |
- DISALLOW_COPY_AND_ASSIGN( |
- DeterministicKeyWebSocketHandshakeStreamCreateHelper); |
-}; |
- |
-class WebSocketStreamCreateTestBase::TestConnectDelegate |
- : public WebSocketStream::ConnectDelegate { |
- public: |
- TestConnectDelegate(WebSocketStreamCreateTestBase* owner, |
- const base::Closure& done_callback) |
- : owner_(owner), done_callback_(done_callback) {} |
- |
- void OnSuccess(scoped_ptr<WebSocketStream> stream) override { |
- stream.swap(owner_->stream_); |
- done_callback_.Run(); |
- } |
- |
- void OnFailure(const std::string& message) override { |
- owner_->has_failed_ = true; |
- owner_->failure_message_ = message; |
- done_callback_.Run(); |
- } |
- |
- void OnStartOpeningHandshake( |
- scoped_ptr<WebSocketHandshakeRequestInfo> request) override { |
- // Can be called multiple times (in the case of HTTP auth). Last call |
- // wins. |
- owner_->request_info_ = request.Pass(); |
- } |
- |
- void OnFinishOpeningHandshake( |
- scoped_ptr<WebSocketHandshakeResponseInfo> response) override { |
- if (owner_->response_info_) |
- ADD_FAILURE(); |
- owner_->response_info_ = response.Pass(); |
- } |
- |
- void OnSSLCertificateError( |
- scoped_ptr<WebSocketEventInterface::SSLErrorCallbacks> |
- ssl_error_callbacks, |
- const SSLInfo& ssl_info, |
- bool fatal) override { |
- owner_->ssl_error_callbacks_ = ssl_error_callbacks.Pass(); |
- owner_->ssl_info_ = ssl_info; |
- owner_->ssl_fatal_ = fatal; |
- } |
- |
- private: |
- WebSocketStreamCreateTestBase* owner_; |
- base::Closure done_callback_; |
- DISALLOW_COPY_AND_ASSIGN(TestConnectDelegate); |
-}; |
- |
-WebSocketStreamCreateTestBase::WebSocketStreamCreateTestBase() |
- : has_failed_(false), ssl_fatal_(false) { |
-} |
- |
-WebSocketStreamCreateTestBase::~WebSocketStreamCreateTestBase() { |
-} |
- |
-void WebSocketStreamCreateTestBase::CreateAndConnectStream( |
- const std::string& socket_url, |
- const std::vector<std::string>& sub_protocols, |
- const std::string& origin, |
- scoped_ptr<base::Timer> timer) { |
- for (size_t i = 0; i < ssl_data_.size(); ++i) { |
- scoped_ptr<SSLSocketDataProvider> ssl_data(ssl_data_[i]); |
- url_request_context_host_.AddSSLSocketDataProvider(ssl_data.Pass()); |
- } |
- ssl_data_.weak_clear(); |
- scoped_ptr<WebSocketStream::ConnectDelegate> connect_delegate( |
- new TestConnectDelegate(this, connect_run_loop_.QuitClosure())); |
- WebSocketStream::ConnectDelegate* delegate = connect_delegate.get(); |
- scoped_ptr<WebSocketHandshakeStreamCreateHelper> create_helper( |
- new DeterministicKeyWebSocketHandshakeStreamCreateHelper(delegate, |
- sub_protocols)); |
- stream_request_ = CreateAndConnectStreamForTesting( |
- GURL(socket_url), create_helper.Pass(), url::Origin(origin), |
- url_request_context_host_.GetURLRequestContext(), BoundNetLog(), |
- connect_delegate.Pass(), |
- timer ? timer.Pass() |
- : scoped_ptr<base::Timer>(new base::Timer(false, false))); |
-} |
- |
-std::vector<HeaderKeyValuePair> |
-WebSocketStreamCreateTestBase::RequestHeadersToVector( |
- const HttpRequestHeaders& headers) { |
- HttpRequestHeaders::Iterator it(headers); |
- std::vector<HeaderKeyValuePair> result; |
- while (it.GetNext()) |
- result.push_back(HeaderKeyValuePair(it.name(), it.value())); |
- return result; |
-} |
- |
-std::vector<HeaderKeyValuePair> |
-WebSocketStreamCreateTestBase::ResponseHeadersToVector( |
- const HttpResponseHeaders& headers) { |
- void* iter = NULL; |
- std::string name, value; |
- std::vector<HeaderKeyValuePair> result; |
- while (headers.EnumerateHeaderLines(&iter, &name, &value)) |
- result.push_back(HeaderKeyValuePair(name, value)); |
- return result; |
-} |
- |
-void WebSocketStreamCreateTestBase::WaitUntilConnectDone() { |
- connect_run_loop_.Run(); |
-} |
- |
-std::vector<std::string> WebSocketStreamCreateTestBase::NoSubProtocols() { |
- return std::vector<std::string>(); |
-} |
- |
-} // namespace net |