// Copyright 2008, Google Inc. // All rights reserved. // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // * Redistributions in binary form must reproduce the above // copyright notice, this list of conditions and the following disclaimer // in the documentation and/or other materials provided with the // distribution. // * Neither the name of Google Inc. nor the names of its // contributors may be used to endorse or promote products derived from // this software without specific prior written permission. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. // NOTE: This class is currently unsed. The plan is to move bookmarks // out of the history db using this class and BookmarksCodec instead // (bug 1256202). #include "chrome/browser/bookmark_storage.h" #include "base/file_util.h" #include "base/json_writer.h" #include "base/message_loop.h" #include "chrome/browser/bookmark_bar_model.h" #include "chrome/browser/bookmark_codec.h" #include "chrome/browser/profile.h" #include "chrome/common/chrome_constants.h" #include "chrome/common/json_value_serializer.h" namespace { // Extension used for backup files (copy of main file created during startup). const wchar_t* const kBackupExtension = L"bak"; // Extension for the temporary file. We write to the temp file than move to // kBookmarksFileName. const wchar_t* const kTmpExtension = L"tmp"; // How often we save. const int kSaveDelayMS = 2500; } // namespace // BookmarkStorage ------------------------------------------------------------- BookmarkStorage::BookmarkStorage(Profile* profile, BookmarkBarModel* model) : model_(model), #pragma warning(suppress: 4355) // Okay to pass "this" here. save_factory_(this), backend_thread_(g_browser_process->file_thread()) { std::wstring path = profile->GetPath(); file_util::AppendToPath(&path, chrome::kBookmarksFileName); std::wstring tmp_history_path = profile->GetPath(); file_util::AppendToPath(&tmp_history_path, chrome::kHistoryBookmarksFileName); backend_ = new BookmarkStorageBackend(path, tmp_history_path); } void BookmarkStorage::LoadBookmarks(bool load_from_history) { if (!backend_thread()) { backend_->Read(scoped_refptr(this), NULL, load_from_history); } else { backend_thread()->message_loop()->PostTask( FROM_HERE, NewRunnableMethod(backend_.get(), &BookmarkStorageBackend::Read, scoped_refptr(this), MessageLoop::current(), load_from_history)); } } void BookmarkStorage::ScheduleSave() { if (save_factory_.empty()) { MessageLoop::current()->PostDelayedTask( FROM_HERE, save_factory_.NewRunnableMethod(&BookmarkStorage::SaveNow), kSaveDelayMS); } } void BookmarkStorage::BookmarkModelDeleted() { if (!save_factory_.empty()) { // There's a pending save. We need to save now as otherwise by the time // SaveNow is invoked the model is gone. save_factory_.RevokeAll(); SaveNow(); } model_ = NULL; } void BookmarkStorage::LoadedBookmarks(Value* root_value, bool bookmark_file_exists, bool loaded_from_history) { scoped_ptr value_ref(root_value); if (model_) { if (root_value) { BookmarkCodec codec; codec.Decode(model_, *root_value); } model_->OnBookmarkStorageLoadedBookmarks(bookmark_file_exists, loaded_from_history); } } void BookmarkStorage::SaveNow() { if (!model_ || !model_->IsLoaded()) { // We should only get here if we have a valid model and it's finished // loading. NOTREACHED(); return; } BookmarkCodec codec; Value* value = codec.Encode(model_); // The backend deletes value in write. if (!backend_thread()) { backend_->Write(value); } else { backend_thread()->message_loop()->PostTask( FROM_HERE, NewRunnableMethod(backend_.get(), &BookmarkStorageBackend::Write, value)); } } // BookmarkStorageBackend ------------------------------------------------------ BookmarkStorageBackend::BookmarkStorageBackend( const std::wstring& path, const std::wstring& tmp_history_path) : path_(path), tmp_history_path_(tmp_history_path) { // Make a backup of the current file. std::wstring backup_path = path; file_util::ReplaceExtension(&backup_path, kBackupExtension); file_util::CopyFile(path, backup_path); } void BookmarkStorageBackend::Write(Value* value) { DCHECK(value); // We own Value. scoped_ptr value_ref(value); std::string content; JSONWriter::Write(value, true, &content); // Write to a temp file, then rename. std::wstring tmp_file = path_; file_util::ReplaceExtension(&tmp_file, kTmpExtension); int bytes_written = file_util::WriteFile(tmp_file, content.c_str(), static_cast(content.length())); if (bytes_written != -1) { MoveFileEx(tmp_file.c_str(), path_.c_str(), MOVEFILE_COPY_ALLOWED | MOVEFILE_REPLACE_EXISTING); // Nuke the history file so that we don't attempt to load from it again. file_util::Delete(tmp_history_path_, false); } } void BookmarkStorageBackend::Read(scoped_refptr service, MessageLoop* message_loop, bool load_from_history) { const std::wstring& path = load_from_history ? tmp_history_path_ : path_; bool bookmark_file_exists = file_util::PathExists(path); Value* root = NULL; if (bookmark_file_exists) { JSONFileValueSerializer serializer(path); serializer.Deserialize(&root); } // BookmarkStorage takes ownership of root. if (message_loop) { message_loop->PostTask(FROM_HERE, NewRunnableMethod( service.get(), &BookmarkStorage::LoadedBookmarks, root, bookmark_file_exists, load_from_history)); } else { service->LoadedBookmarks(root, bookmark_file_exists, load_from_history); } }