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 20namespace copresence { 21 22const char HttpPost::kApiKeyField[] = "key"; 23const char HttpPost::kTracingField[] = "trace"; 24 25HttpPost::HttpPost(net::URLRequestContextGetter* url_context_getter, 26 const std::string& server_host, 27 const std::string& rpc_name, 28 const std::string& tracing_token, 29 std::string api_key, 30 const google::protobuf::MessageLite& request_proto) { 31 // Create the base URL to call. 32 GURL url(server_host + "/" + rpc_name); 33 34 // Add the tracing token, if specified. 35 if (!tracing_token.empty()) { 36 url = net::AppendQueryParameter( 37 url, kTracingField, "token:" + tracing_token); 38 } 39 40 // If no API key is specified, use the Chrome API key. 41 if (api_key.empty()) { 42#ifdef GOOGLE_CHROME_BUILD 43 DCHECK(google_apis::HasKeysConfigured()); 44 api_key = google_apis::GetAPIKey(); 45#else 46 LOG(ERROR) << "No Copresence API key provided"; 47#endif 48 } 49 url = net::AppendQueryParameter(url, kApiKeyField, api_key); 50 51 // Serialize the proto for transmission. 52 std::string request_data; 53 bool serialize_success = request_proto.SerializeToString(&request_data); 54 DCHECK(serialize_success); 55 56 // Configure and send the request. 57 url_fetcher_.reset(net::URLFetcher::Create( 58 kUrlFetcherId, url, net::URLFetcher::POST, this)); 59 url_fetcher_->SetRequestContext(url_context_getter); 60 url_fetcher_->SetLoadFlags(net::LOAD_BYPASS_CACHE | 61 net::LOAD_DISABLE_CACHE | 62 net::LOAD_DO_NOT_SAVE_COOKIES | 63 net::LOAD_DO_NOT_SEND_COOKIES | 64 net::LOAD_DO_NOT_SEND_AUTH_DATA); 65 url_fetcher_->SetUploadData("application/x-protobuf", request_data); 66} 67 68HttpPost::~HttpPost() {} 69 70void HttpPost::Start(const ResponseCallback& response_callback) { 71 response_callback_ = response_callback; 72 DVLOG(3) << "Sending Copresence request to " 73 << url_fetcher_->GetOriginalURL().spec(); 74 url_fetcher_->Start(); 75} 76 77void HttpPost::OnURLFetchComplete(const net::URLFetcher* source) { 78 DCHECK_EQ(url_fetcher_.get(), source); 79 80 // Gather response info. 81 std::string response; 82 source->GetResponseAsString(&response); 83 int response_code = source->GetResponseCode(); 84 85 // Log any errors. 86 if (response_code < 0) { 87 net::URLRequestStatus status = source->GetStatus(); 88 LOG(WARNING) << "Couldn't contact the Copresence server at " 89 << source->GetURL() << ". Status code " << status.status(); 90 LOG_IF(WARNING, status.error()) 91 << "Network error: " << net::ErrorToString(status.error()); 92 LOG_IF(WARNING, !response.empty()) << "HTTP response: " << response; 93 } else if (response_code != net::HTTP_OK) { 94 LOG(WARNING) << "Copresence request got HTTP response code " 95 << response_code << ". Response:\n" << response; 96 } 97 98 // Return the response. 99 response_callback_.Run(response_code, response); 100} 101 102} // namespace copresence 103