| 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/ntp_snippets/content_suggestions_service.h" | 5 #include "components/ntp_snippets/content_suggestions_service.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <iterator> | 8 #include <iterator> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 165 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 176 providers_.push_back(std::move(provider)); | 176 providers_.push_back(std::move(provider)); |
| 177 } | 177 } |
| 178 | 178 |
| 179 //////////////////////////////////////////////////////////////////////////////// | 179 //////////////////////////////////////////////////////////////////////////////// |
| 180 // Private methods | 180 // Private methods |
| 181 | 181 |
| 182 void ContentSuggestionsService::OnNewSuggestions( | 182 void ContentSuggestionsService::OnNewSuggestions( |
| 183 ContentSuggestionsProvider* provider, | 183 ContentSuggestionsProvider* provider, |
| 184 Category category, | 184 Category category, |
| 185 std::vector<ContentSuggestion> new_suggestions) { | 185 std::vector<ContentSuggestion> new_suggestions) { |
| 186 if (RegisterCategoryIfRequired(provider, category)) { | 186 if (RegisterCategoryIfRequired(provider, category)) |
| 187 NotifyCategoryStatusChanged(category); | 187 NotifyCategoryStatusChanged(category); |
| 188 } | 188 |
| 189 if (!IsCategoryStatusAvailable(provider->GetCategoryStatus(category))) |
| 190 return; |
| 189 | 191 |
| 190 for (const ContentSuggestion& suggestion : | 192 for (const ContentSuggestion& suggestion : |
| 191 suggestions_by_category_[category]) { | 193 suggestions_by_category_[category]) { |
| 192 id_category_map_.erase(suggestion.id()); | 194 id_category_map_.erase(suggestion.id()); |
| 193 } | 195 } |
| 194 | 196 |
| 195 for (const ContentSuggestion& suggestion : new_suggestions) { | 197 for (const ContentSuggestion& suggestion : new_suggestions) |
| 196 id_category_map_.insert(std::make_pair(suggestion.id(), category)); | 198 id_category_map_.insert(std::make_pair(suggestion.id(), category)); |
| 197 } | |
| 198 | 199 |
| 199 suggestions_by_category_[category] = std::move(new_suggestions); | 200 suggestions_by_category_[category] = std::move(new_suggestions); |
| 200 | 201 |
| 201 FOR_EACH_OBSERVER(Observer, observers_, OnNewSuggestions(category)); | 202 FOR_EACH_OBSERVER(Observer, observers_, OnNewSuggestions(category)); |
| 202 } | 203 } |
| 203 | 204 |
| 204 void ContentSuggestionsService::OnCategoryStatusChanged( | 205 void ContentSuggestionsService::OnCategoryStatusChanged( |
| 205 ContentSuggestionsProvider* provider, | 206 ContentSuggestionsProvider* provider, |
| 206 Category category, | 207 Category category, |
| 207 CategoryStatus new_status) { | 208 CategoryStatus new_status) { |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 248 return true; | 249 return true; |
| 249 } | 250 } |
| 250 | 251 |
| 251 void ContentSuggestionsService::NotifyCategoryStatusChanged(Category category) { | 252 void ContentSuggestionsService::NotifyCategoryStatusChanged(Category category) { |
| 252 FOR_EACH_OBSERVER( | 253 FOR_EACH_OBSERVER( |
| 253 Observer, observers_, | 254 Observer, observers_, |
| 254 OnCategoryStatusChanged(category, GetCategoryStatus(category))); | 255 OnCategoryStatusChanged(category, GetCategoryStatus(category))); |
| 255 } | 256 } |
| 256 | 257 |
| 257 } // namespace ntp_snippets | 258 } // namespace ntp_snippets |
| OLD | NEW |