Added privet storage list operation

chrome/browser/local_discovery/privet_http_impl.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/local_discovery/privet_http_impl.h"
 
 #include <algorithm>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/message_loop/message_loop.h"
 #include "base/rand_util.h"
 #include "base/strings/string_number_conversions.h"
+#include "base/strings/stringprintf.h"
 #include "chrome/browser/local_discovery/privet_constants.h"
 #include "net/base/url_util.h"
 #include "url/gurl.h"
 
 namespace local_discovery {
 
 namespace {
 const char kUrlPlaceHolder[] = "http://host/";
 const char kPrivetRegisterActionArgName[] = "action";
 const char kPrivetRegisterUserArgName[] = "user";
 
 const char kPrivetURLKeyUser[] = "user";
 const char kPrivetURLKeyJobname[] = "jobname";
 const char kPrivetURLKeyOffline[] = "offline";
 const char kPrivetURLValueOffline[] = "1";
 
 const char kPrivetContentTypePDF[] = "application/pdf";
 const char kPrivetContentTypePWGRaster[] = "image/pwg-raster";
 const char kPrivetContentTypeAny[] = "*/*";
 const char kPrivetContentTypeCJT[] = "application/json";
 
+const char kPrivetStorageListPath[] = "/privet/storage/list";
+const char kPrivetStorageParamPathFormat[] = "path=%s";
+
 const char kPrivetCDDKeySupportedContentTypes[] =
     "printer.supported_content_type";
 
 const char kPrivetCDDKeyContentType[] = "content_type";
 
 const char kPrivetKeyJobID[] = "job_id";
 
 const int kPrivetCancelationTimeoutSeconds = 3;
 
 const int kPrivetLocalPrintMaxRetries = 2;
 
 const int kPrivetLocalPrintDefaultTimeout = 5;
 
 GURL CreatePrivetURL(const std::string& path) {
   GURL url(kUrlPlaceHolder);
   GURL::Replacements replacements;
   replacements.SetPathStr(path);
   return url.ReplaceComponents(replacements);
 }
 
 GURL CreatePrivetRegisterURL(const std::string& action,
                              const std::string& user) {
   GURL url = CreatePrivetURL(kPrivetRegisterPath);
   url = net::AppendQueryParameter(url, kPrivetRegisterActionArgName, action);
   return net::AppendQueryParameter(url, kPrivetRegisterUserArgName, user);
 }
 
+GURL CreatePrivetParamURL(const std::string& path,
+                          const std::string& query_params) {
+  GURL url(kUrlPlaceHolder);
+  GURL::Replacements replacements;
+  replacements.SetPathStr(path);
+  if (!query_params.empty()) {
+    replacements.SetQueryStr(query_params);
+  }
+  return url.ReplaceComponents(replacements);
+}
+
 }  // namespace
 
 PrivetInfoOperationImpl::PrivetInfoOperationImpl(
     PrivetHTTPClientImpl* privet_client,
     const PrivetJSONOperation::ResultCallback& callback)
     : privet_client_(privet_client), callback_(callback) {
 }
 
 PrivetInfoOperationImpl::~PrivetInfoOperationImpl() {
 }
@@ skipping 245 matching lines @@
 
 void PrivetRegisterOperationImpl::Cancelation::Cleanup() {
   // Nothing needs to be done, as base::Owned will delete this object,
   // this callback is just here to pass ownership of the Cancelation to
   // the message loop.
 }
 
 PrivetJSONOperationImpl::PrivetJSONOperationImpl(
     PrivetHTTPClientImpl* privet_client,
     const std::string& path,
+    const std::string& query_params,
     const PrivetJSONOperation::ResultCallback& callback)
-    : privet_client_(privet_client), path_(path), callback_(callback) {
+    : privet_client_(privet_client), path_(path), query_params_(query_params),
+      callback_(callback) {
 }
 
 PrivetJSONOperationImpl::~PrivetJSONOperationImpl() {
 }
 
 void PrivetJSONOperationImpl::Start() {
   url_fetcher_ = privet_client_->CreateURLFetcher(
-      CreatePrivetURL(path_), net::URLFetcher::GET, this);
+      CreatePrivetParamURL(path_, query_params_), net::URLFetcher::GET, this);
   url_fetcher_->DoNotRetryOnTransientError();
   url_fetcher_->Start();
 }
 
 PrivetHTTPClient* PrivetJSONOperationImpl::GetHTTPClient() {
   return privet_client_;
 }
 
 void PrivetJSONOperationImpl::OnError(
     PrivetURLFetcher* fetcher,
@@ skipping 363 matching lines @@
 scoped_ptr<PrivetJSONOperation> PrivetHTTPClientImpl::CreateInfoOperation(
     const PrivetJSONOperation::ResultCallback& callback) {
   return scoped_ptr<PrivetJSONOperation>(
       new PrivetInfoOperationImpl(this, callback));
 }
 
 scoped_ptr<PrivetJSONOperation>
 PrivetHTTPClientImpl::CreateCapabilitiesOperation(
     const PrivetJSONOperation::ResultCallback& callback) {
   return scoped_ptr<PrivetJSONOperation>(
-      new PrivetJSONOperationImpl(this, kPrivetCapabilitiesPath, callback));
+      new PrivetJSONOperationImpl(this, kPrivetCapabilitiesPath, "", callback));
 }
 
 scoped_ptr<PrivetLocalPrintOperation>
 PrivetHTTPClientImpl::CreateLocalPrintOperation(
     PrivetLocalPrintOperation::Delegate* delegate) {
   return scoped_ptr<PrivetLocalPrintOperation>(
       new PrivetLocalPrintOperationImpl(this, delegate));
 }
 
+scoped_ptr<PrivetJSONOperation>
+PrivetHTTPClientImpl::CreateStorageListOperation(
+      const std::string& path,
+      const PrivetJSONOperation::ResultCallback& callback) {
+  std::string url_param = base::StringPrintf(kPrivetStorageParamPathFormat,
+                                            path.c_str());
+  return scoped_ptr<PrivetJSONOperation>(
+      new PrivetJSONOperationImpl(this, kPrivetStorageListPath, url_param,
+                                  callback));
+}
+
 const std::string& PrivetHTTPClientImpl::GetName() {
   return name_;
 }
 
 scoped_ptr<PrivetURLFetcher> PrivetHTTPClientImpl::CreateURLFetcher(
     const GURL& url, net::URLFetcher::RequestType request_type,
     PrivetURLFetcher::Delegate* delegate) const {
   GURL::Replacements replacements;
   replacements.SetHostStr(host_port_.host());
   std::string port(base::IntToString(host_port_.port()));  // Keep string alive.
@@ skipping 41 matching lines @@
   TokenCallbackVector token_callbacks;
   token_callbacks_.swap(token_callbacks);
 
   for (TokenCallbackVector::iterator i = token_callbacks.begin();
        i != token_callbacks.end(); i++) {
     i->Run(token);
   }
 }
 
 }  // namespace local_discovery