Add net::CertificateReportSender for handling cert report sending

net/url_request/certificate_report_sender.cc

+// Copyright 2015 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 "net/url_request/certificate_report_sender.h"
+
+#include "base/stl_util.h"
+#include "net/base/elements_upload_data_stream.h"
+#include "net/base/load_flags.h"
+#include "net/base/request_priority.h"
+#include "net/base/upload_bytes_element_reader.h"
+#include "net/url_request/url_request_context.h"
+#include "net/url_request/url_request_status.h"
+
+namespace net {
+
+CertificateReportSender::CertificateReportSender(
+    URLRequestContext* request_context,
+    CookiesPreference cookies_preference)
+    : request_context_(request_context),
+      cookies_preference_(cookies_preference) {
+}
+
+CertificateReportSender::~CertificateReportSender() {
+  STLDeleteElements(&inflight_requests_);
+}
+
+void CertificateReportSender::Send(const GURL& report_uri,
+                                   const std::string& report) {
+  scoped_ptr<URLRequest> url_request =
+      CreateURLRequest(request_context_, report_uri);
+  url_request->set_method("POST");
+
+  scoped_ptr<UploadElementReader> reader(
+      UploadOwnedBytesElementReader::CreateWithString(report));
+  url_request->set_upload(
+      ElementsUploadDataStream::CreateWithReader(reader.Pass(), 0));
+
+  URLRequest* raw_url_request = url_request.get();
+  inflight_requests_.insert(url_request.release());
+  raw_url_request->Start();
+}
+
+void CertificateReportSender::OnResponseStarted(URLRequest* request) {
+  // TODO(estark): call a callback so that the caller can print a
+  // warning on failure.
+  RequestComplete(request);
+}
+
+void CertificateReportSender::OnReadCompleted(URLRequest* request,
+                                              int bytes_read) {
+  NOTREACHED();
+}
+
+scoped_ptr<URLRequest> CertificateReportSender::CreateURLRequest(
+    URLRequestContext* context,
+    const GURL& report_uri) {
+  scoped_ptr<URLRequest> request =
+      context->CreateRequest(report_uri, DEFAULT_PRIORITY, this);
+  int load_flags =
+      LOAD_BYPASS_CACHE | LOAD_DISABLE_CACHE | LOAD_DO_NOT_SEND_AUTH_DATA;
+  if (cookies_preference_ != SEND_COOKIES) {
+    load_flags =
+        load_flags | LOAD_DO_NOT_SEND_COOKIES | LOAD_DO_NOT_SAVE_COOKIES;
+  }
+  request->SetLoadFlags(load_flags);
+  return request.Pass();
+}
+
+void CertificateReportSender::RequestComplete(URLRequest* request) {
+  std::set<URLRequest*>::iterator i = inflight_requests_.find(request);
+  CHECK(i != inflight_requests_.end());
+  scoped_ptr<URLRequest> url_request(*i);
+  inflight_requests_.erase(i);
+}
+
+}  // namespace net