OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/ntp_snippets/remote/remote_suggestions_provider.h" | 5 #include "components/ntp_snippets/remote/remote_suggestions_provider.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 #include <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
(...skipping 264 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
275 *output = loaded; | 275 *output = loaded; |
276 signal.Run(); | 276 signal.Run(); |
277 }, | 277 }, |
278 run_loop.QuitClosure(), &result)); | 278 run_loop.QuitClosure(), &result)); |
279 run_loop.Run(); | 279 run_loop.Run(); |
280 return result; | 280 return result; |
281 } | 281 } |
282 | 282 |
283 void ParseJson( | 283 void ParseJson( |
284 const std::string& json, | 284 const std::string& json, |
285 const ntp_snippets::NTPSnippetsFetcher::SuccessCallback& success_callback, | 285 const internal::NTPSnippetsJsonRequest::SuccessCallback& success_callback, |
286 const ntp_snippets::NTPSnippetsFetcher::ErrorCallback& error_callback) { | 286 const internal::NTPSnippetsJsonRequest::ErrorCallback& error_callback) { |
287 base::JSONReader json_reader; | 287 base::JSONReader json_reader; |
288 std::unique_ptr<base::Value> value = json_reader.ReadToValue(json); | 288 std::unique_ptr<base::Value> value = json_reader.ReadToValue(json); |
289 if (value) { | 289 if (value) { |
290 success_callback.Run(std::move(value)); | 290 success_callback.Run(std::move(value)); |
291 } else { | 291 } else { |
292 error_callback.Run(json_reader.GetErrorMessage()); | 292 error_callback.Run(json_reader.GetErrorMessage()); |
293 } | 293 } |
294 } | 294 } |
295 | 295 |
296 // Factory for FakeURLFetcher objects that always generate errors. | 296 // Factory for FakeURLFetcher objects that always generate errors. |
(...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
450 auto image_decoder = base::MakeUnique<FakeImageDecoder>(); | 450 auto image_decoder = base::MakeUnique<FakeImageDecoder>(); |
451 image_decoder_ = image_decoder.get(); | 451 image_decoder_ = image_decoder.get(); |
452 EXPECT_FALSE(observer_); | 452 EXPECT_FALSE(observer_); |
453 observer_ = base::MakeUnique<FakeContentSuggestionsProviderObserver>(); | 453 observer_ = base::MakeUnique<FakeContentSuggestionsProviderObserver>(); |
454 auto database = base::MakeUnique<RemoteSuggestionsDatabase>( | 454 auto database = base::MakeUnique<RemoteSuggestionsDatabase>( |
455 database_dir_.GetPath(), task_runner); | 455 database_dir_.GetPath(), task_runner); |
456 database_ = database.get(); | 456 database_ = database.get(); |
457 return base::MakeUnique<RemoteSuggestionsProvider>( | 457 return base::MakeUnique<RemoteSuggestionsProvider>( |
458 observer_.get(), &category_factory_, utils_.pref_service(), "fr", | 458 observer_.get(), &category_factory_, utils_.pref_service(), "fr", |
459 &user_classifier_, &scheduler_, std::move(snippets_fetcher), | 459 &user_classifier_, &scheduler_, std::move(snippets_fetcher), |
460 std::move(image_fetcher), std::move(image_decoder), | 460 std::move(image_fetcher), std::move(image_decoder), std::move(database), |
461 std::move(database), | |
462 base::MakeUnique<RemoteSuggestionsStatusService>( | 461 base::MakeUnique<RemoteSuggestionsStatusService>( |
463 utils_.fake_signin_manager(), utils_.pref_service())); | 462 utils_.fake_signin_manager(), utils_.pref_service())); |
464 } | 463 } |
465 | 464 |
466 void WaitForSnippetsServiceInitialization(RemoteSuggestionsProvider* service, | 465 void WaitForSnippetsServiceInitialization(RemoteSuggestionsProvider* service, |
467 bool set_empty_response) { | 466 bool set_empty_response) { |
468 EXPECT_EQ(RemoteSuggestionsProvider::State::NOT_INITED, service->state_); | 467 EXPECT_EQ(RemoteSuggestionsProvider::State::NOT_INITED, service->state_); |
469 | 468 |
470 // Add an initial fetch response, as the service tries to fetch when there | 469 // Add an initial fetch response, as the service tries to fetch when there |
471 // is nothing in the DB. | 470 // is nothing in the DB. |
(...skipping 1241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1713 service->FetchSnippetsInTheBackground(); | 1712 service->FetchSnippetsInTheBackground(); |
1714 base::RunLoop().RunUntilIdle(); | 1713 base::RunLoop().RunUntilIdle(); |
1715 EXPECT_EQ( | 1714 EXPECT_EQ( |
1716 simple_test_clock_ptr->Now().ToInternalValue(), | 1715 simple_test_clock_ptr->Now().ToInternalValue(), |
1717 pref_service()->GetInt64(prefs::kLastSuccessfulBackgroundFetchTime)); | 1716 pref_service()->GetInt64(prefs::kLastSuccessfulBackgroundFetchTime)); |
1718 // TODO(markusheintz): Add a test that simulates a browser restart once the | 1717 // TODO(markusheintz): Add a test that simulates a browser restart once the |
1719 // scheduler refactoring is done (crbug.com/672434). | 1718 // scheduler refactoring is done (crbug.com/672434). |
1720 } | 1719 } |
1721 | 1720 |
1722 } // namespace ntp_snippets | 1721 } // namespace ntp_snippets |
OLD | NEW |