Commit eecc87f1 authored by Alexey Baskakov's avatar Alexey Baskakov Committed by Commit Bot

WebApp: Cleanup WebAppDatabase implementation.

Inline CreateStore / OnStoreCreated methods.

Bug: 860583
Change-Id: Ia3d8e0892fb8e2461be6233cad8f33f58f9d4ad8
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1816335Reviewed-by: default avatarAlan Cutter <alancutter@chromium.org>
Commit-Queue: Alexey Baskakov <loyso@chromium.org>
Cr-Commit-Position: refs/heads/master@{#699241}
parent 9f21b695
...@@ -25,16 +25,16 @@ WebAppDatabase::~WebAppDatabase() { ...@@ -25,16 +25,16 @@ WebAppDatabase::~WebAppDatabase() {
} }
void WebAppDatabase::OpenDatabase(RegistryOpenedCallback callback) { void WebAppDatabase::OpenDatabase(RegistryOpenedCallback callback) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(!store_); DCHECK(!store_);
syncer::OnceModelTypeStoreFactory store_factory = syncer::OnceModelTypeStoreFactory store_factory =
database_factory_->GetStoreFactory(); database_factory_->GetStoreFactory();
// CreateStore then ReadRegistry. std::move(store_factory)
CreateStore( .Run(syncer::WEB_APPS,
std::move(store_factory), base::BindOnce(&WebAppDatabase::OnDatabaseOpened,
base::BindOnce(&WebAppDatabase::ReadRegistry, weak_ptr_factory_.GetWeakPtr(), std::move(callback)));
weak_ptr_factory_.GetWeakPtr(), std::move(callback)));
} }
void WebAppDatabase::WriteWebApps(AppsToWrite apps, void WebAppDatabase::WriteWebApps(AppsToWrite apps,
...@@ -201,27 +201,8 @@ std::unique_ptr<WebApp> WebAppDatabase::CreateWebApp(const WebAppProto& proto) { ...@@ -201,27 +201,8 @@ std::unique_ptr<WebApp> WebAppDatabase::CreateWebApp(const WebAppProto& proto) {
return web_app; return web_app;
} }
void WebAppDatabase::ReadRegistry(RegistryOpenedCallback callback) { void WebAppDatabase::OnDatabaseOpened(
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); RegistryOpenedCallback callback,
DCHECK(store_);
store_->ReadAllData(base::BindOnce(&WebAppDatabase::OnAllDataRead,
weak_ptr_factory_.GetWeakPtr(),
std::move(callback)));
}
void WebAppDatabase::CreateStore(
syncer::OnceModelTypeStoreFactory store_factory,
base::OnceClosure closure) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
std::move(store_factory)
.Run(syncer::WEB_APPS,
base::BindOnce(&WebAppDatabase::OnStoreCreated,
weak_ptr_factory_.GetWeakPtr(), std::move(closure)));
}
void WebAppDatabase::OnStoreCreated(
base::OnceClosure closure,
const base::Optional<syncer::ModelError>& error, const base::Optional<syncer::ModelError>& error,
std::unique_ptr<syncer::ModelTypeStore> store) { std::unique_ptr<syncer::ModelTypeStore> store) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_); DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
...@@ -231,7 +212,9 @@ void WebAppDatabase::OnStoreCreated( ...@@ -231,7 +212,9 @@ void WebAppDatabase::OnStoreCreated(
} }
store_ = std::move(store); store_ = std::move(store);
std::move(closure).Run(); store_->ReadAllData(base::BindOnce(&WebAppDatabase::OnAllDataRead,
weak_ptr_factory_.GetWeakPtr(),
std::move(callback)));
} }
void WebAppDatabase::OnAllDataRead( void WebAppDatabase::OnAllDataRead(
......
...@@ -45,19 +45,15 @@ class WebAppDatabase { ...@@ -45,19 +45,15 @@ class WebAppDatabase {
// Exposed for testing. // Exposed for testing.
static std::unique_ptr<WebAppProto> CreateWebAppProto(const WebApp& web_app); static std::unique_ptr<WebAppProto> CreateWebAppProto(const WebApp& web_app);
// Exposed for testing. // Exposed for testing.
static std::unique_ptr<WebApp> CreateWebApp(const WebAppProto& proto);
// Exposed for testing.
void ReadRegistry(RegistryOpenedCallback callback);
// Exposed for testing.
static std::unique_ptr<WebApp> ParseWebApp(const AppId& app_id, static std::unique_ptr<WebApp> ParseWebApp(const AppId& app_id,
const std::string& value); const std::string& value);
private: private:
void CreateStore(syncer::OnceModelTypeStoreFactory store_factory, static std::unique_ptr<WebApp> CreateWebApp(const WebAppProto& proto);
base::OnceClosure closure);
void OnStoreCreated(base::OnceClosure closure, void OnDatabaseOpened(RegistryOpenedCallback callback,
const base::Optional<syncer::ModelError>& error, const base::Optional<syncer::ModelError>& error,
std::unique_ptr<syncer::ModelTypeStore> store); std::unique_ptr<syncer::ModelTypeStore> store);
void OnAllDataRead( void OnAllDataRead(
RegistryOpenedCallback callback, RegistryOpenedCallback callback,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment