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 "chrome/browser/component_updater/component_unpacker.h" | 5 #include "chrome/browser/component_updater/component_unpacker.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
91 bool is_delta_; | 91 bool is_delta_; |
92 std::vector<uint8> public_key_; | 92 std::vector<uint8> public_key_; |
93 }; | 93 }; |
94 | 94 |
95 } // namespace | 95 } // namespace |
96 | 96 |
97 ComponentUnpacker::ComponentUnpacker( | 97 ComponentUnpacker::ComponentUnpacker( |
98 const std::vector<uint8>& pk_hash, | 98 const std::vector<uint8>& pk_hash, |
99 const base::FilePath& path, | 99 const base::FilePath& path, |
100 const std::string& fingerprint, | 100 const std::string& fingerprint, |
| 101 ComponentPatcher* patcher, |
101 ComponentInstaller* installer, | 102 ComponentInstaller* installer, |
102 bool in_process, | |
103 scoped_refptr<base::SequencedTaskRunner> task_runner) | 103 scoped_refptr<base::SequencedTaskRunner> task_runner) |
104 : pk_hash_(pk_hash), | 104 : pk_hash_(pk_hash), |
105 path_(path), | 105 path_(path), |
106 is_delta_(false), | 106 is_delta_(false), |
107 fingerprint_(fingerprint), | 107 fingerprint_(fingerprint), |
| 108 patcher_(patcher), |
108 installer_(installer), | 109 installer_(installer), |
109 in_process_(in_process), | |
110 error_(kNone), | 110 error_(kNone), |
111 extended_error_(0), | 111 extended_error_(0), |
| 112 ptr_factory_(this), |
112 task_runner_(task_runner) { | 113 task_runner_(task_runner) { |
113 } | 114 } |
114 | 115 |
115 // TODO(cpu): add a specific attribute check to a component json that the | 116 // TODO(cpu): add a specific attribute check to a component json that the |
116 // extension unpacker will reject, so that a component cannot be installed | 117 // extension unpacker will reject, so that a component cannot be installed |
117 // as an extension. | 118 // as an extension. |
118 scoped_ptr<base::DictionaryValue> ReadManifest( | 119 scoped_ptr<base::DictionaryValue> ReadManifest( |
119 const base::FilePath& unpack_path) { | 120 const base::FilePath& unpack_path) { |
120 base::FilePath manifest = | 121 base::FilePath manifest = |
121 unpack_path.Append(FILE_PATH_LITERAL("manifest.json")); | 122 unpack_path.Append(FILE_PATH_LITERAL("manifest.json")); |
122 if (!base::PathExists(manifest)) | 123 if (!base::PathExists(manifest)) |
123 return scoped_ptr<base::DictionaryValue>(); | 124 return scoped_ptr<base::DictionaryValue>(); |
124 JSONFileValueSerializer serializer(manifest); | 125 JSONFileValueSerializer serializer(manifest); |
125 std::string error; | 126 std::string error; |
126 scoped_ptr<base::Value> root(serializer.Deserialize(NULL, &error)); | 127 scoped_ptr<base::Value> root(serializer.Deserialize(NULL, &error)); |
127 if (!root.get()) | 128 if (!root.get()) |
128 return scoped_ptr<base::DictionaryValue>(); | 129 return scoped_ptr<base::DictionaryValue>(); |
129 if (!root->IsType(base::Value::TYPE_DICTIONARY)) | 130 if (!root->IsType(base::Value::TYPE_DICTIONARY)) |
130 return scoped_ptr<base::DictionaryValue>(); | 131 return scoped_ptr<base::DictionaryValue>(); |
131 return scoped_ptr<base::DictionaryValue>( | 132 return scoped_ptr<base::DictionaryValue>( |
132 static_cast<base::DictionaryValue*>(root.release())).Pass(); | 133 static_cast<base::DictionaryValue*>(root.release())).Pass(); |
133 } | 134 } |
134 | 135 |
135 bool ComponentUnpacker::UnpackInternal() { | 136 bool ComponentUnpacker::UnpackInternal() { |
136 return Verify() && Unzip() && BeginPatching(); | 137 return Verify() && Unzip() && BeginPatching(); |
137 } | 138 } |
138 | 139 |
139 void ComponentUnpacker::Unpack(const Callback& callback) { | 140 void ComponentUnpacker::Unpack( |
| 141 const base::Callback<void(Error, int)>& callback) { |
140 callback_ = callback; | 142 callback_ = callback; |
141 if (!UnpackInternal()) | 143 if (!UnpackInternal()) |
142 Finish(); | 144 Finish(); |
143 } | 145 } |
144 | 146 |
145 bool ComponentUnpacker::Verify() { | 147 bool ComponentUnpacker::Verify() { |
146 if (pk_hash_.empty() || path_.empty()) { | 148 if (pk_hash_.empty() || path_.empty()) { |
147 error_ = kInvalidParams; | 149 error_ = kInvalidParams; |
148 return false; | 150 return false; |
149 } | 151 } |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
193 | 195 |
194 | 196 |
195 bool ComponentUnpacker::BeginPatching() { | 197 bool ComponentUnpacker::BeginPatching() { |
196 if (is_delta_) { // Package is a diff package. | 198 if (is_delta_) { // Package is a diff package. |
197 // Use a different temp directory for the patch output files. | 199 // Use a different temp directory for the patch output files. |
198 if (!base::CreateNewTempDirectory(base::FilePath::StringType(), | 200 if (!base::CreateNewTempDirectory(base::FilePath::StringType(), |
199 &unpack_path_)) { | 201 &unpack_path_)) { |
200 error_ = kUnzipPathError; | 202 error_ = kUnzipPathError; |
201 return false; | 203 return false; |
202 } | 204 } |
203 patcher_ = new ComponentPatcher(unpack_diff_path_, | |
204 unpack_path_, | |
205 installer_, | |
206 in_process_, | |
207 task_runner_); | |
208 task_runner_->PostTask( | 205 task_runner_->PostTask( |
209 FROM_HERE, | 206 FROM_HERE, base::Bind(&DifferentialUpdatePatch, |
210 base::Bind(&ComponentPatcher::Start, | 207 unpack_diff_path_, |
211 patcher_, | 208 unpack_path_, |
212 base::Bind(&ComponentUnpacker::EndPatching, | 209 patcher_, |
213 scoped_refptr<ComponentUnpacker>(this)))); | 210 installer_, |
| 211 base::Bind(&ComponentUnpacker::EndPatching, |
| 212 GetWeakPtr()))); |
214 } else { | 213 } else { |
215 task_runner_->PostTask(FROM_HERE, | 214 task_runner_->PostTask( |
216 base::Bind(&ComponentUnpacker::EndPatching, | 215 FROM_HERE, base::Bind(&ComponentUnpacker::EndPatching, |
217 scoped_refptr<ComponentUnpacker>(this), | 216 GetWeakPtr(), |
218 kNone, | 217 kNone, |
219 0)); | 218 0)); |
220 } | 219 } |
221 return true; | 220 return true; |
222 } | 221 } |
223 | 222 |
224 void ComponentUnpacker::EndPatching(Error error, int extended_error) { | 223 void ComponentUnpacker::EndPatching(Error error, int extended_error) { |
225 error_ = error; | 224 error_ = error; |
226 extended_error_ = extended_error; | 225 extended_error_ = extended_error; |
227 patcher_ = NULL; | |
228 if (error_ != kNone) { | 226 if (error_ != kNone) { |
229 Finish(); | 227 Finish(); |
230 return; | 228 return; |
231 } | 229 } |
232 // Optimization: clean up patch files early, in case disk space is too low to | 230 // Optimization: clean up patch files early, in case disk space is too low to |
233 // install otherwise. | 231 // install otherwise. |
234 if (!unpack_diff_path_.empty()) { | 232 if (!unpack_diff_path_.empty()) { |
235 base::DeleteFile(unpack_diff_path_, true); | 233 base::DeleteFile(unpack_diff_path_, true); |
236 unpack_diff_path_.clear(); | 234 unpack_diff_path_.clear(); |
237 } | 235 } |
(...skipping 24 matching lines...) Expand all Loading... |
262 } | 260 } |
263 | 261 |
264 void ComponentUnpacker::Finish() { | 262 void ComponentUnpacker::Finish() { |
265 if (!unpack_diff_path_.empty()) | 263 if (!unpack_diff_path_.empty()) |
266 base::DeleteFile(unpack_diff_path_, true); | 264 base::DeleteFile(unpack_diff_path_, true); |
267 if (!unpack_path_.empty()) | 265 if (!unpack_path_.empty()) |
268 base::DeleteFile(unpack_path_, true); | 266 base::DeleteFile(unpack_path_, true); |
269 callback_.Run(error_, extended_error_); | 267 callback_.Run(error_, extended_error_); |
270 } | 268 } |
271 | 269 |
| 270 base::WeakPtr<ComponentUnpacker> ComponentUnpacker::GetWeakPtr() { |
| 271 return ptr_factory_.GetWeakPtr(); |
| 272 } |
| 273 |
272 ComponentUnpacker::~ComponentUnpacker() { | 274 ComponentUnpacker::~ComponentUnpacker() { |
273 } | 275 } |
274 | 276 |
275 } // namespace component_updater | 277 } // namespace component_updater |
OLD | NEW |