OLD | NEW |
---|---|
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 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/chrome_to_mobile_service.h" | 5 #include "chrome/browser/chrome_to_mobile_service.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
9 #include "base/file_util.h" | 9 #include "base/file_util.h" |
10 #include "base/guid.h" | 10 #include "base/guid.h" |
11 #include "base/json/json_reader.h" | 11 #include "base/json/json_reader.h" |
12 #include "base/json/json_writer.h" | 12 #include "base/json/json_writer.h" |
13 #include "base/metrics/histogram.h" | 13 #include "base/metrics/histogram.h" |
14 #include "base/stringprintf.h" | |
15 #include "base/utf_string_conversions.h" | 14 #include "base/utf_string_conversions.h" |
16 #include "chrome/app/chrome_command_ids.h" | 15 #include "chrome/app/chrome_command_ids.h" |
17 #include "chrome/browser/content_settings/cookie_settings.h" | |
18 #include "chrome/browser/prefs/pref_service.h" | 16 #include "chrome/browser/prefs/pref_service.h" |
19 #include "chrome/browser/printing/cloud_print/cloud_print_url.h" | 17 #include "chrome/browser/printing/cloud_print/cloud_print_url.h" |
20 #include "chrome/browser/profiles/profile.h" | 18 #include "chrome/browser/profiles/profile.h" |
21 #include "chrome/browser/signin/token_service.h" | 19 #include "chrome/browser/signin/token_service.h" |
22 #include "chrome/browser/signin/token_service_factory.h" | 20 #include "chrome/browser/signin/token_service_factory.h" |
21 #include "chrome/browser/sync/profile_sync_service.h" | |
22 #include "chrome/browser/sync/profile_sync_service_factory.h" | |
23 #include "chrome/browser/ui/browser.h" | 23 #include "chrome/browser/ui/browser.h" |
24 #include "chrome/browser/ui/browser_command_controller.h" | 24 #include "chrome/browser/ui/browser_command_controller.h" |
25 #include "chrome/browser/ui/browser_finder.h" | 25 #include "chrome/browser/ui/browser_finder.h" |
26 #include "chrome/browser/ui/browser_list.h" | 26 #include "chrome/browser/ui/browser_list.h" |
27 #include "chrome/browser/ui/browser_navigator.h" | 27 #include "chrome/browser/ui/browser_navigator.h" |
28 #include "chrome/browser/ui/browser_tabstrip.h" | 28 #include "chrome/browser/ui/browser_tabstrip.h" |
29 #include "chrome/common/chrome_notification_types.h" | 29 #include "chrome/common/chrome_notification_types.h" |
30 #include "chrome/common/chrome_switches.h" | 30 #include "chrome/common/chrome_switches.h" |
31 #include "chrome/common/cloud_print/cloud_print_helpers.h" | 31 #include "chrome/common/cloud_print/cloud_print_helpers.h" |
32 #include "chrome/common/net/gaia/gaia_constants.h" | 32 #include "chrome/common/net/gaia/gaia_constants.h" |
33 #include "chrome/common/net/gaia/gaia_urls.h" | 33 #include "chrome/common/net/gaia/gaia_urls.h" |
34 #include "chrome/common/net/gaia/oauth2_access_token_fetcher.h" | 34 #include "chrome/common/net/gaia/oauth2_access_token_fetcher.h" |
35 #include "chrome/common/pref_names.h" | 35 #include "chrome/common/pref_names.h" |
36 #include "chrome/common/url_constants.h" | 36 #include "chrome/common/url_constants.h" |
37 #include "content/public/browser/browser_thread.h" | 37 #include "content/public/browser/browser_thread.h" |
38 #include "content/public/browser/notification_details.h" | 38 #include "content/public/browser/notification_details.h" |
39 #include "content/public/browser/notification_source.h" | 39 #include "content/public/browser/notification_source.h" |
40 #include "content/public/browser/web_contents.h" | 40 #include "content/public/browser/web_contents.h" |
41 #include "google/cacheinvalidation/include/types.h" | |
42 #include "google/cacheinvalidation/types.pb.h" | |
41 #include "net/base/escape.h" | 43 #include "net/base/escape.h" |
42 #include "net/base/load_flags.h" | 44 #include "net/base/load_flags.h" |
43 #include "net/url_request/url_fetcher.h" | 45 #include "net/url_request/url_fetcher.h" |
44 #include "net/url_request/url_request_context_getter.h" | 46 #include "net/url_request/url_request_context_getter.h" |
47 #include "sync/notifier/invalidation_util.h" | |
45 | 48 |
46 namespace { | 49 namespace { |
47 | 50 |
48 // The default enabled/disabled state of the Chrome To Mobile feature. | 51 // The default enabled/disabled state of the Chrome To Mobile feature. |
49 const bool kChromeToMobileEnabled = true; | 52 const bool kChromeToMobileEnabled = true; |
50 | 53 |
51 // The maximum number of retries for the URLFetcher requests. | 54 // The maximum number of retries for the URLFetcher requests. |
52 const size_t kMaxRetries = 1; | 55 const size_t kMaxRetries = 1; |
53 | 56 |
54 // The number of hours to delay before retrying authentication on failure. | 57 // The number of hours to delay before retrying authentication on failure. |
55 const size_t kAuthRetryDelayHours = 6; | 58 const size_t kAuthRetryDelayHours = 6; |
56 | 59 |
57 // The number of hours before subsequent search requests are allowed. | 60 // The number of hours before subsequent search requests are allowed. |
58 // This value is used to throttle expensive cloud print search requests. | 61 // This value is used to throttle expensive cloud print search requests. |
59 // Note that this limitation does not hold across application restarts. | 62 // Note that this limitation does not hold across application restarts. |
60 const int kSearchRequestDelayHours = 24; | 63 const int kSearchRequestDelayHours = 24; |
61 | 64 |
65 // The sync invalidation object ID for Chrome to Mobile's mobile device list. | |
66 // This corresponds with cloud print's server-side invalidation object ID. | |
67 // Meaning: "U" == "User", "CM" == "Chrome to Mobile", "MLST" == "Mobile LiST". | |
68 const char kSyncInvalidationObjectIdChromeToMobileDeviceList[] = "UCMMLST"; | |
69 | |
62 // The cloud print OAuth2 scope and 'printer' type of compatible mobile devices. | 70 // The cloud print OAuth2 scope and 'printer' type of compatible mobile devices. |
63 const char kCloudPrintAuth[] = "https://www.googleapis.com/auth/cloudprint"; | 71 const char kCloudPrintAuth[] = "https://www.googleapis.com/auth/cloudprint"; |
64 const char kTypeAndroid[] = "ANDROID_CHROME_SNAPSHOT"; | 72 const char kTypeAndroid[] = "ANDROID_CHROME_SNAPSHOT"; |
65 const char kTypeIOS[] = "IOS_CHROME_SNAPSHOT"; | 73 const char kTypeIOS[] = "IOS_CHROME_SNAPSHOT"; |
66 | 74 |
67 // The account info URL pattern and strings to check for cloud print access. | |
68 // The 'key=' query parameter is used for caching; supply a random number. | |
69 // The 'rv=2' query parameter requests a JSON response; use 'rv=1' for XML. | |
70 const char kAccountInfoURL[] = | |
71 "https://clients1.google.com/tbproxy/getaccountinfo?key=%s&rv=2&%s"; | |
72 const char kAccountServicesKey[] = "services"; | |
73 const char kCloudPrintSerivceValue[] = "cprt"; | |
74 | |
75 // The Chrome To Mobile requestor type; used by services for filtering. | 75 // The Chrome To Mobile requestor type; used by services for filtering. |
76 const char kChromeToMobileRequestor[] = "requestor=chrome-to-mobile"; | 76 const char kChromeToMobileRequestor[] = "requestor=chrome-to-mobile"; |
77 | 77 |
78 // Get the job type string for a cloud print job submission. | 78 // Get the job type string for a cloud print job submission. |
79 std::string GetType(const ChromeToMobileService::JobData& data) { | 79 std::string GetType(const ChromeToMobileService::JobData& data) { |
80 if (data.type == ChromeToMobileService::URL) | 80 if (data.type == ChromeToMobileService::URL) |
81 return "url"; | 81 return "url"; |
82 if (data.type == ChromeToMobileService::DELAYED_SNAPSHOT) | 82 if (data.type == ChromeToMobileService::DELAYED_SNAPSHOT) |
83 return "url_with_delayed_snapshot"; | 83 return "url_with_delayed_snapshot"; |
84 DCHECK_EQ(data.type, ChromeToMobileService::SNAPSHOT); | 84 DCHECK_EQ(data.type, ChromeToMobileService::SNAPSHOT); |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
173 if (command_line->HasSwitch(switches::kEnableChromeToMobile)) | 173 if (command_line->HasSwitch(switches::kEnableChromeToMobile)) |
174 return true; | 174 return true; |
175 | 175 |
176 return kChromeToMobileEnabled; | 176 return kChromeToMobileEnabled; |
177 } | 177 } |
178 | 178 |
179 // static | 179 // static |
180 void ChromeToMobileService::RegisterUserPrefs(PrefService* prefs) { | 180 void ChromeToMobileService::RegisterUserPrefs(PrefService* prefs) { |
181 prefs->RegisterListPref(prefs::kChromeToMobileDeviceList, | 181 prefs->RegisterListPref(prefs::kChromeToMobileDeviceList, |
182 PrefService::UNSYNCABLE_PREF); | 182 PrefService::UNSYNCABLE_PREF); |
183 prefs->RegisterInt64Pref(prefs::kChromeToMobileTimestamp, 0, | |
nyquist
2012/08/21 00:00:01
Remove from chrome/common/pref_names.[h|cc]
msw
2012/08/21 03:37:01
Done.
| |
184 PrefService::UNSYNCABLE_PREF); | |
185 } | 183 } |
186 | 184 |
187 ChromeToMobileService::ChromeToMobileService(Profile* profile) | 185 ChromeToMobileService::ChromeToMobileService(Profile* profile) |
188 : ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)), | 186 : ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)), |
189 profile_(profile), | 187 profile_(profile), |
190 cloud_print_url_(new CloudPrintURL(profile)), | 188 profile_sync_service_enabled_(false), |
191 cloud_print_accessible_(false) { | 189 sync_invalidation_enabled_(false), |
192 // TODO(msw): Fix GMock tests, which lack profiles (http://crbug.com/122183). | 190 cloud_print_url_(new CloudPrintURL(profile)) { |
193 if (profile_) { | 191 // TODO(msw): Unit tests do not provide profiles; see http://crbug.com/122183 |
194 // Get an access token as soon as the Gaia login refresh token is available. | 192 ProfileSyncService* profile_sync_service = |
195 TokenService* service = TokenServiceFactory::GetForProfile(profile_); | 193 profile_ ? ProfileSyncServiceFactory::GetForProfile(profile_) : NULL; |
196 registrar_.Add(this, chrome::NOTIFICATION_TOKEN_AVAILABLE, | 194 if (profile_sync_service) { |
197 content::Source<TokenService>(service)); | 195 // Check the profile sync service state, as prescribed by the sync team. |
198 if (service->HasOAuthLoginToken()) | 196 profile_sync_service_enabled_ = profile_sync_service->ShouldPushChanges(); |
199 RequestAccessToken(); | 197 // Register for profile sync and cloud print device list notifications. |
198 profile_sync_service->AddObserver(this); | |
199 profile_sync_service->RegisterInvalidationHandler(this); | |
200 // TODO(msw|akalin): Initialize |sync_invalidation_enabled_| properly. | |
201 syncer::ObjectIdSet ids; | |
202 ids.insert(invalidation::ObjectId( | |
203 ipc::invalidation::ObjectSource::CHROME_COMPONENTS, | |
204 kSyncInvalidationObjectIdChromeToMobileDeviceList)); | |
205 profile_sync_service->UpdateRegisteredInvalidationIds(this, ids); | |
200 } | 206 } |
201 } | 207 } |
202 | 208 |
203 ChromeToMobileService::~ChromeToMobileService() { | 209 ChromeToMobileService::~ChromeToMobileService() { |
204 while (!snapshots_.empty()) | 210 while (!snapshots_.empty()) |
205 DeleteSnapshot(*snapshots_.begin()); | 211 DeleteSnapshot(*snapshots_.begin()); |
212 // TODO(msw): Unit tests do not provide profiles; see http://crbug.com/122183 | |
213 ProfileSyncService* profile_sync_service = | |
214 profile_ ? ProfileSyncServiceFactory::GetForProfile(profile_) : NULL; | |
215 if (profile_sync_service) { | |
216 // Unregister for profile sync and cloud print device list notifications. | |
217 profile_sync_service->RemoveObserver(this); | |
218 profile_sync_service->UnregisterInvalidationHandler(this); | |
219 } | |
206 } | 220 } |
207 | 221 |
208 bool ChromeToMobileService::HasMobiles() const { | 222 bool ChromeToMobileService::HasMobiles() const { |
209 return !GetMobiles()->empty(); | 223 const base::ListValue* mobiles = GetMobiles(); |
224 return mobiles && !mobiles->empty(); | |
210 } | 225 } |
211 | 226 |
212 const base::ListValue* ChromeToMobileService::GetMobiles() const { | 227 const base::ListValue* ChromeToMobileService::GetMobiles() const { |
213 return profile_->GetPrefs()->GetList(prefs::kChromeToMobileDeviceList); | 228 return (profile_sync_service_enabled_ && sync_invalidation_enabled_) ? |
214 } | 229 profile_->GetPrefs()->GetList(prefs::kChromeToMobileDeviceList) : NULL; |
215 | |
216 void ChromeToMobileService::RequestMobileListUpdate() { | |
217 if (access_token_.empty()) | |
218 RequestAccessToken(); | |
219 else if (cloud_print_accessible_) | |
220 RequestDeviceSearch(); | |
221 } | 230 } |
222 | 231 |
223 void ChromeToMobileService::GenerateSnapshot(Browser* browser, | 232 void ChromeToMobileService::GenerateSnapshot(Browser* browser, |
224 base::WeakPtr<Observer> observer) { | 233 base::WeakPtr<Observer> observer) { |
225 // Callback SnapshotFileCreated from CreateSnapshotFile to continue. | 234 // Callback SnapshotFileCreated from CreateSnapshotFile to continue. |
226 CreateSnapshotFileCallback callback = | 235 CreateSnapshotFileCallback callback = |
227 base::Bind(&ChromeToMobileService::SnapshotFileCreated, | 236 base::Bind(&ChromeToMobileService::SnapshotFileCreated, |
228 weak_ptr_factory_.GetWeakPtr(), observer, | 237 weak_ptr_factory_.GetWeakPtr(), observer, |
229 browser->session_id().id()); | 238 browser->session_id().id()); |
230 // Create a temporary file via the blocking pool for snapshot storage. | 239 // Create a temporary file via the blocking pool for snapshot storage. |
231 if (!content::BrowserThread::PostBlockingPoolTask(FROM_HERE, | 240 if (!content::BrowserThread::PostBlockingPoolTask(FROM_HERE, |
232 base::Bind(&CreateSnapshotFile, callback))) { | 241 base::Bind(&CreateSnapshotFile, callback))) { |
233 NOTREACHED(); | 242 NOTREACHED(); |
234 } | 243 } |
235 } | 244 } |
236 | 245 |
237 void ChromeToMobileService::SendToMobile(const base::DictionaryValue& mobile, | 246 void ChromeToMobileService::SendToMobile(const base::DictionaryValue* mobile, |
238 const FilePath& snapshot, | 247 const FilePath& snapshot, |
239 Browser* browser, | 248 Browser* browser, |
240 base::WeakPtr<Observer> observer) { | 249 base::WeakPtr<Observer> observer) { |
250 if (access_token_.empty()) { | |
251 // Enqueue this task to perform after obtaining an access token. | |
252 task_queue_.push(base::Bind(&ChromeToMobileService::SendToMobile, | |
253 weak_ptr_factory_.GetWeakPtr(), base::Owned(mobile->DeepCopy()), | |
254 snapshot, browser, observer)); | |
255 RequestAccessToken(); | |
256 return; | |
257 } | |
258 | |
241 LogMetric(SENDING_URL); | 259 LogMetric(SENDING_URL); |
242 | 260 |
243 JobData data; | 261 JobData data; |
244 std::string mobile_os; | 262 std::string mobile_os; |
245 if (!mobile.GetString("type", &mobile_os)) | 263 if (!mobile->GetString("type", &mobile_os)) |
246 NOTREACHED(); | 264 NOTREACHED(); |
247 data.mobile_os = (mobile_os.compare(kTypeAndroid) == 0) ? | 265 data.mobile_os = (mobile_os.compare(kTypeAndroid) == 0) ? |
248 ChromeToMobileService::ANDROID : ChromeToMobileService::IOS; | 266 ChromeToMobileService::ANDROID : ChromeToMobileService::IOS; |
249 if (!mobile.GetString("id", &data.mobile_id)) | 267 if (!mobile->GetString("id", &data.mobile_id)) |
250 NOTREACHED(); | 268 NOTREACHED(); |
251 content::WebContents* web_contents = chrome::GetActiveWebContents(browser); | 269 content::WebContents* web_contents = chrome::GetActiveWebContents(browser); |
252 data.url = web_contents->GetURL(); | 270 data.url = web_contents->GetURL(); |
253 data.title = web_contents->GetTitle(); | 271 data.title = web_contents->GetTitle(); |
254 data.snapshot = snapshot; | 272 data.snapshot = snapshot; |
255 data.snapshot_id = base::GenerateGUID(); | 273 data.snapshot_id = base::GenerateGUID(); |
256 data.type = !snapshot.empty() ? DELAYED_SNAPSHOT : URL; | 274 data.type = !snapshot.empty() ? DELAYED_SNAPSHOT : URL; |
257 | 275 |
258 net::URLFetcher* submit_url = CreateRequest(data); | 276 net::URLFetcher* submit_url = CreateRequest(data); |
259 request_observer_map_[submit_url] = observer; | 277 request_observer_map_[submit_url] = observer; |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
294 } | 312 } |
295 | 313 |
296 void ChromeToMobileService::LearnMore(Browser* browser) const { | 314 void ChromeToMobileService::LearnMore(Browser* browser) const { |
297 LogMetric(LEARN_MORE_CLICKED); | 315 LogMetric(LEARN_MORE_CLICKED); |
298 chrome::NavigateParams params(browser, | 316 chrome::NavigateParams params(browser, |
299 GURL(chrome::kChromeToMobileLearnMoreURL), content::PAGE_TRANSITION_LINK); | 317 GURL(chrome::kChromeToMobileLearnMoreURL), content::PAGE_TRANSITION_LINK); |
300 params.disposition = NEW_FOREGROUND_TAB; | 318 params.disposition = NEW_FOREGROUND_TAB; |
301 chrome::Navigate(¶ms); | 319 chrome::Navigate(¶ms); |
302 } | 320 } |
303 | 321 |
304 void ChromeToMobileService::OnURLFetchComplete( | 322 void ChromeToMobileService::OnURLFetchComplete(const net::URLFetcher* source) { |
305 const net::URLFetcher* source) { | 323 if (source == search_request_.get()) |
306 if (source == account_info_request_.get()) | |
307 HandleAccountInfoResponse(); | |
308 else if (source == search_request_.get()) | |
309 HandleSearchResponse(); | 324 HandleSearchResponse(); |
310 else | 325 else |
311 HandleSubmitResponse(source); | 326 HandleSubmitResponse(source); |
312 } | 327 } |
313 | 328 |
314 void ChromeToMobileService::Observe( | 329 void ChromeToMobileService::Observe( |
315 int type, | 330 int type, |
316 const content::NotificationSource& source, | 331 const content::NotificationSource& source, |
317 const content::NotificationDetails& details) { | 332 const content::NotificationDetails& details) { |
318 DCHECK_EQ(type, chrome::NOTIFICATION_TOKEN_AVAILABLE); | 333 DCHECK_EQ(type, chrome::NOTIFICATION_TOKEN_AVAILABLE); |
319 TokenService::TokenAvailableDetails* token_details = | 334 TokenService::TokenAvailableDetails* token_details = |
320 content::Details<TokenService::TokenAvailableDetails>(details).ptr(); | 335 content::Details<TokenService::TokenAvailableDetails>(details).ptr(); |
336 // Invalidate the cloud print access token on Gaia login token updates. | |
321 if (token_details->service() == GaiaConstants::kGaiaOAuth2LoginRefreshToken) | 337 if (token_details->service() == GaiaConstants::kGaiaOAuth2LoginRefreshToken) |
322 RequestAccessToken(); | 338 access_token_.clear(); |
323 } | 339 } |
324 | 340 |
325 void ChromeToMobileService::OnGetTokenSuccess( | 341 void ChromeToMobileService::OnGetTokenSuccess( |
326 const std::string& access_token, | 342 const std::string& access_token, |
327 const base::Time& expiration_time) { | 343 const base::Time& expiration_time) { |
328 DCHECK(!access_token.empty()); | 344 DCHECK(!access_token.empty()); |
329 access_token_fetcher_.reset(); | 345 access_token_fetcher_.reset(); |
330 auth_retry_timer_.Stop(); | 346 auth_retry_timer_.Stop(); |
331 access_token_ = access_token; | 347 access_token_ = access_token; |
332 RequestAccountInfo(); | 348 |
349 while (!task_queue_.empty()) { | |
350 // Post all tasks that were queued and waiting on a valid access token. | |
351 if (!content::BrowserThread::PostTask(content::BrowserThread::UI, FROM_HERE, | |
352 task_queue_.front())) { | |
353 NOTREACHED(); | |
354 } | |
355 task_queue_.pop(); | |
356 } | |
333 } | 357 } |
334 | 358 |
335 void ChromeToMobileService::OnGetTokenFailure( | 359 void ChromeToMobileService::OnGetTokenFailure( |
336 const GoogleServiceAuthError& error) { | 360 const GoogleServiceAuthError& error) { |
337 access_token_fetcher_.reset(); | 361 access_token_fetcher_.reset(); |
338 auth_retry_timer_.Stop(); | 362 auth_retry_timer_.Stop(); |
363 | |
339 auth_retry_timer_.Start( | 364 auth_retry_timer_.Start( |
340 FROM_HERE, base::TimeDelta::FromHours(kAuthRetryDelayHours), | 365 FROM_HERE, base::TimeDelta::FromHours(kAuthRetryDelayHours), |
341 this, &ChromeToMobileService::RequestAccessToken); | 366 this, &ChromeToMobileService::RequestAccessToken); |
342 } | 367 } |
343 | 368 |
369 void ChromeToMobileService::OnStateChanged() { | |
370 // Check the profile sync service state, as prescribed by the sync team. | |
371 profile_sync_service_enabled_ = | |
372 ProfileSyncServiceFactory::GetForProfile(profile_)->ShouldPushChanges(); | |
akalin
2012/08/20 22:29:30
maybe dcheck return value of GetForProfile()? I g
msw
2012/08/20 22:43:57
Yup, this ProfileSyncServiceObserver function is o
tim (not reviewing)
2012/08/21 00:33:47
Out of curiosity, what exactly do you need to chec
nyquist
2012/08/21 00:38:59
I believe the intent here is what you propose: Sig
akalin
2012/08/21 01:50:58
Okay I think I was confused, but now I'm not. Bas
msw
2012/08/21 03:37:01
Done. Now it's just tracking OnNotifications[En|Di
| |
373 UpdateCommandState(); | |
374 } | |
375 | |
376 void ChromeToMobileService::OnNotificationsEnabled() { | |
377 sync_invalidation_enabled_ = true; | |
378 UpdateCommandState(); | |
379 } | |
380 | |
381 void ChromeToMobileService::OnNotificationsDisabled( | |
382 syncer::NotificationsDisabledReason reason) { | |
383 sync_invalidation_enabled_ = false; | |
384 UpdateCommandState(); | |
385 } | |
386 | |
387 void ChromeToMobileService::OnIncomingNotification( | |
388 const syncer::ObjectIdPayloadMap& id_payloads, | |
389 syncer::IncomingNotificationSource source) { | |
390 DCHECK_EQ(id_payloads.size(), 1U); | |
391 DCHECK_EQ(id_payloads.count(invalidation::ObjectId( | |
392 ipc::invalidation::ObjectSource::CHROME_COMPONENTS, | |
393 kSyncInvalidationObjectIdChromeToMobileDeviceList)), 1U); | |
394 RequestDeviceSearch(); | |
395 } | |
396 | |
397 const std::string& ChromeToMobileService::GetAccessTokenForTest() const { | |
398 return access_token_; | |
399 } | |
400 | |
401 void ChromeToMobileService::SetAccessTokenForTest( | |
402 const std::string& access_token) { | |
403 access_token_ = access_token; | |
404 } | |
405 | |
344 void ChromeToMobileService::UpdateCommandState() const { | 406 void ChromeToMobileService::UpdateCommandState() const { |
345 // Ensure the feature is not disabled by commandline options. | 407 // Ensure the feature is not disabled by commandline options. |
346 DCHECK(IsChromeToMobileEnabled()); | 408 DCHECK(IsChromeToMobileEnabled()); |
347 const bool has_mobiles = HasMobiles(); | 409 const bool has_mobiles = HasMobiles(); |
348 for (BrowserList::const_iterator i = BrowserList::begin(); | 410 for (BrowserList::const_iterator i = BrowserList::begin(); |
349 i != BrowserList::end(); ++i) { | 411 i != BrowserList::end(); ++i) { |
350 Browser* browser = *i; | 412 Browser* browser = *i; |
351 if (browser->profile() == profile_) | 413 if (browser->profile() == profile_) |
352 browser->command_controller()->SendToMobileStateChanged(has_mobiles); | 414 browser->command_controller()->SendToMobileStateChanged(has_mobiles); |
353 } | 415 } |
(...skipping 74 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
428 } | 490 } |
429 cloud_print::AddMultipartValueForUpload("content", file, bound, | 491 cloud_print::AddMultipartValueForUpload("content", file, bound, |
430 "text/mhtml", &post); | 492 "text/mhtml", &post); |
431 | 493 |
432 post.append("--" + bound + "--\r\n"); | 494 post.append("--" + bound + "--\r\n"); |
433 request->SetUploadData("multipart/form-data; boundary=" + bound, post); | 495 request->SetUploadData("multipart/form-data; boundary=" + bound, post); |
434 request->Start(); | 496 request->Start(); |
435 } | 497 } |
436 | 498 |
437 void ChromeToMobileService::RequestAccessToken() { | 499 void ChromeToMobileService::RequestAccessToken() { |
500 // Register to observe Gaia login refresh token updates. | |
501 TokenService* token_service = TokenServiceFactory::GetForProfile(profile_); | |
502 if (registrar_.IsEmpty()) | |
503 registrar_.Add(this, chrome::NOTIFICATION_TOKEN_AVAILABLE, | |
504 content::Source<TokenService>(token_service)); | |
505 | |
438 // Deny concurrent requests and bail without a valid Gaia login refresh token. | 506 // Deny concurrent requests and bail without a valid Gaia login refresh token. |
439 TokenService* token_service = TokenServiceFactory::GetForProfile(profile_); | |
440 if (access_token_fetcher_.get() || !token_service->HasOAuthLoginToken()) | 507 if (access_token_fetcher_.get() || !token_service->HasOAuthLoginToken()) |
441 return; | 508 return; |
442 | 509 |
443 auth_retry_timer_.Stop(); | 510 auth_retry_timer_.Stop(); |
444 access_token_fetcher_.reset( | 511 access_token_fetcher_.reset( |
445 new OAuth2AccessTokenFetcher(this, profile_->GetRequestContext())); | 512 new OAuth2AccessTokenFetcher(this, profile_->GetRequestContext())); |
446 GaiaUrls* gaia_urls = GaiaUrls::GetInstance(); | 513 GaiaUrls* gaia_urls = GaiaUrls::GetInstance(); |
447 access_token_fetcher_->Start(gaia_urls->oauth2_chrome_client_id(), | 514 access_token_fetcher_->Start(gaia_urls->oauth2_chrome_client_id(), |
448 gaia_urls->oauth2_chrome_client_secret(), | 515 gaia_urls->oauth2_chrome_client_secret(), |
449 token_service->GetOAuth2LoginRefreshToken(), | 516 token_service->GetOAuth2LoginRefreshToken(), |
450 std::vector<std::string>(1, kCloudPrintAuth)); | 517 std::vector<std::string>(1, kCloudPrintAuth)); |
451 } | 518 } |
452 | 519 |
453 void ChromeToMobileService::RequestAccountInfo() { | 520 void ChromeToMobileService::RequestDeviceSearch() { |
454 // Deny concurrent requests. | 521 DCHECK(sync_invalidation_enabled_); |
455 if (account_info_request_.get()) | 522 if (access_token_.empty()) { |
456 return; | 523 // Enqueue this task to perform after obtaining an access token. |
457 | 524 task_queue_.push(base::Bind(&ChromeToMobileService::RequestDeviceSearch, |
458 std::string url_string = StringPrintf(kAccountInfoURL, | 525 weak_ptr_factory_.GetWeakPtr())); |
459 base::GenerateGUID().c_str(), kChromeToMobileRequestor); | 526 RequestAccessToken(); |
460 GURL url(url_string); | |
461 | |
462 // Account information is read from the profile's cookie. If cookies are | |
463 // blocked, access cloud print directly to list any potential devices. | |
464 scoped_refptr<CookieSettings> cookie_settings = | |
465 CookieSettings::Factory::GetForProfile(profile_); | |
466 if (cookie_settings && !cookie_settings->IsReadingCookieAllowed(url, url)) { | |
467 cloud_print_accessible_ = true; | |
468 RequestMobileListUpdate(); | |
469 return; | 527 return; |
470 } | 528 } |
471 | 529 |
472 account_info_request_.reset( | 530 // Deny concurrent requests. |
473 net::URLFetcher::Create(url, net::URLFetcher::GET, this)); | 531 if (search_request_.get()) |
nyquist
2012/08/20 23:19:19
If a user does cleanup in her printer list by dele
msw
2012/08/21 03:37:01
Done; good point. Some users will definitely manag
| |
474 account_info_request_->SetRequestContext(profile_->GetRequestContext()); | |
475 account_info_request_->SetMaxRetries(kMaxRetries); | |
476 // This request sends the user's cookie to check the cloud print service flag. | |
477 account_info_request_->SetLoadFlags(net::LOAD_DO_NOT_SAVE_COOKIES); | |
478 account_info_request_->Start(); | |
479 } | |
480 | |
481 void ChromeToMobileService::RequestDeviceSearch() { | |
482 // Deny requests if cloud print is inaccessible, and deny concurrent requests. | |
483 if (!cloud_print_accessible_ || search_request_.get()) | |
484 return; | |
485 | |
486 PrefService* prefs = profile_->GetPrefs(); | |
487 base::TimeTicks previous_search_time = base::TimeTicks::FromInternalValue( | |
488 prefs->GetInt64(prefs::kChromeToMobileTimestamp)); | |
489 | |
490 // Deny requests before the delay period has passed since the last request. | |
491 base::TimeDelta elapsed_time = base::TimeTicks::Now() - previous_search_time; | |
492 if (!previous_search_time.is_null() && | |
493 elapsed_time.InHours() < kSearchRequestDelayHours) | |
494 return; | 532 return; |
495 | 533 |
496 LogMetric(DEVICES_REQUESTED); | 534 LogMetric(DEVICES_REQUESTED); |
497 | 535 |
498 const GURL service_url(cloud_print_url_->GetCloudPrintServiceURL()); | 536 const GURL service_url(cloud_print_url_->GetCloudPrintServiceURL()); |
499 search_request_.reset(net::URLFetcher::Create(GetSearchURL(service_url), | 537 search_request_.reset(net::URLFetcher::Create(GetSearchURL(service_url), |
500 net::URLFetcher::GET, this)); | 538 net::URLFetcher::GET, this)); |
501 InitRequest(search_request_.get()); | 539 InitRequest(search_request_.get()); |
502 search_request_->Start(); | 540 search_request_->Start(); |
503 } | 541 } |
504 | 542 |
505 void ChromeToMobileService::HandleAccountInfoResponse() { | |
506 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | |
507 | |
508 std::string data; | |
509 account_info_request_->GetResponseAsString(&data); | |
510 account_info_request_.reset(); | |
511 | |
512 ListValue* services = NULL; | |
513 DictionaryValue* dictionary = NULL; | |
514 scoped_ptr<Value> json(base::JSONReader::Read(data)); | |
515 StringValue cloud_print_service(kCloudPrintSerivceValue); | |
516 if (json.get() && json->GetAsDictionary(&dictionary) && dictionary && | |
517 dictionary->GetList(kAccountServicesKey, &services) && services && | |
518 services->Find(cloud_print_service) != services->end()) { | |
519 cloud_print_accessible_ = true; | |
520 RequestMobileListUpdate(); | |
521 } | |
522 } | |
523 | |
524 void ChromeToMobileService::HandleSearchResponse() { | 543 void ChromeToMobileService::HandleSearchResponse() { |
525 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 544 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
526 | 545 |
527 std::string data; | 546 std::string data; |
528 search_request_->GetResponseAsString(&data); | 547 search_request_->GetResponseAsString(&data); |
529 search_request_.reset(); | 548 search_request_.reset(); |
530 | 549 |
531 ListValue* list = NULL; | 550 ListValue* list = NULL; |
532 DictionaryValue* dictionary = NULL; | 551 DictionaryValue* dictionary = NULL; |
533 scoped_ptr<Value> json(base::JSONReader::Read(data)); | 552 scoped_ptr<Value> json(base::JSONReader::Read(data)); |
(...skipping 14 matching lines...) Expand all Loading... | |
548 mobile->SetString("type", type); | 567 mobile->SetString("type", type); |
549 mobile->SetString("name", name); | 568 mobile->SetString("name", name); |
550 mobile->SetString("id", id); | 569 mobile->SetString("id", id); |
551 mobiles.Append(mobile); | 570 mobiles.Append(mobile); |
552 } else { | 571 } else { |
553 NOTREACHED(); | 572 NOTREACHED(); |
554 } | 573 } |
555 } | 574 } |
556 } | 575 } |
557 | 576 |
558 // Update the mobile list and timestamp in prefs. | 577 // Update the cached mobile device list in profile prefs. |
559 PrefService* prefs = profile_->GetPrefs(); | 578 profile_->GetPrefs()->Set(prefs::kChromeToMobileDeviceList, mobiles); |
560 prefs->Set(prefs::kChromeToMobileDeviceList, mobiles); | |
561 prefs->SetInt64(prefs::kChromeToMobileTimestamp, | |
562 base::TimeTicks::Now().ToInternalValue()); | |
563 | 579 |
564 if (HasMobiles()) | 580 if (HasMobiles()) |
565 LogMetric(DEVICES_AVAILABLE); | 581 LogMetric(DEVICES_AVAILABLE); |
566 UpdateCommandState(); | 582 UpdateCommandState(); |
567 } | 583 } |
568 } | 584 } |
569 | 585 |
570 void ChromeToMobileService::HandleSubmitResponse( | 586 void ChromeToMobileService::HandleSubmitResponse( |
571 const net::URLFetcher* source) { | 587 const net::URLFetcher* source) { |
572 // Get the observer for this response; bail if there is none or it is NULL. | 588 // Get the observer for this response; bail if there is none or it is NULL. |
(...skipping 24 matching lines...) Expand all Loading... | |
597 | 613 |
598 // Ensure a second response is not sent after reporting failure below. | 614 // Ensure a second response is not sent after reporting failure below. |
599 request_observer_map_.erase(other); | 615 request_observer_map_.erase(other); |
600 break; | 616 break; |
601 } | 617 } |
602 } | 618 } |
603 | 619 |
604 LogMetric(success ? SEND_SUCCESS : SEND_ERROR); | 620 LogMetric(success ? SEND_SUCCESS : SEND_ERROR); |
605 observer->OnSendComplete(success); | 621 observer->OnSendComplete(success); |
606 } | 622 } |
OLD | NEW |