components/copresence/rpc/http_post.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "components/copresence/rpc/http_post.h"
   6
   7 // TODO(ckehoe): Support third-party protobufs too.
   8 #include <google/protobuf/message_lite.h>
   9
  10 #include "base/bind.h"
  11 #include "google_apis/google_api_keys.h"
  12 #include "net/base/load_flags.h"
  13 #include "net/base/net_errors.h"
  14 #include "net/base/url_util.h"
  15 #include "net/http/http_status_code.h"
  16 #include "net/url_request/url_fetcher.h"
  17 #include "net/url_request/url_request_context_getter.h"
  18 #include "url/gurl.h"
  19
  20 namespace copresence {
  21
  22 const char HttpPost::kApiKeyField[] = "key";
  23 const char HttpPost::kTracingField[] = "trace";
  24
  25 HttpPost::HttpPost(net::URLRequestContextGetter* url_context_getter,
  26                    const std::string& server_host,
  27                    const std::string& rpc_name,
  28                    std::string api_key,
  29                    const std::string& auth_token,
  30                    const std::string& tracing_token,
  31                    const google::protobuf::MessageLite& request_proto) {
  32   // Create the base URL to call.
  33   GURL url(server_host + "/" + rpc_name);
  34
  35   // Add the tracing token, if specified.
  36   if (!tracing_token.empty()) {
  37     url = net::AppendQueryParameter(
  38         url, kTracingField, "token:" + tracing_token);
  39   }
  40
  41   // If we have no auth token, authenticate using the API key.
  42   // If no API key is specified, use the Chrome API key.
  43   if (auth_token.empty()) {
  44     if (api_key.empty()) {
  45 #ifdef GOOGLE_CHROME_BUILD
  46       DCHECK(google_apis::HasKeysConfigured());
  47       api_key = google_apis::GetAPIKey();
  48 #else
  49       LOG(ERROR) << "No Copresence API key provided";
  50 #endif
  51     }
  52     url = net::AppendQueryParameter(url, kApiKeyField, api_key);
  53   }
  54
  55   // Serialize the proto for transmission.
  56   std::string request_data;
  57   bool serialize_success = request_proto.SerializeToString(&request_data);
  58   DCHECK(serialize_success);
  59
  60   // Configure and send the request.
  61   url_fetcher_ =
  62       net::URLFetcher::Create(kUrlFetcherId, url, net::URLFetcher::POST, this);
  63   url_fetcher_->SetRequestContext(url_context_getter);
  64   url_fetcher_->SetLoadFlags(net::LOAD_BYPASS_CACHE |
  65                              net::LOAD_DISABLE_CACHE |
  66                              net::LOAD_DO_NOT_SAVE_COOKIES |
  67                              net::LOAD_DO_NOT_SEND_COOKIES |
  68                              net::LOAD_DO_NOT_SEND_AUTH_DATA);
  69   url_fetcher_->SetUploadData("application/x-protobuf", request_data);
  70   if (!auth_token.empty()) {
  71     url_fetcher_->AddExtraRequestHeader("Authorization: Bearer " + auth_token);
  72   }
  73 }
  74
  75 HttpPost::~HttpPost() {}
  76
  77 void HttpPost::Start(const ResponseCallback& response_callback) {
  78   response_callback_ = response_callback;
  79   DVLOG(3) << "Sending Copresence request to "
  80            << url_fetcher_->GetOriginalURL().spec();
  81   url_fetcher_->Start();
  82 }
  83
  84 void HttpPost::OnURLFetchComplete(const net::URLFetcher* source) {
  85   DCHECK_EQ(url_fetcher_.get(), source);
  86
  87   // Gather response info.
  88   std::string response;
  89   source->GetResponseAsString(&response);
  90   int response_code = source->GetResponseCode();
  91
  92   // Log any errors.
  93   if (response_code < 0) {
  94     net::URLRequestStatus status = source->GetStatus();
  95     LOG(WARNING) << "Couldn't contact the Copresence server at "
  96                  << source->GetURL() << ". Status code " << status.status();
  97     LOG_IF(WARNING, status.error())
  98         << "Network error: " << net::ErrorToString(status.error());
  99     LOG_IF(WARNING, !response.empty()) << "HTTP response: " << response;
 100   } else if (response_code != net::HTTP_OK) {
 101     LOG(WARNING) << "Copresence request got HTTP response code "
 102                  << response_code << ". Response:\n" << response;
 103   }
 104
 105   // Return the response.
 106   response_callback_.Run(response_code, response);
 107 }
 108
 109 }  // namespace copresence