Index: components/update_client/test/ping_manager_unittest.cc |
diff --git a/components/update_client/test/ping_manager_unittest.cc b/components/update_client/test/ping_manager_unittest.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..95539f0313b1d8292b24584c6089c441e6720712 |
--- /dev/null |
+++ b/components/update_client/test/ping_manager_unittest.cc |
@@ -0,0 +1,177 @@ |
+// Copyright 2013 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/memory/scoped_ptr.h" |
+#include "base/message_loop/message_loop.h" |
+#include "base/run_loop.h" |
+#include "base/version.h" |
+#include "components/update_client/crx_update_item.h" |
+#include "components/update_client/ping_manager.h" |
+#include "components/update_client/test/test_configurator.h" |
+#include "components/update_client/test/url_request_post_interceptor.h" |
+#include "net/url_request/url_request_test_util.h" |
+#include "testing/gtest/include/gtest/gtest.h" |
+ |
+using std::string; |
+ |
+namespace update_client { |
+ |
+class ComponentUpdaterPingManagerTest : public testing::Test { |
+ public: |
+ ComponentUpdaterPingManagerTest(); |
+ ~ComponentUpdaterPingManagerTest() override {} |
+ |
+ void RunThreadsUntilIdle(); |
+ |
+ // Overrides from testing::Test. |
+ void SetUp() override; |
+ void TearDown() override; |
+ |
+ protected: |
+ scoped_ptr<TestConfigurator> config_; |
+ scoped_ptr<PingManager> ping_manager_; |
+ |
+ private: |
+ base::MessageLoopForIO loop_; |
+}; |
+ |
+ComponentUpdaterPingManagerTest::ComponentUpdaterPingManagerTest() |
+ : config_(new TestConfigurator(base::MessageLoopProxy::current(), |
+ base::MessageLoopProxy::current())) { |
+} |
+ |
+void ComponentUpdaterPingManagerTest::SetUp() { |
+ ping_manager_.reset(new PingManager(*config_)); |
+} |
+ |
+void ComponentUpdaterPingManagerTest::TearDown() { |
+ ping_manager_.reset(); |
+ config_.reset(); |
+} |
+ |
+void ComponentUpdaterPingManagerTest::RunThreadsUntilIdle() { |
+ base::RunLoop().RunUntilIdle(); |
+} |
+ |
+// Test is flaky: http://crbug.com/349547 |
+TEST_F(ComponentUpdaterPingManagerTest, DISABLED_PingManagerTest) { |
+ scoped_ptr<InterceptorFactory> interceptor_factory( |
+ new InterceptorFactory(base::MessageLoopProxy::current())); |
+ URLRequestPostInterceptor* interceptor = |
+ interceptor_factory->CreateInterceptor(); |
+ EXPECT_TRUE(interceptor); |
+ |
+ // Test eventresult="1" is sent for successful updates. |
+ CrxUpdateItem item; |
+ item.id = "abc"; |
+ item.status = CrxUpdateItem::kUpdated; |
+ item.previous_version = base::Version("1.0"); |
+ item.next_version = base::Version("2.0"); |
+ |
+ ping_manager_->OnUpdateComplete(&item); |
+ base::RunLoop().RunUntilIdle(); |
+ |
+ EXPECT_EQ(1, interceptor->GetCount()) << interceptor->GetRequestsAsString(); |
+ EXPECT_NE(string::npos, |
+ interceptor->GetRequests()[0].find( |
+ "<app appid=\"abc\" version=\"1.0\" nextversion=\"2.0\">" |
+ "<event eventtype=\"3\" eventresult=\"1\"/></app>")) |
+ << interceptor->GetRequestsAsString(); |
+ interceptor->Reset(); |
+ |
+ // Test eventresult="0" is sent for failed updates. |
+ item = CrxUpdateItem(); |
+ item.id = "abc"; |
+ item.status = CrxUpdateItem::kNoUpdate; |
+ item.previous_version = base::Version("1.0"); |
+ item.next_version = base::Version("2.0"); |
+ |
+ ping_manager_->OnUpdateComplete(&item); |
+ base::RunLoop().RunUntilIdle(); |
+ |
+ EXPECT_EQ(1, interceptor->GetCount()) << interceptor->GetRequestsAsString(); |
+ EXPECT_NE(string::npos, |
+ interceptor->GetRequests()[0].find( |
+ "<app appid=\"abc\" version=\"1.0\" nextversion=\"2.0\">" |
+ "<event eventtype=\"3\" eventresult=\"0\"/></app>")) |
+ << interceptor->GetRequestsAsString(); |
+ interceptor->Reset(); |
+ |
+ // Test the error values and the fingerprints. |
+ item = CrxUpdateItem(); |
+ item.id = "abc"; |
+ item.status = CrxUpdateItem::kNoUpdate; |
+ item.previous_version = base::Version("1.0"); |
+ item.next_version = base::Version("2.0"); |
+ item.previous_fp = "prev fp"; |
+ item.next_fp = "next fp"; |
+ item.error_category = 1; |
+ item.error_code = 2; |
+ item.extra_code1 = -1; |
+ item.diff_error_category = 10; |
+ item.diff_error_code = 20; |
+ item.diff_extra_code1 = -10; |
+ item.diff_update_failed = true; |
+ item.crx_diffurls.push_back(GURL("http://host/path")); |
+ |
+ ping_manager_->OnUpdateComplete(&item); |
+ base::RunLoop().RunUntilIdle(); |
+ |
+ EXPECT_EQ(1, interceptor->GetCount()) << interceptor->GetRequestsAsString(); |
+ EXPECT_NE(string::npos, |
+ interceptor->GetRequests()[0].find( |
+ "<app appid=\"abc\" version=\"1.0\" nextversion=\"2.0\">" |
+ "<event eventtype=\"3\" eventresult=\"0\" errorcat=\"1\" " |
+ "errorcode=\"2\" extracode1=\"-1\" diffresult=\"0\" " |
+ "differrorcat=\"10\" " |
+ "differrorcode=\"20\" diffextracode1=\"-10\" " |
+ "previousfp=\"prev fp\" nextfp=\"next fp\"/></app>")) |
+ << interceptor->GetRequestsAsString(); |
+ interceptor->Reset(); |
+ |
+ // Test the download metrics. |
+ item = CrxUpdateItem(); |
+ item.id = "abc"; |
+ item.status = CrxUpdateItem::kUpdated; |
+ item.previous_version = base::Version("1.0"); |
+ item.next_version = base::Version("2.0"); |
+ |
+ CrxDownloader::DownloadMetrics download_metrics; |
+ download_metrics.url = GURL("http://host1/path1"); |
+ download_metrics.downloader = CrxDownloader::DownloadMetrics::kUrlFetcher; |
+ download_metrics.error = -1; |
+ download_metrics.downloaded_bytes = 123; |
+ download_metrics.total_bytes = 456; |
+ download_metrics.download_time_ms = 987; |
+ item.download_metrics.push_back(download_metrics); |
+ |
+ download_metrics = CrxDownloader::DownloadMetrics(); |
+ download_metrics.url = GURL("http://host2/path2"); |
+ download_metrics.downloader = CrxDownloader::DownloadMetrics::kBits; |
+ download_metrics.error = 0; |
+ download_metrics.downloaded_bytes = 1230; |
+ download_metrics.total_bytes = 4560; |
+ download_metrics.download_time_ms = 9870; |
+ item.download_metrics.push_back(download_metrics); |
+ |
+ ping_manager_->OnUpdateComplete(&item); |
+ base::RunLoop().RunUntilIdle(); |
+ |
+ EXPECT_EQ(1, interceptor->GetCount()) << interceptor->GetRequestsAsString(); |
+ EXPECT_NE( |
+ string::npos, |
+ interceptor->GetRequests()[0].find( |
+ "<app appid=\"abc\" version=\"1.0\" nextversion=\"2.0\">" |
+ "<event eventtype=\"3\" eventresult=\"1\"/>" |
+ "<event eventtype=\"14\" eventresult=\"0\" downloader=\"direct\" " |
+ "errorcode=\"-1\" url=\"http://host1/path1\" downloaded=\"123\" " |
+ "total=\"456\" download_time_ms=\"987\"/>" |
+ "<event eventtype=\"14\" eventresult=\"1\" downloader=\"bits\" " |
+ "url=\"http://host2/path2\" downloaded=\"1230\" total=\"4560\" " |
+ "download_time_ms=\"9870\"/></app>")) |
+ << interceptor->GetRequestsAsString(); |
+ interceptor->Reset(); |
+} |
+ |
+} // namespace update_client |