| Index: ios/chrome/browser/omaha/omaha_service_unittest.mm
|
| diff --git a/ios/chrome/browser/omaha/omaha_service_unittest.mm b/ios/chrome/browser/omaha/omaha_service_unittest.mm
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..c1f590480bf7ace9a5def93eed7cf1686a00a3dc
|
| --- /dev/null
|
| +++ b/ios/chrome/browser/omaha/omaha_service_unittest.mm
|
| @@ -0,0 +1,506 @@
|
| +// Copyright 2012 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.
|
| +
|
| +#import "ios/chrome/browser/omaha/omaha_service.h"
|
| +
|
| +#include <regex.h>
|
| +#include <sys/types.h>
|
| +
|
| +#include "base/bind.h"
|
| +#include "base/logging.h"
|
| +#include "base/message_loop/message_loop.h"
|
| +#include "base/run_loop.h"
|
| +#include "base/strings/stringprintf.h"
|
| +#include "components/metrics/metrics_pref_names.h"
|
| +#include "components/prefs/pref_registry_simple.h"
|
| +#include "components/version_info/version_info.h"
|
| +#include "ios/chrome/browser/application_context.h"
|
| +#include "ios/chrome/browser/browser_state/test_chrome_browser_state_manager.h"
|
| +#include "ios/chrome/browser/install_time_util.h"
|
| +#include "ios/chrome/common/channel_info.h"
|
| +#include "ios/chrome/test/testing_application_context.h"
|
| +#include "ios/public/provider/chrome/browser/chrome_browser_provider.h"
|
| +#include "ios/public/provider/chrome/browser/omaha/omaha_service_provider.h"
|
| +#include "ios/web/public/test/test_web_thread.h"
|
| +#include "net/url_request/test_url_fetcher_factory.h"
|
| +#include "testing/gtest/include/gtest/gtest.h"
|
| +#include "testing/gtest_mac.h"
|
| +#include "testing/platform_test.h"
|
| +
|
| +namespace {
|
| +
|
| +const char kUserDataDir[] = ".";
|
| +
|
| +} // namespace
|
| +
|
| +class OmahaServiceTest : public PlatformTest {
|
| + public:
|
| + OmahaServiceTest()
|
| + : need_update_(false),
|
| + loop_(base::MessageLoop::TYPE_IO),
|
| + browser_state_manager_(base::FilePath(kUserDataDir)),
|
| + ui_thread_(web::WebThread::UI, &loop_),
|
| + io_thread_(web::WebThread::IO, &loop_) {
|
| + GetApplicationContext()->GetLocalState()->SetInt64(
|
| + metrics::prefs::kInstallDate, install_time_util::kUnknownInstallDate);
|
| + OmahaService::ClearPersistentStateForTests();
|
| + test_application_id_ = ios::GetChromeBrowserProvider()
|
| + ->GetOmahaServiceProvider()
|
| + ->GetApplicationID();
|
| + }
|
| +
|
| + ~OmahaServiceTest() override {}
|
| +
|
| + void OnNeedUpdate(const UpgradeRecommendedDetails& details) {
|
| + need_update_ = true;
|
| + }
|
| +
|
| + bool NeedUpdate() {
|
| + DCHECK_CURRENTLY_ON(web::WebThread::UI);
|
| + if (!need_update_) {
|
| + base::RunLoop().RunUntilIdle();
|
| + }
|
| + return need_update_;
|
| + }
|
| +
|
| + void CleanService(OmahaService* service,
|
| + const std::string& last_sent_version) {
|
| + service->ClearInstallRetryRequestId();
|
| + service->number_of_tries_ = 0;
|
| + if (last_sent_version.length() == 0)
|
| + service->last_sent_version_ = base::Version("0.0.0.0");
|
| + else
|
| + service->last_sent_version_ = base::Version(last_sent_version);
|
| + service->current_ping_time_ = base::Time();
|
| + service->last_sent_time_ = base::Time();
|
| + service->locale_lang_ = std::string();
|
| + }
|
| +
|
| + protected:
|
| + std::string test_application_id_;
|
| + bool need_update_;
|
| + base::MessageLoop loop_;
|
| + TestChromeBrowserStateManager browser_state_manager_;
|
| +
|
| + private:
|
| + web::TestWebThread ui_thread_;
|
| + web::TestWebThread io_thread_;
|
| +};
|
| +
|
| +TEST_F(OmahaServiceTest, PingMessageTest) {
|
| + const char* expectedResult =
|
| + "<request protocol=\"3.0\" version=\"iOS-1.0.0.0\" ismachine=\"1\" "
|
| + "requestid=\"requestId\" sessionid=\"sessionId\""
|
| + " hardware_class=\"[^\"]*\">"
|
| + "<os platform=\"ios\" version=\"[0-9][0-9]*\\(\\.[0-9][0-9]*\\)*\""
|
| + " arch=\"[^\"]*\"/>"
|
| + "<app version=\"[^\"]*\" nextversion=\"\" lang=\"[^\"]*\""
|
| + " brand=\"[A-Z][A-Z][A-Z][A-Z]\" client=\"\" appid=\"{[^}]*}\""
|
| + " installage=\"0\">"
|
| + "<updatecheck tag=\"[^\"]*\"/>"
|
| + "<ping active=\"1\"/></app></request>";
|
| +
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + std::string content = service.GetPingContent(
|
| + "requestId", "sessionId", version_info::GetVersionNumber(),
|
| + GetChannelString(), base::Time::Now(), OmahaService::USAGE_PING);
|
| + regex_t regex;
|
| + regcomp(®ex, expectedResult, REG_NOSUB);
|
| + int result = regexec(®ex, content.c_str(), 0, NULL, 0);
|
| + regfree(®ex);
|
| + EXPECT_EQ(0, result);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, PingMessageTestWithUnknownInstallDate) {
|
| + const char* expectedResult =
|
| + "<request protocol=\"3.0\" version=\"iOS-1.0.0.0\" ismachine=\"1\" "
|
| + "requestid=\"requestId\" sessionid=\"sessionId\""
|
| + " hardware_class=\"[^\"]*\">"
|
| + "<os platform=\"ios\" version=\"[0-9][0-9]*\\(\\.[0-9][0-9]*\\)*\""
|
| + " arch=\"[^\"]*\"/>"
|
| + "<app version=\"[^\"]*\" nextversion=\"\" lang=\"[^\"]*\""
|
| + " brand=\"[A-Z][A-Z][A-Z][A-Z]\" client=\"\" appid=\"{[^}]*}\">"
|
| + "<updatecheck tag=\"[^\"]*\"/>"
|
| + "<ping active=\"1\"/></app></request>";
|
| +
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + std::string content = service.GetPingContent(
|
| + "requestId", "sessionId", version_info::GetVersionNumber(),
|
| + GetChannelString(),
|
| + base::Time::FromTimeT(install_time_util::kUnknownInstallDate),
|
| + OmahaService::USAGE_PING);
|
| + regex_t regex;
|
| + regcomp(®ex, expectedResult, REG_NOSUB);
|
| + int result = regexec(®ex, content.c_str(), 0, NULL, 0);
|
| + regfree(®ex);
|
| + EXPECT_EQ(0, result);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, InstallEventMessageTest) {
|
| + const char* kExpectedResultFormat =
|
| + "<request protocol=\"3.0\" version=\"iOS-1.0.0.0\" ismachine=\"1\" "
|
| + "requestid=\"requestId\" sessionid=\"sessionId\""
|
| + " hardware_class=\"[^\"]*\">"
|
| + "<os platform=\"ios\" version=\"[0-9][0-9]*(\\.[0-9][0-9]*)*\""
|
| + " arch=\"[^\"]*\"/>"
|
| + "<app version=\"%s\" nextversion=\"[^\"]*\" lang=\"[^\"]*\""
|
| + " brand=\"[A-Z][A-Z][A-Z][A-Z]\" client=\"\" appid=\"{[^}]*}\""
|
| + " installage=\"%d\">"
|
| + "<event eventtype=\"%d\" eventresult=\"1\"/>"
|
| + "</app></request>";
|
| +
|
| + // First install.
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, "");
|
| + std::string content = service.GetPingContent(
|
| + "requestId", "sessionId", version_info::GetVersionNumber(),
|
| + GetChannelString(), base::Time::Now(), OmahaService::INSTALL_EVENT);
|
| + regmatch_t matches[2];
|
| + regex_t regex;
|
| + std::string expected_result =
|
| + base::StringPrintf(kExpectedResultFormat, "" /* previous version */,
|
| + -1 /* install age */, 2 /* event type */);
|
| + regcomp(®ex, expected_result.c_str(), REG_EXTENDED);
|
| + int result = regexec(®ex, content.c_str(), arraysize(matches), matches, 0);
|
| + regfree(®ex);
|
| + EXPECT_EQ(0, result) << "Actual contents: " << content;
|
| + EXPECT_FALSE(NeedUpdate());
|
| +
|
| + // Update install.
|
| + const char* kPreviousVersion = "0.5";
|
| + CleanService(&service, kPreviousVersion);
|
| + content = service.GetPingContent(
|
| + "requestId", "sessionId", version_info::GetVersionNumber(),
|
| + GetChannelString(), base::Time::Now(), OmahaService::INSTALL_EVENT);
|
| + expected_result = base::StringPrintf(kExpectedResultFormat, kPreviousVersion,
|
| + 0 /* install age */, 3 /* event type */);
|
| + regcomp(®ex, expected_result.c_str(), REG_EXTENDED);
|
| + result = regexec(®ex, content.c_str(), arraysize(matches), matches, 0);
|
| + regfree(®ex);
|
| + EXPECT_EQ(0, result) << "Actual contents: " << content;
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, SendPingSuccess) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, version_info::GetVersionNumber());
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"56754\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<updatecheck status=\"noupdate\"/><ping status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(0, service.number_of_tries_);
|
| + EXPECT_FALSE(service.current_ping_time_.is_null());
|
| + EXPECT_EQ(service.current_ping_time_, service.next_tries_time_);
|
| + EXPECT_GT(service.last_sent_time_, now);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, SendInstallEventSuccess) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, "");
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"56754\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<event status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_FALSE(service.current_ping_time_.is_null());
|
| + EXPECT_GT(service.last_sent_time_, now);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, SendPingReceiveUpdate) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, version_info::GetVersionNumber());
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"56754\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<updatecheck status=\"ok\"><urls>"
|
| + "<url codebase=\"http://www.goo.fr/foo/\"/></urls>"
|
| + "<manifest version=\"0.0.1075.1441\">"
|
| + "<packages>"
|
| + "<package hash=\"0\" name=\"Chrome\" required=\"true\" size=\"0\"/>"
|
| + "</packages>"
|
| + "<actions>"
|
| + "<action event=\"update\" run=\"Chrome\"/>"
|
| + "<action event=\"postinstall\" osminversion=\"6.0\"/>"
|
| + "</actions>"
|
| + "</manifest>"
|
| + "</updatecheck><ping status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(0, service.number_of_tries_);
|
| + EXPECT_FALSE(service.current_ping_time_.is_null());
|
| + EXPECT_EQ(service.current_ping_time_, service.next_tries_time_);
|
| + EXPECT_GT(service.last_sent_time_, now);
|
| + EXPECT_TRUE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, SendPingFailure) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, version_info::GetVersionNumber());
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + // Tries with a non 200 result.
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| + base::Time next_tries_time = service.next_tries_time_;
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(400);
|
| + fetcher->SetResponseString("");
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_EQ(next_tries_time, service.next_tries_time_);
|
| + EXPECT_LT(service.last_sent_time_, now);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +
|
| + // Tries with an incorrect xml message.
|
| + service.SendPing();
|
| + EXPECT_EQ(2, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| + next_tries_time = service.next_tries_time_;
|
| +
|
| + fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + fetcher->SetResponseString("Incorrect Message");
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(2, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_EQ(next_tries_time, service.next_tries_time_);
|
| + EXPECT_LT(service.last_sent_time_, now);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, PersistStatesTest) {
|
| + std::string version_string = version_info::GetVersionNumber();
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + service.number_of_tries_ = 5;
|
| + service.last_sent_time_ = now - base::TimeDelta::FromSeconds(1);
|
| + service.next_tries_time_ = now + base::TimeDelta::FromSeconds(2);
|
| + service.current_ping_time_ = now + base::TimeDelta::FromSeconds(3);
|
| + service.last_sent_version_ = base::Version(version_string);
|
| + service.PersistStates();
|
| +
|
| + OmahaService service2(false);
|
| + EXPECT_EQ(service.number_of_tries_, 5);
|
| + EXPECT_EQ(service2.last_sent_time_, now - base::TimeDelta::FromSeconds(1));
|
| + EXPECT_EQ(service2.next_tries_time_, now + base::TimeDelta::FromSeconds(2));
|
| + EXPECT_EQ(service2.current_ping_time_, now + base::TimeDelta::FromSeconds(3));
|
| + EXPECT_EQ(service.last_sent_version_.GetString(), version_string);
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, BackoffTest) {
|
| + for (int i = 1; i < 100; ++i) {
|
| + // Testing multiple times for a given number of retries, as the method has
|
| + // a random part.
|
| + for (int j = 0; j < 2; ++j) {
|
| + EXPECT_GE(OmahaService::GetBackOff(i).InSeconds(), 3600 - 360);
|
| + EXPECT_LE(OmahaService::GetBackOff(i).InSeconds(), 6 * 3600);
|
| + }
|
| + }
|
| +}
|
| +
|
| +// Tests that an active ping is scheduled immediately after a successful install
|
| +// event send.
|
| +TEST_F(OmahaServiceTest, ActivePingAfterInstallEventTest) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, "");
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"0\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<event status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_LT(service.current_ping_time_ - now, base::TimeDelta::FromMinutes(1));
|
| + EXPECT_GT(service.next_tries_time_, service.current_ping_time_);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +// Tests that active pings are not sent in rapid succession.
|
| +TEST_F(OmahaServiceTest, NonSpammingTest) {
|
| + base::Time now = base::Time::Now();
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, version_info::GetVersionNumber());
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + service.SendPing();
|
| + EXPECT_EQ(1, service.number_of_tries_);
|
| + EXPECT_TRUE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_, now + base::TimeDelta::FromMinutes(54));
|
| + EXPECT_LE(service.next_tries_time_, now + base::TimeDelta::FromHours(7));
|
| +
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"0\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<updatecheck status=\"noupdate\"/><ping status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_EQ(0, service.number_of_tries_);
|
| + EXPECT_FALSE(service.current_ping_time_.is_null());
|
| + EXPECT_GE(service.next_tries_time_ - now, base::TimeDelta::FromHours(2));
|
| + EXPECT_GT(service.last_sent_time_, now);
|
| + EXPECT_FALSE(NeedUpdate());
|
| +}
|
| +
|
| +TEST_F(OmahaServiceTest, InstallRetryTest) {
|
| + OmahaService service(false);
|
| + service.set_upgrade_recommended_callback(
|
| + base::Bind(&OmahaServiceTest::OnNeedUpdate, base::Unretained(this)));
|
| + CleanService(&service, "");
|
| + net::TestURLFetcherFactory factory_;
|
| +
|
| + EXPECT_FALSE(service.IsNextPingInstallRetry());
|
| + std::string id1 = service.GetNextPingRequestId(OmahaService::INSTALL_EVENT);
|
| + EXPECT_TRUE(service.IsNextPingInstallRetry());
|
| + ASSERT_EQ(id1, service.GetNextPingRequestId(OmahaService::INSTALL_EVENT));
|
| +
|
| + service.SendPing();
|
| + net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| + DCHECK(fetcher);
|
| + DCHECK(fetcher->delegate());
|
| + fetcher->set_status(net::URLRequestStatus());
|
| + fetcher->set_response_code(200);
|
| + std::string response =
|
| + std::string(
|
| + "<?xml version=\"1.0\"?><response protocol=\"3.0\" server=\"prod\">"
|
| + "<daystart elapsed_seconds=\"56754\"/><app appid=\"") +
|
| + test_application_id_ +
|
| + "\" status=\"ok\">"
|
| + "<updatecheck status=\"noupdate\"/><ping status=\"ok\"/>"
|
| + "</app></response>";
|
| + fetcher->SetResponseString(response);
|
| + fetcher->delegate()->OnURLFetchComplete(fetcher);
|
| +
|
| + EXPECT_FALSE(service.IsNextPingInstallRetry());
|
| + id1 = service.GetNextPingRequestId(OmahaService::USAGE_PING);
|
| + ASSERT_NE(id1, service.GetNextPingRequestId(OmahaService::USAGE_PING));
|
| +}
|
|
|