OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "chrome/browser/ui/search/search_ipc_router.h" | 5 #include "chrome/browser/ui/search/search_ipc_router.h" |
6 | 6 |
7 #include "chrome/browser/search/search.h" | 7 #include "chrome/browser/search/search.h" |
8 #include "chrome/common/render_messages.h" | 8 #include "chrome/common/render_messages.h" |
| 9 #include "content/public/browser/navigation_details.h" |
9 #include "content/public/browser/web_contents.h" | 10 #include "content/public/browser/web_contents.h" |
10 | 11 |
11 namespace { | 12 namespace { |
12 | 13 |
13 bool IsProviderValid(const base::string16& provider) { | 14 bool IsProviderValid(const base::string16& provider) { |
14 // Only allow string of 8 alphanumeric characters or less as providers. | 15 // Only allow string of 8 alphanumeric characters or less as providers. |
15 // The empty string is considered valid and should be treated as if no | 16 // The empty string is considered valid and should be treated as if no |
16 // provider were specified. | 17 // provider were specified. |
17 if (provider.length() > 8) | 18 if (provider.length() > 8) |
18 return false; | 19 return false; |
19 for (base::string16::const_iterator it = provider.begin(); | 20 for (base::string16::const_iterator it = provider.begin(); |
20 it != provider.end(); ++it) { | 21 it != provider.end(); ++it) { |
21 if (!IsAsciiAlpha(*it) && !IsAsciiDigit(*it)) | 22 if (!IsAsciiAlpha(*it) && !IsAsciiDigit(*it)) |
22 return false; | 23 return false; |
23 } | 24 } |
24 return true; | 25 return true; |
25 } | 26 } |
26 | 27 |
27 } // namespace | 28 } // namespace |
28 | 29 |
29 SearchIPCRouter::SearchIPCRouter(content::WebContents* web_contents, | 30 SearchIPCRouter::SearchIPCRouter(content::WebContents* web_contents, |
30 Delegate* delegate, scoped_ptr<Policy> policy) | 31 Delegate* delegate, scoped_ptr<Policy> policy) |
31 : WebContentsObserver(web_contents), | 32 : WebContentsObserver(web_contents), |
32 delegate_(delegate), | 33 delegate_(delegate), |
33 policy_(policy.Pass()), | 34 policy_(policy.Pass()), |
| 35 commit_counter_(0), |
34 is_active_tab_(false) { | 36 is_active_tab_(false) { |
35 DCHECK(web_contents); | 37 DCHECK(web_contents); |
36 DCHECK(delegate); | 38 DCHECK(delegate); |
37 DCHECK(policy_.get()); | 39 DCHECK(policy_.get()); |
38 } | 40 } |
39 | 41 |
40 SearchIPCRouter::~SearchIPCRouter() {} | 42 SearchIPCRouter::~SearchIPCRouter() {} |
41 | 43 |
| 44 void SearchIPCRouter::OnNavigationEntryCommitted() { |
| 45 ++commit_counter_; |
| 46 Send(new ChromeViewMsg_SetPageSequenceNumber(routing_id(), commit_counter_)); |
| 47 } |
| 48 |
42 void SearchIPCRouter::DetermineIfPageSupportsInstant() { | 49 void SearchIPCRouter::DetermineIfPageSupportsInstant() { |
43 Send(new ChromeViewMsg_DetermineIfPageSupportsInstant(routing_id())); | 50 Send(new ChromeViewMsg_DetermineIfPageSupportsInstant(routing_id())); |
44 } | 51 } |
45 | 52 |
46 void SearchIPCRouter::SendChromeIdentityCheckResult( | 53 void SearchIPCRouter::SendChromeIdentityCheckResult( |
47 const base::string16& identity, | 54 const base::string16& identity, |
48 bool identity_match) { | 55 bool identity_match) { |
49 if (!policy_->ShouldProcessChromeIdentityCheck()) | 56 if (!policy_->ShouldProcessChromeIdentityCheck()) |
50 return; | 57 return; |
51 | 58 |
(...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
165 OnLogMostVisitedNavigation); | 172 OnLogMostVisitedNavigation); |
166 IPC_MESSAGE_HANDLER(ChromeViewHostMsg_PasteAndOpenDropdown, | 173 IPC_MESSAGE_HANDLER(ChromeViewHostMsg_PasteAndOpenDropdown, |
167 OnPasteAndOpenDropDown); | 174 OnPasteAndOpenDropDown); |
168 IPC_MESSAGE_HANDLER(ChromeViewHostMsg_ChromeIdentityCheck, | 175 IPC_MESSAGE_HANDLER(ChromeViewHostMsg_ChromeIdentityCheck, |
169 OnChromeIdentityCheck); | 176 OnChromeIdentityCheck); |
170 IPC_MESSAGE_UNHANDLED(handled = false) | 177 IPC_MESSAGE_UNHANDLED(handled = false) |
171 IPC_END_MESSAGE_MAP() | 178 IPC_END_MESSAGE_MAP() |
172 return handled; | 179 return handled; |
173 } | 180 } |
174 | 181 |
175 void SearchIPCRouter::OnInstantSupportDetermined(int page_id, | 182 void SearchIPCRouter::OnInstantSupportDetermined(int page_seq_no, |
176 bool instant_support) const { | 183 bool instant_support) const { |
177 if (!web_contents()->IsActiveEntry(page_id)) | 184 if (page_seq_no != commit_counter_) |
178 return; | 185 return; |
179 | 186 |
180 delegate_->OnInstantSupportDetermined(instant_support); | 187 delegate_->OnInstantSupportDetermined(instant_support); |
181 } | 188 } |
182 | 189 |
183 void SearchIPCRouter::OnVoiceSearchSupportDetermined( | 190 void SearchIPCRouter::OnVoiceSearchSupportDetermined( |
184 int page_id, | 191 int page_seq_no, |
185 bool supports_voice_search) const { | 192 bool supports_voice_search) const { |
186 if (!web_contents()->IsActiveEntry(page_id)) | 193 if (page_seq_no != commit_counter_) |
187 return; | 194 return; |
188 | 195 |
189 delegate_->OnInstantSupportDetermined(true); | 196 delegate_->OnInstantSupportDetermined(true); |
190 if (!policy_->ShouldProcessSetVoiceSearchSupport()) | 197 if (!policy_->ShouldProcessSetVoiceSearchSupport()) |
191 return; | 198 return; |
192 | 199 |
193 delegate_->OnSetVoiceSearchSupport(supports_voice_search); | 200 delegate_->OnSetVoiceSearchSupport(supports_voice_search); |
194 } | 201 } |
195 | 202 |
196 void SearchIPCRouter::OnFocusOmnibox(int page_id, | 203 void SearchIPCRouter::OnFocusOmnibox(int page_seq_no, |
197 OmniboxFocusState state) const { | 204 OmniboxFocusState state) const { |
198 if (!web_contents()->IsActiveEntry(page_id)) | 205 if (page_seq_no != commit_counter_) |
199 return; | 206 return; |
200 | 207 |
201 delegate_->OnInstantSupportDetermined(true); | 208 delegate_->OnInstantSupportDetermined(true); |
202 if (!policy_->ShouldProcessFocusOmnibox(is_active_tab_)) | 209 if (!policy_->ShouldProcessFocusOmnibox(is_active_tab_)) |
203 return; | 210 return; |
204 | 211 |
205 delegate_->FocusOmnibox(state); | 212 delegate_->FocusOmnibox(state); |
206 } | 213 } |
207 | 214 |
208 void SearchIPCRouter::OnSearchBoxNavigate( | 215 void SearchIPCRouter::OnSearchBoxNavigate( |
209 int page_id, | 216 int page_seq_no, |
210 const GURL& url, | 217 const GURL& url, |
211 WindowOpenDisposition disposition, | 218 WindowOpenDisposition disposition, |
212 bool is_most_visited_item_url) const { | 219 bool is_most_visited_item_url) const { |
213 if (!web_contents()->IsActiveEntry(page_id)) | 220 if (page_seq_no != commit_counter_) |
214 return; | 221 return; |
215 | 222 |
216 delegate_->OnInstantSupportDetermined(true); | 223 delegate_->OnInstantSupportDetermined(true); |
217 if (!policy_->ShouldProcessNavigateToURL(is_active_tab_)) | 224 if (!policy_->ShouldProcessNavigateToURL(is_active_tab_)) |
218 return; | 225 return; |
219 | 226 |
220 delegate_->NavigateToURL(url, disposition, is_most_visited_item_url); | 227 delegate_->NavigateToURL(url, disposition, is_most_visited_item_url); |
221 } | 228 } |
222 | 229 |
223 void SearchIPCRouter::OnDeleteMostVisitedItem(int page_id, | 230 void SearchIPCRouter::OnDeleteMostVisitedItem(int page_seq_no, |
224 const GURL& url) const { | 231 const GURL& url) const { |
225 if (!web_contents()->IsActiveEntry(page_id)) | 232 if (page_seq_no != commit_counter_) |
226 return; | 233 return; |
227 | 234 |
228 delegate_->OnInstantSupportDetermined(true); | 235 delegate_->OnInstantSupportDetermined(true); |
229 if (!policy_->ShouldProcessDeleteMostVisitedItem()) | 236 if (!policy_->ShouldProcessDeleteMostVisitedItem()) |
230 return; | 237 return; |
231 | 238 |
232 delegate_->OnDeleteMostVisitedItem(url); | 239 delegate_->OnDeleteMostVisitedItem(url); |
233 } | 240 } |
234 | 241 |
235 void SearchIPCRouter::OnUndoMostVisitedDeletion(int page_id, | 242 void SearchIPCRouter::OnUndoMostVisitedDeletion(int page_seq_no, |
236 const GURL& url) const { | 243 const GURL& url) const { |
237 if (!web_contents()->IsActiveEntry(page_id)) | 244 if (page_seq_no != commit_counter_) |
238 return; | 245 return; |
239 | 246 |
240 delegate_->OnInstantSupportDetermined(true); | 247 delegate_->OnInstantSupportDetermined(true); |
241 if (!policy_->ShouldProcessUndoMostVisitedDeletion()) | 248 if (!policy_->ShouldProcessUndoMostVisitedDeletion()) |
242 return; | 249 return; |
243 | 250 |
244 delegate_->OnUndoMostVisitedDeletion(url); | 251 delegate_->OnUndoMostVisitedDeletion(url); |
245 } | 252 } |
246 | 253 |
247 void SearchIPCRouter::OnUndoAllMostVisitedDeletions(int page_id) const { | 254 void SearchIPCRouter::OnUndoAllMostVisitedDeletions(int page_seq_no) const { |
248 if (!web_contents()->IsActiveEntry(page_id)) | 255 if (page_seq_no != commit_counter_) |
249 return; | 256 return; |
250 | 257 |
251 delegate_->OnInstantSupportDetermined(true); | 258 delegate_->OnInstantSupportDetermined(true); |
252 if (!policy_->ShouldProcessUndoAllMostVisitedDeletions()) | 259 if (!policy_->ShouldProcessUndoAllMostVisitedDeletions()) |
253 return; | 260 return; |
254 | 261 |
255 delegate_->OnUndoAllMostVisitedDeletions(); | 262 delegate_->OnUndoAllMostVisitedDeletions(); |
256 } | 263 } |
257 | 264 |
258 void SearchIPCRouter::OnLogEvent(int page_id, NTPLoggingEventType event) const { | 265 void SearchIPCRouter::OnLogEvent(int page_seq_no, |
259 if (!web_contents()->IsActiveEntry(page_id)) | 266 NTPLoggingEventType event) const { |
| 267 if (page_seq_no != commit_counter_) |
260 return; | 268 return; |
261 | 269 |
262 delegate_->OnInstantSupportDetermined(true); | 270 delegate_->OnInstantSupportDetermined(true); |
263 if (!policy_->ShouldProcessLogEvent()) | 271 if (!policy_->ShouldProcessLogEvent()) |
264 return; | 272 return; |
265 | 273 |
266 delegate_->OnLogEvent(event); | 274 delegate_->OnLogEvent(event); |
267 } | 275 } |
268 | 276 |
269 void SearchIPCRouter::OnLogMostVisitedImpression( | 277 void SearchIPCRouter::OnLogMostVisitedImpression( |
270 int page_id, int position, const base::string16& provider) const { | 278 int page_seq_no, int position, const base::string16& provider) const { |
271 if (!web_contents()->IsActiveEntry(page_id) || !IsProviderValid(provider)) | 279 if (page_seq_no != commit_counter_ || !IsProviderValid(provider)) |
272 return; | 280 return; |
273 | 281 |
274 delegate_->OnInstantSupportDetermined(true); | 282 delegate_->OnInstantSupportDetermined(true); |
275 // Logging impressions is controlled by the same policy as logging events. | 283 // Logging impressions is controlled by the same policy as logging events. |
276 if (!policy_->ShouldProcessLogEvent()) | 284 if (!policy_->ShouldProcessLogEvent()) |
277 return; | 285 return; |
278 | 286 |
279 delegate_->OnLogMostVisitedImpression(position, provider); | 287 delegate_->OnLogMostVisitedImpression(position, provider); |
280 } | 288 } |
281 | 289 |
282 void SearchIPCRouter::OnLogMostVisitedNavigation( | 290 void SearchIPCRouter::OnLogMostVisitedNavigation( |
283 int page_id, int position, const base::string16& provider) const { | 291 int page_seq_no, int position, const base::string16& provider) const { |
284 if (!web_contents()->IsActiveEntry(page_id) || !IsProviderValid(provider)) | 292 if (page_seq_no != commit_counter_ || !IsProviderValid(provider)) |
285 return; | 293 return; |
286 | 294 |
287 delegate_->OnInstantSupportDetermined(true); | 295 delegate_->OnInstantSupportDetermined(true); |
288 // Logging navigations is controlled by the same policy as logging events. | 296 // Logging navigations is controlled by the same policy as logging events. |
289 if (!policy_->ShouldProcessLogEvent()) | 297 if (!policy_->ShouldProcessLogEvent()) |
290 return; | 298 return; |
291 | 299 |
292 delegate_->OnLogMostVisitedNavigation(position, provider); | 300 delegate_->OnLogMostVisitedNavigation(position, provider); |
293 } | 301 } |
294 | 302 |
295 void SearchIPCRouter::OnPasteAndOpenDropDown(int page_id, | 303 void SearchIPCRouter::OnPasteAndOpenDropDown(int page_seq_no, |
296 const base::string16& text) const { | 304 const base::string16& text) const { |
297 if (!web_contents()->IsActiveEntry(page_id)) | 305 if (page_seq_no != commit_counter_) |
298 return; | 306 return; |
299 | 307 |
300 delegate_->OnInstantSupportDetermined(true); | 308 delegate_->OnInstantSupportDetermined(true); |
301 if (!policy_->ShouldProcessPasteIntoOmnibox(is_active_tab_)) | 309 if (!policy_->ShouldProcessPasteIntoOmnibox(is_active_tab_)) |
302 return; | 310 return; |
303 | 311 |
304 delegate_->PasteIntoOmnibox(text); | 312 delegate_->PasteIntoOmnibox(text); |
305 } | 313 } |
306 | 314 |
307 void SearchIPCRouter::OnChromeIdentityCheck( | 315 void SearchIPCRouter::OnChromeIdentityCheck( |
308 int page_id, | 316 int page_seq_no, |
309 const base::string16& identity) const { | 317 const base::string16& identity) const { |
310 if (!web_contents()->IsActiveEntry(page_id)) | 318 if (page_seq_no != commit_counter_) |
311 return; | 319 return; |
312 | 320 |
313 delegate_->OnInstantSupportDetermined(true); | 321 delegate_->OnInstantSupportDetermined(true); |
314 if (!policy_->ShouldProcessChromeIdentityCheck()) | 322 if (!policy_->ShouldProcessChromeIdentityCheck()) |
315 return; | 323 return; |
316 | 324 |
317 delegate_->OnChromeIdentityCheck(identity); | 325 delegate_->OnChromeIdentityCheck(identity); |
318 } | 326 } |
319 | 327 |
320 void SearchIPCRouter::set_delegate(Delegate* delegate) { | 328 void SearchIPCRouter::set_delegate_for_testing(Delegate* delegate) { |
321 DCHECK(delegate); | 329 DCHECK(delegate); |
322 delegate_ = delegate; | 330 delegate_ = delegate; |
323 } | 331 } |
324 | 332 |
325 void SearchIPCRouter::set_policy(scoped_ptr<Policy> policy) { | 333 void SearchIPCRouter::set_policy_for_testing(scoped_ptr<Policy> policy) { |
326 DCHECK(policy.get()); | 334 DCHECK(policy.get()); |
327 policy_.reset(policy.release()); | 335 policy_.reset(policy.release()); |
328 } | 336 } |
OLD | NEW |