WebApp: Introduce WebAppDatabase.
For now we try to reuse as much USS code as possible.
It has limitations and drawbacks (see the code).
We will rethink our persistence code later when we start to design
WebAppSyncBridge
(an implementation for syncer::ModelTypeSyncBridge interface).
Bug: 896150
Change-Id: Ia898b905f39869a6b1c3f79751358425449a617a
Reviewed-on: https://chromium-review.googlesource.com/c/1295529
Reviewed-by: calamity <[email protected]>
Reviewed-by: Mikel Astiz <[email protected]>
Reviewed-by: Ben Wells <[email protected]>
Commit-Queue: Alexey Baskakov <[email protected]>
Cr-Commit-Position: refs/heads/master@{#605974}diff --git a/chrome/browser/web_applications/web_app_database.h b/chrome/browser/web_applications/web_app_database.h
new file mode 100644
index 0000000..8ef472b
--- /dev/null
+++ b/chrome/browser/web_applications/web_app_database.h
@@ -0,0 +1,83 @@
+// Copyright 2018 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.
+
+#ifndef CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_
+#define CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_
+
+#include <memory>
+
+#include "base/callback_forward.h"
+#include "base/macros.h"
+#include "base/memory/weak_ptr.h"
+#include "base/optional.h"
+#include "base/sequence_checker.h"
+#include "chrome/browser/web_applications/abstract_web_app_database.h"
+#include "chrome/browser/web_applications/components/web_app_helpers.h"
+#include "components/sync/model/model_type_store.h"
+
+namespace syncer {
+class ModelError;
+} // namespace syncer
+
+namespace web_app {
+
+class AbstractWebAppDatabaseFactory;
+class WebApp;
+class WebAppProto;
+
+// Exclusively used from the UI thread.
+class WebAppDatabase : public AbstractWebAppDatabase {
+ public:
+ explicit WebAppDatabase(AbstractWebAppDatabaseFactory* database_factory);
+ ~WebAppDatabase() override;
+
+ // AbstractWebAppDatabase:
+ void OpenDatabase(OnceRegistryOpenedCallback callback) override;
+ void WriteWebApp(const WebApp& web_app) override;
+ void DeleteWebApps(std::vector<AppId> app_ids) override;
+
+ // Exposed for testing.
+ static std::unique_ptr<WebAppProto> CreateWebAppProto(const WebApp& web_app);
+ // Exposed for testing.
+ static std::unique_ptr<WebApp> CreateWebApp(const WebAppProto& proto);
+ // Exposed for testing.
+ void ReadRegistry(OnceRegistryOpenedCallback callback);
+
+ private:
+ void CreateStore(syncer::OnceModelTypeStoreFactory store_factory,
+ base::OnceClosure closure);
+ void OnStoreCreated(base::OnceClosure closure,
+ const base::Optional<syncer::ModelError>& error,
+ std::unique_ptr<syncer::ModelTypeStore> store);
+
+ void OnAllDataRead(
+ OnceRegistryOpenedCallback callback,
+ const base::Optional<syncer::ModelError>& error,
+ std::unique_ptr<syncer::ModelTypeStore::RecordList> data_records);
+
+ void OnDataWritten(const base::Optional<syncer::ModelError>& error);
+
+ static std::unique_ptr<WebApp> ParseWebApp(const AppId& app_id,
+ const std::string& value);
+
+ void BeginTransaction();
+ void CommitTransaction();
+
+ std::unique_ptr<syncer::ModelTypeStore> store_;
+ std::unique_ptr<syncer::ModelTypeStore::WriteBatch> write_batch_;
+ AbstractWebAppDatabaseFactory* database_factory_;
+
+ // Database is opened if store is created and all data read.
+ bool opened_ = false;
+
+ SEQUENCE_CHECKER(sequence_checker_);
+
+ base::WeakPtrFactory<WebAppDatabase> weak_ptr_factory_{this};
+
+ DISALLOW_COPY_AND_ASSIGN(WebAppDatabase);
+};
+
+} // namespace web_app
+
+#endif // CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_
