Index: components/component_updater/component_unpacker.cc |
diff --git a/components/component_updater/component_unpacker.cc b/components/component_updater/component_unpacker.cc |
deleted file mode 100644 |
index d904e32623c97ad8aa6de9c5da4303b397606c56..0000000000000000000000000000000000000000 |
--- a/components/component_updater/component_unpacker.cc |
+++ /dev/null |
@@ -1,288 +0,0 @@ |
-// Copyright 2014 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 "components/component_updater/component_unpacker.h" |
- |
-#include <stdint.h> |
-#include <string> |
-#include <vector> |
- |
-#include "base/bind.h" |
-#include "base/files/file_path.h" |
-#include "base/files/file_util.h" |
-#include "base/files/scoped_file.h" |
-#include "base/json/json_file_value_serializer.h" |
-#include "base/location.h" |
-#include "base/logging.h" |
-#include "base/numerics/safe_conversions.h" |
-#include "base/strings/string_number_conversions.h" |
-#include "base/strings/stringprintf.h" |
-#include "base/values.h" |
-#include "components/component_updater/component_patcher.h" |
-#include "components/component_updater/component_patcher_operation.h" |
-#include "components/component_updater/component_updater_service.h" |
-#include "components/crx_file/constants.h" |
-#include "components/crx_file/crx_file.h" |
-#include "crypto/secure_hash.h" |
-#include "crypto/signature_verifier.h" |
-#include "third_party/zlib/google/zip.h" |
- |
-using crypto::SecureHash; |
- |
-namespace component_updater { |
- |
-namespace { |
- |
-// This class makes sure that the CRX digital signature is valid |
-// and well formed. |
-class CRXValidator { |
- public: |
- explicit CRXValidator(FILE* crx_file) : valid_(false), is_delta_(false) { |
- crx_file::CrxFile::Header header; |
- size_t len = fread(&header, 1, sizeof(header), crx_file); |
- if (len < sizeof(header)) |
- return; |
- |
- crx_file::CrxFile::Error error; |
- scoped_ptr<crx_file::CrxFile> crx( |
- crx_file::CrxFile::Parse(header, &error)); |
- if (!crx.get()) |
- return; |
- is_delta_ = crx_file::CrxFile::HeaderIsDelta(header); |
- |
- std::vector<uint8_t> key(header.key_size); |
- len = fread(&key[0], sizeof(uint8_t), header.key_size, crx_file); |
- if (len < header.key_size) |
- return; |
- |
- std::vector<uint8_t> signature(header.signature_size); |
- len = |
- fread(&signature[0], sizeof(uint8_t), header.signature_size, crx_file); |
- if (len < header.signature_size) |
- return; |
- |
- crypto::SignatureVerifier verifier; |
- if (!verifier.VerifyInit(crx_file::kSignatureAlgorithm, |
- base::checked_cast<int>( |
- sizeof(crx_file::kSignatureAlgorithm)), |
- &signature[0], |
- base::checked_cast<int>(signature.size()), |
- &key[0], |
- base::checked_cast<int>(key.size()))) { |
- // Signature verification initialization failed. This is most likely |
- // caused by a public key in the wrong format (should encode algorithm). |
- return; |
- } |
- |
- const size_t kBufSize = 8 * 1024; |
- scoped_ptr<uint8_t[]> buf(new uint8_t[kBufSize]); |
- while ((len = fread(buf.get(), 1, kBufSize, crx_file)) > 0) |
- verifier.VerifyUpdate(buf.get(), base::checked_cast<int>(len)); |
- |
- if (!verifier.VerifyFinal()) |
- return; |
- |
- public_key_.swap(key); |
- valid_ = true; |
- } |
- |
- bool valid() const { return valid_; } |
- |
- bool is_delta() const { return is_delta_; } |
- |
- const std::vector<uint8_t>& public_key() const { return public_key_; } |
- |
- private: |
- bool valid_; |
- bool is_delta_; |
- std::vector<uint8_t> public_key_; |
-}; |
- |
-} // namespace |
- |
-ComponentUnpacker::ComponentUnpacker( |
- const std::vector<uint8_t>& pk_hash, |
- const base::FilePath& path, |
- const std::string& fingerprint, |
- ComponentInstaller* installer, |
- scoped_refptr<OutOfProcessPatcher> out_of_process_patcher, |
- scoped_refptr<base::SequencedTaskRunner> task_runner) |
- : pk_hash_(pk_hash), |
- path_(path), |
- is_delta_(false), |
- fingerprint_(fingerprint), |
- installer_(installer), |
- out_of_process_patcher_(out_of_process_patcher), |
- error_(kNone), |
- extended_error_(0), |
- task_runner_(task_runner) { |
-} |
- |
-// TODO(cpu): add a specific attribute check to a component json that the |
-// extension unpacker will reject, so that a component cannot be installed |
-// as an extension. |
-scoped_ptr<base::DictionaryValue> ReadManifest( |
- const base::FilePath& unpack_path) { |
- base::FilePath manifest = |
- unpack_path.Append(FILE_PATH_LITERAL("manifest.json")); |
- if (!base::PathExists(manifest)) |
- return scoped_ptr<base::DictionaryValue>(); |
- JSONFileValueSerializer serializer(manifest); |
- std::string error; |
- scoped_ptr<base::Value> root(serializer.Deserialize(NULL, &error)); |
- if (!root.get()) |
- return scoped_ptr<base::DictionaryValue>(); |
- if (!root->IsType(base::Value::TYPE_DICTIONARY)) |
- return scoped_ptr<base::DictionaryValue>(); |
- return scoped_ptr<base::DictionaryValue>( |
- static_cast<base::DictionaryValue*>(root.release())).Pass(); |
-} |
- |
-bool ComponentUnpacker::UnpackInternal() { |
- return Verify() && Unzip() && BeginPatching(); |
-} |
- |
-void ComponentUnpacker::Unpack(const Callback& callback) { |
- callback_ = callback; |
- if (!UnpackInternal()) |
- Finish(); |
-} |
- |
-bool ComponentUnpacker::Verify() { |
- VLOG(1) << "Verifying component: " << path_.value(); |
- if (pk_hash_.empty() || path_.empty()) { |
- error_ = kInvalidParams; |
- return false; |
- } |
- // First, validate the CRX header and signature. As of today |
- // this is SHA1 with RSA 1024. |
- base::ScopedFILE file(base::OpenFile(path_, "rb")); |
- if (!file.get()) { |
- error_ = kInvalidFile; |
- return false; |
- } |
- CRXValidator validator(file.get()); |
- file.reset(); |
- if (!validator.valid()) { |
- error_ = kInvalidFile; |
- return false; |
- } |
- is_delta_ = validator.is_delta(); |
- |
- // File is valid and the digital signature matches. Now make sure |
- // the public key hash matches the expected hash. If they do we fully |
- // trust this CRX. |
- uint8_t hash[32] = {}; |
- scoped_ptr<SecureHash> sha256(SecureHash::Create(SecureHash::SHA256)); |
- sha256->Update(&(validator.public_key()[0]), validator.public_key().size()); |
- sha256->Finish(hash, arraysize(hash)); |
- |
- if (!std::equal(pk_hash_.begin(), pk_hash_.end(), hash)) { |
- VLOG(1) << "Hash mismatch: " << path_.value(); |
- error_ = kInvalidId; |
- return false; |
- } |
- VLOG(1) << "Verification successful: " << path_.value(); |
- return true; |
-} |
- |
-bool ComponentUnpacker::Unzip() { |
- base::FilePath& destination = is_delta_ ? unpack_diff_path_ : unpack_path_; |
- VLOG(1) << "Unpacking in: " << destination.value(); |
- if (!base::CreateNewTempDirectory(base::FilePath::StringType(), |
- &destination)) { |
- VLOG(1) << "Unable to create temporary directory for unpacking."; |
- error_ = kUnzipPathError; |
- return false; |
- } |
- if (!zip::Unzip(path_, destination)) { |
- VLOG(1) << "Unzipping failed."; |
- error_ = kUnzipFailed; |
- return false; |
- } |
- VLOG(1) << "Unpacked successfully"; |
- return true; |
-} |
- |
-bool ComponentUnpacker::BeginPatching() { |
- if (is_delta_) { // Package is a diff package. |
- // Use a different temp directory for the patch output files. |
- if (!base::CreateNewTempDirectory(base::FilePath::StringType(), |
- &unpack_path_)) { |
- error_ = kUnzipPathError; |
- return false; |
- } |
- patcher_ = new ComponentPatcher(unpack_diff_path_, |
- unpack_path_, |
- installer_, |
- out_of_process_patcher_, |
- task_runner_); |
- task_runner_->PostTask( |
- FROM_HERE, |
- base::Bind(&ComponentPatcher::Start, |
- patcher_, |
- base::Bind(&ComponentUnpacker::EndPatching, |
- scoped_refptr<ComponentUnpacker>(this)))); |
- } else { |
- task_runner_->PostTask(FROM_HERE, |
- base::Bind(&ComponentUnpacker::EndPatching, |
- scoped_refptr<ComponentUnpacker>(this), |
- kNone, |
- 0)); |
- } |
- return true; |
-} |
- |
-void ComponentUnpacker::EndPatching(Error error, int extended_error) { |
- error_ = error; |
- extended_error_ = extended_error; |
- patcher_ = NULL; |
- if (error_ != kNone) { |
- Finish(); |
- return; |
- } |
- // Optimization: clean up patch files early, in case disk space is too low to |
- // install otherwise. |
- if (!unpack_diff_path_.empty()) { |
- base::DeleteFile(unpack_diff_path_, true); |
- unpack_diff_path_.clear(); |
- } |
- Install(); |
- Finish(); |
-} |
- |
-void ComponentUnpacker::Install() { |
- // Write the fingerprint to disk. |
- if (static_cast<int>(fingerprint_.size()) != |
- base::WriteFile( |
- unpack_path_.Append(FILE_PATH_LITERAL("manifest.fingerprint")), |
- fingerprint_.c_str(), |
- base::checked_cast<int>(fingerprint_.size()))) { |
- error_ = kFingerprintWriteFailed; |
- return; |
- } |
- scoped_ptr<base::DictionaryValue> manifest(ReadManifest(unpack_path_)); |
- if (!manifest.get()) { |
- error_ = kBadManifest; |
- return; |
- } |
- DCHECK(error_ == kNone); |
- if (!installer_->Install(*manifest, unpack_path_)) { |
- error_ = kInstallerError; |
- return; |
- } |
-} |
- |
-void ComponentUnpacker::Finish() { |
- if (!unpack_diff_path_.empty()) |
- base::DeleteFile(unpack_diff_path_, true); |
- if (!unpack_path_.empty()) |
- base::DeleteFile(unpack_path_, true); |
- callback_.Run(error_, extended_error_); |
-} |
- |
-ComponentUnpacker::~ComponentUnpacker() { |
-} |
- |
-} // namespace component_updater |