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/google_apis/gdata_wapi_requests.h" | 5 #include "chrome/browser/google_apis/gdata_wapi_requests.h" |
6 | 6 |
7 #include "base/strings/string_number_conversions.h" | 7 #include "base/strings/string_number_conversions.h" |
8 #include "base/strings/stringprintf.h" | 8 #include "base/strings/stringprintf.h" |
9 #include "base/task_runner_util.h" | 9 #include "base/task_runner_util.h" |
10 #include "base/threading/sequenced_worker_pool.h" | 10 #include "base/threading/sequenced_worker_pool.h" |
(...skipping 141 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
152 error = GDATA_OTHER_ERROR; | 152 error = GDATA_OTHER_ERROR; |
153 | 153 |
154 callback.Run(error, open_link); | 154 callback.Run(error, open_link); |
155 } | 155 } |
156 | 156 |
157 } // namespace | 157 } // namespace |
158 | 158 |
159 //============================ GetResourceListRequest ======================== | 159 //============================ GetResourceListRequest ======================== |
160 | 160 |
161 GetResourceListRequest::GetResourceListRequest( | 161 GetResourceListRequest::GetResourceListRequest( |
162 RequestSender* runner, | 162 RequestSender* sender, |
163 net::URLRequestContextGetter* url_request_context_getter, | |
164 const GDataWapiUrlGenerator& url_generator, | 163 const GDataWapiUrlGenerator& url_generator, |
165 const GURL& override_url, | 164 const GURL& override_url, |
166 int64 start_changestamp, | 165 int64 start_changestamp, |
167 const std::string& search_string, | 166 const std::string& search_string, |
168 const std::string& directory_resource_id, | 167 const std::string& directory_resource_id, |
169 const GetResourceListCallback& callback) | 168 const GetResourceListCallback& callback) |
170 : GetDataRequest(runner, url_request_context_getter, | 169 : GetDataRequest(sender, |
171 base::Bind(&ParseResourceListAndRun, callback)), | 170 base::Bind(&ParseResourceListAndRun, callback)), |
172 url_generator_(url_generator), | 171 url_generator_(url_generator), |
173 override_url_(override_url), | 172 override_url_(override_url), |
174 start_changestamp_(start_changestamp), | 173 start_changestamp_(start_changestamp), |
175 search_string_(search_string), | 174 search_string_(search_string), |
176 directory_resource_id_(directory_resource_id) { | 175 directory_resource_id_(directory_resource_id) { |
177 DCHECK(!callback.is_null()); | 176 DCHECK(!callback.is_null()); |
178 } | 177 } |
179 | 178 |
180 GetResourceListRequest::~GetResourceListRequest() {} | 179 GetResourceListRequest::~GetResourceListRequest() {} |
181 | 180 |
182 GURL GetResourceListRequest::GetURL() const { | 181 GURL GetResourceListRequest::GetURL() const { |
183 return url_generator_.GenerateResourceListUrl(override_url_, | 182 return url_generator_.GenerateResourceListUrl(override_url_, |
184 start_changestamp_, | 183 start_changestamp_, |
185 search_string_, | 184 search_string_, |
186 directory_resource_id_); | 185 directory_resource_id_); |
187 } | 186 } |
188 | 187 |
189 //============================ SearchByTitleRequest ========================== | 188 //============================ SearchByTitleRequest ========================== |
190 | 189 |
191 SearchByTitleRequest::SearchByTitleRequest( | 190 SearchByTitleRequest::SearchByTitleRequest( |
192 RequestSender* runner, | 191 RequestSender* sender, |
193 net::URLRequestContextGetter* url_request_context_getter, | |
194 const GDataWapiUrlGenerator& url_generator, | 192 const GDataWapiUrlGenerator& url_generator, |
195 const std::string& title, | 193 const std::string& title, |
196 const std::string& directory_resource_id, | 194 const std::string& directory_resource_id, |
197 const GetResourceListCallback& callback) | 195 const GetResourceListCallback& callback) |
198 : GetDataRequest(runner, url_request_context_getter, | 196 : GetDataRequest(sender, |
199 base::Bind(&ParseResourceListAndRun, callback)), | 197 base::Bind(&ParseResourceListAndRun, callback)), |
200 url_generator_(url_generator), | 198 url_generator_(url_generator), |
201 title_(title), | 199 title_(title), |
202 directory_resource_id_(directory_resource_id) { | 200 directory_resource_id_(directory_resource_id) { |
203 DCHECK(!callback.is_null()); | 201 DCHECK(!callback.is_null()); |
204 } | 202 } |
205 | 203 |
206 SearchByTitleRequest::~SearchByTitleRequest() {} | 204 SearchByTitleRequest::~SearchByTitleRequest() {} |
207 | 205 |
208 GURL SearchByTitleRequest::GetURL() const { | 206 GURL SearchByTitleRequest::GetURL() const { |
209 return url_generator_.GenerateSearchByTitleUrl( | 207 return url_generator_.GenerateSearchByTitleUrl( |
210 title_, directory_resource_id_); | 208 title_, directory_resource_id_); |
211 } | 209 } |
212 | 210 |
213 //============================ GetResourceEntryRequest ======================= | 211 //============================ GetResourceEntryRequest ======================= |
214 | 212 |
215 GetResourceEntryRequest::GetResourceEntryRequest( | 213 GetResourceEntryRequest::GetResourceEntryRequest( |
216 RequestSender* runner, | 214 RequestSender* sender, |
217 net::URLRequestContextGetter* url_request_context_getter, | |
218 const GDataWapiUrlGenerator& url_generator, | 215 const GDataWapiUrlGenerator& url_generator, |
219 const std::string& resource_id, | 216 const std::string& resource_id, |
220 const GetDataCallback& callback) | 217 const GetDataCallback& callback) |
221 : GetDataRequest(runner, url_request_context_getter, callback), | 218 : GetDataRequest(sender, callback), |
222 url_generator_(url_generator), | 219 url_generator_(url_generator), |
223 resource_id_(resource_id) { | 220 resource_id_(resource_id) { |
224 DCHECK(!callback.is_null()); | 221 DCHECK(!callback.is_null()); |
225 } | 222 } |
226 | 223 |
227 GetResourceEntryRequest::~GetResourceEntryRequest() {} | 224 GetResourceEntryRequest::~GetResourceEntryRequest() {} |
228 | 225 |
229 GURL GetResourceEntryRequest::GetURL() const { | 226 GURL GetResourceEntryRequest::GetURL() const { |
230 return url_generator_.GenerateEditUrl(resource_id_); | 227 return url_generator_.GenerateEditUrl(resource_id_); |
231 } | 228 } |
232 | 229 |
233 //========================= GetAccountMetadataRequest ======================== | 230 //========================= GetAccountMetadataRequest ======================== |
234 | 231 |
235 GetAccountMetadataRequest::GetAccountMetadataRequest( | 232 GetAccountMetadataRequest::GetAccountMetadataRequest( |
236 RequestSender* runner, | 233 RequestSender* sender, |
237 net::URLRequestContextGetter* url_request_context_getter, | |
238 const GDataWapiUrlGenerator& url_generator, | 234 const GDataWapiUrlGenerator& url_generator, |
239 const GetAccountMetadataCallback& callback, | 235 const GetAccountMetadataCallback& callback, |
240 bool include_installed_apps) | 236 bool include_installed_apps) |
241 : GetDataRequest(runner, url_request_context_getter, | 237 : GetDataRequest(sender, |
242 base::Bind(&ParseAccounetMetadataAndRun, callback)), | 238 base::Bind(&ParseAccounetMetadataAndRun, callback)), |
243 url_generator_(url_generator), | 239 url_generator_(url_generator), |
244 include_installed_apps_(include_installed_apps) { | 240 include_installed_apps_(include_installed_apps) { |
245 DCHECK(!callback.is_null()); | 241 DCHECK(!callback.is_null()); |
246 } | 242 } |
247 | 243 |
248 GetAccountMetadataRequest::~GetAccountMetadataRequest() {} | 244 GetAccountMetadataRequest::~GetAccountMetadataRequest() {} |
249 | 245 |
250 GURL GetAccountMetadataRequest::GetURL() const { | 246 GURL GetAccountMetadataRequest::GetURL() const { |
251 return url_generator_.GenerateAccountMetadataUrl(include_installed_apps_); | 247 return url_generator_.GenerateAccountMetadataUrl(include_installed_apps_); |
252 } | 248 } |
253 | 249 |
254 //=========================== DeleteResourceRequest ========================== | 250 //=========================== DeleteResourceRequest ========================== |
255 | 251 |
256 DeleteResourceRequest::DeleteResourceRequest( | 252 DeleteResourceRequest::DeleteResourceRequest( |
257 RequestSender* runner, | 253 RequestSender* sender, |
258 net::URLRequestContextGetter* url_request_context_getter, | |
259 const GDataWapiUrlGenerator& url_generator, | 254 const GDataWapiUrlGenerator& url_generator, |
260 const EntryActionCallback& callback, | 255 const EntryActionCallback& callback, |
261 const std::string& resource_id, | 256 const std::string& resource_id, |
262 const std::string& etag) | 257 const std::string& etag) |
263 : EntryActionRequest(runner, url_request_context_getter, callback), | 258 : EntryActionRequest(sender, callback), |
264 url_generator_(url_generator), | 259 url_generator_(url_generator), |
265 resource_id_(resource_id), | 260 resource_id_(resource_id), |
266 etag_(etag) { | 261 etag_(etag) { |
267 DCHECK(!callback.is_null()); | 262 DCHECK(!callback.is_null()); |
268 } | 263 } |
269 | 264 |
270 DeleteResourceRequest::~DeleteResourceRequest() {} | 265 DeleteResourceRequest::~DeleteResourceRequest() {} |
271 | 266 |
272 GURL DeleteResourceRequest::GetURL() const { | 267 GURL DeleteResourceRequest::GetURL() const { |
273 return url_generator_.GenerateEditUrl(resource_id_); | 268 return url_generator_.GenerateEditUrl(resource_id_); |
274 } | 269 } |
275 | 270 |
276 URLFetcher::RequestType DeleteResourceRequest::GetRequestType() const { | 271 URLFetcher::RequestType DeleteResourceRequest::GetRequestType() const { |
277 return URLFetcher::DELETE_REQUEST; | 272 return URLFetcher::DELETE_REQUEST; |
278 } | 273 } |
279 | 274 |
280 std::vector<std::string> | 275 std::vector<std::string> |
281 DeleteResourceRequest::GetExtraRequestHeaders() const { | 276 DeleteResourceRequest::GetExtraRequestHeaders() const { |
282 std::vector<std::string> headers; | 277 std::vector<std::string> headers; |
283 headers.push_back(util::GenerateIfMatchHeader(etag_)); | 278 headers.push_back(util::GenerateIfMatchHeader(etag_)); |
284 return headers; | 279 return headers; |
285 } | 280 } |
286 | 281 |
287 //========================== CreateDirectoryRequest ========================== | 282 //========================== CreateDirectoryRequest ========================== |
288 | 283 |
289 CreateDirectoryRequest::CreateDirectoryRequest( | 284 CreateDirectoryRequest::CreateDirectoryRequest( |
290 RequestSender* runner, | 285 RequestSender* sender, |
291 net::URLRequestContextGetter* url_request_context_getter, | |
292 const GDataWapiUrlGenerator& url_generator, | 286 const GDataWapiUrlGenerator& url_generator, |
293 const GetDataCallback& callback, | 287 const GetDataCallback& callback, |
294 const std::string& parent_resource_id, | 288 const std::string& parent_resource_id, |
295 const std::string& directory_name) | 289 const std::string& directory_name) |
296 : GetDataRequest(runner, url_request_context_getter, callback), | 290 : GetDataRequest(sender, callback), |
297 url_generator_(url_generator), | 291 url_generator_(url_generator), |
298 parent_resource_id_(parent_resource_id), | 292 parent_resource_id_(parent_resource_id), |
299 directory_name_(directory_name) { | 293 directory_name_(directory_name) { |
300 DCHECK(!callback.is_null()); | 294 DCHECK(!callback.is_null()); |
301 } | 295 } |
302 | 296 |
303 CreateDirectoryRequest::~CreateDirectoryRequest() {} | 297 CreateDirectoryRequest::~CreateDirectoryRequest() {} |
304 | 298 |
305 GURL CreateDirectoryRequest::GetURL() const { | 299 GURL CreateDirectoryRequest::GetURL() const { |
306 return url_generator_.GenerateContentUrl(parent_resource_id_); | 300 return url_generator_.GenerateContentUrl(parent_resource_id_); |
(...skipping 25 matching lines...) Expand all Loading... |
332 xml_writer.StopWriting(); | 326 xml_writer.StopWriting(); |
333 upload_content->assign(xml_writer.GetWrittenString()); | 327 upload_content->assign(xml_writer.GetWrittenString()); |
334 DVLOG(1) << "CreateDirectory data: " << *upload_content_type << ", [" | 328 DVLOG(1) << "CreateDirectory data: " << *upload_content_type << ", [" |
335 << *upload_content << "]"; | 329 << *upload_content << "]"; |
336 return true; | 330 return true; |
337 } | 331 } |
338 | 332 |
339 //============================ CopyHostedDocumentRequest ===================== | 333 //============================ CopyHostedDocumentRequest ===================== |
340 | 334 |
341 CopyHostedDocumentRequest::CopyHostedDocumentRequest( | 335 CopyHostedDocumentRequest::CopyHostedDocumentRequest( |
342 RequestSender* runner, | 336 RequestSender* sender, |
343 net::URLRequestContextGetter* url_request_context_getter, | |
344 const GDataWapiUrlGenerator& url_generator, | 337 const GDataWapiUrlGenerator& url_generator, |
345 const GetDataCallback& callback, | 338 const GetDataCallback& callback, |
346 const std::string& resource_id, | 339 const std::string& resource_id, |
347 const std::string& new_name) | 340 const std::string& new_name) |
348 : GetDataRequest(runner, url_request_context_getter, callback), | 341 : GetDataRequest(sender, callback), |
349 url_generator_(url_generator), | 342 url_generator_(url_generator), |
350 resource_id_(resource_id), | 343 resource_id_(resource_id), |
351 new_name_(new_name) { | 344 new_name_(new_name) { |
352 DCHECK(!callback.is_null()); | 345 DCHECK(!callback.is_null()); |
353 } | 346 } |
354 | 347 |
355 CopyHostedDocumentRequest::~CopyHostedDocumentRequest() {} | 348 CopyHostedDocumentRequest::~CopyHostedDocumentRequest() {} |
356 | 349 |
357 URLFetcher::RequestType CopyHostedDocumentRequest::GetRequestType() const { | 350 URLFetcher::RequestType CopyHostedDocumentRequest::GetRequestType() const { |
358 return URLFetcher::POST; | 351 return URLFetcher::POST; |
(...skipping 19 matching lines...) Expand all Loading... |
378 xml_writer.StopWriting(); | 371 xml_writer.StopWriting(); |
379 upload_content->assign(xml_writer.GetWrittenString()); | 372 upload_content->assign(xml_writer.GetWrittenString()); |
380 DVLOG(1) << "CopyHostedDocumentRequest data: " << *upload_content_type | 373 DVLOG(1) << "CopyHostedDocumentRequest data: " << *upload_content_type |
381 << ", [" << *upload_content << "]"; | 374 << ", [" << *upload_content << "]"; |
382 return true; | 375 return true; |
383 } | 376 } |
384 | 377 |
385 //=========================== RenameResourceRequest ========================== | 378 //=========================== RenameResourceRequest ========================== |
386 | 379 |
387 RenameResourceRequest::RenameResourceRequest( | 380 RenameResourceRequest::RenameResourceRequest( |
388 RequestSender* runner, | 381 RequestSender* sender, |
389 net::URLRequestContextGetter* url_request_context_getter, | |
390 const GDataWapiUrlGenerator& url_generator, | 382 const GDataWapiUrlGenerator& url_generator, |
391 const EntryActionCallback& callback, | 383 const EntryActionCallback& callback, |
392 const std::string& resource_id, | 384 const std::string& resource_id, |
393 const std::string& new_name) | 385 const std::string& new_name) |
394 : EntryActionRequest(runner, url_request_context_getter, callback), | 386 : EntryActionRequest(sender, callback), |
395 url_generator_(url_generator), | 387 url_generator_(url_generator), |
396 resource_id_(resource_id), | 388 resource_id_(resource_id), |
397 new_name_(new_name) { | 389 new_name_(new_name) { |
398 DCHECK(!callback.is_null()); | 390 DCHECK(!callback.is_null()); |
399 } | 391 } |
400 | 392 |
401 RenameResourceRequest::~RenameResourceRequest() {} | 393 RenameResourceRequest::~RenameResourceRequest() {} |
402 | 394 |
403 URLFetcher::RequestType RenameResourceRequest::GetRequestType() const { | 395 URLFetcher::RequestType RenameResourceRequest::GetRequestType() const { |
404 return URLFetcher::PUT; | 396 return URLFetcher::PUT; |
(...skipping 24 matching lines...) Expand all Loading... |
429 xml_writer.StopWriting(); | 421 xml_writer.StopWriting(); |
430 upload_content->assign(xml_writer.GetWrittenString()); | 422 upload_content->assign(xml_writer.GetWrittenString()); |
431 DVLOG(1) << "RenameResourceRequest data: " << *upload_content_type << ", [" | 423 DVLOG(1) << "RenameResourceRequest data: " << *upload_content_type << ", [" |
432 << *upload_content << "]"; | 424 << *upload_content << "]"; |
433 return true; | 425 return true; |
434 } | 426 } |
435 | 427 |
436 //=========================== AuthorizeAppRequest ========================== | 428 //=========================== AuthorizeAppRequest ========================== |
437 | 429 |
438 AuthorizeAppRequest::AuthorizeAppRequest( | 430 AuthorizeAppRequest::AuthorizeAppRequest( |
439 RequestSender* runner, | 431 RequestSender* sender, |
440 net::URLRequestContextGetter* url_request_context_getter, | |
441 const GDataWapiUrlGenerator& url_generator, | 432 const GDataWapiUrlGenerator& url_generator, |
442 const AuthorizeAppCallback& callback, | 433 const AuthorizeAppCallback& callback, |
443 const std::string& resource_id, | 434 const std::string& resource_id, |
444 const std::string& app_id) | 435 const std::string& app_id) |
445 : GetDataRequest(runner, url_request_context_getter, | 436 : GetDataRequest(sender, |
446 base::Bind(&ParseOpenLinkAndRun, app_id, callback)), | 437 base::Bind(&ParseOpenLinkAndRun, app_id, callback)), |
447 url_generator_(url_generator), | 438 url_generator_(url_generator), |
448 resource_id_(resource_id), | 439 resource_id_(resource_id), |
449 app_id_(app_id) { | 440 app_id_(app_id) { |
450 DCHECK(!callback.is_null()); | 441 DCHECK(!callback.is_null()); |
451 } | 442 } |
452 | 443 |
453 AuthorizeAppRequest::~AuthorizeAppRequest() {} | 444 AuthorizeAppRequest::~AuthorizeAppRequest() {} |
454 | 445 |
455 URLFetcher::RequestType AuthorizeAppRequest::GetRequestType() const { | 446 URLFetcher::RequestType AuthorizeAppRequest::GetRequestType() const { |
(...skipping 25 matching lines...) Expand all Loading... |
481 return true; | 472 return true; |
482 } | 473 } |
483 | 474 |
484 GURL AuthorizeAppRequest::GetURL() const { | 475 GURL AuthorizeAppRequest::GetURL() const { |
485 return url_generator_.GenerateEditUrl(resource_id_); | 476 return url_generator_.GenerateEditUrl(resource_id_); |
486 } | 477 } |
487 | 478 |
488 //======================= AddResourceToDirectoryRequest ====================== | 479 //======================= AddResourceToDirectoryRequest ====================== |
489 | 480 |
490 AddResourceToDirectoryRequest::AddResourceToDirectoryRequest( | 481 AddResourceToDirectoryRequest::AddResourceToDirectoryRequest( |
491 RequestSender* runner, | 482 RequestSender* sender, |
492 net::URLRequestContextGetter* url_request_context_getter, | |
493 const GDataWapiUrlGenerator& url_generator, | 483 const GDataWapiUrlGenerator& url_generator, |
494 const EntryActionCallback& callback, | 484 const EntryActionCallback& callback, |
495 const std::string& parent_resource_id, | 485 const std::string& parent_resource_id, |
496 const std::string& resource_id) | 486 const std::string& resource_id) |
497 : EntryActionRequest(runner, url_request_context_getter, callback), | 487 : EntryActionRequest(sender, callback), |
498 url_generator_(url_generator), | 488 url_generator_(url_generator), |
499 parent_resource_id_(parent_resource_id), | 489 parent_resource_id_(parent_resource_id), |
500 resource_id_(resource_id) { | 490 resource_id_(resource_id) { |
501 DCHECK(!callback.is_null()); | 491 DCHECK(!callback.is_null()); |
502 } | 492 } |
503 | 493 |
504 AddResourceToDirectoryRequest::~AddResourceToDirectoryRequest() {} | 494 AddResourceToDirectoryRequest::~AddResourceToDirectoryRequest() {} |
505 | 495 |
506 GURL AddResourceToDirectoryRequest::GetURL() const { | 496 GURL AddResourceToDirectoryRequest::GetURL() const { |
507 return url_generator_.GenerateContentUrl(parent_resource_id_); | 497 return url_generator_.GenerateContentUrl(parent_resource_id_); |
(...skipping 19 matching lines...) Expand all Loading... |
527 xml_writer.StopWriting(); | 517 xml_writer.StopWriting(); |
528 upload_content->assign(xml_writer.GetWrittenString()); | 518 upload_content->assign(xml_writer.GetWrittenString()); |
529 DVLOG(1) << "AddResourceToDirectoryRequest data: " << *upload_content_type | 519 DVLOG(1) << "AddResourceToDirectoryRequest data: " << *upload_content_type |
530 << ", [" << *upload_content << "]"; | 520 << ", [" << *upload_content << "]"; |
531 return true; | 521 return true; |
532 } | 522 } |
533 | 523 |
534 //==================== RemoveResourceFromDirectoryRequest ==================== | 524 //==================== RemoveResourceFromDirectoryRequest ==================== |
535 | 525 |
536 RemoveResourceFromDirectoryRequest::RemoveResourceFromDirectoryRequest( | 526 RemoveResourceFromDirectoryRequest::RemoveResourceFromDirectoryRequest( |
537 RequestSender* runner, | 527 RequestSender* sender, |
538 net::URLRequestContextGetter* url_request_context_getter, | |
539 const GDataWapiUrlGenerator& url_generator, | 528 const GDataWapiUrlGenerator& url_generator, |
540 const EntryActionCallback& callback, | 529 const EntryActionCallback& callback, |
541 const std::string& parent_resource_id, | 530 const std::string& parent_resource_id, |
542 const std::string& document_resource_id) | 531 const std::string& document_resource_id) |
543 : EntryActionRequest(runner, url_request_context_getter, callback), | 532 : EntryActionRequest(sender, callback), |
544 url_generator_(url_generator), | 533 url_generator_(url_generator), |
545 resource_id_(document_resource_id), | 534 resource_id_(document_resource_id), |
546 parent_resource_id_(parent_resource_id) { | 535 parent_resource_id_(parent_resource_id) { |
547 DCHECK(!callback.is_null()); | 536 DCHECK(!callback.is_null()); |
548 } | 537 } |
549 | 538 |
550 RemoveResourceFromDirectoryRequest::~RemoveResourceFromDirectoryRequest() { | 539 RemoveResourceFromDirectoryRequest::~RemoveResourceFromDirectoryRequest() { |
551 } | 540 } |
552 | 541 |
553 GURL RemoveResourceFromDirectoryRequest::GetURL() const { | 542 GURL RemoveResourceFromDirectoryRequest::GetURL() const { |
554 return url_generator_.GenerateResourceUrlForRemoval( | 543 return url_generator_.GenerateResourceUrlForRemoval( |
555 parent_resource_id_, resource_id_); | 544 parent_resource_id_, resource_id_); |
556 } | 545 } |
557 | 546 |
558 URLFetcher::RequestType | 547 URLFetcher::RequestType |
559 RemoveResourceFromDirectoryRequest::GetRequestType() const { | 548 RemoveResourceFromDirectoryRequest::GetRequestType() const { |
560 return URLFetcher::DELETE_REQUEST; | 549 return URLFetcher::DELETE_REQUEST; |
561 } | 550 } |
562 | 551 |
563 std::vector<std::string> | 552 std::vector<std::string> |
564 RemoveResourceFromDirectoryRequest::GetExtraRequestHeaders() const { | 553 RemoveResourceFromDirectoryRequest::GetExtraRequestHeaders() const { |
565 std::vector<std::string> headers; | 554 std::vector<std::string> headers; |
566 headers.push_back(util::kIfMatchAllHeader); | 555 headers.push_back(util::kIfMatchAllHeader); |
567 return headers; | 556 return headers; |
568 } | 557 } |
569 | 558 |
570 //======================= InitiateUploadNewFileRequest ======================= | 559 //======================= InitiateUploadNewFileRequest ======================= |
571 | 560 |
572 InitiateUploadNewFileRequest::InitiateUploadNewFileRequest( | 561 InitiateUploadNewFileRequest::InitiateUploadNewFileRequest( |
573 RequestSender* runner, | 562 RequestSender* sender, |
574 net::URLRequestContextGetter* url_request_context_getter, | |
575 const GDataWapiUrlGenerator& url_generator, | 563 const GDataWapiUrlGenerator& url_generator, |
576 const InitiateUploadCallback& callback, | 564 const InitiateUploadCallback& callback, |
577 const std::string& content_type, | 565 const std::string& content_type, |
578 int64 content_length, | 566 int64 content_length, |
579 const std::string& parent_resource_id, | 567 const std::string& parent_resource_id, |
580 const std::string& title) | 568 const std::string& title) |
581 : InitiateUploadRequestBase(runner, | 569 : InitiateUploadRequestBase(sender, |
582 url_request_context_getter, | |
583 callback, | 570 callback, |
584 content_type, | 571 content_type, |
585 content_length), | 572 content_length), |
586 url_generator_(url_generator), | 573 url_generator_(url_generator), |
587 parent_resource_id_(parent_resource_id), | 574 parent_resource_id_(parent_resource_id), |
588 title_(title) { | 575 title_(title) { |
589 } | 576 } |
590 | 577 |
591 InitiateUploadNewFileRequest::~InitiateUploadNewFileRequest() {} | 578 InitiateUploadNewFileRequest::~InitiateUploadNewFileRequest() {} |
592 | 579 |
(...skipping 21 matching lines...) Expand all Loading... |
614 xml_writer.StopWriting(); | 601 xml_writer.StopWriting(); |
615 upload_content->assign(xml_writer.GetWrittenString()); | 602 upload_content->assign(xml_writer.GetWrittenString()); |
616 DVLOG(1) << "InitiateUploadNewFile: " << *upload_content_type << ", [" | 603 DVLOG(1) << "InitiateUploadNewFile: " << *upload_content_type << ", [" |
617 << *upload_content << "]"; | 604 << *upload_content << "]"; |
618 return true; | 605 return true; |
619 } | 606 } |
620 | 607 |
621 //===================== InitiateUploadExistingFileRequest ==================== | 608 //===================== InitiateUploadExistingFileRequest ==================== |
622 | 609 |
623 InitiateUploadExistingFileRequest::InitiateUploadExistingFileRequest( | 610 InitiateUploadExistingFileRequest::InitiateUploadExistingFileRequest( |
624 RequestSender* runner, | 611 RequestSender* sender, |
625 net::URLRequestContextGetter* url_request_context_getter, | |
626 const GDataWapiUrlGenerator& url_generator, | 612 const GDataWapiUrlGenerator& url_generator, |
627 const InitiateUploadCallback& callback, | 613 const InitiateUploadCallback& callback, |
628 const std::string& content_type, | 614 const std::string& content_type, |
629 int64 content_length, | 615 int64 content_length, |
630 const std::string& resource_id, | 616 const std::string& resource_id, |
631 const std::string& etag) | 617 const std::string& etag) |
632 : InitiateUploadRequestBase(runner, | 618 : InitiateUploadRequestBase(sender, |
633 url_request_context_getter, | |
634 callback, | 619 callback, |
635 content_type, | 620 content_type, |
636 content_length), | 621 content_length), |
637 url_generator_(url_generator), | 622 url_generator_(url_generator), |
638 resource_id_(resource_id), | 623 resource_id_(resource_id), |
639 etag_(etag) { | 624 etag_(etag) { |
640 } | 625 } |
641 | 626 |
642 InitiateUploadExistingFileRequest::~InitiateUploadExistingFileRequest() {} | 627 InitiateUploadExistingFileRequest::~InitiateUploadExistingFileRequest() {} |
643 | 628 |
(...skipping 22 matching lines...) Expand all Loading... |
666 InitiateUploadExistingFileRequest::GetExtraRequestHeaders() const { | 651 InitiateUploadExistingFileRequest::GetExtraRequestHeaders() const { |
667 std::vector<std::string> headers( | 652 std::vector<std::string> headers( |
668 InitiateUploadRequestBase::GetExtraRequestHeaders()); | 653 InitiateUploadRequestBase::GetExtraRequestHeaders()); |
669 headers.push_back(util::GenerateIfMatchHeader(etag_)); | 654 headers.push_back(util::GenerateIfMatchHeader(etag_)); |
670 return headers; | 655 return headers; |
671 } | 656 } |
672 | 657 |
673 //============================ ResumeUploadRequest =========================== | 658 //============================ ResumeUploadRequest =========================== |
674 | 659 |
675 ResumeUploadRequest::ResumeUploadRequest( | 660 ResumeUploadRequest::ResumeUploadRequest( |
676 RequestSender* runner, | 661 RequestSender* sender, |
677 net::URLRequestContextGetter* url_request_context_getter, | |
678 const UploadRangeCallback& callback, | 662 const UploadRangeCallback& callback, |
679 const ProgressCallback& progress_callback, | 663 const ProgressCallback& progress_callback, |
680 const GURL& upload_location, | 664 const GURL& upload_location, |
681 int64 start_position, | 665 int64 start_position, |
682 int64 end_position, | 666 int64 end_position, |
683 int64 content_length, | 667 int64 content_length, |
684 const std::string& content_type, | 668 const std::string& content_type, |
685 const base::FilePath& local_file_path) | 669 const base::FilePath& local_file_path) |
686 : ResumeUploadRequestBase(runner, | 670 : ResumeUploadRequestBase(sender, |
687 url_request_context_getter, | |
688 upload_location, | 671 upload_location, |
689 start_position, | 672 start_position, |
690 end_position, | 673 end_position, |
691 content_length, | 674 content_length, |
692 content_type, | 675 content_type, |
693 local_file_path), | 676 local_file_path), |
694 callback_(callback), | 677 callback_(callback), |
695 progress_callback_(progress_callback) { | 678 progress_callback_(progress_callback) { |
696 DCHECK(!callback_.is_null()); | 679 DCHECK(!callback_.is_null()); |
697 } | 680 } |
698 | 681 |
699 ResumeUploadRequest::~ResumeUploadRequest() {} | 682 ResumeUploadRequest::~ResumeUploadRequest() {} |
700 | 683 |
701 void ResumeUploadRequest::OnRangeRequestComplete( | 684 void ResumeUploadRequest::OnRangeRequestComplete( |
702 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { | 685 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { |
703 callback_.Run(response, ParseResourceEntry(value.Pass())); | 686 callback_.Run(response, ParseResourceEntry(value.Pass())); |
704 } | 687 } |
705 | 688 |
706 void ResumeUploadRequest::OnURLFetchUploadProgress( | 689 void ResumeUploadRequest::OnURLFetchUploadProgress( |
707 const URLFetcher* source, int64 current, int64 total) { | 690 const URLFetcher* source, int64 current, int64 total) { |
708 if (!progress_callback_.is_null()) | 691 if (!progress_callback_.is_null()) |
709 progress_callback_.Run(current, total); | 692 progress_callback_.Run(current, total); |
710 } | 693 } |
711 | 694 |
712 //========================== GetUploadStatusRequest ========================== | 695 //========================== GetUploadStatusRequest ========================== |
713 | 696 |
714 GetUploadStatusRequest::GetUploadStatusRequest( | 697 GetUploadStatusRequest::GetUploadStatusRequest( |
715 RequestSender* runner, | 698 RequestSender* sender, |
716 net::URLRequestContextGetter* url_request_context_getter, | |
717 const UploadRangeCallback& callback, | 699 const UploadRangeCallback& callback, |
718 const GURL& upload_url, | 700 const GURL& upload_url, |
719 int64 content_length) | 701 int64 content_length) |
720 : GetUploadStatusRequestBase(runner, | 702 : GetUploadStatusRequestBase(sender, upload_url, content_length), |
721 url_request_context_getter, | |
722 upload_url, | |
723 content_length), | |
724 callback_(callback) { | 703 callback_(callback) { |
725 DCHECK(!callback.is_null()); | 704 DCHECK(!callback.is_null()); |
726 } | 705 } |
727 | 706 |
728 GetUploadStatusRequest::~GetUploadStatusRequest() {} | 707 GetUploadStatusRequest::~GetUploadStatusRequest() {} |
729 | 708 |
730 void GetUploadStatusRequest::OnRangeRequestComplete( | 709 void GetUploadStatusRequest::OnRangeRequestComplete( |
731 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { | 710 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { |
732 callback_.Run(response, ParseResourceEntry(value.Pass())); | 711 callback_.Run(response, ParseResourceEntry(value.Pass())); |
733 } | 712 } |
734 | 713 |
735 } // namespace google_apis | 714 } // namespace google_apis |
OLD | NEW |