| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "chrome/browser/extensions/api/messaging/message_property_provider.h" | 5 #include "chrome/browser/extensions/api/messaging/message_property_provider.h" |
| 6 | 6 |
| 7 #include "base/json/json_writer.h" | 7 #include "base/json/json_writer.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/strings/string_piece.h" | 9 #include "base/strings/string_piece.h" |
| 10 #include "base/thread_task_runner_handle.h" | 10 #include "base/thread_task_runner_handle.h" |
| 11 #include "base/values.h" | 11 #include "base/values.h" |
| 12 #include "chrome/browser/profiles/profile.h" | 12 #include "chrome/browser/profiles/profile.h" |
| 13 #include "content/public/browser/browser_thread.h" | 13 #include "content/public/browser/browser_thread.h" |
| 14 #include "crypto/ec_private_key.h" |
| 14 #include "extensions/common/api/runtime.h" | 15 #include "extensions/common/api/runtime.h" |
| 15 #include "net/base/completion_callback.h" | 16 #include "net/base/completion_callback.h" |
| 16 #include "net/cert/asn1_util.h" | 17 #include "net/cert/asn1_util.h" |
| 17 #include "net/cert/jwk_serializer.h" | 18 #include "net/cert/jwk_serializer.h" |
| 18 #include "net/ssl/channel_id_service.h" | 19 #include "net/ssl/channel_id_service.h" |
| 19 #include "net/url_request/url_request_context.h" | 20 #include "net/url_request/url_request_context.h" |
| 20 #include "net/url_request/url_request_context_getter.h" | 21 #include "net/url_request/url_request_context_getter.h" |
| 21 #include "url/gurl.h" | 22 #include "url/gurl.h" |
| 22 | 23 |
| 23 namespace extensions { | 24 namespace extensions { |
| (...skipping 15 matching lines...) Expand all Loading... |
| 39 base::ThreadTaskRunnerHandle::Get(), | 40 base::ThreadTaskRunnerHandle::Get(), |
| 40 request_context_getter, | 41 request_context_getter, |
| 41 source_url.host(), | 42 source_url.host(), |
| 42 reply)); | 43 reply)); |
| 43 } | 44 } |
| 44 | 45 |
| 45 // Helper struct to bind the memory addresses that will be written to by | 46 // Helper struct to bind the memory addresses that will be written to by |
| 46 // ChannelIDService::GetChannelID to the callback provided to | 47 // ChannelIDService::GetChannelID to the callback provided to |
| 47 // MessagePropertyProvider::GetChannelID. | 48 // MessagePropertyProvider::GetChannelID. |
| 48 struct MessagePropertyProvider::GetChannelIDOutput { | 49 struct MessagePropertyProvider::GetChannelIDOutput { |
| 49 std::string domain_bound_private_key; | 50 scoped_ptr<crypto::ECPrivateKey> channel_id_key; |
| 50 std::string domain_bound_cert; | |
| 51 net::ChannelIDService::RequestHandle request_handle; | 51 net::ChannelIDService::RequestHandle request_handle; |
| 52 }; | 52 }; |
| 53 | 53 |
| 54 // static | 54 // static |
| 55 void MessagePropertyProvider::GetChannelIDOnIOThread( | 55 void MessagePropertyProvider::GetChannelIDOnIOThread( |
| 56 scoped_refptr<base::TaskRunner> original_task_runner, | 56 scoped_refptr<base::TaskRunner> original_task_runner, |
| 57 scoped_refptr<net::URLRequestContextGetter> request_context_getter, | 57 scoped_refptr<net::URLRequestContextGetter> request_context_getter, |
| 58 const std::string& host, | 58 const std::string& host, |
| 59 const ChannelIDCallback& reply) { | 59 const ChannelIDCallback& reply) { |
| 60 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); | 60 DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
| 61 net::ChannelIDService* channel_id_service = | 61 net::ChannelIDService* channel_id_service = |
| 62 request_context_getter->GetURLRequestContext()-> | 62 request_context_getter->GetURLRequestContext()-> |
| 63 channel_id_service(); | 63 channel_id_service(); |
| 64 GetChannelIDOutput* output = new GetChannelIDOutput(); | 64 GetChannelIDOutput* output = new GetChannelIDOutput(); |
| 65 net::CompletionCallback net_completion_callback = | 65 net::CompletionCallback net_completion_callback = |
| 66 base::Bind(&MessagePropertyProvider::GotChannelID, | 66 base::Bind(&MessagePropertyProvider::GotChannelID, |
| 67 original_task_runner, | 67 original_task_runner, |
| 68 base::Owned(output), | 68 base::Owned(output), |
| 69 reply); | 69 reply); |
| 70 int status = channel_id_service->GetChannelID( | 70 int status = channel_id_service->GetChannelID(host, &output->channel_id_key, |
| 71 host, | 71 net_completion_callback, |
| 72 &output->domain_bound_private_key, | 72 &output->request_handle); |
| 73 &output->domain_bound_cert, | |
| 74 net_completion_callback, | |
| 75 &output->request_handle); | |
| 76 if (status == net::ERR_IO_PENDING) | 73 if (status == net::ERR_IO_PENDING) |
| 77 return; | 74 return; |
| 78 GotChannelID(original_task_runner, output, reply, status); | 75 GotChannelID(original_task_runner, output, reply, status); |
| 79 } | 76 } |
| 80 | 77 |
| 81 // static | 78 // static |
| 82 void MessagePropertyProvider::GotChannelID( | 79 void MessagePropertyProvider::GotChannelID( |
| 83 scoped_refptr<base::TaskRunner> original_task_runner, | 80 scoped_refptr<base::TaskRunner> original_task_runner, |
| 84 struct GetChannelIDOutput* output, | 81 struct GetChannelIDOutput* output, |
| 85 const ChannelIDCallback& reply, | 82 const ChannelIDCallback& reply, |
| 86 int status) { | 83 int status) { |
| 87 base::Closure no_tls_channel_id_closure = base::Bind(reply, ""); | 84 base::Closure no_tls_channel_id_closure = base::Bind(reply, ""); |
| 88 if (status != net::OK) { | 85 if (status != net::OK) { |
| 89 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); | 86 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); |
| 90 return; | 87 return; |
| 91 } | 88 } |
| 92 base::StringPiece spki; | 89 std::vector<uint8> spki_vector; |
| 93 if (!net::asn1::ExtractSPKIFromDERCert(output->domain_bound_cert, &spki)) { | 90 if (!output->channel_id_key->ExportPublicKey(&spki_vector)) { |
| 94 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); | 91 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); |
| 95 return; | 92 return; |
| 96 } | 93 } |
| 94 base::StringPiece spki(reinterpret_cast<char*>(vector_as_array(&spki_vector)), |
| 95 spki_vector.size()); |
| 97 base::DictionaryValue jwk_value; | 96 base::DictionaryValue jwk_value; |
| 98 if (!net::JwkSerializer::ConvertSpkiFromDerToJwk(spki, &jwk_value)) { | 97 if (!net::JwkSerializer::ConvertSpkiFromDerToJwk(spki, &jwk_value)) { |
| 99 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); | 98 original_task_runner->PostTask(FROM_HERE, no_tls_channel_id_closure); |
| 100 return; | 99 return; |
| 101 } | 100 } |
| 102 std::string jwk_str; | 101 std::string jwk_str; |
| 103 base::JSONWriter::Write(jwk_value, &jwk_str); | 102 base::JSONWriter::Write(jwk_value, &jwk_str); |
| 104 original_task_runner->PostTask(FROM_HERE, base::Bind(reply, jwk_str)); | 103 original_task_runner->PostTask(FROM_HERE, base::Bind(reply, jwk_str)); |
| 105 } | 104 } |
| 106 | 105 |
| 107 } // namespace extensions | 106 } // namespace extensions |
| OLD | NEW |