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/drive/gdata_wapi_service.h" | 5 #include "chrome/browser/drive/gdata_wapi_service.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
192 // to the Drive API v2, so we'll reuse GetResourceListRequest to implement | 192 // to the Drive API v2, so we'll reuse GetResourceListRequest to implement |
193 // following methods, instead of cleaning the request class. | 193 // following methods, instead of cleaning the request class. |
194 | 194 |
195 CancelCallback GDataWapiService::GetAllResourceList( | 195 CancelCallback GDataWapiService::GetAllResourceList( |
196 const GetResourceListCallback& callback) { | 196 const GetResourceListCallback& callback) { |
197 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 197 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
198 DCHECK(!callback.is_null()); | 198 DCHECK(!callback.is_null()); |
199 | 199 |
200 return sender_->StartRequestWithRetry( | 200 return sender_->StartRequestWithRetry( |
201 new GetResourceListRequest(sender_.get(), | 201 new GetResourceListRequest(sender_.get(), |
202 url_request_context_getter_, | |
203 url_generator_, | 202 url_generator_, |
204 GURL(), // No override url | 203 GURL(), // No override url |
205 0, // start changestamp | 204 0, // start changestamp |
206 std::string(), // empty search query | 205 std::string(), // empty search query |
207 std::string(), // no directory resource id | 206 std::string(), // no directory resource id |
208 callback)); | 207 callback)); |
209 } | 208 } |
210 | 209 |
211 CancelCallback GDataWapiService::GetResourceListInDirectory( | 210 CancelCallback GDataWapiService::GetResourceListInDirectory( |
212 const std::string& directory_resource_id, | 211 const std::string& directory_resource_id, |
213 const GetResourceListCallback& callback) { | 212 const GetResourceListCallback& callback) { |
214 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 213 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
215 DCHECK(!directory_resource_id.empty()); | 214 DCHECK(!directory_resource_id.empty()); |
216 DCHECK(!callback.is_null()); | 215 DCHECK(!callback.is_null()); |
217 | 216 |
218 return sender_->StartRequestWithRetry( | 217 return sender_->StartRequestWithRetry( |
219 new GetResourceListRequest(sender_.get(), | 218 new GetResourceListRequest(sender_.get(), |
220 url_request_context_getter_, | |
221 url_generator_, | 219 url_generator_, |
222 GURL(), // No override url | 220 GURL(), // No override url |
223 0, // start changestamp | 221 0, // start changestamp |
224 std::string(), // empty search query | 222 std::string(), // empty search query |
225 directory_resource_id, | 223 directory_resource_id, |
226 callback)); | 224 callback)); |
227 } | 225 } |
228 | 226 |
229 CancelCallback GDataWapiService::Search( | 227 CancelCallback GDataWapiService::Search( |
230 const std::string& search_query, | 228 const std::string& search_query, |
231 const GetResourceListCallback& callback) { | 229 const GetResourceListCallback& callback) { |
232 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 230 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
233 DCHECK(!search_query.empty()); | 231 DCHECK(!search_query.empty()); |
234 DCHECK(!callback.is_null()); | 232 DCHECK(!callback.is_null()); |
235 | 233 |
236 return sender_->StartRequestWithRetry( | 234 return sender_->StartRequestWithRetry( |
237 new GetResourceListRequest(sender_.get(), | 235 new GetResourceListRequest(sender_.get(), |
238 url_request_context_getter_, | |
239 url_generator_, | 236 url_generator_, |
240 GURL(), // No override url | 237 GURL(), // No override url |
241 0, // start changestamp | 238 0, // start changestamp |
242 search_query, | 239 search_query, |
243 std::string(), // no directory resource id | 240 std::string(), // no directory resource id |
244 callback)); | 241 callback)); |
245 } | 242 } |
246 | 243 |
247 CancelCallback GDataWapiService::SearchByTitle( | 244 CancelCallback GDataWapiService::SearchByTitle( |
248 const std::string& title, | 245 const std::string& title, |
249 const std::string& directory_resource_id, | 246 const std::string& directory_resource_id, |
250 const GetResourceListCallback& callback) { | 247 const GetResourceListCallback& callback) { |
251 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 248 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
252 DCHECK(!title.empty()); | 249 DCHECK(!title.empty()); |
253 DCHECK(!callback.is_null()); | 250 DCHECK(!callback.is_null()); |
254 | 251 |
255 return sender_->StartRequestWithRetry( | 252 return sender_->StartRequestWithRetry( |
256 new SearchByTitleRequest(sender_.get(), | 253 new SearchByTitleRequest(sender_.get(), |
257 url_request_context_getter_, | |
258 url_generator_, | 254 url_generator_, |
259 title, | 255 title, |
260 directory_resource_id, | 256 directory_resource_id, |
261 callback)); | 257 callback)); |
262 } | 258 } |
263 | 259 |
264 CancelCallback GDataWapiService::GetChangeList( | 260 CancelCallback GDataWapiService::GetChangeList( |
265 int64 start_changestamp, | 261 int64 start_changestamp, |
266 const GetResourceListCallback& callback) { | 262 const GetResourceListCallback& callback) { |
267 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 263 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
268 DCHECK(!callback.is_null()); | 264 DCHECK(!callback.is_null()); |
269 | 265 |
270 return sender_->StartRequestWithRetry( | 266 return sender_->StartRequestWithRetry( |
271 new GetResourceListRequest(sender_.get(), | 267 new GetResourceListRequest(sender_.get(), |
272 url_request_context_getter_, | |
273 url_generator_, | 268 url_generator_, |
274 GURL(), // No override url | 269 GURL(), // No override url |
275 start_changestamp, | 270 start_changestamp, |
276 std::string(), // empty search query | 271 std::string(), // empty search query |
277 std::string(), // no directory resource id | 272 std::string(), // no directory resource id |
278 callback)); | 273 callback)); |
279 } | 274 } |
280 | 275 |
281 CancelCallback GDataWapiService::ContinueGetResourceList( | 276 CancelCallback GDataWapiService::ContinueGetResourceList( |
282 const GURL& override_url, | 277 const GURL& override_url, |
283 const GetResourceListCallback& callback) { | 278 const GetResourceListCallback& callback) { |
284 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 279 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
285 DCHECK(!override_url.is_empty()); | 280 DCHECK(!override_url.is_empty()); |
286 DCHECK(!callback.is_null()); | 281 DCHECK(!callback.is_null()); |
287 | 282 |
288 return sender_->StartRequestWithRetry( | 283 return sender_->StartRequestWithRetry( |
289 new GetResourceListRequest(sender_.get(), | 284 new GetResourceListRequest(sender_.get(), |
290 url_request_context_getter_, | |
291 url_generator_, | 285 url_generator_, |
292 override_url, | 286 override_url, |
293 0, // start changestamp | 287 0, // start changestamp |
294 std::string(), // empty search query | 288 std::string(), // empty search query |
295 std::string(), // no directory resource id | 289 std::string(), // no directory resource id |
296 callback)); | 290 callback)); |
297 } | 291 } |
298 | 292 |
299 CancelCallback GDataWapiService::GetResourceEntry( | 293 CancelCallback GDataWapiService::GetResourceEntry( |
300 const std::string& resource_id, | 294 const std::string& resource_id, |
301 const GetResourceEntryCallback& callback) { | 295 const GetResourceEntryCallback& callback) { |
302 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 296 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
303 DCHECK(!callback.is_null()); | 297 DCHECK(!callback.is_null()); |
304 | 298 |
305 return sender_->StartRequestWithRetry( | 299 return sender_->StartRequestWithRetry( |
306 new GetResourceEntryRequest(sender_.get(), | 300 new GetResourceEntryRequest(sender_.get(), |
307 url_request_context_getter_, | |
308 url_generator_, | 301 url_generator_, |
309 resource_id, | 302 resource_id, |
310 base::Bind(&ParseResourceEntryAndRun, | 303 base::Bind(&ParseResourceEntryAndRun, |
311 callback))); | 304 callback))); |
312 } | 305 } |
313 | 306 |
314 CancelCallback GDataWapiService::GetAboutResource( | 307 CancelCallback GDataWapiService::GetAboutResource( |
315 const GetAboutResourceCallback& callback) { | 308 const GetAboutResourceCallback& callback) { |
316 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 309 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
317 DCHECK(!callback.is_null()); | 310 DCHECK(!callback.is_null()); |
318 | 311 |
319 return sender_->StartRequestWithRetry( | 312 return sender_->StartRequestWithRetry( |
320 new GetAccountMetadataRequest( | 313 new GetAccountMetadataRequest( |
321 sender_.get(), | 314 sender_.get(), |
322 url_request_context_getter_, | |
323 url_generator_, | 315 url_generator_, |
324 base::Bind(&ParseAboutResourceAndRun, callback), | 316 base::Bind(&ParseAboutResourceAndRun, callback), |
325 false)); // Exclude installed apps. | 317 false)); // Exclude installed apps. |
326 } | 318 } |
327 | 319 |
328 CancelCallback GDataWapiService::GetAppList( | 320 CancelCallback GDataWapiService::GetAppList( |
329 const GetAppListCallback& callback) { | 321 const GetAppListCallback& callback) { |
330 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 322 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
331 DCHECK(!callback.is_null()); | 323 DCHECK(!callback.is_null()); |
332 | 324 |
333 return sender_->StartRequestWithRetry( | 325 return sender_->StartRequestWithRetry( |
334 new GetAccountMetadataRequest(sender_.get(), | 326 new GetAccountMetadataRequest(sender_.get(), |
335 url_request_context_getter_, | |
336 url_generator_, | 327 url_generator_, |
337 base::Bind(&ParseAppListAndRun, callback), | 328 base::Bind(&ParseAppListAndRun, callback), |
338 true)); // Include installed apps. | 329 true)); // Include installed apps. |
339 } | 330 } |
340 | 331 |
341 CancelCallback GDataWapiService::DownloadFile( | 332 CancelCallback GDataWapiService::DownloadFile( |
342 const base::FilePath& local_cache_path, | 333 const base::FilePath& local_cache_path, |
343 const GURL& download_url, | 334 const GURL& download_url, |
344 const DownloadActionCallback& download_action_callback, | 335 const DownloadActionCallback& download_action_callback, |
345 const GetContentCallback& get_content_callback, | 336 const GetContentCallback& get_content_callback, |
346 const ProgressCallback& progress_callback) { | 337 const ProgressCallback& progress_callback) { |
347 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 338 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
348 DCHECK(!download_action_callback.is_null()); | 339 DCHECK(!download_action_callback.is_null()); |
349 // get_content_callback and progress_callback may be null. | 340 // get_content_callback and progress_callback may be null. |
350 | 341 |
351 return sender_->StartRequestWithRetry( | 342 return sender_->StartRequestWithRetry( |
352 new DownloadFileRequest(sender_.get(), | 343 new DownloadFileRequest(sender_.get(), |
353 url_request_context_getter_, | |
354 download_action_callback, | 344 download_action_callback, |
355 get_content_callback, | 345 get_content_callback, |
356 progress_callback, | 346 progress_callback, |
357 download_url, | 347 download_url, |
358 local_cache_path)); | 348 local_cache_path)); |
359 } | 349 } |
360 | 350 |
361 CancelCallback GDataWapiService::DeleteResource( | 351 CancelCallback GDataWapiService::DeleteResource( |
362 const std::string& resource_id, | 352 const std::string& resource_id, |
363 const std::string& etag, | 353 const std::string& etag, |
364 const EntryActionCallback& callback) { | 354 const EntryActionCallback& callback) { |
365 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 355 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
366 DCHECK(!callback.is_null()); | 356 DCHECK(!callback.is_null()); |
367 | 357 |
368 return sender_->StartRequestWithRetry( | 358 return sender_->StartRequestWithRetry( |
369 new DeleteResourceRequest(sender_.get(), | 359 new DeleteResourceRequest(sender_.get(), |
370 url_request_context_getter_, | |
371 url_generator_, | 360 url_generator_, |
372 callback, | 361 callback, |
373 resource_id, | 362 resource_id, |
374 etag)); | 363 etag)); |
375 } | 364 } |
376 | 365 |
377 CancelCallback GDataWapiService::AddNewDirectory( | 366 CancelCallback GDataWapiService::AddNewDirectory( |
378 const std::string& parent_resource_id, | 367 const std::string& parent_resource_id, |
379 const std::string& directory_name, | 368 const std::string& directory_name, |
380 const GetResourceEntryCallback& callback) { | 369 const GetResourceEntryCallback& callback) { |
381 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 370 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
382 DCHECK(!callback.is_null()); | 371 DCHECK(!callback.is_null()); |
383 | 372 |
384 return sender_->StartRequestWithRetry( | 373 return sender_->StartRequestWithRetry( |
385 new CreateDirectoryRequest(sender_.get(), | 374 new CreateDirectoryRequest(sender_.get(), |
386 url_request_context_getter_, | |
387 url_generator_, | 375 url_generator_, |
388 base::Bind(&ParseResourceEntryAndRun, | 376 base::Bind(&ParseResourceEntryAndRun, |
389 callback), | 377 callback), |
390 parent_resource_id, | 378 parent_resource_id, |
391 directory_name)); | 379 directory_name)); |
392 } | 380 } |
393 | 381 |
394 CancelCallback GDataWapiService::CopyResource( | 382 CancelCallback GDataWapiService::CopyResource( |
395 const std::string& resource_id, | 383 const std::string& resource_id, |
396 const std::string& parent_resource_id, | 384 const std::string& parent_resource_id, |
(...skipping 11 matching lines...) Expand all Loading... |
408 | 396 |
409 CancelCallback GDataWapiService::CopyHostedDocument( | 397 CancelCallback GDataWapiService::CopyHostedDocument( |
410 const std::string& resource_id, | 398 const std::string& resource_id, |
411 const std::string& new_name, | 399 const std::string& new_name, |
412 const GetResourceEntryCallback& callback) { | 400 const GetResourceEntryCallback& callback) { |
413 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 401 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
414 DCHECK(!callback.is_null()); | 402 DCHECK(!callback.is_null()); |
415 | 403 |
416 return sender_->StartRequestWithRetry( | 404 return sender_->StartRequestWithRetry( |
417 new CopyHostedDocumentRequest(sender_.get(), | 405 new CopyHostedDocumentRequest(sender_.get(), |
418 url_request_context_getter_, | |
419 url_generator_, | 406 url_generator_, |
420 base::Bind(&ParseResourceEntryAndRun, | 407 base::Bind(&ParseResourceEntryAndRun, |
421 callback), | 408 callback), |
422 resource_id, | 409 resource_id, |
423 new_name)); | 410 new_name)); |
424 } | 411 } |
425 | 412 |
426 CancelCallback GDataWapiService::RenameResource( | 413 CancelCallback GDataWapiService::RenameResource( |
427 const std::string& resource_id, | 414 const std::string& resource_id, |
428 const std::string& new_name, | 415 const std::string& new_name, |
429 const EntryActionCallback& callback) { | 416 const EntryActionCallback& callback) { |
430 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 417 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
431 DCHECK(!callback.is_null()); | 418 DCHECK(!callback.is_null()); |
432 | 419 |
433 return sender_->StartRequestWithRetry( | 420 return sender_->StartRequestWithRetry( |
434 new RenameResourceRequest(sender_.get(), | 421 new RenameResourceRequest(sender_.get(), |
435 url_request_context_getter_, | |
436 url_generator_, | 422 url_generator_, |
437 callback, | 423 callback, |
438 resource_id, | 424 resource_id, |
439 new_name)); | 425 new_name)); |
440 } | 426 } |
441 | 427 |
442 CancelCallback GDataWapiService::TouchResource( | 428 CancelCallback GDataWapiService::TouchResource( |
443 const std::string& resource_id, | 429 const std::string& resource_id, |
444 const base::Time& modified_date, | 430 const base::Time& modified_date, |
445 const base::Time& last_viewed_by_me_date, | 431 const base::Time& last_viewed_by_me_date, |
(...skipping 14 matching lines...) Expand all Loading... |
460 | 446 |
461 CancelCallback GDataWapiService::AddResourceToDirectory( | 447 CancelCallback GDataWapiService::AddResourceToDirectory( |
462 const std::string& parent_resource_id, | 448 const std::string& parent_resource_id, |
463 const std::string& resource_id, | 449 const std::string& resource_id, |
464 const EntryActionCallback& callback) { | 450 const EntryActionCallback& callback) { |
465 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 451 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
466 DCHECK(!callback.is_null()); | 452 DCHECK(!callback.is_null()); |
467 | 453 |
468 return sender_->StartRequestWithRetry( | 454 return sender_->StartRequestWithRetry( |
469 new AddResourceToDirectoryRequest(sender_.get(), | 455 new AddResourceToDirectoryRequest(sender_.get(), |
470 url_request_context_getter_, | |
471 url_generator_, | 456 url_generator_, |
472 callback, | 457 callback, |
473 parent_resource_id, | 458 parent_resource_id, |
474 resource_id)); | 459 resource_id)); |
475 } | 460 } |
476 | 461 |
477 CancelCallback GDataWapiService::RemoveResourceFromDirectory( | 462 CancelCallback GDataWapiService::RemoveResourceFromDirectory( |
478 const std::string& parent_resource_id, | 463 const std::string& parent_resource_id, |
479 const std::string& resource_id, | 464 const std::string& resource_id, |
480 const EntryActionCallback& callback) { | 465 const EntryActionCallback& callback) { |
481 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 466 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
482 DCHECK(!callback.is_null()); | 467 DCHECK(!callback.is_null()); |
483 | 468 |
484 return sender_->StartRequestWithRetry( | 469 return sender_->StartRequestWithRetry( |
485 new RemoveResourceFromDirectoryRequest(sender_.get(), | 470 new RemoveResourceFromDirectoryRequest(sender_.get(), |
486 url_request_context_getter_, | |
487 url_generator_, | 471 url_generator_, |
488 callback, | 472 callback, |
489 parent_resource_id, | 473 parent_resource_id, |
490 resource_id)); | 474 resource_id)); |
491 } | 475 } |
492 | 476 |
493 CancelCallback GDataWapiService::InitiateUploadNewFile( | 477 CancelCallback GDataWapiService::InitiateUploadNewFile( |
494 const std::string& content_type, | 478 const std::string& content_type, |
495 int64 content_length, | 479 int64 content_length, |
496 const std::string& parent_resource_id, | 480 const std::string& parent_resource_id, |
497 const std::string& title, | 481 const std::string& title, |
498 const InitiateUploadCallback& callback) { | 482 const InitiateUploadCallback& callback) { |
499 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 483 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
500 DCHECK(!callback.is_null()); | 484 DCHECK(!callback.is_null()); |
501 DCHECK(!parent_resource_id.empty()); | 485 DCHECK(!parent_resource_id.empty()); |
502 | 486 |
503 return sender_->StartRequestWithRetry( | 487 return sender_->StartRequestWithRetry( |
504 new InitiateUploadNewFileRequest(sender_.get(), | 488 new InitiateUploadNewFileRequest(sender_.get(), |
505 url_request_context_getter_, | |
506 url_generator_, | 489 url_generator_, |
507 callback, | 490 callback, |
508 content_type, | 491 content_type, |
509 content_length, | 492 content_length, |
510 parent_resource_id, | 493 parent_resource_id, |
511 title)); | 494 title)); |
512 } | 495 } |
513 | 496 |
514 CancelCallback GDataWapiService::InitiateUploadExistingFile( | 497 CancelCallback GDataWapiService::InitiateUploadExistingFile( |
515 const std::string& content_type, | 498 const std::string& content_type, |
516 int64 content_length, | 499 int64 content_length, |
517 const std::string& resource_id, | 500 const std::string& resource_id, |
518 const std::string& etag, | 501 const std::string& etag, |
519 const InitiateUploadCallback& callback) { | 502 const InitiateUploadCallback& callback) { |
520 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 503 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
521 DCHECK(!callback.is_null()); | 504 DCHECK(!callback.is_null()); |
522 DCHECK(!resource_id.empty()); | 505 DCHECK(!resource_id.empty()); |
523 | 506 |
524 return sender_->StartRequestWithRetry( | 507 return sender_->StartRequestWithRetry( |
525 new InitiateUploadExistingFileRequest(sender_.get(), | 508 new InitiateUploadExistingFileRequest(sender_.get(), |
526 url_request_context_getter_, | |
527 url_generator_, | 509 url_generator_, |
528 callback, | 510 callback, |
529 content_type, | 511 content_type, |
530 content_length, | 512 content_length, |
531 resource_id, | 513 resource_id, |
532 etag)); | 514 etag)); |
533 } | 515 } |
534 | 516 |
535 CancelCallback GDataWapiService::ResumeUpload( | 517 CancelCallback GDataWapiService::ResumeUpload( |
536 const GURL& upload_url, | 518 const GURL& upload_url, |
537 int64 start_position, | 519 int64 start_position, |
538 int64 end_position, | 520 int64 end_position, |
539 int64 content_length, | 521 int64 content_length, |
540 const std::string& content_type, | 522 const std::string& content_type, |
541 const base::FilePath& local_file_path, | 523 const base::FilePath& local_file_path, |
542 const UploadRangeCallback& callback, | 524 const UploadRangeCallback& callback, |
543 const ProgressCallback& progress_callback) { | 525 const ProgressCallback& progress_callback) { |
544 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 526 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
545 DCHECK(!callback.is_null()); | 527 DCHECK(!callback.is_null()); |
546 | 528 |
547 return sender_->StartRequestWithRetry( | 529 return sender_->StartRequestWithRetry( |
548 new ResumeUploadRequest(sender_.get(), | 530 new ResumeUploadRequest(sender_.get(), |
549 url_request_context_getter_, | |
550 callback, | 531 callback, |
551 progress_callback, | 532 progress_callback, |
552 upload_url, | 533 upload_url, |
553 start_position, | 534 start_position, |
554 end_position, | 535 end_position, |
555 content_length, | 536 content_length, |
556 content_type, | 537 content_type, |
557 local_file_path)); | 538 local_file_path)); |
558 } | 539 } |
559 | 540 |
560 CancelCallback GDataWapiService::GetUploadStatus( | 541 CancelCallback GDataWapiService::GetUploadStatus( |
561 const GURL& upload_url, | 542 const GURL& upload_url, |
562 int64 content_length, | 543 int64 content_length, |
563 const UploadRangeCallback& callback) { | 544 const UploadRangeCallback& callback) { |
564 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 545 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
565 DCHECK(!callback.is_null()); | 546 DCHECK(!callback.is_null()); |
566 | 547 |
567 return sender_->StartRequestWithRetry( | 548 return sender_->StartRequestWithRetry( |
568 new GetUploadStatusRequest(sender_.get(), | 549 new GetUploadStatusRequest(sender_.get(), |
569 url_request_context_getter_, | |
570 callback, | 550 callback, |
571 upload_url, | 551 upload_url, |
572 content_length)); | 552 content_length)); |
573 } | 553 } |
574 | 554 |
575 CancelCallback GDataWapiService::AuthorizeApp( | 555 CancelCallback GDataWapiService::AuthorizeApp( |
576 const std::string& resource_id, | 556 const std::string& resource_id, |
577 const std::string& app_id, | 557 const std::string& app_id, |
578 const AuthorizeAppCallback& callback) { | 558 const AuthorizeAppCallback& callback) { |
579 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 559 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
580 DCHECK(!callback.is_null()); | 560 DCHECK(!callback.is_null()); |
581 | 561 |
582 return sender_->StartRequestWithRetry( | 562 return sender_->StartRequestWithRetry( |
583 new AuthorizeAppRequest(sender_.get(), | 563 new AuthorizeAppRequest(sender_.get(), |
584 url_request_context_getter_, | |
585 url_generator_, | 564 url_generator_, |
586 callback, | 565 callback, |
587 resource_id, | 566 resource_id, |
588 app_id)); | 567 app_id)); |
589 } | 568 } |
590 | 569 |
591 bool GDataWapiService::HasAccessToken() const { | 570 bool GDataWapiService::HasAccessToken() const { |
592 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 571 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
593 | 572 |
594 return sender_->auth_service()->HasAccessToken(); | 573 return sender_->auth_service()->HasAccessToken(); |
(...skipping 20 matching lines...) Expand all Loading... |
615 if (CanSendRequest()) { | 594 if (CanSendRequest()) { |
616 FOR_EACH_OBSERVER( | 595 FOR_EACH_OBSERVER( |
617 DriveServiceObserver, observers_, OnReadyToSendRequests()); | 596 DriveServiceObserver, observers_, OnReadyToSendRequests()); |
618 } else if (!HasRefreshToken()) { | 597 } else if (!HasRefreshToken()) { |
619 FOR_EACH_OBSERVER( | 598 FOR_EACH_OBSERVER( |
620 DriveServiceObserver, observers_, OnRefreshTokenInvalid()); | 599 DriveServiceObserver, observers_, OnRefreshTokenInvalid()); |
621 } | 600 } |
622 } | 601 } |
623 | 602 |
624 } // namespace drive | 603 } // namespace drive |
OLD | NEW |