blob: f76cb6a87c7e00a9633e20dd1c89a7329849addc [file] [log] [blame]
// 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/update_client/component_unpacker.h"
#include <stdint.h>
#include <string>
#include <utility>
#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/location.h"
#include "base/logging.h"
#include "base/macros.h"
#include "base/numerics/safe_conversions.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/stringprintf.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "components/crx_file/crx_verifier.h"
#include "components/update_client/component_patcher.h"
#include "components/update_client/patcher.h"
#include "components/update_client/unzipper.h"
#include "components/update_client/update_client.h"
#include "components/update_client/update_client_errors.h"
namespace update_client {
ComponentUnpacker::Result::Result() {}
ComponentUnpacker::ComponentUnpacker(const std::vector<uint8_t>& pk_hash,
const base::FilePath& path,
scoped_refptr<CrxInstaller> installer,
std::unique_ptr<Unzipper> unzipper,
scoped_refptr<Patcher> patcher,
crx_file::VerifierFormat crx_format)
: pk_hash_(pk_hash),
path_(path),
is_delta_(false),
installer_(installer),
unzipper_(std::move(unzipper)),
patcher_tool_(patcher),
crx_format_(crx_format),
error_(UnpackerError::kNone),
extended_error_(0) {}
ComponentUnpacker::~ComponentUnpacker() {}
void ComponentUnpacker::Unpack(Callback callback) {
callback_ = std::move(callback);
if (!Verify() || !BeginUnzipping())
EndUnpacking();
}
bool ComponentUnpacker::Verify() {
VLOG(1) << "Verifying component: " << path_.value();
if (path_.empty()) {
error_ = UnpackerError::kInvalidParams;
return false;
}
std::vector<std::vector<uint8_t>> required_keys;
if (!pk_hash_.empty())
required_keys.push_back(pk_hash_);
const crx_file::VerifierResult result =
crx_file::Verify(path_, crx_format_, required_keys,
std::vector<uint8_t>(), &public_key_, nullptr);
if (result != crx_file::VerifierResult::OK_FULL &&
result != crx_file::VerifierResult::OK_DELTA) {
error_ = UnpackerError::kInvalidFile;
extended_error_ = static_cast<int>(result);
LOG(INFO) << "Verification failed. Verifier error = " << extended_error_;
return false;
}
is_delta_ = result == crx_file::VerifierResult::OK_DELTA;
VLOG(1) << "Verification successful: " << path_.value();
return true;
}
bool ComponentUnpacker::BeginUnzipping() {
// Mind the reference to non-const type, passed as an argument below.
base::FilePath& destination = is_delta_ ? unpack_diff_path_ : unpack_path_;
#if !defined(STARBOARD)
if (!base::CreateNewTempDirectory(base::FilePath::StringType(),
&destination)) {
VLOG(1) << "Unable to create temporary directory for unpacking.";
error_ = UnpackerError::kUnzipPathError;
return false;
}
#else
// The directory of path_ is the installation slot.
destination = path_.DirName();
#endif
VLOG(1) << "Unpacking in: " << destination.value();
unzipper_->Unzip(path_, destination,
base::BindOnce(&ComponentUnpacker::EndUnzipping, this));
return true;
}
void ComponentUnpacker::EndUnzipping(bool result) {
if (!result) {
VLOG(1) << "Unzipping failed.";
error_ = UnpackerError::kUnzipFailed;
EndUnpacking();
return;
}
VLOG(1) << "Unpacked successfully";
BeginPatching();
}
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_ = UnpackerError::kUnzipPathError;
return false;
}
patcher_ = base::MakeRefCounted<ComponentPatcher>(
unpack_diff_path_, unpack_path_, installer_, patcher_tool_);
base::SequencedTaskRunnerHandle::Get()->PostTask(
FROM_HERE,
base::BindOnce(&ComponentPatcher::Start, patcher_,
base::BindOnce(&ComponentUnpacker::EndPatching,
scoped_refptr<ComponentUnpacker>(this))));
} else {
base::SequencedTaskRunnerHandle::Get()->PostTask(
FROM_HERE, base::BindOnce(&ComponentUnpacker::EndPatching,
scoped_refptr<ComponentUnpacker>(this),
UnpackerError::kNone, 0));
}
return true;
}
void ComponentUnpacker::EndPatching(UnpackerError error, int extended_error) {
error_ = error;
extended_error_ = extended_error;
patcher_ = nullptr;
EndUnpacking();
}
void ComponentUnpacker::EndUnpacking() {
#if !defined(STARBOARD)
if (!unpack_diff_path_.empty())
base::DeleteFile(unpack_diff_path_, true);
if (error_ != UnpackerError::kNone && !unpack_path_.empty())
base::DeleteFile(unpack_path_, true);
#endif
Result result;
result.error = error_;
result.extended_error = extended_error_;
if (error_ == UnpackerError::kNone) {
result.unpack_path = unpack_path_;
result.public_key = public_key_;
}
base::SequencedTaskRunnerHandle::Get()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback_), result));
}
} // namespace update_client