| OLD | NEW |
|---|
| (Empty) |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "components/offline_pages/background/change_requests_state_task.h" | |
| 6 | |
| 7 #include <memory> | |
| 8 | |
| 9 #include "base/bind.h" | |
| 10 #include "base/test/test_simple_task_runner.h" | |
| 11 #include "base/threading/thread_task_runner_handle.h" | |
| 12 #include "components/offline_pages/background/request_queue_in_memory_store.h" | |
| 13 #include "testing/gtest/include/gtest/gtest.h" | |
| 14 | |
| 15 namespace offline_pages { | |
| 16 namespace { | |
| 17 const int64_t kRequestId1 = 42; | |
| 18 const int64_t kRequestId2 = 43; | |
| 19 const int64_t kRequestId3 = 44; | |
| 20 const GURL kUrl1("http://example.com"); | |
| 21 const GURL kUrl2("http://another-example.com"); | |
| 22 const ClientId kClientId1("bookmark", "1234"); | |
| 23 const ClientId kClientId2("async", "5678"); | |
| 24 } // namespace | |
| 25 | |
| 26 class ChangeRequestsStateTaskTest : public testing::Test { | |
| 27 public: | |
| 28 ChangeRequestsStateTaskTest(); | |
| 29 ~ChangeRequestsStateTaskTest() override; | |
| 30 | |
| 31 void PumpLoop(); | |
| 32 | |
| 33 void InitializeStore(RequestQueueStore* store); | |
| 34 void AddItemsToStore(RequestQueueStore* store); | |
| 35 void ChangeRequestsStateCallback( | |
| 36 std::unique_ptr<UpdateRequestsResult> result); | |
| 37 | |
| 38 UpdateRequestsResult* last_result() const { return result_.get(); } | |
| 39 | |
| 40 private: | |
| 41 void InitializeStoreDone(bool success); | |
| 42 void AddRequestDone(ItemActionStatus status); | |
| 43 | |
| 44 std::unique_ptr<UpdateRequestsResult> result_; | |
| 45 scoped_refptr<base::TestSimpleTaskRunner> task_runner_; | |
| 46 base::ThreadTaskRunnerHandle task_runner_handle_; | |
| 47 }; | |
| 48 | |
| 49 ChangeRequestsStateTaskTest::ChangeRequestsStateTaskTest() | |
| 50 : task_runner_(new base::TestSimpleTaskRunner), | |
| 51 task_runner_handle_(task_runner_) {} | |
| 52 | |
| 53 ChangeRequestsStateTaskTest::~ChangeRequestsStateTaskTest() {} | |
| 54 | |
| 55 void ChangeRequestsStateTaskTest::PumpLoop() { | |
| 56 task_runner_->RunUntilIdle(); | |
| 57 } | |
| 58 | |
| 59 void ChangeRequestsStateTaskTest::InitializeStore(RequestQueueStore* store) { | |
| 60 store->Initialize( | |
| 61 base::Bind(&ChangeRequestsStateTaskTest::InitializeStoreDone, | |
| 62 base::Unretained(this))); | |
| 63 PumpLoop(); | |
| 64 } | |
| 65 | |
| 66 void ChangeRequestsStateTaskTest::AddItemsToStore(RequestQueueStore* store) { | |
| 67 base::Time creation_time = base::Time::Now(); | |
| 68 SavePageRequest request_1(kRequestId1, kUrl1, kClientId1, creation_time, | |
| 69 true); | |
| 70 store->AddRequest(request_1, | |
| 71 base::Bind(&ChangeRequestsStateTaskTest::AddRequestDone, | |
| 72 base::Unretained(this))); | |
| 73 SavePageRequest request_2(kRequestId2, kUrl2, kClientId2, creation_time, | |
| 74 true); | |
| 75 store->AddRequest(request_2, | |
| 76 base::Bind(&ChangeRequestsStateTaskTest::AddRequestDone, | |
| 77 base::Unretained(this))); | |
| 78 PumpLoop(); | |
| 79 } | |
| 80 | |
| 81 void ChangeRequestsStateTaskTest::ChangeRequestsStateCallback( | |
| 82 std::unique_ptr<UpdateRequestsResult> result) { | |
| 83 result_ = std::move(result); | |
| 84 } | |
| 85 | |
| 86 void ChangeRequestsStateTaskTest::InitializeStoreDone(bool success) { | |
| 87 ASSERT_TRUE(success); | |
| 88 } | |
| 89 | |
| 90 void ChangeRequestsStateTaskTest::AddRequestDone(ItemActionStatus status) { | |
| 91 ASSERT_EQ(ItemActionStatus::SUCCESS, status); | |
| 92 } | |
| 93 | |
| 94 TEST_F(ChangeRequestsStateTaskTest, UpdateWhenStoreEmpty) { | |
| 95 RequestQueueInMemoryStore store; | |
| 96 InitializeStore(&store); | |
| 97 | |
| 98 std::vector<int64_t> request_ids{kRequestId1}; | |
| 99 ChangeRequestsStateTask task( | |
| 100 &store, request_ids, SavePageRequest::RequestState::PAUSED, | |
| 101 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | |
| 102 base::Unretained(this))); | |
| 103 task.Run(); | |
| 104 PumpLoop(); | |
| 105 ASSERT_TRUE(last_result()); | |
| 106 EXPECT_EQ(1UL, last_result()->item_statuses.size()); | |
| 107 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); | |
| 108 EXPECT_EQ(ItemActionStatus::NOT_FOUND, | |
| 109 last_result()->item_statuses.at(0).second); | |
| 110 EXPECT_EQ(0UL, last_result()->updated_items.size()); | |
| 111 } | |
| 112 | |
| 113 TEST_F(ChangeRequestsStateTaskTest, UpdateSingleItem) { | |
| 114 RequestQueueInMemoryStore store; | |
| 115 InitializeStore(&store); | |
| 116 AddItemsToStore(&store); | |
| 117 | |
| 118 std::vector<int64_t> request_ids{kRequestId1}; | |
| 119 ChangeRequestsStateTask task( | |
| 120 &store, request_ids, SavePageRequest::RequestState::PAUSED, | |
| 121 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | |
| 122 base::Unretained(this))); | |
| 123 task.Run(); | |
| 124 PumpLoop(); | |
| 125 ASSERT_TRUE(last_result()); | |
| 126 EXPECT_EQ(1UL, last_result()->item_statuses.size()); | |
| 127 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); | |
| 128 EXPECT_EQ(ItemActionStatus::SUCCESS, | |
| 129 last_result()->item_statuses.at(0).second); | |
| 130 EXPECT_EQ(1UL, last_result()->updated_items.size()); | |
| 131 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | |
| 132 last_result()->updated_items.at(0).request_state()); | |
| 133 } | |
| 134 | |
| 135 TEST_F(ChangeRequestsStateTaskTest, UpdateMultipleItems) { | |
| 136 RequestQueueInMemoryStore store; | |
| 137 InitializeStore(&store); | |
| 138 AddItemsToStore(&store); | |
| 139 | |
| 140 std::vector<int64_t> request_ids{kRequestId1, kRequestId2}; | |
| 141 ChangeRequestsStateTask task( | |
| 142 &store, request_ids, SavePageRequest::RequestState::PAUSED, | |
| 143 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | |
| 144 base::Unretained(this))); | |
| 145 task.Run(); | |
| 146 PumpLoop(); | |
| 147 ASSERT_TRUE(last_result()); | |
| 148 ASSERT_EQ(2UL, last_result()->item_statuses.size()); | |
| 149 | |
| 150 // Calculating the position of the items in the vector here, because it does | |
| 151 // not matter, and might be platform dependent. | |
| 152 // |index_id_1| is expected to correspond to |kRequestId1|. | |
| 153 int index_id_1 = | |
| 154 last_result()->item_statuses.at(0).first == kRequestId1 ? 0 : 1; | |
| 155 // |index_id_2| is expected to correspond to |kRequestId2|. | |
| 156 int index_id_2 = 1 - index_id_1; | |
| 157 | |
| 158 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(index_id_1).first); | |
| 159 EXPECT_EQ(ItemActionStatus::SUCCESS, | |
| 160 last_result()->item_statuses.at(index_id_1).second); | |
| 161 EXPECT_EQ(kRequestId2, last_result()->item_statuses.at(index_id_2).first); | |
| 162 EXPECT_EQ(ItemActionStatus::SUCCESS, | |
| 163 last_result()->item_statuses.at(index_id_2).second); | |
| 164 ASSERT_EQ(2UL, last_result()->updated_items.size()); | |
| 165 EXPECT_EQ(kRequestId1, | |
| 166 last_result()->updated_items.at(index_id_1).request_id()); | |
| 167 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | |
| 168 last_result()->updated_items.at(index_id_1).request_state()); | |
| 169 EXPECT_EQ(kRequestId2, | |
| 170 last_result()->updated_items.at(index_id_2).request_id()); | |
| 171 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | |
| 172 last_result()->updated_items.at(index_id_2).request_state()); | |
| 173 } | |
| 174 | |
| 175 TEST_F(ChangeRequestsStateTaskTest, EmptyRequestsList) { | |
| 176 RequestQueueInMemoryStore store; | |
| 177 InitializeStore(&store); | |
| 178 | |
| 179 std::vector<int64_t> request_ids; | |
| 180 ChangeRequestsStateTask task( | |
| 181 &store, request_ids, SavePageRequest::RequestState::PAUSED, | |
| 182 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | |
| 183 base::Unretained(this))); | |
| 184 task.Run(); | |
| 185 PumpLoop(); | |
| 186 ASSERT_TRUE(last_result()); | |
| 187 EXPECT_EQ(0UL, last_result()->item_statuses.size()); | |
| 188 EXPECT_EQ(0UL, last_result()->updated_items.size()); | |
| 189 } | |
| 190 | |
| 191 TEST_F(ChangeRequestsStateTaskTest, UpdateMissingItem) { | |
| 192 RequestQueueInMemoryStore store; | |
| 193 InitializeStore(&store); | |
| 194 AddItemsToStore(&store); | |
| 195 | |
| 196 std::vector<int64_t> request_ids{kRequestId1, kRequestId3}; | |
| 197 ChangeRequestsStateTask task( | |
| 198 &store, request_ids, SavePageRequest::RequestState::PAUSED, | |
| 199 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | |
| 200 base::Unretained(this))); | |
| 201 task.Run(); | |
| 202 PumpLoop(); | |
| 203 ASSERT_TRUE(last_result()); | |
| 204 ASSERT_EQ(2UL, last_result()->item_statuses.size()); | |
| 205 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); | |
| 206 EXPECT_EQ(ItemActionStatus::SUCCESS, | |
| 207 last_result()->item_statuses.at(0).second); | |
| 208 EXPECT_EQ(kRequestId3, last_result()->item_statuses.at(1).first); | |
| 209 EXPECT_EQ(ItemActionStatus::NOT_FOUND, | |
| 210 last_result()->item_statuses.at(1).second); | |
| 211 EXPECT_EQ(1UL, last_result()->updated_items.size()); | |
| 212 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | |
| 213 last_result()->updated_items.at(0).request_state()); | |
| 214 } | |
| 215 | |
| 216 } // namespace offline_pages | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 2489443002:
Move all components/offline_pages/ files into component/offline_pages/core (Closed)
