Index: components/component_updater/test/request_sender_unittest.cc |
diff --git a/components/component_updater/test/request_sender_unittest.cc b/components/component_updater/test/request_sender_unittest.cc |
deleted file mode 100644 |
index 47e0e6f183031038afe9e852e5de3aada0a51946..0000000000000000000000000000000000000000 |
--- a/components/component_updater/test/request_sender_unittest.cc |
+++ /dev/null |
@@ -1,208 +0,0 @@ |
-// 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. |
- |
-#include "base/compiler_specific.h" |
-#include "base/macros.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/message_loop/message_loop.h" |
-#include "base/run_loop.h" |
-#include "components/component_updater/request_sender.h" |
-#include "components/component_updater/test/test_configurator.h" |
-#include "components/component_updater/test/url_request_post_interceptor.h" |
-#include "net/url_request/url_fetcher.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace component_updater { |
- |
-namespace { |
- |
-const char kUrl1[] = "https://localhost2/path1"; |
-const char kUrl2[] = "https://localhost2/path2"; |
-const char kUrlPath1[] = "path1"; |
-const char kUrlPath2[] = "path2"; |
- |
-} // namespace |
- |
-class RequestSenderTest : public testing::Test { |
- public: |
- RequestSenderTest(); |
- ~RequestSenderTest() override; |
- |
- // Overrides from testing::Test. |
- void SetUp() override; |
- void TearDown() override; |
- |
- void RequestSenderComplete(const net::URLFetcher* source); |
- |
- protected: |
- void Quit(); |
- void RunThreads(); |
- void RunThreadsUntilIdle(); |
- |
- scoped_ptr<TestConfigurator> config_; |
- scoped_ptr<RequestSender> request_sender_; |
- scoped_ptr<InterceptorFactory> interceptor_factory_; |
- |
- URLRequestPostInterceptor* post_interceptor_1; // Owned by the factory. |
- URLRequestPostInterceptor* post_interceptor_2; // Owned by the factory. |
- |
- const net::URLFetcher* url_fetcher_source_; |
- |
- private: |
- base::MessageLoopForIO loop_; |
- base::Closure quit_closure_; |
- |
- DISALLOW_COPY_AND_ASSIGN(RequestSenderTest); |
-}; |
- |
-RequestSenderTest::RequestSenderTest() |
- : post_interceptor_1(NULL), |
- post_interceptor_2(NULL), |
- url_fetcher_source_(NULL) { |
-} |
- |
-RequestSenderTest::~RequestSenderTest() { |
-} |
- |
-void RequestSenderTest::SetUp() { |
- config_.reset(new TestConfigurator(base::MessageLoopProxy::current(), |
- base::MessageLoopProxy::current())); |
- interceptor_factory_.reset( |
- new InterceptorFactory(base::MessageLoopProxy::current())); |
- post_interceptor_1 = |
- interceptor_factory_->CreateInterceptorForPath(kUrlPath1); |
- post_interceptor_2 = |
- interceptor_factory_->CreateInterceptorForPath(kUrlPath2); |
- EXPECT_TRUE(post_interceptor_1); |
- EXPECT_TRUE(post_interceptor_2); |
- |
- request_sender_.reset(); |
-} |
- |
-void RequestSenderTest::TearDown() { |
- request_sender_.reset(); |
- |
- post_interceptor_1 = NULL; |
- post_interceptor_2 = NULL; |
- |
- interceptor_factory_.reset(); |
- |
- config_.reset(); |
- |
- RunThreadsUntilIdle(); |
-} |
- |
-void RequestSenderTest::RunThreads() { |
- base::RunLoop runloop; |
- quit_closure_ = runloop.QuitClosure(); |
- runloop.Run(); |
- |
- // Since some tests need to drain currently enqueued tasks such as network |
- // intercepts on the IO thread, run the threads until they are |
- // idle. The component updater service won't loop again until the loop count |
- // is set and the service is started. |
- RunThreadsUntilIdle(); |
-} |
- |
-void RequestSenderTest::RunThreadsUntilIdle() { |
- base::RunLoop().RunUntilIdle(); |
-} |
- |
-void RequestSenderTest::Quit() { |
- if (!quit_closure_.is_null()) |
- quit_closure_.Run(); |
-} |
- |
-void RequestSenderTest::RequestSenderComplete(const net::URLFetcher* source) { |
- url_fetcher_source_ = source; |
- Quit(); |
-} |
- |
-// Tests that when a request to the first url succeeds, the subsequent urls are |
-// not tried. |
-TEST_F(RequestSenderTest, RequestSendSuccess) { |
- EXPECT_TRUE(post_interceptor_1->ExpectRequest(new PartialMatch("test"))); |
- |
- std::vector<GURL> urls; |
- urls.push_back(GURL(kUrl1)); |
- urls.push_back(GURL(kUrl2)); |
- request_sender_.reset(new RequestSender(*config_)); |
- request_sender_->Send("test", |
- urls, |
- base::Bind(&RequestSenderTest::RequestSenderComplete, |
- base::Unretained(this))); |
- RunThreads(); |
- |
- EXPECT_EQ(1, post_interceptor_1->GetHitCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_1->GetCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- |
- EXPECT_STREQ("test", post_interceptor_1->GetRequests()[0].c_str()); |
- EXPECT_EQ(GURL(kUrl1), url_fetcher_source_->GetOriginalURL()); |
- EXPECT_EQ(200, url_fetcher_source_->GetResponseCode()); |
-} |
- |
-// Tests that the request succeeds using the second url after the first url |
-// has failed. |
-TEST_F(RequestSenderTest, RequestSendSuccessWithFallback) { |
- EXPECT_TRUE(post_interceptor_1->ExpectRequest(new PartialMatch("test"), 403)); |
- EXPECT_TRUE(post_interceptor_2->ExpectRequest(new PartialMatch("test"))); |
- |
- std::vector<GURL> urls; |
- urls.push_back(GURL(kUrl1)); |
- urls.push_back(GURL(kUrl2)); |
- request_sender_.reset(new RequestSender(*config_)); |
- request_sender_->Send("test", |
- urls, |
- base::Bind(&RequestSenderTest::RequestSenderComplete, |
- base::Unretained(this))); |
- RunThreads(); |
- |
- EXPECT_EQ(1, post_interceptor_1->GetHitCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_1->GetCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_2->GetHitCount()) |
- << post_interceptor_2->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_2->GetCount()) |
- << post_interceptor_2->GetRequestsAsString(); |
- |
- EXPECT_STREQ("test", post_interceptor_1->GetRequests()[0].c_str()); |
- EXPECT_STREQ("test", post_interceptor_2->GetRequests()[0].c_str()); |
- EXPECT_EQ(GURL(kUrl2), url_fetcher_source_->GetOriginalURL()); |
- EXPECT_EQ(200, url_fetcher_source_->GetResponseCode()); |
-} |
- |
-// Tests that the request fails when both urls have failed. |
-TEST_F(RequestSenderTest, RequestSendFailed) { |
- EXPECT_TRUE(post_interceptor_1->ExpectRequest(new PartialMatch("test"), 403)); |
- EXPECT_TRUE(post_interceptor_2->ExpectRequest(new PartialMatch("test"), 403)); |
- |
- std::vector<GURL> urls; |
- urls.push_back(GURL(kUrl1)); |
- urls.push_back(GURL(kUrl2)); |
- request_sender_.reset(new RequestSender(*config_)); |
- request_sender_->Send("test", |
- urls, |
- base::Bind(&RequestSenderTest::RequestSenderComplete, |
- base::Unretained(this))); |
- RunThreads(); |
- |
- EXPECT_EQ(1, post_interceptor_1->GetHitCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_1->GetCount()) |
- << post_interceptor_1->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_2->GetHitCount()) |
- << post_interceptor_2->GetRequestsAsString(); |
- EXPECT_EQ(1, post_interceptor_2->GetCount()) |
- << post_interceptor_2->GetRequestsAsString(); |
- |
- EXPECT_STREQ("test", post_interceptor_1->GetRequests()[0].c_str()); |
- EXPECT_STREQ("test", post_interceptor_2->GetRequests()[0].c_str()); |
- EXPECT_EQ(GURL(kUrl2), url_fetcher_source_->GetOriginalURL()); |
- EXPECT_EQ(403, url_fetcher_source_->GetResponseCode()); |
-} |
- |
-} // namespace component_updater |