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 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
118 // Utility function to call cloud_print::AddMultipartValueForUpload. | 118 // Utility function to call cloud_print::AddMultipartValueForUpload. |
119 void AddValue(const std::string& value_name, | 119 void AddValue(const std::string& value_name, |
120 const std::string& value, | 120 const std::string& value, |
121 const std::string& mime_boundary, | 121 const std::string& mime_boundary, |
122 std::string* post_data) { | 122 std::string* post_data) { |
123 cloud_print::AddMultipartValueForUpload(value_name, value, mime_boundary, | 123 cloud_print::AddMultipartValueForUpload(value_name, value, mime_boundary, |
124 std::string(), post_data); | 124 std::string(), post_data); |
125 } | 125 } |
126 | 126 |
127 // Get the URL for cloud print device search; appends a requestor query param. | 127 // Get the URL for cloud print device search; appends a requestor query param. |
128 GURL GetSearchURL(const GURL& service_url) { | 128 GURL GetSearchURL(const GURL& cloud_print_url) { |
129 GURL search_url = cloud_print::GetUrlForSearch(service_url); | 129 GURL search_url = cloud_print::GetUrlForSearch(cloud_print_url); |
130 GURL::Replacements replacements; | 130 GURL::Replacements replacements; |
131 std::string query(kChromeToMobileRequestor); | 131 std::string query(kChromeToMobileRequestor); |
132 replacements.SetQueryStr(query); | 132 replacements.SetQueryStr(query); |
133 return search_url.ReplaceComponents(replacements); | 133 return search_url.ReplaceComponents(replacements); |
134 } | 134 } |
135 | 135 |
136 // A callback to continue snapshot generation after creating the temp file. | 136 // A callback to continue snapshot generation after creating the temp file. |
137 typedef base::Callback<void(const FilePath& path, bool success)> | 137 typedef base::Callback<void(const FilePath& path, bool success)> |
138 CreateSnapshotFileCallback; | 138 CreateSnapshotFileCallback; |
139 | 139 |
(...skipping 33 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, | |
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 sync_invalidation_enabled_(false) { |
191 cloud_print_accessible_(false) { | 189 // TODO(msw): Unit tests do not provide profiles; see http://crbug.com/122183 |
192 // TODO(msw): Fix GMock tests, which lack profiles (http://crbug.com/122183). | 190 ProfileSyncService* profile_sync_service = |
193 if (profile_) { | 191 profile_ ? ProfileSyncServiceFactory::GetForProfile(profile_) : NULL; |
194 // Get an access token as soon as the Gaia login refresh token is available. | 192 if (profile_sync_service) { |
195 TokenService* service = TokenServiceFactory::GetForProfile(profile_); | 193 CloudPrintURL cloud_print_url(profile_); |
196 registrar_.Add(this, chrome::NOTIFICATION_TOKEN_AVAILABLE, | 194 cloud_print_url_ = cloud_print_url.GetCloudPrintServiceURL(); |
197 content::Source<TokenService>(service)); | 195 // Register for cloud print device list invalidation notifications. |
198 if (service->HasOAuthLoginToken()) | 196 // TODO(msw|akalin): Initialize |sync_invalidation_enabled_| properly. |
199 RequestAccessToken(); | 197 profile_sync_service->RegisterInvalidationHandler(this); |
198 syncer::ObjectIdSet ids; | |
199 ids.insert(invalidation::ObjectId( | |
200 ipc::invalidation::ObjectSource::CHROME_COMPONENTS, | |
201 kSyncInvalidationObjectIdChromeToMobileDeviceList)); | |
202 profile_sync_service->UpdateRegisteredInvalidationIds(this, ids); | |
200 } | 203 } |
201 } | 204 } |
202 | 205 |
203 ChromeToMobileService::~ChromeToMobileService() { | 206 ChromeToMobileService::~ChromeToMobileService() { |
204 while (!snapshots_.empty()) | 207 while (!snapshots_.empty()) |
205 DeleteSnapshot(*snapshots_.begin()); | 208 DeleteSnapshot(*snapshots_.begin()); |
209 // TODO(msw): Unit tests do not provide profiles; see http://crbug.com/122183 | |
210 // Unregister for profile sync and cloud print device list notifications. | |
akalin
2012/08/21 07:47:50
update comment
msw
2012/08/21 19:46:09
Done.
| |
211 ProfileSyncService* profile_sync_service = | |
212 profile_ ? ProfileSyncServiceFactory::GetForProfile(profile_) : NULL; | |
213 if (profile_sync_service) | |
214 profile_sync_service->UnregisterInvalidationHandler(this); | |
206 } | 215 } |
207 | 216 |
208 bool ChromeToMobileService::HasMobiles() const { | 217 bool ChromeToMobileService::HasMobiles() const { |
209 return !GetMobiles()->empty(); | 218 const base::ListValue* mobiles = GetMobiles(); |
219 return mobiles && !mobiles->empty(); | |
210 } | 220 } |
211 | 221 |
212 const base::ListValue* ChromeToMobileService::GetMobiles() const { | 222 const base::ListValue* ChromeToMobileService::GetMobiles() const { |
213 return profile_->GetPrefs()->GetList(prefs::kChromeToMobileDeviceList); | 223 return sync_invalidation_enabled_ ? |
214 } | 224 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 } | 225 } |
222 | 226 |
223 void ChromeToMobileService::GenerateSnapshot(Browser* browser, | 227 void ChromeToMobileService::GenerateSnapshot(Browser* browser, |
224 base::WeakPtr<Observer> observer) { | 228 base::WeakPtr<Observer> observer) { |
225 // Callback SnapshotFileCreated from CreateSnapshotFile to continue. | 229 // Callback SnapshotFileCreated from CreateSnapshotFile to continue. |
226 CreateSnapshotFileCallback callback = | 230 CreateSnapshotFileCallback callback = |
227 base::Bind(&ChromeToMobileService::SnapshotFileCreated, | 231 base::Bind(&ChromeToMobileService::SnapshotFileCreated, |
228 weak_ptr_factory_.GetWeakPtr(), observer, | 232 weak_ptr_factory_.GetWeakPtr(), observer, |
229 browser->session_id().id()); | 233 browser->session_id().id()); |
230 // Create a temporary file via the blocking pool for snapshot storage. | 234 // Create a temporary file via the blocking pool for snapshot storage. |
231 if (!content::BrowserThread::PostBlockingPoolTask(FROM_HERE, | 235 if (!content::BrowserThread::PostBlockingPoolTask(FROM_HERE, |
232 base::Bind(&CreateSnapshotFile, callback))) { | 236 base::Bind(&CreateSnapshotFile, callback))) { |
233 NOTREACHED(); | 237 NOTREACHED(); |
234 } | 238 } |
235 } | 239 } |
236 | 240 |
237 void ChromeToMobileService::SendToMobile(const base::DictionaryValue& mobile, | 241 void ChromeToMobileService::SendToMobile(const base::DictionaryValue* mobile, |
238 const FilePath& snapshot, | 242 const FilePath& snapshot, |
239 Browser* browser, | 243 Browser* browser, |
240 base::WeakPtr<Observer> observer) { | 244 base::WeakPtr<Observer> observer) { |
245 if (access_token_.empty()) { | |
246 // Enqueue this task to perform after obtaining an access token. | |
247 task_queue_.push(base::Bind(&ChromeToMobileService::SendToMobile, | |
248 weak_ptr_factory_.GetWeakPtr(), base::Owned(mobile->DeepCopy()), | |
249 snapshot, browser, observer)); | |
250 RequestAccessToken(); | |
251 return; | |
252 } | |
253 | |
241 LogMetric(SENDING_URL); | 254 LogMetric(SENDING_URL); |
242 | 255 |
243 JobData data; | 256 JobData data; |
244 std::string mobile_os; | 257 std::string mobile_os; |
245 if (!mobile.GetString("type", &mobile_os)) | 258 if (!mobile->GetString("type", &mobile_os)) |
246 NOTREACHED(); | 259 NOTREACHED(); |
247 data.mobile_os = (mobile_os.compare(kTypeAndroid) == 0) ? | 260 data.mobile_os = (mobile_os.compare(kTypeAndroid) == 0) ? |
248 ChromeToMobileService::ANDROID : ChromeToMobileService::IOS; | 261 ChromeToMobileService::ANDROID : ChromeToMobileService::IOS; |
249 if (!mobile.GetString("id", &data.mobile_id)) | 262 if (!mobile->GetString("id", &data.mobile_id)) |
250 NOTREACHED(); | 263 NOTREACHED(); |
251 content::WebContents* web_contents = chrome::GetActiveWebContents(browser); | 264 content::WebContents* web_contents = chrome::GetActiveWebContents(browser); |
252 data.url = web_contents->GetURL(); | 265 data.url = web_contents->GetURL(); |
253 data.title = web_contents->GetTitle(); | 266 data.title = web_contents->GetTitle(); |
254 data.snapshot = snapshot; | 267 data.snapshot = snapshot; |
255 data.snapshot_id = base::GenerateGUID(); | 268 data.snapshot_id = base::GenerateGUID(); |
256 data.type = !snapshot.empty() ? DELAYED_SNAPSHOT : URL; | 269 data.type = !snapshot.empty() ? DELAYED_SNAPSHOT : URL; |
257 | 270 |
258 net::URLFetcher* submit_url = CreateRequest(data); | 271 net::URLFetcher* submit_url = CreateRequest(data); |
259 request_observer_map_[submit_url] = observer; | 272 request_observer_map_[submit_url] = observer; |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
294 } | 307 } |
295 | 308 |
296 void ChromeToMobileService::LearnMore(Browser* browser) const { | 309 void ChromeToMobileService::LearnMore(Browser* browser) const { |
297 LogMetric(LEARN_MORE_CLICKED); | 310 LogMetric(LEARN_MORE_CLICKED); |
298 chrome::NavigateParams params(browser, | 311 chrome::NavigateParams params(browser, |
299 GURL(chrome::kChromeToMobileLearnMoreURL), content::PAGE_TRANSITION_LINK); | 312 GURL(chrome::kChromeToMobileLearnMoreURL), content::PAGE_TRANSITION_LINK); |
300 params.disposition = NEW_FOREGROUND_TAB; | 313 params.disposition = NEW_FOREGROUND_TAB; |
301 chrome::Navigate(¶ms); | 314 chrome::Navigate(¶ms); |
302 } | 315 } |
303 | 316 |
304 void ChromeToMobileService::OnURLFetchComplete( | 317 void ChromeToMobileService::OnURLFetchComplete(const net::URLFetcher* source) { |
305 const net::URLFetcher* source) { | 318 if (source->GetURL() == GetSearchURL(cloud_print_url_)) |
306 if (source == account_info_request_.get()) | 319 HandleSearchResponse(source); |
307 HandleAccountInfoResponse(); | |
308 else if (source == search_request_.get()) | |
309 HandleSearchResponse(); | |
310 else | 320 else |
311 HandleSubmitResponse(source); | 321 HandleSubmitResponse(source); |
312 } | 322 } |
313 | 323 |
314 void ChromeToMobileService::Observe( | 324 void ChromeToMobileService::Observe( |
315 int type, | 325 int type, |
316 const content::NotificationSource& source, | 326 const content::NotificationSource& source, |
317 const content::NotificationDetails& details) { | 327 const content::NotificationDetails& details) { |
318 DCHECK_EQ(type, chrome::NOTIFICATION_TOKEN_AVAILABLE); | 328 DCHECK_EQ(type, chrome::NOTIFICATION_TOKEN_AVAILABLE); |
319 TokenService::TokenAvailableDetails* token_details = | 329 TokenService::TokenAvailableDetails* token_details = |
320 content::Details<TokenService::TokenAvailableDetails>(details).ptr(); | 330 content::Details<TokenService::TokenAvailableDetails>(details).ptr(); |
331 // Invalidate the cloud print access token on Gaia login token updates. | |
321 if (token_details->service() == GaiaConstants::kGaiaOAuth2LoginRefreshToken) | 332 if (token_details->service() == GaiaConstants::kGaiaOAuth2LoginRefreshToken) |
322 RequestAccessToken(); | 333 access_token_.clear(); |
323 } | 334 } |
324 | 335 |
325 void ChromeToMobileService::OnGetTokenSuccess( | 336 void ChromeToMobileService::OnGetTokenSuccess( |
326 const std::string& access_token, | 337 const std::string& access_token, |
327 const base::Time& expiration_time) { | 338 const base::Time& expiration_time) { |
328 DCHECK(!access_token.empty()); | 339 DCHECK(!access_token.empty()); |
329 access_token_fetcher_.reset(); | 340 access_token_fetcher_.reset(); |
330 auth_retry_timer_.Stop(); | 341 auth_retry_timer_.Stop(); |
331 access_token_ = access_token; | 342 access_token_ = access_token; |
332 RequestAccountInfo(); | 343 |
344 while (!task_queue_.empty()) { | |
345 // Post all tasks that were queued and waiting on a valid access token. | |
346 if (!content::BrowserThread::PostTask(content::BrowserThread::UI, FROM_HERE, | |
347 task_queue_.front())) { | |
348 NOTREACHED(); | |
349 } | |
350 task_queue_.pop(); | |
351 } | |
333 } | 352 } |
334 | 353 |
335 void ChromeToMobileService::OnGetTokenFailure( | 354 void ChromeToMobileService::OnGetTokenFailure( |
336 const GoogleServiceAuthError& error) { | 355 const GoogleServiceAuthError& error) { |
337 access_token_fetcher_.reset(); | 356 access_token_fetcher_.reset(); |
338 auth_retry_timer_.Stop(); | 357 auth_retry_timer_.Stop(); |
358 | |
339 auth_retry_timer_.Start( | 359 auth_retry_timer_.Start( |
340 FROM_HERE, base::TimeDelta::FromHours(kAuthRetryDelayHours), | 360 FROM_HERE, base::TimeDelta::FromHours(kAuthRetryDelayHours), |
341 this, &ChromeToMobileService::RequestAccessToken); | 361 this, &ChromeToMobileService::RequestAccessToken); |
342 } | 362 } |
343 | 363 |
364 void ChromeToMobileService::OnNotificationsEnabled() { | |
365 sync_invalidation_enabled_ = true; | |
366 UpdateCommandState(); | |
367 } | |
368 | |
369 void ChromeToMobileService::OnNotificationsDisabled( | |
370 syncer::NotificationsDisabledReason reason) { | |
371 sync_invalidation_enabled_ = false; | |
372 UpdateCommandState(); | |
373 } | |
374 | |
375 void ChromeToMobileService::OnIncomingNotification( | |
376 const syncer::ObjectIdPayloadMap& id_payloads, | |
377 syncer::IncomingNotificationSource source) { | |
378 DCHECK_EQ(id_payloads.size(), 1U); | |
379 DCHECK_EQ(id_payloads.count(invalidation::ObjectId( | |
380 ipc::invalidation::ObjectSource::CHROME_COMPONENTS, | |
381 kSyncInvalidationObjectIdChromeToMobileDeviceList)), 1U); | |
382 RequestDeviceSearch(); | |
383 } | |
384 | |
385 const std::string& ChromeToMobileService::GetAccessTokenForTest() const { | |
386 return access_token_; | |
387 } | |
388 | |
389 void ChromeToMobileService::SetAccessTokenForTest( | |
390 const std::string& access_token) { | |
391 access_token_ = access_token; | |
392 } | |
393 | |
344 void ChromeToMobileService::UpdateCommandState() const { | 394 void ChromeToMobileService::UpdateCommandState() const { |
345 // Ensure the feature is not disabled by commandline options. | 395 // Ensure the feature is not disabled by commandline options. |
346 DCHECK(IsChromeToMobileEnabled()); | 396 DCHECK(IsChromeToMobileEnabled()); |
347 const bool has_mobiles = HasMobiles(); | 397 const bool has_mobiles = HasMobiles(); |
348 for (BrowserList::const_iterator i = BrowserList::begin(); | 398 for (BrowserList::const_iterator i = BrowserList::begin(); |
349 i != BrowserList::end(); ++i) { | 399 i != BrowserList::end(); ++i) { |
350 Browser* browser = *i; | 400 Browser* browser = *i; |
351 if (browser->profile() == profile_) | 401 if (browser->profile() == profile_) |
352 browser->command_controller()->SendToMobileStateChanged(has_mobiles); | 402 browser->command_controller()->SendToMobileStateChanged(has_mobiles); |
353 } | 403 } |
(...skipping 13 matching lines...) Expand all Loading... | |
367 // Generate the snapshot and have the observer be called back on completion. | 417 // Generate the snapshot and have the observer be called back on completion. |
368 chrome::GetActiveWebContents(browser)->GenerateMHTML(path, | 418 chrome::GetActiveWebContents(browser)->GenerateMHTML(path, |
369 base::Bind(&Observer::SnapshotGenerated, observer)); | 419 base::Bind(&Observer::SnapshotGenerated, observer)); |
370 } else if (observer.get()) { | 420 } else if (observer.get()) { |
371 // Signal snapshot generation failure. | 421 // Signal snapshot generation failure. |
372 observer->SnapshotGenerated(FilePath(), 0); | 422 observer->SnapshotGenerated(FilePath(), 0); |
373 } | 423 } |
374 } | 424 } |
375 | 425 |
376 net::URLFetcher* ChromeToMobileService::CreateRequest(const JobData& data) { | 426 net::URLFetcher* ChromeToMobileService::CreateRequest(const JobData& data) { |
377 const GURL service_url(cloud_print_url_->GetCloudPrintServiceURL()); | |
378 net::URLFetcher* request = net::URLFetcher::Create( | 427 net::URLFetcher* request = net::URLFetcher::Create( |
379 cloud_print::GetUrlForSubmit(service_url), net::URLFetcher::POST, this); | 428 cloud_print::GetUrlForSubmit(cloud_print_url_), |
429 net::URLFetcher::POST, this); | |
380 InitRequest(request); | 430 InitRequest(request); |
381 return request; | 431 return request; |
382 } | 432 } |
383 | 433 |
384 void ChromeToMobileService::InitRequest(net::URLFetcher* request) { | 434 void ChromeToMobileService::InitRequest(net::URLFetcher* request) { |
385 request->SetRequestContext(profile_->GetRequestContext()); | 435 request->SetRequestContext(profile_->GetRequestContext()); |
386 request->SetMaxRetries(kMaxRetries); | 436 request->SetMaxRetries(kMaxRetries); |
387 DCHECK(!access_token_.empty()); | 437 DCHECK(!access_token_.empty()); |
388 request->SetExtraRequestHeaders("Authorization: OAuth " + | 438 request->SetExtraRequestHeaders("Authorization: OAuth " + |
389 access_token_ + "\r\n" + cloud_print::kChromeCloudPrintProxyHeader); | 439 access_token_ + "\r\n" + cloud_print::kChromeCloudPrintProxyHeader); |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
428 } | 478 } |
429 cloud_print::AddMultipartValueForUpload("content", file, bound, | 479 cloud_print::AddMultipartValueForUpload("content", file, bound, |
430 "text/mhtml", &post); | 480 "text/mhtml", &post); |
431 | 481 |
432 post.append("--" + bound + "--\r\n"); | 482 post.append("--" + bound + "--\r\n"); |
433 request->SetUploadData("multipart/form-data; boundary=" + bound, post); | 483 request->SetUploadData("multipart/form-data; boundary=" + bound, post); |
434 request->Start(); | 484 request->Start(); |
435 } | 485 } |
436 | 486 |
437 void ChromeToMobileService::RequestAccessToken() { | 487 void ChromeToMobileService::RequestAccessToken() { |
488 // Register to observe Gaia login refresh token updates. | |
489 TokenService* token_service = TokenServiceFactory::GetForProfile(profile_); | |
490 if (registrar_.IsEmpty()) | |
491 registrar_.Add(this, chrome::NOTIFICATION_TOKEN_AVAILABLE, | |
492 content::Source<TokenService>(token_service)); | |
493 | |
438 // Deny concurrent requests and bail without a valid Gaia login refresh token. | 494 // 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()) | 495 if (access_token_fetcher_.get() || !token_service->HasOAuthLoginToken()) |
441 return; | 496 return; |
442 | 497 |
443 auth_retry_timer_.Stop(); | 498 auth_retry_timer_.Stop(); |
444 access_token_fetcher_.reset( | 499 access_token_fetcher_.reset( |
445 new OAuth2AccessTokenFetcher(this, profile_->GetRequestContext())); | 500 new OAuth2AccessTokenFetcher(this, profile_->GetRequestContext())); |
446 GaiaUrls* gaia_urls = GaiaUrls::GetInstance(); | 501 GaiaUrls* gaia_urls = GaiaUrls::GetInstance(); |
447 access_token_fetcher_->Start(gaia_urls->oauth2_chrome_client_id(), | 502 access_token_fetcher_->Start(gaia_urls->oauth2_chrome_client_id(), |
448 gaia_urls->oauth2_chrome_client_secret(), | 503 gaia_urls->oauth2_chrome_client_secret(), |
449 token_service->GetOAuth2LoginRefreshToken(), | 504 token_service->GetOAuth2LoginRefreshToken(), |
450 std::vector<std::string>(1, kCloudPrintAuth)); | 505 std::vector<std::string>(1, kCloudPrintAuth)); |
451 } | 506 } |
452 | 507 |
453 void ChromeToMobileService::RequestAccountInfo() { | 508 void ChromeToMobileService::RequestDeviceSearch() { |
454 // Deny concurrent requests. | 509 DCHECK(sync_invalidation_enabled_); |
455 if (account_info_request_.get()) | 510 if (access_token_.empty()) { |
456 return; | 511 // Enqueue this task to perform after obtaining an access token. |
457 | 512 task_queue_.push(base::Bind(&ChromeToMobileService::RequestDeviceSearch, |
458 std::string url_string = StringPrintf(kAccountInfoURL, | 513 weak_ptr_factory_.GetWeakPtr())); |
459 base::GenerateGUID().c_str(), kChromeToMobileRequestor); | 514 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; | 515 return; |
470 } | 516 } |
471 | 517 |
472 account_info_request_.reset( | 518 LogMetric(DEVICES_REQUESTED); |
473 net::URLFetcher::Create(url, net::URLFetcher::GET, this)); | 519 |
474 account_info_request_->SetRequestContext(profile_->GetRequestContext()); | 520 net::URLFetcher* search_request = net::URLFetcher::Create( |
475 account_info_request_->SetMaxRetries(kMaxRetries); | 521 GetSearchURL(cloud_print_url_), net::URLFetcher::GET, this); |
476 // This request sends the user's cookie to check the cloud print service flag. | 522 InitRequest(search_request); |
477 account_info_request_->SetLoadFlags(net::LOAD_DO_NOT_SAVE_COOKIES); | 523 search_request->Start(); |
478 account_info_request_->Start(); | |
479 } | 524 } |
480 | 525 |
481 void ChromeToMobileService::RequestDeviceSearch() { | 526 void ChromeToMobileService::HandleSearchResponse( |
482 // Deny requests if cloud print is inaccessible, and deny concurrent requests. | 527 const net::URLFetcher* source) { |
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; | |
495 | |
496 LogMetric(DEVICES_REQUESTED); | |
497 | |
498 const GURL service_url(cloud_print_url_->GetCloudPrintServiceURL()); | |
499 search_request_.reset(net::URLFetcher::Create(GetSearchURL(service_url), | |
500 net::URLFetcher::GET, this)); | |
501 InitRequest(search_request_.get()); | |
502 search_request_->Start(); | |
503 } | |
504 | |
505 void ChromeToMobileService::HandleAccountInfoResponse() { | |
506 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 528 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
529 DCHECK_EQ(source->GetURL(), GetSearchURL(cloud_print_url_)); | |
507 | 530 |
508 std::string data; | 531 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() { | |
525 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | |
526 | |
527 std::string data; | |
528 search_request_->GetResponseAsString(&data); | |
529 search_request_.reset(); | |
530 | |
531 ListValue* list = NULL; | 532 ListValue* list = NULL; |
532 DictionaryValue* dictionary = NULL; | 533 DictionaryValue* dictionary = NULL; |
534 source->GetResponseAsString(&data); | |
533 scoped_ptr<Value> json(base::JSONReader::Read(data)); | 535 scoped_ptr<Value> json(base::JSONReader::Read(data)); |
534 if (json.get() && json->GetAsDictionary(&dictionary) && dictionary && | 536 if (json.get() && json->GetAsDictionary(&dictionary) && dictionary && |
535 dictionary->GetList(cloud_print::kPrinterListValue, &list)) { | 537 dictionary->GetList(cloud_print::kPrinterListValue, &list)) { |
536 ListValue mobiles; | 538 ListValue mobiles; |
537 std::string type, name, id; | 539 std::string type, name, id; |
538 DictionaryValue* printer = NULL; | 540 DictionaryValue* printer = NULL; |
539 DictionaryValue* mobile = NULL; | 541 DictionaryValue* mobile = NULL; |
540 for (size_t index = 0; index < list->GetSize(); ++index) { | 542 for (size_t index = 0; index < list->GetSize(); ++index) { |
541 if (list->GetDictionary(index, &printer) && | 543 if (list->GetDictionary(index, &printer) && |
542 printer->GetString("type", &type) && | 544 printer->GetString("type", &type) && |
543 (type.compare(kTypeAndroid) == 0 || type.compare(kTypeIOS) == 0)) { | 545 (type.compare(kTypeAndroid) == 0 || type.compare(kTypeIOS) == 0)) { |
544 // Copy just the requisite values from the full |printer| definition. | 546 // Copy just the requisite values from the full |printer| definition. |
545 if (printer->GetString("displayName", &name) && | 547 if (printer->GetString("displayName", &name) && |
546 printer->GetString("id", &id)) { | 548 printer->GetString("id", &id)) { |
547 mobile = new DictionaryValue(); | 549 mobile = new DictionaryValue(); |
548 mobile->SetString("type", type); | 550 mobile->SetString("type", type); |
549 mobile->SetString("name", name); | 551 mobile->SetString("name", name); |
550 mobile->SetString("id", id); | 552 mobile->SetString("id", id); |
551 mobiles.Append(mobile); | 553 mobiles.Append(mobile); |
552 } else { | 554 } else { |
553 NOTREACHED(); | 555 NOTREACHED(); |
554 } | 556 } |
555 } | 557 } |
556 } | 558 } |
557 | 559 |
558 // Update the mobile list and timestamp in prefs. | 560 // Update the cached mobile device list in profile prefs. |
559 PrefService* prefs = profile_->GetPrefs(); | 561 profile_->GetPrefs()->Set(prefs::kChromeToMobileDeviceList, mobiles); |
560 prefs->Set(prefs::kChromeToMobileDeviceList, mobiles); | |
561 prefs->SetInt64(prefs::kChromeToMobileTimestamp, | |
562 base::TimeTicks::Now().ToInternalValue()); | |
563 | 562 |
564 if (HasMobiles()) | 563 if (HasMobiles()) |
565 LogMetric(DEVICES_AVAILABLE); | 564 LogMetric(DEVICES_AVAILABLE); |
566 UpdateCommandState(); | 565 UpdateCommandState(); |
567 } | 566 } |
568 } | 567 } |
569 | 568 |
570 void ChromeToMobileService::HandleSubmitResponse( | 569 void ChromeToMobileService::HandleSubmitResponse( |
571 const net::URLFetcher* source) { | 570 const net::URLFetcher* source) { |
572 // Get the observer for this response; bail if there is none or it is NULL. | 571 // Get the observer for this response; bail if there is none or it is NULL. |
(...skipping 24 matching lines...) Expand all Loading... | |
597 | 596 |
598 // Ensure a second response is not sent after reporting failure below. | 597 // Ensure a second response is not sent after reporting failure below. |
599 request_observer_map_.erase(other); | 598 request_observer_map_.erase(other); |
600 break; | 599 break; |
601 } | 600 } |
602 } | 601 } |
603 | 602 |
604 LogMetric(success ? SEND_SUCCESS : SEND_ERROR); | 603 LogMetric(success ? SEND_SUCCESS : SEND_ERROR); |
605 observer->OnSendComplete(success); | 604 observer->OnSendComplete(success); |
606 } | 605 } |
OLD | NEW |