Chromium Code Reviews| Index: content/browser/loader/intercepting_resource_handler_unittest.cc |
| diff --git a/content/browser/loader/intercepting_resource_handler_unittest.cc b/content/browser/loader/intercepting_resource_handler_unittest.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..d2c55c28b46680c81531e5874f1249483739d142 |
| --- /dev/null |
| +++ b/content/browser/loader/intercepting_resource_handler_unittest.cc |
| @@ -0,0 +1,153 @@ |
| +// Copyright 2016 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 "content/browser/loader/intercepting_resource_handler.h" |
| + |
| +#include <stdint.h> |
| + |
| +#include <memory> |
| + |
| +#include "base/files/file_path.h" |
| +#include "base/location.h" |
| +#include "base/logging.h" |
| +#include "base/macros.h" |
| +#include "base/single_thread_task_runner.h" |
| +#include "base/threading/thread_task_runner_handle.h" |
| +#include "content/public/browser/resource_controller.h" |
| +#include "content/public/browser/resource_request_info.h" |
| +#include "content/public/common/resource_response.h" |
| +#include "content/public/common/webplugininfo.h" |
| +#include "content/public/test/test_browser_thread_bundle.h" |
| +#include "content/public/test/test_utils.h" |
| +#include "net/url_request/url_request_context.h" |
| +#include "testing/gtest/include/gtest/gtest.h" |
| +#include "url/gurl.h" |
| + |
| +namespace content { |
| + |
| +namespace { |
| + |
| +class TestResourceHandler : public ResourceHandler { |
| + public: |
| + TestResourceHandler() |
| + : ResourceHandler(nullptr), buffer_(new net::IOBuffer(2048)) {} |
| + ~TestResourceHandler() override {} |
| + |
| + void SetController(ResourceController* controller) override {} |
| + |
| + bool OnRequestRedirected(const net::RedirectInfo& redirect_info, |
| + ResourceResponse* response, |
| + bool* defer) override { |
| + NOTREACHED(); |
| + return false; |
| + } |
| + |
| + bool OnResponseStarted(ResourceResponse* response, bool* defer) override { |
| + return true; |
| + } |
| + |
| + bool OnWillStart(const GURL& url, bool* defer) override { return false; } |
| + |
| + bool OnBeforeNetworkStart(const GURL& url, bool* defer) override { |
| + NOTREACHED(); |
| + return false; |
| + } |
| + |
| + bool OnWillRead(scoped_refptr<net::IOBuffer>* buf, |
| + int* buf_size, |
| + int min_size) override { |
| + *buf = buffer_; |
| + *buf_size = 2048; |
| + return true; |
| + } |
| + |
| + bool OnReadCompleted(int bytes_read, bool* defer) override { |
| + DCHECK_LT(bytes_read, 2048); |
| + return true; |
| + } |
| + |
| + void OnResponseCompleted(const net::URLRequestStatus& status, |
| + const std::string& security_info, |
| + bool* defer) override {} |
| + |
| + void OnDataDownloaded(int bytes_downloaded) override { NOTREACHED(); } |
| + |
| + scoped_refptr<net::IOBuffer> buffer() { return buffer_; } |
| + |
| + private: |
| + scoped_refptr<net::IOBuffer> buffer_; |
| + DISALLOW_COPY_AND_ASSIGN(TestResourceHandler); |
| +}; |
| + |
| +class InterceptingResourceHandlerTest : public testing::Test { |
| + public: |
| + InterceptingResourceHandlerTest() {} |
| + |
| + private: |
| + TestBrowserThreadBundle thread_bundle_; |
| +}; |
| + |
| +// Tests that the data received is transmitted to the newly created |
| +// ResourceHandler. |
| +TEST_F(InterceptingResourceHandlerTest, ResponseBodyHandling) { |
|
mmenke
2016/07/19 21:42:33
Hrm...We aren't testing any of the failure cases (
mmenke
2016/07/19 21:42:33
Seems like we should also test the non-intercept c
clamy
2016/07/25 16:58:26
Done. I only included some of the failure cases, s
|
| + net::URLRequestContext context; |
| + std::unique_ptr<net::URLRequest> request(context.CreateRequest( |
| + GURL("http://www.google.com"), net::DEFAULT_PRIORITY, nullptr)); |
| + ResourceRequestInfo::AllocateForTesting(request.get(), |
| + RESOURCE_TYPE_MAIN_FRAME, |
| + nullptr, // context |
| + 0, // render_process_id |
| + 0, // render_view_id |
| + 0, // render_frame_id |
| + true, // is_main_frame |
| + false, // parent_is_main_frame |
| + true, // allow_download |
| + true, // is_async |
| + false); // is_using_lofi |
| + |
| + std::unique_ptr<ResourceHandler> old_handler(new TestResourceHandler()); |
| + scoped_refptr<net::IOBuffer> old_buffer = |
| + static_cast<TestResourceHandler*>(old_handler.get())->buffer(); |
| + std::unique_ptr<ResourceHandler> handler( |
| + new InterceptingResourceHandler(std::move(old_handler), request.get())); |
| + InterceptingResourceHandler* intercepting_handler = |
| + static_cast<InterceptingResourceHandler*>(handler.get()); |
| + |
| + scoped_refptr<ResourceResponse> response(new ResourceResponse); |
| + |
| + // Simulate the MimeSniffingResourceHandler buffering the data. |
| + scoped_refptr<net::IOBuffer> read_buffer; |
| + int buf_size = 0; |
| + handler->OnWillRead(&read_buffer, &buf_size, -1); |
| + |
| + char data[] = "The data"; |
|
mmenke
2016/07/19 21:42:33
const char kData
clamy
2016/07/25 16:58:25
Done.
|
| + CHECK_EQ(read_buffer.get(), old_buffer.get()); |
| + memcpy(read_buffer->data(), data, sizeof(data)); |
| + |
| + // Simulate the MimeSniffingResourceHandler asking the |
| + // InterceptingResourceHandler to switch to a new handler. |
| + std::unique_ptr<ResourceHandler> new_handler(new TestResourceHandler()); |
| + TestResourceHandler* new_test_handler = |
| + static_cast<TestResourceHandler*>(new_handler.get()); |
| + intercepting_handler->UseNewHandler(std::move(new_handler), std::string()); |
|
mmenke
2016/07/19 21:42:33
Should check that the old handler gets the abort m
clamy
2016/07/25 16:58:25
Done.
|
| + |
| + // The response is received. The new ResourceHandler should be used handle |
| + // the download. |
| + bool defer = false; |
| + handler->OnResponseStarted(response.get(), &defer); |
| + EXPECT_FALSE(defer); |
| + |
| + // It should not have received the download data yet. |
| + EXPECT_FALSE(!memcmp(data, new_test_handler->buffer()->data(), sizeof(data))); |
|
mmenke
2016/07/19 21:42:33
Have we put any data in new_test_handler->buffer()
clamy
2016/07/25 16:58:26
Done. The buffer is now populated with 0s at creat
|
| + |
| + // The read is replayed by the MimeSniffingResourceHandler. The data should |
| + // have been received by the new handler. |
| + handler->OnReadCompleted(sizeof(data), &defer); |
| + EXPECT_FALSE(defer); |
| + EXPECT_TRUE(!memcmp(data, new_test_handler->buffer()->data(), sizeof(data))); |
|
mmenke
2016/07/19 21:42:33
Seems like we should check a second read, make sur
clamy
2016/07/25 16:58:26
Done.
|
| +} |
| + |
| +} // namespace |
| + |
| +} // namespace content |