| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/browser/loader/x509_user_cert_resource_handler.h" | 5 #include "content/browser/loader/certificate_resource_handler.h" |
| 6 | 6 |
| 7 #include "base/string_util.h" | 7 #include "base/string_util.h" |
| 8 #include "content/browser/loader/resource_request_info_impl.h" | 8 #include "content/browser/loader/resource_request_info_impl.h" |
| 9 #include "content/public/browser/content_browser_client.h" | 9 #include "content/public/browser/content_browser_client.h" |
| 10 #include "content/public/common/resource_response.h" | 10 #include "content/public/common/resource_response.h" |
| 11 #include "net/base/io_buffer.h" | 11 #include "net/base/io_buffer.h" |
| 12 #include "net/base/mime_sniffer.h" | 12 #include "net/base/mime_sniffer.h" |
| 13 #include "net/base/mime_util.h" | 13 #include "net/base/mime_util.h" |
| 14 #include "net/base/x509_certificate.h" | |
| 15 #include "net/http/http_response_headers.h" | 14 #include "net/http/http_response_headers.h" |
| 16 #include "net/url_request/url_request.h" | 15 #include "net/url_request/url_request.h" |
| 17 #include "net/url_request/url_request_status.h" | 16 #include "net/url_request/url_request_status.h" |
| 18 | 17 |
| 19 namespace content { | 18 namespace content { |
| 20 | 19 |
| 21 X509UserCertResourceHandler::X509UserCertResourceHandler( | 20 CertificateResourceHandler::CertificateResourceHandler( |
| 22 net::URLRequest* request, | 21 net::URLRequest* request, |
| 23 int render_process_host_id, | 22 int render_process_host_id, |
| 24 int render_view_id) | 23 int render_view_id) |
| 25 : request_(request), | 24 : request_(request), |
| 26 content_length_(0), | 25 content_length_(0), |
| 27 read_buffer_(NULL), | 26 read_buffer_(NULL), |
| 28 resource_buffer_(NULL), | 27 resource_buffer_(NULL), |
| 29 render_process_host_id_(render_process_host_id), | 28 render_process_host_id_(render_process_host_id), |
| 30 render_view_id_(render_view_id) { | 29 render_view_id_(render_view_id), |
| 30 cert_type_(net::CERTIFICATE_MIME_TYPE_UNKNOWN) { |
| 31 } | 31 } |
| 32 | 32 |
| 33 X509UserCertResourceHandler::~X509UserCertResourceHandler() { | 33 CertificateResourceHandler::~CertificateResourceHandler() { |
| 34 } | 34 } |
| 35 | 35 |
| 36 bool X509UserCertResourceHandler::OnUploadProgress(int request_id, | 36 bool CertificateResourceHandler::OnUploadProgress(int request_id, |
| 37 uint64 position, | 37 uint64 position, |
| 38 uint64 size) { | 38 uint64 size) { |
| 39 return true; | 39 return true; |
| 40 } | 40 } |
| 41 | 41 |
| 42 bool X509UserCertResourceHandler::OnRequestRedirected(int request_id, | 42 bool CertificateResourceHandler::OnRequestRedirected(int request_id, |
| 43 const GURL& url, | 43 const GURL& url, |
| 44 ResourceResponse* resp, | 44 ResourceResponse* resp, |
| 45 bool* defer) { | 45 bool* defer) { |
| 46 url_ = url; | 46 url_ = url; |
| 47 return true; | 47 return true; |
| 48 } | 48 } |
| 49 | 49 |
| 50 bool X509UserCertResourceHandler::OnResponseStarted(int request_id, | 50 bool CertificateResourceHandler::OnResponseStarted(int request_id, |
| 51 ResourceResponse* resp, | 51 ResourceResponse* resp, |
| 52 bool* defer) { | 52 bool* defer) { |
| 53 return (resp->head.mime_type == "application/x-x509-user-cert"); | 53 cert_type_ = net::GetCertificateMimeTypeForMimeType(resp->head.mime_type); |
| 54 return cert_type_ != net::CERTIFICATE_MIME_TYPE_UNKNOWN; |
| 54 } | 55 } |
| 55 | 56 |
| 56 bool X509UserCertResourceHandler::OnWillStart(int request_id, | 57 bool CertificateResourceHandler::OnWillStart(int request_id, |
| 57 const GURL& url, | 58 const GURL& url, |
| 58 bool* defer) { | 59 bool* defer) { |
| 59 return true; | 60 return true; |
| 60 } | 61 } |
| 61 | 62 |
| 62 bool X509UserCertResourceHandler::OnWillRead(int request_id, | 63 bool CertificateResourceHandler::OnWillRead(int request_id, |
| 63 net::IOBuffer** buf, | 64 net::IOBuffer** buf, |
| 64 int* buf_size, | 65 int* buf_size, |
| 65 int min_size) { | 66 int min_size) { |
| 66 static const int kReadBufSize = 32768; | 67 static const int kReadBufSize = 32768; |
| 67 | 68 |
| 68 // TODO(gauravsh): Should we use 'min_size' here? | 69 // TODO(gauravsh): Should we use 'min_size' here? |
| 69 DCHECK(buf && buf_size); | 70 DCHECK(buf && buf_size); |
| 70 if (!read_buffer_) { | 71 if (!read_buffer_) { |
| 71 read_buffer_ = new net::IOBuffer(kReadBufSize); | 72 read_buffer_ = new net::IOBuffer(kReadBufSize); |
| 72 } | 73 } |
| 73 *buf = read_buffer_.get(); | 74 *buf = read_buffer_.get(); |
| 74 *buf_size = kReadBufSize; | 75 *buf_size = kReadBufSize; |
| 75 | 76 |
| 76 return true; | 77 return true; |
| 77 } | 78 } |
| 78 | 79 |
| 79 bool X509UserCertResourceHandler::OnReadCompleted(int request_id, | 80 bool CertificateResourceHandler::OnReadCompleted(int request_id, |
| 80 int bytes_read, | 81 int bytes_read, |
| 81 bool* defer) { | 82 bool* defer) { |
| 82 if (!bytes_read) | 83 if (!bytes_read) |
| 83 return true; | 84 return true; |
| 84 | 85 |
| 85 // We have more data to read. | 86 // We have more data to read. |
| 86 DCHECK(read_buffer_); | 87 DCHECK(read_buffer_); |
| 87 content_length_ += bytes_read; | 88 content_length_ += bytes_read; |
| 88 | 89 |
| 89 // Release the ownership of the buffer, and store a reference | 90 // Release the ownership of the buffer, and store a reference |
| 90 // to it. A new one will be allocated in OnWillRead(). | 91 // to it. A new one will be allocated in OnWillRead(). |
| 91 net::IOBuffer* buffer = NULL; | 92 net::IOBuffer* buffer = NULL; |
| 92 read_buffer_.swap(&buffer); | 93 read_buffer_.swap(&buffer); |
| 93 // TODO(gauravsh): Should this be handled by a separate thread? | 94 // TODO(gauravsh): Should this be handled by a separate thread? |
| 94 buffer_.push_back(std::make_pair(buffer, bytes_read)); | 95 buffer_.push_back(std::make_pair(buffer, bytes_read)); |
| 95 | 96 |
| 96 return true; | 97 return true; |
| 97 } | 98 } |
| 98 | 99 |
| 99 bool X509UserCertResourceHandler::OnResponseCompleted( | 100 bool CertificateResourceHandler::OnResponseCompleted( |
| 100 int request_id, | 101 int request_id, |
| 101 const net::URLRequestStatus& urs, | 102 const net::URLRequestStatus& urs, |
| 102 const std::string& sec_info) { | 103 const std::string& sec_info) { |
| 103 if (urs.status() != net::URLRequestStatus::SUCCESS) | 104 if (urs.status() != net::URLRequestStatus::SUCCESS) |
| 104 return false; | 105 return false; |
| 105 | 106 |
| 106 AssembleResource(); | 107 AssembleResource(); |
| 107 scoped_refptr<net::X509Certificate> cert; | 108 |
| 108 if (resource_buffer_) { | 109 const void* content_bytes = NULL; |
| 109 cert = net::X509Certificate::CreateFromBytes(resource_buffer_->data(), | 110 if (resource_buffer_) |
| 110 content_length_); | 111 content_bytes = resource_buffer_->data(); |
| 111 } | 112 |
| 112 GetContentClient()->browser()->AddNewCertificate( | 113 // Note that it's up to the browser to verify that the certificate |
| 113 request_, cert, render_process_host_id_, render_view_id_); | 114 // data is well-formed. |
| 115 GetContentClient()->browser()->AddCertificate( |
| 116 request_, cert_type_, content_bytes, content_length_, |
| 117 render_process_host_id_, render_view_id_); |
| 118 |
| 114 return true; | 119 return true; |
| 115 } | 120 } |
| 116 | 121 |
| 117 void X509UserCertResourceHandler::AssembleResource() { | 122 void CertificateResourceHandler::AssembleResource() { |
| 118 // 0-length IOBuffers are not allowed. | 123 // 0-length IOBuffers are not allowed. |
| 119 if (content_length_ == 0) { | 124 if (content_length_ == 0) { |
| 120 resource_buffer_ = NULL; | 125 resource_buffer_ = NULL; |
| 121 return; | 126 return; |
| 122 } | 127 } |
| 123 | 128 |
| 124 // Create the new buffer. | 129 // Create the new buffer. |
| 125 resource_buffer_ = new net::IOBuffer(content_length_); | 130 resource_buffer_ = new net::IOBuffer(content_length_); |
| 126 | 131 |
| 127 // Copy the data into it. | 132 // Copy the data into it. |
| 128 size_t bytes_copied = 0; | 133 size_t bytes_copied = 0; |
| 129 for (size_t i = 0; i < buffer_.size(); ++i) { | 134 for (size_t i = 0; i < buffer_.size(); ++i) { |
| 130 net::IOBuffer* data = buffer_[i].first; | 135 net::IOBuffer* data = buffer_[i].first; |
| 131 size_t data_len = buffer_[i].second; | 136 size_t data_len = buffer_[i].second; |
| 132 DCHECK(data != NULL); | 137 DCHECK(data != NULL); |
| 133 DCHECK_LE(bytes_copied + data_len, content_length_); | 138 DCHECK_LE(bytes_copied + data_len, content_length_); |
| 134 memcpy(resource_buffer_->data() + bytes_copied, data->data(), data_len); | 139 memcpy(resource_buffer_->data() + bytes_copied, data->data(), data_len); |
| 135 bytes_copied += data_len; | 140 bytes_copied += data_len; |
| 136 } | 141 } |
| 137 DCHECK_EQ(content_length_, bytes_copied); | 142 DCHECK_EQ(content_length_, bytes_copied); |
| 138 } | 143 } |
| 139 | 144 |
| 140 } // namespace content | 145 } // namespace content |
| OLD | NEW |