| OLD | NEW |
|---|
| (Empty) |
| 1 // Copyright (c) 2012 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 "chrome/browser/extensions/api/declarative_content/content_rules_regist
ry.h" | |
| 6 | |
| 7 #include "chrome/browser/chrome_notification_types.h" | |
| 8 #include "chrome/browser/extensions/api/declarative_content/content_action.h" | |
| 9 #include "chrome/browser/extensions/api/declarative_content/content_condition.h" | |
| 10 #include "chrome/browser/extensions/api/declarative_content/content_constants.h" | |
| 11 #include "chrome/browser/extensions/extension_tab_util.h" | |
| 12 #include "content/public/browser/navigation_details.h" | |
| 13 #include "content/public/browser/notification_service.h" | |
| 14 #include "content/public/browser/notification_source.h" | |
| 15 #include "content/public/browser/render_process_host.h" | |
| 16 #include "content/public/browser/web_contents.h" | |
| 17 #include "extensions/browser/extension_registry.h" | |
| 18 #include "extensions/browser/extension_system.h" | |
| 19 #include "extensions/common/extension_messages.h" | |
| 20 | |
| 21 using url_matcher::URLMatcherConditionSet; | |
| 22 | |
| 23 namespace extensions { | |
| 24 | |
| 25 ContentRulesRegistry::ContentRulesRegistry( | |
| 26 content::BrowserContext* browser_context, | |
| 27 RulesCacheDelegate* cache_delegate) | |
| 28 : RulesRegistry(browser_context, | |
| 29 declarative_content_constants::kOnPageChanged, | |
| 30 content::BrowserThread::UI, | |
| 31 cache_delegate, | |
| 32 WebViewKey(0, 0)) { | |
| 33 extension_info_map_ = ExtensionSystem::Get(browser_context)->info_map(); | |
| 34 | |
| 35 registrar_.Add(this, content::NOTIFICATION_RENDERER_PROCESS_CREATED, | |
| 36 content::NotificationService::AllBrowserContextsAndSources()); | |
| 37 registrar_.Add(this, content::NOTIFICATION_WEB_CONTENTS_DESTROYED, | |
| 38 content::NotificationService::AllBrowserContextsAndSources()); | |
| 39 } | |
| 40 | |
| 41 void ContentRulesRegistry::Observe( | |
| 42 int type, | |
| 43 const content::NotificationSource& source, | |
| 44 const content::NotificationDetails& details) { | |
| 45 switch (type) { | |
| 46 case content::NOTIFICATION_RENDERER_PROCESS_CREATED: { | |
| 47 content::RenderProcessHost* process = | |
| 48 content::Source<content::RenderProcessHost>(source).ptr(); | |
| 49 if (process->GetBrowserContext() == browser_context()) | |
| 50 InstructRenderProcess(process); | |
| 51 break; | |
| 52 } | |
| 53 case content::NOTIFICATION_WEB_CONTENTS_DESTROYED: { | |
| 54 content::WebContents* tab = | |
| 55 content::Source<content::WebContents>(source).ptr(); | |
| 56 // GetTabId() returns -1 for non-tab WebContents, which won't be | |
| 57 // in the map. Similarly, tabs from other browser_contexts won't be in | |
| 58 // the map. | |
| 59 active_rules_.erase(ExtensionTabUtil::GetTabId(tab)); | |
| 60 break; | |
| 61 } | |
| 62 } | |
| 63 } | |
| 64 | |
| 65 void ContentRulesRegistry::Apply( | |
| 66 content::WebContents* contents, | |
| 67 const std::vector<std::string>& matching_css_selectors) { | |
| 68 const int tab_id = ExtensionTabUtil::GetTabId(contents); | |
| 69 RendererContentMatchData renderer_data; | |
| 70 renderer_data.page_url_matches = url_matcher_.MatchURL(contents->GetURL()); | |
| 71 renderer_data.css_selectors.insert(matching_css_selectors.begin(), | |
| 72 matching_css_selectors.end()); | |
| 73 std::set<ContentRule*> matching_rules = GetMatches(renderer_data); | |
| 74 if (matching_rules.empty() && !ContainsKey(active_rules_, tab_id)) | |
| 75 return; | |
| 76 | |
| 77 std::set<ContentRule*>& prev_matching_rules = active_rules_[tab_id]; | |
| 78 ContentAction::ApplyInfo apply_info = { | |
| 79 browser_context(), contents | |
| 80 }; | |
| 81 for (std::set<ContentRule*>::const_iterator it = matching_rules.begin(); | |
| 82 it != matching_rules.end(); ++it) { | |
| 83 apply_info.priority = (*it)->priority(); | |
| 84 if (!ContainsKey(prev_matching_rules, *it)) { | |
| 85 (*it)->actions().Apply((*it)->extension_id(), base::Time(), &apply_info); | |
| 86 } else { | |
| 87 (*it)->actions().Reapply( | |
| 88 (*it)->extension_id(), base::Time(), &apply_info); | |
| 89 } | |
| 90 } | |
| 91 for (std::set<ContentRule*>::const_iterator it = prev_matching_rules.begin(); | |
| 92 it != prev_matching_rules.end(); ++it) { | |
| 93 if (!ContainsKey(matching_rules, *it)) { | |
| 94 apply_info.priority = (*it)->priority(); | |
| 95 (*it)->actions().Revert((*it)->extension_id(), base::Time(), &apply_info); | |
| 96 } | |
| 97 } | |
| 98 | |
| 99 if (matching_rules.empty()) | |
| 100 active_rules_.erase(tab_id); | |
| 101 else | |
| 102 swap(matching_rules, prev_matching_rules); | |
| 103 } | |
| 104 | |
| 105 void ContentRulesRegistry::DidNavigateMainFrame( | |
| 106 content::WebContents* contents, | |
| 107 const content::LoadCommittedDetails& details, | |
| 108 const content::FrameNavigateParams& params) { | |
| 109 if (details.is_in_page) { | |
| 110 // Within-page navigations don't change the set of elements that | |
| 111 // exist, and we only support filtering on the top-level URL, so | |
| 112 // this can't change which rules match. | |
| 113 return; | |
| 114 } | |
| 115 | |
| 116 // Top-level navigation produces a new document. Initially, the | |
| 117 // document's empty, so no CSS rules match. The renderer will send | |
| 118 // an ExtensionHostMsg_OnWatchedPageChange later if any CSS rules | |
| 119 // match. | |
| 120 std::vector<std::string> no_css_selectors; | |
| 121 Apply(contents, no_css_selectors); | |
| 122 } | |
| 123 | |
| 124 std::set<ContentRule*> | |
| 125 ContentRulesRegistry::GetMatches( | |
| 126 const RendererContentMatchData& renderer_data) const { | |
| 127 std::set<ContentRule*> result; | |
| 128 | |
| 129 // Then we need to check for each of these, whether the other | |
| 130 // attributes are also fulfilled. | |
| 131 for (std::set<URLMatcherConditionSet::ID>::iterator | |
| 132 url_match = renderer_data.page_url_matches.begin(); | |
| 133 url_match != renderer_data.page_url_matches.end(); ++url_match) { | |
| 134 URLMatcherIdToRule::const_iterator rule_iter = | |
| 135 match_id_to_rule_.find(*url_match); | |
| 136 CHECK(rule_iter != match_id_to_rule_.end()); | |
| 137 | |
| 138 ContentRule* rule = rule_iter->second; | |
| 139 if (rule->conditions().IsFulfilled(*url_match, renderer_data)) | |
| 140 result.insert(rule); | |
| 141 } | |
| 142 return result; | |
| 143 } | |
| 144 | |
| 145 std::string ContentRulesRegistry::AddRulesImpl( | |
| 146 const std::string& extension_id, | |
| 147 const std::vector<linked_ptr<RulesRegistry::Rule> >& rules) { | |
| 148 const Extension* extension = | |
| 149 ExtensionRegistry::Get(browser_context()) | |
| 150 ->GetExtensionById(extension_id, ExtensionRegistry::EVERYTHING); | |
| 151 DCHECK(extension) << "Must have extension with id " << extension_id; | |
| 152 | |
| 153 base::Time extension_installation_time = | |
| 154 GetExtensionInstallationTime(extension_id); | |
| 155 | |
| 156 std::string error; | |
| 157 RulesMap new_content_rules; | |
| 158 | |
| 159 for (std::vector<linked_ptr<RulesRegistry::Rule> >::const_iterator rule = | |
| 160 rules.begin(); rule != rules.end(); ++rule) { | |
| 161 ContentRule::GlobalRuleId rule_id(extension_id, *(*rule)->id); | |
| 162 DCHECK(content_rules_.find(rule_id) == content_rules_.end()); | |
| 163 | |
| 164 scoped_ptr<ContentRule> content_rule( | |
| 165 ContentRule::Create(url_matcher_.condition_factory(), | |
| 166 browser_context(), | |
| 167 extension, | |
| 168 extension_installation_time, | |
| 169 *rule, | |
| 170 ContentRule::ConsistencyChecker(), | |
| 171 &error)); | |
| 172 if (!error.empty()) { | |
| 173 // Clean up temporary condition sets created during rule creation. | |
| 174 url_matcher_.ClearUnusedConditionSets(); | |
| 175 return error; | |
| 176 } | |
| 177 DCHECK(content_rule); | |
| 178 | |
| 179 new_content_rules[rule_id] = make_linked_ptr(content_rule.release()); | |
| 180 } | |
| 181 | |
| 182 // Wohoo, everything worked fine. | |
| 183 content_rules_.insert(new_content_rules.begin(), new_content_rules.end()); | |
| 184 | |
| 185 // Create the triggers. | |
| 186 for (RulesMap::iterator i = new_content_rules.begin(); | |
| 187 i != new_content_rules.end(); ++i) { | |
| 188 URLMatcherConditionSet::Vector url_condition_sets; | |
| 189 const ContentConditionSet& conditions = i->second->conditions(); | |
| 190 conditions.GetURLMatcherConditionSets(&url_condition_sets); | |
| 191 for (URLMatcherConditionSet::Vector::iterator j = | |
| 192 url_condition_sets.begin(); j != url_condition_sets.end(); ++j) { | |
| 193 match_id_to_rule_[(*j)->id()] = i->second.get(); | |
| 194 } | |
| 195 } | |
| 196 | |
| 197 // Register url patterns in url_matcher_. | |
| 198 URLMatcherConditionSet::Vector all_new_condition_sets; | |
| 199 for (RulesMap::iterator i = new_content_rules.begin(); | |
| 200 i != new_content_rules.end(); ++i) { | |
| 201 i->second->conditions().GetURLMatcherConditionSets(&all_new_condition_sets); | |
| 202 } | |
| 203 url_matcher_.AddConditionSets(all_new_condition_sets); | |
| 204 | |
| 205 UpdateConditionCache(); | |
| 206 | |
| 207 return std::string(); | |
| 208 } | |
| 209 | |
| 210 std::string ContentRulesRegistry::RemoveRulesImpl( | |
| 211 const std::string& extension_id, | |
| 212 const std::vector<std::string>& rule_identifiers) { | |
| 213 // URLMatcherConditionSet IDs that can be removed from URLMatcher. | |
| 214 std::vector<URLMatcherConditionSet::ID> remove_from_url_matcher; | |
| 215 | |
| 216 for (std::vector<std::string>::const_iterator i = rule_identifiers.begin(); | |
| 217 i != rule_identifiers.end(); ++i) { | |
| 218 ContentRule::GlobalRuleId rule_id(extension_id, *i); | |
| 219 | |
| 220 // Skip unknown rules. | |
| 221 RulesMap::iterator content_rules_entry = content_rules_.find(rule_id); | |
| 222 if (content_rules_entry == content_rules_.end()) | |
| 223 continue; | |
| 224 | |
| 225 // Remove all triggers but collect their IDs. | |
| 226 URLMatcherConditionSet::Vector condition_sets; | |
| 227 ContentRule* rule = content_rules_entry->second.get(); | |
| 228 rule->conditions().GetURLMatcherConditionSets(&condition_sets); | |
| 229 for (URLMatcherConditionSet::Vector::iterator j = condition_sets.begin(); | |
| 230 j != condition_sets.end(); ++j) { | |
| 231 remove_from_url_matcher.push_back((*j)->id()); | |
| 232 match_id_to_rule_.erase((*j)->id()); | |
| 233 } | |
| 234 | |
| 235 // Remove the ContentRule from active_rules_. | |
| 236 for (std::map<int, std::set<ContentRule*> >::iterator | |
| 237 it = active_rules_.begin(); | |
| 238 it != active_rules_.end(); ++it) { | |
| 239 if (ContainsKey(it->second, rule)) { | |
| 240 content::WebContents* tab; | |
| 241 if (!ExtensionTabUtil::GetTabById( | |
| 242 it->first, browser_context(), true, NULL, NULL, &tab, NULL)) { | |
| 243 LOG(DFATAL) << "Tab id " << it->first | |
| 244 << " still in active_rules_, but tab has been destroyed"; | |
| 245 continue; | |
| 246 } | |
| 247 ContentAction::ApplyInfo apply_info = {browser_context(), tab}; | |
| 248 rule->actions().Revert(rule->extension_id(), base::Time(), &apply_info); | |
| 249 it->second.erase(rule); | |
| 250 } | |
| 251 } | |
| 252 | |
| 253 // Remove reference to actual rule. | |
| 254 content_rules_.erase(content_rules_entry); | |
| 255 } | |
| 256 | |
| 257 // Clear URLMatcher based on condition_set_ids that are not needed any more. | |
| 258 url_matcher_.RemoveConditionSets(remove_from_url_matcher); | |
| 259 | |
| 260 UpdateConditionCache(); | |
| 261 | |
| 262 return std::string(); | |
| 263 } | |
| 264 | |
| 265 std::string ContentRulesRegistry::RemoveAllRulesImpl( | |
| 266 const std::string& extension_id) { | |
| 267 // Search all identifiers of rules that belong to extension |extension_id|. | |
| 268 std::vector<std::string> rule_identifiers; | |
| 269 for (RulesMap::iterator i = content_rules_.begin(); | |
| 270 i != content_rules_.end(); ++i) { | |
| 271 const ContentRule::GlobalRuleId& global_rule_id = i->first; | |
| 272 if (global_rule_id.first == extension_id) | |
| 273 rule_identifiers.push_back(global_rule_id.second); | |
| 274 } | |
| 275 | |
| 276 return RemoveRulesImpl(extension_id, rule_identifiers); | |
| 277 } | |
| 278 | |
| 279 void ContentRulesRegistry::UpdateConditionCache() { | |
| 280 std::set<std::string> css_selectors; // We rely on this being sorted. | |
| 281 for (RulesMap::const_iterator i = content_rules_.begin(); | |
| 282 i != content_rules_.end(); ++i) { | |
| 283 ContentRule& rule = *i->second; | |
| 284 for (ContentConditionSet::const_iterator | |
| 285 condition = rule.conditions().begin(); | |
| 286 condition != rule.conditions().end(); ++condition) { | |
| 287 const std::vector<std::string>& condition_css_selectors = | |
| 288 (*condition)->css_selectors(); | |
| 289 css_selectors.insert(condition_css_selectors.begin(), | |
| 290 condition_css_selectors.end()); | |
| 291 } | |
| 292 } | |
| 293 | |
| 294 if (css_selectors.size() != watched_css_selectors_.size() || | |
| 295 !std::equal(css_selectors.begin(), css_selectors.end(), | |
| 296 watched_css_selectors_.begin())) { | |
| 297 watched_css_selectors_.assign(css_selectors.begin(), css_selectors.end()); | |
| 298 | |
| 299 for (content::RenderProcessHost::iterator it( | |
| 300 content::RenderProcessHost::AllHostsIterator()); | |
| 301 !it.IsAtEnd(); it.Advance()) { | |
| 302 content::RenderProcessHost* process = it.GetCurrentValue(); | |
| 303 if (process->GetBrowserContext() == browser_context()) | |
| 304 InstructRenderProcess(process); | |
| 305 } | |
| 306 } | |
| 307 } | |
| 308 | |
| 309 void ContentRulesRegistry::InstructRenderProcess( | |
| 310 content::RenderProcessHost* process) { | |
| 311 process->Send(new ExtensionMsg_WatchPages(watched_css_selectors_)); | |
| 312 } | |
| 313 | |
| 314 bool ContentRulesRegistry::IsEmpty() const { | |
| 315 return match_id_to_rule_.empty() && content_rules_.empty() && | |
| 316 url_matcher_.IsEmpty(); | |
| 317 } | |
| 318 | |
| 319 ContentRulesRegistry::~ContentRulesRegistry() {} | |
| 320 | |
| 321 base::Time ContentRulesRegistry::GetExtensionInstallationTime( | |
| 322 const std::string& extension_id) const { | |
| 323 if (!extension_info_map_.get()) // May be NULL during testing. | |
| 324 return base::Time(); | |
| 325 | |
| 326 return extension_info_map_->GetInstallTime(extension_id); | |
| 327 } | |
| 328 | |
| 329 } // namespace extensions | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 590573002:
Remove ContentRulesRegistry dependence from RulesRegistryService. (Closed)
Base URL: https://chromium.googlesource.com/chromium/src.git@master