content/browser/appcache/appcache_host_unittest.cc - chromium/src - Git at Google

 // 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 "content/browser/appcache/appcache_host.h"

 #include <stdint.h>

 #include <memory>

 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/test/scoped_task_environment.h"
 #include "content/browser/appcache/appcache.h"
 #include "content/browser/appcache/appcache_backend_impl.h"
 #include "content/browser/appcache/appcache_group.h"
 #include "content/browser/appcache/mock_appcache_policy.h"
 #include "content/browser/appcache/mock_appcache_service.h"
 #include "net/url_request/url_request.h"
 #include "storage/browser/quota/quota_manager.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "url/origin.h"

 namespace content {

 class AppCacheHostTest : public testing::Test {
  public:
   AppCacheHostTest() {
     get_status_callback_ = base::BindRepeating(
         &AppCacheHostTest::GetStatusCallback, base::Unretained(this));
   }

   class MockFrontend : public AppCacheFrontend {
    public:
     MockFrontend()
         : last_host_id_(-222),
           last_cache_id_(-222),
           last_status_(AppCacheStatus::APPCACHE_STATUS_OBSOLETE),
           last_status_changed_(AppCacheStatus::APPCACHE_STATUS_OBSOLETE),
           last_event_id_(AppCacheEventID::APPCACHE_OBSOLETE_EVENT),
           content_blocked_(false) {}

     void OnCacheSelected(int host_id, const AppCacheInfo& info) override {
       last_host_id_ = host_id;
       last_cache_id_ = info.cache_id;
       last_status_ = info.status;
     }

     void OnStatusChanged(const std::vector<int>& host_ids,
                          AppCacheStatus status) override {
       last_status_changed_ = status;
     }

     void OnEventRaised(const std::vector<int>& host_ids,
                        AppCacheEventID event_id) override {
       last_event_id_ = event_id;
     }

     void OnErrorEventRaised(const std::vector<int>& host_ids,
                             const AppCacheErrorDetails& details) override {
       last_event_id_ = AppCacheEventID::APPCACHE_ERROR_EVENT;
     }

     void OnProgressEventRaised(const std::vector<int>& host_ids,
                                const GURL& url,
                                int num_total,
                                int num_complete) override {
       last_event_id_ = AppCacheEventID::APPCACHE_PROGRESS_EVENT;
     }

     void OnLogMessage(int host_id,
                       AppCacheLogLevel log_level,
                       const std::string& message) override {}

     void OnContentBlocked(int host_id, const GURL& manifest_url) override {
       content_blocked_ = true;
     }

     void OnSetSubresourceFactory(
         int host_id,
         network::mojom::URLLoaderFactoryPtr url_loader_factory) override {}

     int last_host_id_;
     int64_t last_cache_id_;
     AppCacheStatus last_status_;
     AppCacheStatus last_status_changed_;
     AppCacheEventID last_event_id_;
     bool content_blocked_;
   };

   class MockQuotaManagerProxy : public storage::QuotaManagerProxy {
    public:
     MockQuotaManagerProxy() : QuotaManagerProxy(nullptr, nullptr) {}

     // Not needed for our tests.
     void RegisterClient(storage::QuotaClient* client) override {}
     void NotifyStorageAccessed(storage::QuotaClient::ID client_id,
                                const url::Origin& origin,
                                blink::mojom::StorageType type) override {}
     void NotifyStorageModified(storage::QuotaClient::ID client_id,
                                const url::Origin& origin,
                                blink::mojom::StorageType type,
                                int64_t delta) override {}
     void SetUsageCacheEnabled(storage::QuotaClient::ID client_id,
                               const url::Origin& origin,
                               blink::mojom::StorageType type,
                               bool enabled) override {}
     void GetUsageAndQuota(base::SequencedTaskRunner* original_task_runner,
                           const url::Origin& origin,
                           blink::mojom::StorageType type,
                           UsageAndQuotaCallback callback) override {}

     void NotifyOriginInUse(const url::Origin& origin) override {
       inuse_[origin] += 1;
     }

     void NotifyOriginNoLongerInUse(const url::Origin& origin) override {
       inuse_[origin] -= 1;
     }

     int GetInUseCount(const url::Origin& origin) { return inuse_[origin]; }

     void reset() {
       inuse_.clear();
     }

     // Map from origin to count of inuse notifications.
     std::map<url::Origin, int> inuse_;

    protected:
     ~MockQuotaManagerProxy() override {}
   };

   void GetStatusCallback(AppCacheStatus status) {
     last_status_result_ = status;
   }

   void StartUpdateCallback(bool result) { last_start_result_ = result; }

   void SwapCacheCallback(bool result) { last_swap_result_ = result; }

   base::test::ScopedTaskEnvironment scoped_task_environment_;

   // Mock classes for the 'host' to work with
   MockAppCacheService service_;
   MockFrontend mock_frontend_;

   // Mock callbacks we expect to receive from the 'host'
   content::GetStatusCallback get_status_callback_;

   AppCacheStatus last_status_result_;
   bool last_swap_result_;
   bool last_start_result_;
 };

 TEST_F(AppCacheHostTest, Basic) {
   // Construct a host and test what state it appears to be in.
   AppCacheHost host(1, &mock_frontend_, &service_);
   EXPECT_EQ(1, host.host_id());
   EXPECT_EQ(&service_, host.service());
   EXPECT_EQ(&mock_frontend_, host.frontend());
   EXPECT_EQ(nullptr, host.associated_cache());
   EXPECT_FALSE(host.is_selection_pending());

   // See that the callbacks are delivered immediately
   // and respond as if there is no cache selected.
   last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
   host.GetStatusWithCallback(std::move(get_status_callback_));
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);

   last_start_result_ = true;
   host.StartUpdateWithCallback(base::BindOnce(
       &AppCacheHostTest::StartUpdateCallback, base::Unretained(this)));
   EXPECT_FALSE(last_start_result_);

   last_swap_result_ = true;
   host.SwapCacheWithCallback(base::BindOnce(
       &AppCacheHostTest::SwapCacheCallback, base::Unretained(this)));
   EXPECT_FALSE(last_swap_result_);
 }

 TEST_F(AppCacheHostTest, SelectNoCache) {
   scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
       new MockQuotaManagerProxy);
   service_.set_quota_manager_proxy(mock_quota_proxy.get());

   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

   const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
   const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
   {
     AppCacheHost host(1, &mock_frontend_, &service_);
     host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL());
     EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

     // We should have received an OnCacheSelected msg
     EXPECT_EQ(1, mock_frontend_.last_host_id_);
     EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
     EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
               mock_frontend_.last_status_);

     // Otherwise, see that it respond as if there is no cache selected.
     EXPECT_EQ(1, host.host_id());
     EXPECT_EQ(&service_, host.service());
     EXPECT_EQ(&mock_frontend_, host.frontend());
     EXPECT_EQ(nullptr, host.associated_cache());
     EXPECT_FALSE(host.is_selection_pending());
     EXPECT_TRUE(host.preferred_manifest_url().is_empty());
   }
   EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
   service_.set_quota_manager_proxy(nullptr);
 }

 TEST_F(AppCacheHostTest, ForeignEntry) {
   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

   // Precondition, a cache with an entry that is not marked as foreign.
   const int kCacheId = 22;
   const GURL kDocumentURL("http://origin/document");
   scoped_refptr<AppCache> cache = new AppCache(service_.storage(), kCacheId);
   cache->AddEntry(kDocumentURL, AppCacheEntry(AppCacheEntry::EXPLICIT));

   AppCacheHost host(1, &mock_frontend_, &service_);
   host.MarkAsForeignEntry(kDocumentURL, kCacheId);

   // We should have received an OnCacheSelected msg for kAppCacheNoCacheId.
   EXPECT_EQ(1, mock_frontend_.last_host_id_);
   EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
             mock_frontend_.last_status_);

   // See that it respond as if there is no cache selected.
   EXPECT_EQ(1, host.host_id());
   EXPECT_EQ(&service_, host.service());
   EXPECT_EQ(&mock_frontend_, host.frontend());
   EXPECT_EQ(nullptr, host.associated_cache());
   EXPECT_FALSE(host.is_selection_pending());

   // See that the entry was marked as foreign.
   EXPECT_TRUE(cache->GetEntry(kDocumentURL)->IsForeign());
 }

 TEST_F(AppCacheHostTest, ForeignFallbackEntry) {
   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

   // Precondition, a cache with a fallback entry that is not marked as foreign.
   const int kCacheId = 22;
   const GURL kFallbackURL("http://origin/fallback_resource");
   scoped_refptr<AppCache> cache = new AppCache(service_.storage(), kCacheId);
   cache->AddEntry(kFallbackURL, AppCacheEntry(AppCacheEntry::FALLBACK));

   AppCacheHost host(1, &mock_frontend_, &service_);
   host.NotifyMainResourceIsNamespaceEntry(kFallbackURL);
   host.MarkAsForeignEntry(GURL("http://origin/missing_document"), kCacheId);

   // We should have received an OnCacheSelected msg for kAppCacheNoCacheId.
   EXPECT_EQ(1, mock_frontend_.last_host_id_);
   EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
             mock_frontend_.last_status_);

   // See that the fallback entry was marked as foreign.
   EXPECT_TRUE(cache->GetEntry(kFallbackURL)->IsForeign());
 }

 TEST_F(AppCacheHostTest, FailedCacheLoad) {
   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

   AppCacheHost host(1, &mock_frontend_, &service_);
   EXPECT_FALSE(host.is_selection_pending());

   const int kMockCacheId = 333;

   // Put it in a state where we're waiting on a cache
   // load prior to finishing cache selection.
   host.pending_selected_cache_id_ = kMockCacheId;
   EXPECT_TRUE(host.is_selection_pending());

   // The callback should not occur until we finish cache selection.
   last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
   host.GetStatusWithCallback(std::move(get_status_callback_));
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE, last_status_result_);

   // Satisfy the load with NULL, a failure.
   host.OnCacheLoaded(nullptr, kMockCacheId);

   // Cache selection should have finished
   EXPECT_FALSE(host.is_selection_pending());
   EXPECT_EQ(1, mock_frontend_.last_host_id_);
   EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
             mock_frontend_.last_status_);

   // Callback should have fired upon completing the cache load too.
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);
 }

 TEST_F(AppCacheHostTest, FailedGroupLoad) {
   AppCacheHost host(1, &mock_frontend_, &service_);

   const GURL kMockManifestUrl("http://foo.bar/baz");

   // Put it in a state where we're waiting on a cache
   // load prior to finishing cache selection.
   host.pending_selected_manifest_url_ = kMockManifestUrl;
   EXPECT_TRUE(host.is_selection_pending());

   // The callback should not occur until we finish cache selection.
   last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
   host.GetStatusWithCallback(std::move(get_status_callback_));
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE, last_status_result_);

   // Satisfy the load will NULL, a failure.
   host.OnGroupLoaded(nullptr, kMockManifestUrl);

   // Cache selection should have finished
   EXPECT_FALSE(host.is_selection_pending());
   EXPECT_EQ(1, mock_frontend_.last_host_id_);
   EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
             mock_frontend_.last_status_);

   // Callback should have fired upon completing the group load.
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);
 }

 TEST_F(AppCacheHostTest, SetSwappableCache) {
   AppCacheHost host(1, &mock_frontend_, &service_);
   host.SetSwappableCache(nullptr);
   EXPECT_FALSE(host.swappable_cache_.get());

   scoped_refptr<AppCacheGroup> group1(new AppCacheGroup(
       service_.storage(), GURL(), service_.storage()->NewGroupId()));
   host.SetSwappableCache(group1.get());
   EXPECT_FALSE(host.swappable_cache_.get());

   AppCache* cache1 = new AppCache(service_.storage(), 111);
   cache1->set_complete(true);
   group1->AddCache(cache1);
   host.SetSwappableCache(group1.get());
   EXPECT_EQ(cache1, host.swappable_cache_.get());

   mock_frontend_.last_host_id_ = -222;  // to verify we received OnCacheSelected

   host.AssociateCompleteCache(cache1);
   EXPECT_FALSE(host.swappable_cache_.get());  // was same as associated cache
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_IDLE, host.GetStatus());
   // verify OnCacheSelected was called
   EXPECT_EQ(host.host_id(), mock_frontend_.last_host_id_);
   EXPECT_EQ(cache1->cache_id(), mock_frontend_.last_cache_id_);
   EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_IDLE, mock_frontend_.last_status_);

   AppCache* cache2 = new AppCache(service_.storage(), 222);
   cache2->set_complete(true);
   group1->AddCache(cache2);
   EXPECT_EQ(cache2, host.swappable_cache_.get());  // updated to newest

   scoped_refptr<AppCacheGroup> group2(
       new AppCacheGroup(service_.storage(), GURL("http://foo.com"),
                         service_.storage()->NewGroupId()));
   AppCache* cache3 = new AppCache(service_.storage(), 333);
   cache3->set_complete(true);
   group2->AddCache(cache3);

   AppCache* cache4 = new AppCache(service_.storage(), 444);
   cache4->set_complete(true);
   group2->AddCache(cache4);
   EXPECT_EQ(cache2, host.swappable_cache_.get());  // unchanged

   host.AssociateCompleteCache(cache3);
   EXPECT_EQ(cache4, host.swappable_cache_.get());  // newest cache in group2
   EXPECT_FALSE(group1->HasCache());  // both caches in group1 have refcount 0

   host.AssociateNoCache(GURL());
   EXPECT_FALSE(host.swappable_cache_.get());
   EXPECT_FALSE(group2->HasCache());  // both caches in group2 have refcount 0

   // Host adds reference to newest cache when an update is complete.
   AppCache* cache5 = new AppCache(service_.storage(), 555);
   cache5->set_complete(true);
   group2->AddCache(cache5);
   host.group_being_updated_ = group2;
   host.OnUpdateComplete(group2.get());
   EXPECT_FALSE(host.group_being_updated_.get());
   EXPECT_EQ(cache5, host.swappable_cache_.get());

   group2->RemoveCache(cache5);
   EXPECT_FALSE(group2->HasCache());
   host.group_being_updated_ = group2;
   host.OnUpdateComplete(group2.get());
   EXPECT_FALSE(host.group_being_updated_.get());
   EXPECT_FALSE(host.swappable_cache_.get());  // group2 had no newest cache
 }

 TEST_F(AppCacheHostTest, SelectCacheAllowed) {
   scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
       new MockQuotaManagerProxy);
   MockAppCachePolicy mock_appcache_policy;
   mock_appcache_policy.can_create_return_value_ = true;
   service_.set_quota_manager_proxy(mock_quota_proxy.get());
   service_.set_appcache_policy(&mock_appcache_policy);

   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
   mock_frontend_.last_event_id_ = AppCacheEventID::APPCACHE_OBSOLETE_EVENT;
   mock_frontend_.content_blocked_ = false;

   const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
   const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
   const GURL kManifestUrl(GURL("http://whatever/cache.manifest"));
   {
     AppCacheHost host(1, &mock_frontend_, &service_);
     host.first_party_url_ = kDocAndOriginUrl;
     host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, kManifestUrl);
     EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

     // MockAppCacheService::LoadOrCreateGroup is asynchronous, so we shouldn't
     // have received an OnCacheSelected msg yet.
     EXPECT_EQ(-333, mock_frontend_.last_host_id_);
     EXPECT_EQ(-333, mock_frontend_.last_cache_id_);
     EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE,
               mock_frontend_.last_status_);
     // No error events either
     EXPECT_EQ(AppCacheEventID::APPCACHE_OBSOLETE_EVENT,
               mock_frontend_.last_event_id_);
     EXPECT_FALSE(mock_frontend_.content_blocked_);

     EXPECT_TRUE(host.is_selection_pending());
   }
   EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
   service_.set_quota_manager_proxy(nullptr);
 }

 TEST_F(AppCacheHostTest, SelectCacheBlocked) {
   scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
       new MockQuotaManagerProxy);
   MockAppCachePolicy mock_appcache_policy;
   mock_appcache_policy.can_create_return_value_ = false;
   service_.set_quota_manager_proxy(mock_quota_proxy.get());
   service_.set_appcache_policy(&mock_appcache_policy);

   // Reset our mock frontend
   mock_frontend_.last_cache_id_ = -333;
   mock_frontend_.last_host_id_ = -333;
   mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
   mock_frontend_.last_event_id_ = AppCacheEventID::APPCACHE_OBSOLETE_EVENT;
   mock_frontend_.content_blocked_ = false;

   const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
   const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
   const GURL kManifestUrl(GURL("http://whatever/cache.manifest"));
   {
     AppCacheHost host(1, &mock_frontend_, &service_);
     host.first_party_url_ = kDocAndOriginUrl;
     host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, kManifestUrl);
     EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

     // We should have received an OnCacheSelected msg
     EXPECT_EQ(1, mock_frontend_.last_host_id_);
     EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
     EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
               mock_frontend_.last_status_);

     // Also, an error event was raised
     EXPECT_EQ(AppCacheEventID::APPCACHE_ERROR_EVENT,
               mock_frontend_.last_event_id_);
     EXPECT_TRUE(mock_frontend_.content_blocked_);

     // Otherwise, see that it respond as if there is no cache selected.
     EXPECT_EQ(1, host.host_id());
     EXPECT_EQ(&service_, host.service());
     EXPECT_EQ(&mock_frontend_, host.frontend());
     EXPECT_EQ(nullptr, host.associated_cache());
     EXPECT_FALSE(host.is_selection_pending());
     EXPECT_TRUE(host.preferred_manifest_url().is_empty());
   }
   EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
   service_.set_quota_manager_proxy(nullptr);
 }

 TEST_F(AppCacheHostTest, SelectCacheTwice) {
   AppCacheHost host(1, &mock_frontend_, &service_);
   const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());

   EXPECT_TRUE(host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL()));

   // Select methods should bail if cache has already been selected.
   EXPECT_FALSE(host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL()));
   EXPECT_FALSE(host.SelectCacheForSharedWorker(kAppCacheNoCacheId));
   EXPECT_FALSE(host.MarkAsForeignEntry(kDocAndOriginUrl, kAppCacheNoCacheId));
 }

 }  // namespace content
	// 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 "content/browser/appcache/appcache_host.h"

	#include <stdint.h>

	#include <memory>

	#include "base/bind.h"
	#include "base/bind_helpers.h"
	#include "base/test/scoped_task_environment.h"
	#include "content/browser/appcache/appcache.h"
	#include "content/browser/appcache/appcache_backend_impl.h"
	#include "content/browser/appcache/appcache_group.h"
	#include "content/browser/appcache/mock_appcache_policy.h"
	#include "content/browser/appcache/mock_appcache_service.h"
	#include "net/url_request/url_request.h"
	#include "storage/browser/quota/quota_manager.h"
	#include "testing/gtest/include/gtest/gtest.h"
	#include "url/origin.h"

	namespace content {

	class AppCacheHostTest : public testing::Test {
	public:
	AppCacheHostTest() {
	get_status_callback_ = base::BindRepeating(
	&AppCacheHostTest::GetStatusCallback, base::Unretained(this));
	}

	class MockFrontend : public AppCacheFrontend {
	public:
	MockFrontend()
	: last_host_id_(-222),
	last_cache_id_(-222),
	last_status_(AppCacheStatus::APPCACHE_STATUS_OBSOLETE),
	last_status_changed_(AppCacheStatus::APPCACHE_STATUS_OBSOLETE),
	last_event_id_(AppCacheEventID::APPCACHE_OBSOLETE_EVENT),
	content_blocked_(false) {}

	void OnCacheSelected(int host_id, const AppCacheInfo& info) override {
	last_host_id_ = host_id;
	last_cache_id_ = info.cache_id;
	last_status_ = info.status;
	}

	void OnStatusChanged(const std::vector<int>& host_ids,
	AppCacheStatus status) override {
	last_status_changed_ = status;
	}

	void OnEventRaised(const std::vector<int>& host_ids,
	AppCacheEventID event_id) override {
	last_event_id_ = event_id;
	}

	void OnErrorEventRaised(const std::vector<int>& host_ids,
	const AppCacheErrorDetails& details) override {
	last_event_id_ = AppCacheEventID::APPCACHE_ERROR_EVENT;
	}

	void OnProgressEventRaised(const std::vector<int>& host_ids,
	const GURL& url,
	int num_total,
	int num_complete) override {
	last_event_id_ = AppCacheEventID::APPCACHE_PROGRESS_EVENT;
	}

	void OnLogMessage(int host_id,
	AppCacheLogLevel log_level,
	const std::string& message) override {}

	void OnContentBlocked(int host_id, const GURL& manifest_url) override {
	content_blocked_ = true;
	}

	void OnSetSubresourceFactory(
	int host_id,
	network::mojom::URLLoaderFactoryPtr url_loader_factory) override {}

	int last_host_id_;
	int64_t last_cache_id_;
	AppCacheStatus last_status_;
	AppCacheStatus last_status_changed_;
	AppCacheEventID last_event_id_;
	bool content_blocked_;
	};

	class MockQuotaManagerProxy : public storage::QuotaManagerProxy {
	public:
	MockQuotaManagerProxy() : QuotaManagerProxy(nullptr, nullptr) {}

	// Not needed for our tests.
	void RegisterClient(storage::QuotaClient* client) override {}
	void NotifyStorageAccessed(storage::QuotaClient::ID client_id,
	const url::Origin& origin,
	blink::mojom::StorageType type) override {}
	void NotifyStorageModified(storage::QuotaClient::ID client_id,
	const url::Origin& origin,
	blink::mojom::StorageType type,
	int64_t delta) override {}
	void SetUsageCacheEnabled(storage::QuotaClient::ID client_id,
	const url::Origin& origin,
	blink::mojom::StorageType type,
	bool enabled) override {}
	void GetUsageAndQuota(base::SequencedTaskRunner* original_task_runner,
	const url::Origin& origin,
	blink::mojom::StorageType type,
	UsageAndQuotaCallback callback) override {}

	void NotifyOriginInUse(const url::Origin& origin) override {
	inuse_[origin] += 1;
	}

	void NotifyOriginNoLongerInUse(const url::Origin& origin) override {
	inuse_[origin] -= 1;
	}

	int GetInUseCount(const url::Origin& origin) { return inuse_[origin]; }

	void reset() {
	inuse_.clear();
	}

	// Map from origin to count of inuse notifications.
	std::map<url::Origin, int> inuse_;

	protected:
	~MockQuotaManagerProxy() override {}
	};

	void GetStatusCallback(AppCacheStatus status) {
	last_status_result_ = status;
	}

	void StartUpdateCallback(bool result) { last_start_result_ = result; }

	void SwapCacheCallback(bool result) { last_swap_result_ = result; }

	base::test::ScopedTaskEnvironment scoped_task_environment_;

	// Mock classes for the 'host' to work with
	MockAppCacheService service_;
	MockFrontend mock_frontend_;

	// Mock callbacks we expect to receive from the 'host'
	content::GetStatusCallback get_status_callback_;

	AppCacheStatus last_status_result_;
	bool last_swap_result_;
	bool last_start_result_;
	};

	TEST_F(AppCacheHostTest, Basic) {
	// Construct a host and test what state it appears to be in.
	AppCacheHost host(1, &mock_frontend_, &service_);
	EXPECT_EQ(1, host.host_id());
	EXPECT_EQ(&service_, host.service());
	EXPECT_EQ(&mock_frontend_, host.frontend());
	EXPECT_EQ(nullptr, host.associated_cache());
	EXPECT_FALSE(host.is_selection_pending());

	// See that the callbacks are delivered immediately
	// and respond as if there is no cache selected.
	last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
	host.GetStatusWithCallback(std::move(get_status_callback_));
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);

	last_start_result_ = true;
	host.StartUpdateWithCallback(base::BindOnce(
	&AppCacheHostTest::StartUpdateCallback, base::Unretained(this)));
	EXPECT_FALSE(last_start_result_);

	last_swap_result_ = true;
	host.SwapCacheWithCallback(base::BindOnce(
	&AppCacheHostTest::SwapCacheCallback, base::Unretained(this)));
	EXPECT_FALSE(last_swap_result_);
	}

	TEST_F(AppCacheHostTest, SelectNoCache) {
	scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
	new MockQuotaManagerProxy);
	service_.set_quota_manager_proxy(mock_quota_proxy.get());

	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

	const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
	const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
	{
	AppCacheHost host(1, &mock_frontend_, &service_);
	host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL());
	EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

	// We should have received an OnCacheSelected msg
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// Otherwise, see that it respond as if there is no cache selected.
	EXPECT_EQ(1, host.host_id());
	EXPECT_EQ(&service_, host.service());
	EXPECT_EQ(&mock_frontend_, host.frontend());
	EXPECT_EQ(nullptr, host.associated_cache());
	EXPECT_FALSE(host.is_selection_pending());
	EXPECT_TRUE(host.preferred_manifest_url().is_empty());
	}
	EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
	service_.set_quota_manager_proxy(nullptr);
	}

	TEST_F(AppCacheHostTest, ForeignEntry) {
	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

	// Precondition, a cache with an entry that is not marked as foreign.
	const int kCacheId = 22;
	const GURL kDocumentURL("http://origin/document");
	scoped_refptr<AppCache> cache = new AppCache(service_.storage(), kCacheId);
	cache->AddEntry(kDocumentURL, AppCacheEntry(AppCacheEntry::EXPLICIT));

	AppCacheHost host(1, &mock_frontend_, &service_);
	host.MarkAsForeignEntry(kDocumentURL, kCacheId);

	// We should have received an OnCacheSelected msg for kAppCacheNoCacheId.
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// See that it respond as if there is no cache selected.
	EXPECT_EQ(1, host.host_id());
	EXPECT_EQ(&service_, host.service());
	EXPECT_EQ(&mock_frontend_, host.frontend());
	EXPECT_EQ(nullptr, host.associated_cache());
	EXPECT_FALSE(host.is_selection_pending());

	// See that the entry was marked as foreign.
	EXPECT_TRUE(cache->GetEntry(kDocumentURL)->IsForeign());
	}

	TEST_F(AppCacheHostTest, ForeignFallbackEntry) {
	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

	// Precondition, a cache with a fallback entry that is not marked as foreign.
	const int kCacheId = 22;
	const GURL kFallbackURL("http://origin/fallback_resource");
	scoped_refptr<AppCache> cache = new AppCache(service_.storage(), kCacheId);
	cache->AddEntry(kFallbackURL, AppCacheEntry(AppCacheEntry::FALLBACK));

	AppCacheHost host(1, &mock_frontend_, &service_);
	host.NotifyMainResourceIsNamespaceEntry(kFallbackURL);
	host.MarkAsForeignEntry(GURL("http://origin/missing_document"), kCacheId);

	// We should have received an OnCacheSelected msg for kAppCacheNoCacheId.
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// See that the fallback entry was marked as foreign.
	EXPECT_TRUE(cache->GetEntry(kFallbackURL)->IsForeign());
	}

	TEST_F(AppCacheHostTest, FailedCacheLoad) {
	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;

	AppCacheHost host(1, &mock_frontend_, &service_);
	EXPECT_FALSE(host.is_selection_pending());

	const int kMockCacheId = 333;

	// Put it in a state where we're waiting on a cache
	// load prior to finishing cache selection.
	host.pending_selected_cache_id_ = kMockCacheId;
	EXPECT_TRUE(host.is_selection_pending());

	// The callback should not occur until we finish cache selection.
	last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
	host.GetStatusWithCallback(std::move(get_status_callback_));
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE, last_status_result_);

	// Satisfy the load with NULL, a failure.
	host.OnCacheLoaded(nullptr, kMockCacheId);

	// Cache selection should have finished
	EXPECT_FALSE(host.is_selection_pending());
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// Callback should have fired upon completing the cache load too.
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);
	}

	TEST_F(AppCacheHostTest, FailedGroupLoad) {
	AppCacheHost host(1, &mock_frontend_, &service_);

	const GURL kMockManifestUrl("http://foo.bar/baz");

	// Put it in a state where we're waiting on a cache
	// load prior to finishing cache selection.
	host.pending_selected_manifest_url_ = kMockManifestUrl;
	EXPECT_TRUE(host.is_selection_pending());

	// The callback should not occur until we finish cache selection.
	last_status_result_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
	host.GetStatusWithCallback(std::move(get_status_callback_));
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE, last_status_result_);

	// Satisfy the load will NULL, a failure.
	host.OnGroupLoaded(nullptr, kMockManifestUrl);

	// Cache selection should have finished
	EXPECT_FALSE(host.is_selection_pending());
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// Callback should have fired upon completing the group load.
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED, last_status_result_);
	}

	TEST_F(AppCacheHostTest, SetSwappableCache) {
	AppCacheHost host(1, &mock_frontend_, &service_);
	host.SetSwappableCache(nullptr);
	EXPECT_FALSE(host.swappable_cache_.get());

	scoped_refptr<AppCacheGroup> group1(new AppCacheGroup(
	service_.storage(), GURL(), service_.storage()->NewGroupId()));
	host.SetSwappableCache(group1.get());
	EXPECT_FALSE(host.swappable_cache_.get());

	AppCache* cache1 = new AppCache(service_.storage(), 111);
	cache1->set_complete(true);
	group1->AddCache(cache1);
	host.SetSwappableCache(group1.get());
	EXPECT_EQ(cache1, host.swappable_cache_.get());

	mock_frontend_.last_host_id_ = -222; // to verify we received OnCacheSelected

	host.AssociateCompleteCache(cache1);
	EXPECT_FALSE(host.swappable_cache_.get()); // was same as associated cache
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_IDLE, host.GetStatus());
	// verify OnCacheSelected was called
	EXPECT_EQ(host.host_id(), mock_frontend_.last_host_id_);
	EXPECT_EQ(cache1->cache_id(), mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_IDLE, mock_frontend_.last_status_);

	AppCache* cache2 = new AppCache(service_.storage(), 222);
	cache2->set_complete(true);
	group1->AddCache(cache2);
	EXPECT_EQ(cache2, host.swappable_cache_.get()); // updated to newest

	scoped_refptr<AppCacheGroup> group2(
	new AppCacheGroup(service_.storage(), GURL("http://foo.com"),
	service_.storage()->NewGroupId()));
	AppCache* cache3 = new AppCache(service_.storage(), 333);
	cache3->set_complete(true);
	group2->AddCache(cache3);

	AppCache* cache4 = new AppCache(service_.storage(), 444);
	cache4->set_complete(true);
	group2->AddCache(cache4);
	EXPECT_EQ(cache2, host.swappable_cache_.get()); // unchanged

	host.AssociateCompleteCache(cache3);
	EXPECT_EQ(cache4, host.swappable_cache_.get()); // newest cache in group2
	EXPECT_FALSE(group1->HasCache()); // both caches in group1 have refcount 0

	host.AssociateNoCache(GURL());
	EXPECT_FALSE(host.swappable_cache_.get());
	EXPECT_FALSE(group2->HasCache()); // both caches in group2 have refcount 0

	// Host adds reference to newest cache when an update is complete.
	AppCache* cache5 = new AppCache(service_.storage(), 555);
	cache5->set_complete(true);
	group2->AddCache(cache5);
	host.group_being_updated_ = group2;
	host.OnUpdateComplete(group2.get());
	EXPECT_FALSE(host.group_being_updated_.get());
	EXPECT_EQ(cache5, host.swappable_cache_.get());

	group2->RemoveCache(cache5);
	EXPECT_FALSE(group2->HasCache());
	host.group_being_updated_ = group2;
	host.OnUpdateComplete(group2.get());
	EXPECT_FALSE(host.group_being_updated_.get());
	EXPECT_FALSE(host.swappable_cache_.get()); // group2 had no newest cache
	}

	TEST_F(AppCacheHostTest, SelectCacheAllowed) {
	scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
	new MockQuotaManagerProxy);
	MockAppCachePolicy mock_appcache_policy;
	mock_appcache_policy.can_create_return_value_ = true;
	service_.set_quota_manager_proxy(mock_quota_proxy.get());
	service_.set_appcache_policy(&mock_appcache_policy);

	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
	mock_frontend_.last_event_id_ = AppCacheEventID::APPCACHE_OBSOLETE_EVENT;
	mock_frontend_.content_blocked_ = false;

	const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
	const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
	const GURL kManifestUrl(GURL("http://whatever/cache.manifest"));
	{
	AppCacheHost host(1, &mock_frontend_, &service_);
	host.first_party_url_ = kDocAndOriginUrl;
	host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, kManifestUrl);
	EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

	// MockAppCacheService::LoadOrCreateGroup is asynchronous, so we shouldn't
	// have received an OnCacheSelected msg yet.
	EXPECT_EQ(-333, mock_frontend_.last_host_id_);
	EXPECT_EQ(-333, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_OBSOLETE,
	mock_frontend_.last_status_);
	// No error events either
	EXPECT_EQ(AppCacheEventID::APPCACHE_OBSOLETE_EVENT,
	mock_frontend_.last_event_id_);
	EXPECT_FALSE(mock_frontend_.content_blocked_);

	EXPECT_TRUE(host.is_selection_pending());
	}
	EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
	service_.set_quota_manager_proxy(nullptr);
	}

	TEST_F(AppCacheHostTest, SelectCacheBlocked) {
	scoped_refptr<MockQuotaManagerProxy> mock_quota_proxy(
	new MockQuotaManagerProxy);
	MockAppCachePolicy mock_appcache_policy;
	mock_appcache_policy.can_create_return_value_ = false;
	service_.set_quota_manager_proxy(mock_quota_proxy.get());
	service_.set_appcache_policy(&mock_appcache_policy);

	// Reset our mock frontend
	mock_frontend_.last_cache_id_ = -333;
	mock_frontend_.last_host_id_ = -333;
	mock_frontend_.last_status_ = AppCacheStatus::APPCACHE_STATUS_OBSOLETE;
	mock_frontend_.last_event_id_ = AppCacheEventID::APPCACHE_OBSOLETE_EVENT;
	mock_frontend_.content_blocked_ = false;

	const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());
	const url::Origin kOrigin(url::Origin::Create(kDocAndOriginUrl));
	const GURL kManifestUrl(GURL("http://whatever/cache.manifest"));
	{
	AppCacheHost host(1, &mock_frontend_, &service_);
	host.first_party_url_ = kDocAndOriginUrl;
	host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, kManifestUrl);
	EXPECT_EQ(1, mock_quota_proxy->GetInUseCount(kOrigin));

	// We should have received an OnCacheSelected msg
	EXPECT_EQ(1, mock_frontend_.last_host_id_);
	EXPECT_EQ(kAppCacheNoCacheId, mock_frontend_.last_cache_id_);
	EXPECT_EQ(AppCacheStatus::APPCACHE_STATUS_UNCACHED,
	mock_frontend_.last_status_);

	// Also, an error event was raised
	EXPECT_EQ(AppCacheEventID::APPCACHE_ERROR_EVENT,
	mock_frontend_.last_event_id_);
	EXPECT_TRUE(mock_frontend_.content_blocked_);

	// Otherwise, see that it respond as if there is no cache selected.
	EXPECT_EQ(1, host.host_id());
	EXPECT_EQ(&service_, host.service());
	EXPECT_EQ(&mock_frontend_, host.frontend());
	EXPECT_EQ(nullptr, host.associated_cache());
	EXPECT_FALSE(host.is_selection_pending());
	EXPECT_TRUE(host.preferred_manifest_url().is_empty());
	}
	EXPECT_EQ(0, mock_quota_proxy->GetInUseCount(kOrigin));
	service_.set_quota_manager_proxy(nullptr);
	}

	TEST_F(AppCacheHostTest, SelectCacheTwice) {
	AppCacheHost host(1, &mock_frontend_, &service_);
	const GURL kDocAndOriginUrl(GURL("http://whatever/").GetOrigin());

	EXPECT_TRUE(host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL()));

	// Select methods should bail if cache has already been selected.
	EXPECT_FALSE(host.SelectCache(kDocAndOriginUrl, kAppCacheNoCacheId, GURL()));
	EXPECT_FALSE(host.SelectCacheForSharedWorker(kAppCacheNoCacheId));
	EXPECT_FALSE(host.MarkAsForeignEntry(kDocAndOriginUrl, kAppCacheNoCacheId));
	}

	} // namespace content