Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(91)

Side by Side Diff: chrome/service/cloud_print/cloud_print_connector.cc

Issue 11360151: Move common cloud print methods from service/cloud_print to common/cloud_print. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 8 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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/service/cloud_print/cloud_print_connector.h" 5 #include "chrome/service/cloud_print/cloud_print_connector.h"
6 6
7 #include "base/bind.h" 7 #include "base/bind.h"
8 #include "base/bind_helpers.h" 8 #include "base/bind_helpers.h"
9 #include "base/md5.h" 9 #include "base/md5.h"
10 #include "base/rand_util.h" 10 #include "base/rand_util.h"
11 #include "base/string_number_conversions.h" 11 #include "base/string_number_conversions.h"
12 #include "base/string_split.h" 12 #include "base/string_split.h"
13 #include "base/stringprintf.h" 13 #include "base/stringprintf.h"
14 #include "base/utf_string_conversions.h" 14 #include "base/utf_string_conversions.h"
15 #include "base/values.h" 15 #include "base/values.h"
16 #include "chrome/common/cloud_print/cloud_print_consts.h"
16 #include "chrome/common/cloud_print/cloud_print_helpers.h" 17 #include "chrome/common/cloud_print/cloud_print_helpers.h"
17 #include "chrome/service/cloud_print/cloud_print_consts.h" 18 #include "chrome/service/cloud_print/cloud_print_consts.h"
18 #include "chrome/service/cloud_print/cloud_print_helpers.h" 19 #include "chrome/service/cloud_print/cloud_print_helpers.h"
19 #include "grit/generated_resources.h" 20 #include "grit/generated_resources.h"
20 #include "ui/base/l10n/l10n_util.h" 21 #include "ui/base/l10n/l10n_util.h"
21 22
22 CloudPrintConnector::CloudPrintConnector(Client* client, 23 CloudPrintConnector::CloudPrintConnector(Client* client,
23 const ConnectorSettings& settings) 24 const ConnectorSettings& settings)
24 : client_(client), 25 : client_(client),
25 next_response_handler_(NULL) { 26 next_response_handler_(NULL) {
(...skipping 175 matching lines...) Expand 10 before | Expand all | Expand 10 after
201 202
202 // Go through the list of the cloud printers and init print job handlers. 203 // Go through the list of the cloud printers and init print job handlers.
203 ListValue* printer_list = NULL; 204 ListValue* printer_list = NULL;
204 // There may be no "printers" value in the JSON 205 // There may be no "printers" value in the JSON
205 if (json_data->GetList(cloud_print::kPrinterListValue, &printer_list) 206 if (json_data->GetList(cloud_print::kPrinterListValue, &printer_list)
206 && printer_list) { 207 && printer_list) {
207 for (size_t index = 0; index < printer_list->GetSize(); index++) { 208 for (size_t index = 0; index < printer_list->GetSize(); index++) {
208 DictionaryValue* printer_data = NULL; 209 DictionaryValue* printer_data = NULL;
209 if (printer_list->GetDictionary(index, &printer_data)) { 210 if (printer_list->GetDictionary(index, &printer_data)) {
210 std::string printer_name; 211 std::string printer_name;
211 printer_data->GetString(kNameValue, &printer_name); 212 printer_data->GetString(cloud_print::kNameValue, &printer_name);
212 std::string printer_id; 213 std::string printer_id;
213 printer_data->GetString(kIdValue, &printer_id); 214 printer_data->GetString(cloud_print::kIdValue, &printer_id);
214 if (settings_.IsPrinterBlacklisted(printer_name)) { 215 if (settings_.IsPrinterBlacklisted(printer_name)) {
215 VLOG(1) << "CP_CONNECTOR: Deleting " << printer_name << 216 VLOG(1) << "CP_CONNECTOR: Deleting " << printer_name <<
216 " id: " << printer_id << " as blacklisted"; 217 " id: " << printer_id << " as blacklisted";
217 AddPendingDeleteTask(printer_id); 218 AddPendingDeleteTask(printer_id);
218 } else if (RemovePrinterFromList(printer_name, &local_printers)) { 219 } else if (RemovePrinterFromList(printer_name, &local_printers)) {
219 InitJobHandlerForPrinter(printer_data); 220 InitJobHandlerForPrinter(printer_data);
220 } else { 221 } else {
221 // Cloud printer is not found on the local system. 222 // Cloud printer is not found on the local system.
222 if (full_list || settings_.delete_on_enum_fail()) { 223 if (full_list || settings_.delete_on_enum_fail()) {
223 // Delete if we get the full list of printers or 224 // Delete if we get the full list of printers or
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after
302 request_->StartPostRequest( 303 request_->StartPostRequest(
303 url, this, max_retries, mime_type, post_data, std::string()); 304 url, this, max_retries, mime_type, post_data, std::string());
304 } 305 }
305 306
306 void CloudPrintConnector::ReportUserMessage(const std::string& message_id, 307 void CloudPrintConnector::ReportUserMessage(const std::string& message_id,
307 const std::string& failure_msg) { 308 const std::string& failure_msg) {
308 // This is a fire and forget type of function. 309 // This is a fire and forget type of function.
309 // Result of this request will be ignored. 310 // Result of this request will be ignored.
310 std::string mime_boundary; 311 std::string mime_boundary;
311 cloud_print::CreateMimeBoundaryForUpload(&mime_boundary); 312 cloud_print::CreateMimeBoundaryForUpload(&mime_boundary);
312 GURL url = CloudPrintHelpers::GetUrlForUserMessage(settings_.server_url(), 313 GURL url = cloud_print::GetUrlForUserMessage(settings_.server_url(),
313 message_id); 314 message_id);
314 std::string post_data; 315 std::string post_data;
315 cloud_print::AddMultipartValueForUpload(kMessageTextValue, failure_msg, 316 cloud_print::AddMultipartValueForUpload(cloud_print::kMessageTextValue,
316 mime_boundary, std::string(), &post_data); 317 failure_msg, mime_boundary, std::string(), &post_data);
317 // Terminate the request body 318 // Terminate the request body
318 post_data.append("--" + mime_boundary + "--\r\n"); 319 post_data.append("--" + mime_boundary + "--\r\n");
319 std::string mime_type("multipart/form-data; boundary="); 320 std::string mime_type("multipart/form-data; boundary=");
320 mime_type += mime_boundary; 321 mime_type += mime_boundary;
321 user_message_request_ = new CloudPrintURLFetcher; 322 user_message_request_ = new CloudPrintURLFetcher;
322 user_message_request_->StartPostRequest(url, this, 1, mime_type, post_data, 323 user_message_request_->StartPostRequest(url, this, 1, mime_type, post_data,
323 std::string()); 324 std::string());
324 } 325 }
325 326
326 bool CloudPrintConnector::RemovePrinterFromList( 327 bool CloudPrintConnector::RemovePrinterFromList(
327 const std::string& printer_name, 328 const std::string& printer_name,
328 printing::PrinterList* printer_list) { 329 printing::PrinterList* printer_list) {
329 for (printing::PrinterList::iterator index = printer_list->begin(); 330 for (printing::PrinterList::iterator index = printer_list->begin();
330 index != printer_list->end(); index++) { 331 index != printer_list->end(); index++) {
331 if (IsSamePrinter(index->printer_name, printer_name)) { 332 if (IsSamePrinter(index->printer_name, printer_name)) {
332 index = printer_list->erase(index); 333 index = printer_list->erase(index);
333 return true; 334 return true;
334 } 335 }
335 } 336 }
336 return false; 337 return false;
337 } 338 }
338 339
339 void CloudPrintConnector::InitJobHandlerForPrinter( 340 void CloudPrintConnector::InitJobHandlerForPrinter(
340 DictionaryValue* printer_data) { 341 DictionaryValue* printer_data) {
341 DCHECK(printer_data); 342 DCHECK(printer_data);
342 PrinterJobHandler::PrinterInfoFromCloud printer_info_cloud; 343 PrinterJobHandler::PrinterInfoFromCloud printer_info_cloud;
343 printer_data->GetString(kIdValue, &printer_info_cloud.printer_id); 344 printer_data->GetString(cloud_print::kIdValue,
345 &printer_info_cloud.printer_id);
344 DCHECK(!printer_info_cloud.printer_id.empty()); 346 DCHECK(!printer_info_cloud.printer_id.empty());
345 VLOG(1) << "CP_CONNECTOR: Init job handler" 347 VLOG(1) << "CP_CONNECTOR: Init job handler"
346 << ", printer id: " << printer_info_cloud.printer_id; 348 << ", printer id: " << printer_info_cloud.printer_id;
347 JobHandlerMap::iterator index = job_handler_map_.find( 349 JobHandlerMap::iterator index = job_handler_map_.find(
348 printer_info_cloud.printer_id); 350 printer_info_cloud.printer_id);
349 if (index != job_handler_map_.end()) 351 if (index != job_handler_map_.end())
350 return; // Nothing to do if we already have a job handler for this printer. 352 return; // Nothing to do if we already have a job handler for this printer.
351 353
352 printing::PrinterBasicInfo printer_info; 354 printing::PrinterBasicInfo printer_info;
353 printer_data->GetString(kNameValue, &printer_info.printer_name); 355 printer_data->GetString(cloud_print::kNameValue, &printer_info.printer_name);
354 DCHECK(!printer_info.printer_name.empty()); 356 DCHECK(!printer_info.printer_name.empty());
355 printer_data->GetString(kPrinterDescValue, 357 printer_data->GetString(cloud_print::kPrinterDescValue,
356 &printer_info.printer_description); 358 &printer_info.printer_description);
357 // Printer status is a string value which actually contains an integer. 359 // Printer status is a string value which actually contains an integer.
358 std::string printer_status; 360 std::string printer_status;
359 if (printer_data->GetString(kPrinterStatusValue, &printer_status)) { 361 if (printer_data->GetString(
362 cloud_print::kPrinterStatusValue, &printer_status)) {
360 base::StringToInt(printer_status, &printer_info.printer_status); 363 base::StringToInt(printer_status, &printer_info.printer_status);
361 } 364 }
362 printer_data->GetString(kPrinterCapsHashValue, 365 printer_data->GetString(cloud_print::kPrinterCapsHashValue,
363 &printer_info_cloud.caps_hash); 366 &printer_info_cloud.caps_hash);
364 ListValue* tags_list = NULL; 367 ListValue* tags_list = NULL;
365 if (printer_data->GetList(kTagsValue, &tags_list) && tags_list) { 368 if (printer_data->GetList(cloud_print::kTagsValue, &tags_list) && tags_list) {
366 for (size_t index = 0; index < tags_list->GetSize(); index++) { 369 for (size_t index = 0; index < tags_list->GetSize(); index++) {
367 std::string tag; 370 std::string tag;
368 if (tags_list->GetString(index, &tag) && 371 if (tags_list->GetString(index, &tag) &&
369 StartsWithASCII(tag, kTagsHashTagName, false)) { 372 StartsWithASCII(tag, kTagsHashTagName, false)) {
370 std::vector<std::string> tag_parts; 373 std::vector<std::string> tag_parts;
371 base::SplitStringDontTrim(tag, '=', &tag_parts); 374 base::SplitStringDontTrim(tag, '=', &tag_parts);
372 DCHECK_EQ(tag_parts.size(), 2U); 375 DCHECK_EQ(tag_parts.size(), 2U);
373 if (tag_parts.size() == 2) 376 if (tag_parts.size() == 2)
374 printer_info_cloud.tags_hash = tag_parts[1]; 377 printer_info_cloud.tags_hash = tag_parts[1];
375 } 378 }
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after
444 447
445 // Delete current task and repost if we have more task available. 448 // Delete current task and repost if we have more task available.
446 pending_tasks_.pop_front(); 449 pending_tasks_.pop_front();
447 if (pending_tasks_.size() != 0) { 450 if (pending_tasks_.size() != 0) {
448 MessageLoop::current()->PostTask( 451 MessageLoop::current()->PostTask(
449 FROM_HERE, base::Bind(&CloudPrintConnector::ProcessPendingTask, this)); 452 FROM_HERE, base::Bind(&CloudPrintConnector::ProcessPendingTask, this));
450 } 453 }
451 } 454 }
452 455
453 void CloudPrintConnector::OnPrintersAvailable() { 456 void CloudPrintConnector::OnPrintersAvailable() {
454 GURL printer_list_url = CloudPrintHelpers::GetUrlForPrinterList( 457 GURL printer_list_url = cloud_print::GetUrlForPrinterList(
455 settings_.server_url(), settings_.proxy_id()); 458 settings_.server_url(), settings_.proxy_id());
456 StartGetRequest(printer_list_url, 459 StartGetRequest(printer_list_url,
457 kCloudPrintRegisterMaxRetryCount, 460 kCloudPrintRegisterMaxRetryCount,
458 &CloudPrintConnector::HandlePrinterListResponse); 461 &CloudPrintConnector::HandlePrinterListResponse);
459 } 462 }
460 463
461 void CloudPrintConnector::OnPrinterRegister( 464 void CloudPrintConnector::OnPrinterRegister(
462 const printing::PrinterBasicInfo& info) { 465 const printing::PrinterBasicInfo& info) {
463 for (JobHandlerMap::iterator it = job_handler_map_.begin(); 466 for (JobHandlerMap::iterator it = job_handler_map_.begin();
464 it != job_handler_map_.end(); ++it) { 467 it != job_handler_map_.end(); ++it) {
(...skipping 16 matching lines...) Expand all
481 // Remove corresponding printer job handler. 484 // Remove corresponding printer job handler.
482 JobHandlerMap::iterator it = job_handler_map_.find(printer_id); 485 JobHandlerMap::iterator it = job_handler_map_.find(printer_id);
483 if (it != job_handler_map_.end()) { 486 if (it != job_handler_map_.end()) {
484 it->second->Shutdown(); 487 it->second->Shutdown();
485 job_handler_map_.erase(it); 488 job_handler_map_.erase(it);
486 } 489 }
487 490
488 // TODO(gene): We probably should not try indefinitely here. Just once or 491 // TODO(gene): We probably should not try indefinitely here. Just once or
489 // twice should be enough. 492 // twice should be enough.
490 // Bug: http://code.google.com/p/chromium/issues/detail?id=101850 493 // Bug: http://code.google.com/p/chromium/issues/detail?id=101850
491 GURL url = CloudPrintHelpers::GetUrlForPrinterDelete( 494 GURL url = cloud_print::GetUrlForPrinterDelete(
492 settings_.server_url(), printer_id, "printer_deleted"); 495 settings_.server_url(), printer_id, "printer_deleted");
493 StartGetRequest(url, 496 StartGetRequest(url,
494 kCloudPrintAPIMaxRetryCount, 497 kCloudPrintAPIMaxRetryCount,
495 &CloudPrintConnector::HandlePrinterDeleteResponse); 498 &CloudPrintConnector::HandlePrinterDeleteResponse);
496 } 499 }
497 500
498 void CloudPrintConnector::OnReceivePrinterCaps( 501 void CloudPrintConnector::OnReceivePrinterCaps(
499 bool succeeded, 502 bool succeeded,
500 const std::string& printer_name, 503 const std::string& printer_name,
501 const printing::PrinterCapsAndDefaults& caps_and_defaults) { 504 const printing::PrinterCapsAndDefaults& caps_and_defaults) {
(...skipping 17 matching lines...) Expand all
519 return; 522 return;
520 } 523 }
521 524
522 const printing::PrinterBasicInfo& info = pending_tasks_.front().printer_info; 525 const printing::PrinterBasicInfo& info = pending_tasks_.front().printer_info;
523 DCHECK(IsSamePrinter(info.printer_name, printer_name)); 526 DCHECK(IsSamePrinter(info.printer_name, printer_name));
524 527
525 std::string mime_boundary; 528 std::string mime_boundary;
526 cloud_print::CreateMimeBoundaryForUpload(&mime_boundary); 529 cloud_print::CreateMimeBoundaryForUpload(&mime_boundary);
527 std::string post_data; 530 std::string post_data;
528 531
529 cloud_print::AddMultipartValueForUpload(kProxyIdValue, settings_.proxy_id(), 532 cloud_print::AddMultipartValueForUpload(cloud_print::kProxyIdValue,
530 mime_boundary, std::string(), &post_data); 533 settings_.proxy_id(), mime_boundary, std::string(), &post_data);
531 cloud_print::AddMultipartValueForUpload(kPrinterNameValue, info.printer_name, 534 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterNameValue,
532 mime_boundary, std::string(), &post_data); 535 info.printer_name, mime_boundary, std::string(), &post_data);
533 cloud_print::AddMultipartValueForUpload(kPrinterDescValue, 536 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterDescValue,
534 info.printer_description, mime_boundary, std::string() , &post_data); 537 info.printer_description, mime_boundary, std::string(), &post_data);
535 cloud_print::AddMultipartValueForUpload(kPrinterStatusValue, 538 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterStatusValue,
536 base::StringPrintf("%d", info.printer_status), 539 base::StringPrintf("%d", info.printer_status),
537 mime_boundary, std::string(), &post_data); 540 mime_boundary, std::string(), &post_data);
538 post_data += CloudPrintHelpers::GetPostDataForPrinterTags(info, 541 post_data += CloudPrintHelpers::GetPostDataForPrinterTags(info,
539 mime_boundary); 542 mime_boundary);
540 cloud_print::AddMultipartValueForUpload(kPrinterCapsValue, 543 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterCapsValue,
541 caps_and_defaults.printer_capabilities, mime_boundary, 544 caps_and_defaults.printer_capabilities, mime_boundary,
542 caps_and_defaults.caps_mime_type, &post_data); 545 caps_and_defaults.caps_mime_type, &post_data);
543 cloud_print::AddMultipartValueForUpload(kPrinterDefaultsValue, 546 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterDefaultsValue,
544 caps_and_defaults.printer_defaults, mime_boundary, 547 caps_and_defaults.printer_defaults, mime_boundary,
545 caps_and_defaults.defaults_mime_type, &post_data); 548 caps_and_defaults.defaults_mime_type, &post_data);
546 // Send a hash of the printer capabilities to the server. We will use this 549 // Send a hash of the printer capabilities to the server. We will use this
547 // later to check if the capabilities have changed 550 // later to check if the capabilities have changed
548 cloud_print::AddMultipartValueForUpload(kPrinterCapsHashValue, 551 cloud_print::AddMultipartValueForUpload(cloud_print::kPrinterCapsHashValue,
549 base::MD5String(caps_and_defaults.printer_capabilities), 552 base::MD5String(caps_and_defaults.printer_capabilities),
550 mime_boundary, std::string(), &post_data); 553 mime_boundary, std::string(), &post_data);
551 554
552 // Terminate the request body 555 // Terminate the request body
553 post_data.append("--" + mime_boundary + "--\r\n"); 556 post_data.append("--" + mime_boundary + "--\r\n");
554 std::string mime_type("multipart/form-data; boundary="); 557 std::string mime_type("multipart/form-data; boundary=");
555 mime_type += mime_boundary; 558 mime_type += mime_boundary;
556 559
557 GURL post_url = CloudPrintHelpers::GetUrlForPrinterRegistration( 560 GURL post_url = cloud_print::GetUrlForPrinterRegistration(
558 settings_.server_url()); 561 settings_.server_url());
559 StartPostRequest(post_url, 562 StartPostRequest(post_url,
560 kCloudPrintAPIMaxRetryCount, 563 kCloudPrintAPIMaxRetryCount,
561 mime_type, 564 mime_type,
562 post_data, 565 post_data,
563 &CloudPrintConnector::HandleRegisterPrinterResponse); 566 &CloudPrintConnector::HandleRegisterPrinterResponse);
564 } 567 }
565 568
566 bool CloudPrintConnector::IsSamePrinter(const std::string& name1, 569 bool CloudPrintConnector::IsSamePrinter(const std::string& name1,
567 const std::string& name2) const { 570 const std::string& name2) const {
568 return (0 == base::strcasecmp(name1.c_str(), name2.c_str())); 571 return (0 == base::strcasecmp(name1.c_str(), name2.c_str()));
569 } 572 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698