| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/offline_pages/background/change_requests_state_task.h" | 5 #include "components/offline_pages/background/change_requests_state_task.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/test/test_simple_task_runner.h" | 10 #include "base/test/test_simple_task_runner.h" |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 AddItemsToStore(&store); | 138 AddItemsToStore(&store); |
| 139 | 139 |
| 140 std::vector<int64_t> request_ids{kRequestId1, kRequestId2}; | 140 std::vector<int64_t> request_ids{kRequestId1, kRequestId2}; |
| 141 ChangeRequestsStateTask task( | 141 ChangeRequestsStateTask task( |
| 142 &store, request_ids, SavePageRequest::RequestState::PAUSED, | 142 &store, request_ids, SavePageRequest::RequestState::PAUSED, |
| 143 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | 143 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, |
| 144 base::Unretained(this))); | 144 base::Unretained(this))); |
| 145 task.Run(); | 145 task.Run(); |
| 146 PumpLoop(); | 146 PumpLoop(); |
| 147 ASSERT_TRUE(last_result()); | 147 ASSERT_TRUE(last_result()); |
| 148 EXPECT_EQ(2UL, last_result()->item_statuses.size()); | 148 ASSERT_EQ(2UL, last_result()->item_statuses.size()); |
| 149 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); | 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); |
| 150 EXPECT_EQ(ItemActionStatus::SUCCESS, | 159 EXPECT_EQ(ItemActionStatus::SUCCESS, |
| 151 last_result()->item_statuses.at(0).second); | 160 last_result()->item_statuses.at(index_id_1).second); |
| 152 EXPECT_EQ(kRequestId2, last_result()->item_statuses.at(1).first); | 161 EXPECT_EQ(kRequestId2, last_result()->item_statuses.at(index_id_2).first); |
| 153 EXPECT_EQ(ItemActionStatus::SUCCESS, | 162 EXPECT_EQ(ItemActionStatus::SUCCESS, |
| 154 last_result()->item_statuses.at(1).second); | 163 last_result()->item_statuses.at(index_id_2).second); |
| 155 EXPECT_EQ(2UL, last_result()->updated_items.size()); | 164 ASSERT_EQ(2UL, last_result()->updated_items.size()); |
| 156 EXPECT_EQ(kRequestId1, last_result()->updated_items.at(0).request_id()); | 165 EXPECT_EQ(kRequestId1, |
| 166 last_result()->updated_items.at(index_id_1).request_id()); |
| 157 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | 167 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, |
| 158 last_result()->updated_items.at(0).request_state()); | 168 last_result()->updated_items.at(index_id_1).request_state()); |
| 159 EXPECT_EQ(kRequestId2, last_result()->updated_items.at(1).request_id()); | 169 EXPECT_EQ(kRequestId2, |
| 170 last_result()->updated_items.at(index_id_2).request_id()); |
| 160 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | 171 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, |
| 161 last_result()->updated_items.at(1).request_state()); | 172 last_result()->updated_items.at(index_id_2).request_state()); |
| 162 } | 173 } |
| 163 | 174 |
| 164 TEST_F(ChangeRequestsStateTaskTest, EmptyRequestsList) { | 175 TEST_F(ChangeRequestsStateTaskTest, EmptyRequestsList) { |
| 165 RequestQueueInMemoryStore store; | 176 RequestQueueInMemoryStore store; |
| 166 InitializeStore(&store); | 177 InitializeStore(&store); |
| 167 | 178 |
| 168 std::vector<int64_t> request_ids; | 179 std::vector<int64_t> request_ids; |
| 169 ChangeRequestsStateTask task( | 180 ChangeRequestsStateTask task( |
| 170 &store, request_ids, SavePageRequest::RequestState::PAUSED, | 181 &store, request_ids, SavePageRequest::RequestState::PAUSED, |
| 171 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | 182 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, |
| (...skipping 11 matching lines...) Expand all Loading... |
| 183 AddItemsToStore(&store); | 194 AddItemsToStore(&store); |
| 184 | 195 |
| 185 std::vector<int64_t> request_ids{kRequestId1, kRequestId3}; | 196 std::vector<int64_t> request_ids{kRequestId1, kRequestId3}; |
| 186 ChangeRequestsStateTask task( | 197 ChangeRequestsStateTask task( |
| 187 &store, request_ids, SavePageRequest::RequestState::PAUSED, | 198 &store, request_ids, SavePageRequest::RequestState::PAUSED, |
| 188 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, | 199 base::Bind(&ChangeRequestsStateTaskTest::ChangeRequestsStateCallback, |
| 189 base::Unretained(this))); | 200 base::Unretained(this))); |
| 190 task.Run(); | 201 task.Run(); |
| 191 PumpLoop(); | 202 PumpLoop(); |
| 192 ASSERT_TRUE(last_result()); | 203 ASSERT_TRUE(last_result()); |
| 193 EXPECT_EQ(2UL, last_result()->item_statuses.size()); | 204 ASSERT_EQ(2UL, last_result()->item_statuses.size()); |
| 194 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); | 205 EXPECT_EQ(kRequestId1, last_result()->item_statuses.at(0).first); |
| 195 EXPECT_EQ(ItemActionStatus::SUCCESS, | 206 EXPECT_EQ(ItemActionStatus::SUCCESS, |
| 196 last_result()->item_statuses.at(0).second); | 207 last_result()->item_statuses.at(0).second); |
| 197 EXPECT_EQ(kRequestId3, last_result()->item_statuses.at(1).first); | 208 EXPECT_EQ(kRequestId3, last_result()->item_statuses.at(1).first); |
| 198 EXPECT_EQ(ItemActionStatus::NOT_FOUND, | 209 EXPECT_EQ(ItemActionStatus::NOT_FOUND, |
| 199 last_result()->item_statuses.at(1).second); | 210 last_result()->item_statuses.at(1).second); |
| 200 EXPECT_EQ(1UL, last_result()->updated_items.size()); | 211 EXPECT_EQ(1UL, last_result()->updated_items.size()); |
| 201 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, | 212 EXPECT_EQ(SavePageRequest::RequestState::PAUSED, |
| 202 last_result()->updated_items.at(0).request_state()); | 213 last_result()->updated_items.at(0).request_state()); |
| 203 } | 214 } |
| 204 | 215 |
| 205 } // namespace offline_pages | 216 } // namespace offline_pages |
| OLD | NEW |