1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219
|
// Copyright 2025 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chrome/browser/extensions/api/platform_keys/verify_trust_api_v1.h"
#include <algorithm>
#include <memory>
#include <optional>
#include <string_view>
#include <utility>
#include "base/containers/contains.h"
#include "base/containers/span.h"
#include "base/functional/bind.h"
#include "base/functional/callback_helpers.h"
#include "base/lazy_instance.h"
#include "base/memory/ref_counted.h"
#include "chrome/browser/extensions/api/platform_keys_core/platform_keys_utils.h"
#include "chrome/common/extensions/api/platform_keys_internal.h"
#include "content/public/browser/browser_thread.h"
#include "net/base/net_errors.h"
#include "net/cert/cert_verifier.h"
#include "net/cert/cert_verify_result.h"
#include "net/cert/x509_certificate.h"
#include "net/log/net_log_with_source.h"
namespace extensions {
namespace {
const char kErrorEmptyCertificateChain[] =
"Server certificate chain must not be empty.";
} // namespace
// This class bundles IO data and functions of the VerifyTrustApi that are to be
// used on the IO thread only.
// It is created on the UI thread and afterwards lives on the IO thread.
class VerifyTrustApiV1::IOPart {
public:
~IOPart();
// Verifies the certificate as stated by `params` and calls back `callback`
// with the result (see the declaration of VerifyCallback).
// Will not call back after this object is destructed or the verifier for this
// extension is deleted (see OnExtensionUnloaded).
void Verify(Params params,
const std::string& extension_id,
VerifyCallback callback);
// Must be called when the extension with id `extension_id` is unloaded.
// Deletes the verifier for `extension_id` and cancels all pending
// verifications of this verifier.
void OnExtensionUnloaded(const std::string& extension_id);
private:
struct RequestState {
RequestState() = default;
RequestState(const RequestState&) = delete;
RequestState& operator=(const RequestState&) = delete;
std::unique_ptr<net::CertVerifier::Request> request;
net::NetLogWithSource net_log;
};
// Keeps `request_state` alive until the `verify_result` is received, then
// calls back the `callback` with the result and no error.
void CallBackWithResult(VerifyCallback callback,
std::unique_ptr<net::CertVerifyResult> verify_result,
std::unique_ptr<RequestState> request_state,
int return_value);
// One CertVerifier per extension to verify trust. Each verifier is created on
// first usage and deleted when this IOPart is destructed or the respective
// extension is unloaded.
std::map<std::string, std::unique_ptr<net::CertVerifier>>
extension_to_verifier_;
};
VerifyTrustApiV1::VerifyTrustApiV1(content::BrowserContext* context)
: io_part_(new IOPart) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
registry_observation_.Observe(ExtensionRegistry::Get(context));
}
VerifyTrustApiV1::~VerifyTrustApiV1() {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
}
void VerifyTrustApiV1::Verify(Params params,
const std::string& extension_id,
VerifyCallback ui_callback) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
// Call back through the VerifyTrustApi object on the UIThread. Because of the
// WeakPtr usage, this will ensure that `ui_callback` is not called after the
// API is destroyed.
VerifyCallback finish_callback(base::BindOnce(
&CallBackOnUI,
base::BindOnce(&VerifyTrustApiV1::FinishedVerificationOnUI,
weak_factory_.GetWeakPtr(), std::move(ui_callback))));
content::GetIOThreadTaskRunner({})->PostTask(
FROM_HERE,
base::BindOnce(&IOPart::Verify, base::Unretained(io_part_.get()),
std::move(params), extension_id,
std::move(finish_callback)));
}
void VerifyTrustApiV1::OnExtensionUnloaded(
content::BrowserContext* browser_context,
const Extension* extension,
UnloadedExtensionReason reason) {
content::GetIOThreadTaskRunner({})->PostTask(
FROM_HERE,
base::BindOnce(&IOPart::OnExtensionUnloaded,
base::Unretained(io_part_.get()), extension->id()));
}
void VerifyTrustApiV1::FinishedVerificationOnUI(VerifyCallback ui_callback,
const std::string& error,
int return_value,
int cert_status) {
DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
std::move(ui_callback).Run(error, return_value, cert_status);
}
// static
void VerifyTrustApiV1::CallBackOnUI(VerifyCallback ui_callback,
const std::string& error,
int return_value,
int cert_status) {
content::GetUIThreadTaskRunner({})->PostTask(
FROM_HERE,
base::BindOnce(std::move(ui_callback), error, return_value, cert_status));
}
VerifyTrustApiV1::IOPart::~IOPart() {
DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
}
void VerifyTrustApiV1::IOPart::Verify(Params params,
const std::string& extension_id,
VerifyCallback callback) {
DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
const api::platform_keys::VerificationDetails& details = params.details;
if (details.server_certificate_chain.empty()) {
std::move(callback).Run(kErrorEmptyCertificateChain, 0, 0);
return;
}
std::vector<std::string_view> der_cert_chain;
for (const std::vector<uint8_t>& cert_der :
details.server_certificate_chain) {
if (cert_der.empty()) {
std::move(callback).Run(platform_keys::kErrorInvalidX509Cert, 0, 0);
return;
}
der_cert_chain.push_back(base::as_string_view(cert_der));
}
scoped_refptr<net::X509Certificate> cert_chain(
net::X509Certificate::CreateFromDERCertChain(der_cert_chain));
if (!cert_chain) {
std::move(callback).Run(platform_keys::kErrorInvalidX509Cert, 0, 0);
return;
}
if (!base::Contains(extension_to_verifier_, extension_id)) {
extension_to_verifier_[extension_id] =
net::CertVerifier::CreateDefault(/*cert_net_fetcher=*/nullptr);
}
net::CertVerifier* verifier = extension_to_verifier_[extension_id].get();
auto verify_result = std::make_unique<net::CertVerifyResult>();
auto request_state = std::make_unique<RequestState>();
net::CertVerifyResult* const verify_result_ptr = verify_result.get();
RequestState* const request_state_ptr = request_state.get();
base::OnceCallback<void(int)> bound_callback = base::BindOnce(
&IOPart::CallBackWithResult, base::Unretained(this), std::move(callback),
std::move(verify_result), std::move(request_state));
auto [first_callback, second_callback] =
base::SplitOnceCallback(std::move(bound_callback));
const int return_value =
verifier->Verify(net::CertVerifier::RequestParams(
std::move(cert_chain), details.hostname,
/*flags=*/0, /*ocsp_response=*/{}, /*sct_list=*/{}),
verify_result_ptr, std::move(first_callback),
&request_state_ptr->request, request_state_ptr->net_log);
if (return_value != net::ERR_IO_PENDING) {
std::move(second_callback).Run(return_value);
return;
}
}
void VerifyTrustApiV1::IOPart::OnExtensionUnloaded(
const std::string& extension_id) {
extension_to_verifier_.erase(extension_id);
}
void VerifyTrustApiV1::IOPart::CallBackWithResult(
VerifyCallback callback,
std::unique_ptr<net::CertVerifyResult> verify_result,
std::unique_ptr<RequestState> request_state,
int return_value) {
DCHECK_CURRENTLY_ON(content::BrowserThread::IO);
std::move(callback).Run(std::string() /* no error message */, return_value,
verify_result->cert_status);
}
} // namespace extensions
|