blob: 4b9739b358ea4a5cce05935d9e93b2816d60e63b [file] [log] [blame]
// Copyright 2013 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 <memory>
#include <string>
#include <vector>
#include "base/callback_forward.h"
#include "base/files/file_path.h"
#include "base/files/important_file_writer.h"
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "ui/app_list/app_list_export.h"
namespace base {
class DictionaryValue;
class SequencedTaskRunner;
class SequencedWorkerPool;
namespace app_list {
// A simple JSON store to persist a dictionary.
class APP_LIST_EXPORT DictionaryDataStore
: public base::RefCountedThreadSafe<DictionaryDataStore>,
public base::ImportantFileWriter::DataSerializer {
typedef base::Callback<void(std::unique_ptr<base::DictionaryValue>)>
typedef base::Closure OnFlushedCallback;
DictionaryDataStore(const base::FilePath& data_file,
base::SequencedWorkerPool* worker_pool);
// Flushes pending writes.
void Flush(const OnFlushedCallback& on_flushed);
// Reads the persisted data from disk asynchronously. |on_read| is called
// with the loaded and parsed data. If there is an error, |on_read| is called
// without data.
void Load(const OnLoadedCallback& on_loaded);
// Schedule a job to persist the cached dictionary.
void ScheduleWrite();
// Used to get a pointer to the cached dictionary. Changes to this dictionary
// will not be persisted unless ScheduleWrite() is called.
base::DictionaryValue* cached_dict() { return cached_dict_.get(); }
friend class base::RefCountedThreadSafe<DictionaryDataStore>;
~DictionaryDataStore() override;
// Reads data from backing file.
std::unique_ptr<base::DictionaryValue> LoadOnBlockingPool();
// ImportantFileWriter::DataSerializer overrides:
bool SerializeData(std::string* data) override;
base::FilePath data_file_;
scoped_refptr<base::SequencedTaskRunner> file_task_runner_;
std::unique_ptr<base::ImportantFileWriter> writer_;
// Cached JSON dictionary to serve read and incremental change calls.
std::unique_ptr<base::DictionaryValue> cached_dict_;
base::SequencedWorkerPool* worker_pool_;
} // namespace app_list