| 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 |