Initial (partial) implementation of HPKP violation reporting

net/http/certificate_report_sender_impl.cc

Index: net/http/certificate_report_sender_impl.cc
diff --git a/net/http/certificate_report_sender_impl.cc b/net/http/certificate_report_sender_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..57940fadc22a4400eb6bfc7064cec9ba0cb55530
--- /dev/null
+++ b/net/http/certificate_report_sender_impl.cc
@@ -0,0 +1,71 @@
+// 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/http/certificate_report_sender_impl.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 {
+
+CertificateReportSenderImpl::CertificateReportSenderImpl(
+    URLRequestContext* request_context,
+    CookiesPreference cookies_preference)
+    : request_context_(request_context),
+      cookies_preference_(cookies_preference) {
+}
+
+CertificateReportSenderImpl::~CertificateReportSenderImpl() {
+  STLDeleteElements(&inflight_requests_);
+}
+
+void CertificateReportSenderImpl::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 CertificateReportSenderImpl::OnResponseStarted(URLRequest* request) {
+  // TODO(estark): call a callback so that the caller can print a
+  //  warning on failure.
+  RequestComplete(request);
+}
+
+void CertificateReportSenderImpl::OnReadCompleted(URLRequest* request,
+                                                  int bytes_read) {
+}
+
+scoped_ptr<URLRequest> CertificateReportSenderImpl::CreateURLRequest(
+    URLRequestContext* context,
+    const GURL& report_uri) {
+  scoped_ptr<URLRequest> request =
+      context->CreateRequest(report_uri, DEFAULT_PRIORITY, this);
+  if (cookies_preference_ != SEND_COOKIES)
+    request->SetLoadFlags(LOAD_DO_NOT_SEND_COOKIES | LOAD_DO_NOT_SAVE_COOKIES);
+  return request.Pass();
+}
+
+void CertificateReportSenderImpl::RequestComplete(URLRequest* request) {
+  std::set<URLRequest*>::iterator i = inflight_requests_.find(request);
+  DCHECK(i != inflight_requests_.end());
+  scoped_ptr<URLRequest> url_request(*i);
+  inflight_requests_.erase(i);
+}
+
+}  // namespace net