Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 1 | // Copyright 2018 The Chromium Authors. All rights reserved. |
| 2 | // Use of this source code is governed by a BSD-style license that can be |
| 3 | // found in the LICENSE file. |
| 4 | |
| 5 | #ifndef CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_ |
| 6 | #define CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_ |
| 7 | |
| 8 | #include <memory> |
| 9 | |
| 10 | #include "base/callback_forward.h" |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 11 | #include "base/memory/weak_ptr.h" |
| 12 | #include "base/optional.h" |
| 13 | #include "base/sequence_checker.h" |
Eric Willigers | d32986ad | 2019-11-04 00:40:04 | [diff] [blame] | 14 | #include "chrome/browser/web_applications/components/web_app_constants.h" |
Glen Robertson | 271d133 | 2020-01-28 00:16:02 | [diff] [blame] | 15 | #include "chrome/browser/web_applications/components/web_app_id.h" |
Eric Willigers | 14c5e57 | 2019-10-29 11:39:49 | [diff] [blame] | 16 | #include "chrome/browser/web_applications/proto/web_app.pb.h" |
Alexey Baskakov | 27f14d4 | 2019-09-20 07:09:48 | [diff] [blame] | 17 | #include "chrome/browser/web_applications/web_app_registrar.h" |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 18 | #include "components/sync/model/model_type_store.h" |
Eric Willigers | 1854428 | 2019-10-09 05:59:58 | [diff] [blame] | 19 | #include "components/sync/protocol/web_app_specifics.pb.h" |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 20 | |
| 21 | namespace syncer { |
| 22 | class ModelError; |
Alexey Baskakov | 0b50ec6 | 2019-10-01 03:29:23 | [diff] [blame] | 23 | class MetadataBatch; |
Alexey Baskakov | f8fb8c6 | 2019-10-10 04:55:49 | [diff] [blame] | 24 | class MetadataChangeList; |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 25 | } // namespace syncer |
| 26 | |
| 27 | namespace web_app { |
| 28 | |
| 29 | class AbstractWebAppDatabaseFactory; |
| 30 | class WebApp; |
| 31 | class WebAppProto; |
Alexey Baskakov | 6856e5e4 | 2019-09-26 04:31:26 | [diff] [blame] | 32 | struct RegistryUpdateData; |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 33 | |
| 34 | // Exclusively used from the UI thread. |
Alexey Baskakov | 4702d663 | 2019-09-17 06:58:51 | [diff] [blame] | 35 | class WebAppDatabase { |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 36 | public: |
Alexey Baskakov | 0b50ec6 | 2019-10-01 03:29:23 | [diff] [blame] | 37 | using ReportErrorCallback = |
| 38 | base::RepeatingCallback<void(const syncer::ModelError&)>; |
| 39 | |
| 40 | WebAppDatabase(AbstractWebAppDatabaseFactory* database_factory, |
| 41 | ReportErrorCallback error_callback); |
Haben Foto | e3d073b | 2020-10-06 01:22:58 | [diff] [blame^] | 42 | WebAppDatabase(const WebAppDatabase&) = delete; |
| 43 | WebAppDatabase& operator=(const WebAppDatabase&) = delete; |
Alexey Baskakov | 4702d663 | 2019-09-17 06:58:51 | [diff] [blame] | 44 | ~WebAppDatabase(); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 45 | |
Alexey Baskakov | 0b50ec6 | 2019-10-01 03:29:23 | [diff] [blame] | 46 | using RegistryOpenedCallback = base::OnceCallback<void( |
| 47 | Registry registry, |
| 48 | std::unique_ptr<syncer::MetadataBatch> metadata_batch)>; |
Alexey Baskakov | 27f14d4 | 2019-09-20 07:09:48 | [diff] [blame] | 49 | // Open existing or create new DB. Read all data and return it via callback. |
Alexey Baskakov | 4702d663 | 2019-09-17 06:58:51 | [diff] [blame] | 50 | void OpenDatabase(RegistryOpenedCallback callback); |
Alexey Baskakov | 6856e5e4 | 2019-09-26 04:31:26 | [diff] [blame] | 51 | |
| 52 | using CompletionCallback = base::OnceCallback<void(bool success)>; |
Alexey Baskakov | d6e9382 | 2019-10-11 02:39:44 | [diff] [blame] | 53 | void Write(const RegistryUpdateData& update_data, |
| 54 | std::unique_ptr<syncer::MetadataChangeList> metadata_change_list, |
| 55 | CompletionCallback callback); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 56 | |
| 57 | // Exposed for testing. |
| 58 | static std::unique_ptr<WebAppProto> CreateWebAppProto(const WebApp& web_app); |
| 59 | // Exposed for testing. |
Alexey Baskakov | 27f14d4 | 2019-09-20 07:09:48 | [diff] [blame] | 60 | static std::unique_ptr<WebApp> ParseWebApp(const AppId& app_id, |
| 61 | const std::string& value); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 62 | |
Alexey Baskakov | 583f6edf | 2020-05-21 03:56:11 | [diff] [blame] | 63 | bool is_opened() const { return opened_; } |
| 64 | |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 65 | private: |
Alexey Baskakov | 8c864f18 | 2019-10-04 03:39:56 | [diff] [blame] | 66 | static std::unique_ptr<WebApp> CreateWebApp(const WebAppProto& local_data); |
Alexey Baskakov | eecc87f1 | 2019-09-24 08:03:01 | [diff] [blame] | 67 | |
| 68 | void OnDatabaseOpened(RegistryOpenedCallback callback, |
| 69 | const base::Optional<syncer::ModelError>& error, |
| 70 | std::unique_ptr<syncer::ModelTypeStore> store); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 71 | |
| 72 | void OnAllDataRead( |
Alexey Baskakov | 4702d663 | 2019-09-17 06:58:51 | [diff] [blame] | 73 | RegistryOpenedCallback callback, |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 74 | const base::Optional<syncer::ModelError>& error, |
| 75 | std::unique_ptr<syncer::ModelTypeStore::RecordList> data_records); |
Alexey Baskakov | 0b50ec6 | 2019-10-01 03:29:23 | [diff] [blame] | 76 | void OnAllMetadataRead( |
| 77 | std::unique_ptr<syncer::ModelTypeStore::RecordList> data_records, |
| 78 | RegistryOpenedCallback callback, |
| 79 | const base::Optional<syncer::ModelError>& error, |
| 80 | std::unique_ptr<syncer::MetadataBatch> metadata_batch); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 81 | |
Alexey Baskakov | 00fb85eae | 2019-09-03 07:29:12 | [diff] [blame] | 82 | void OnDataWritten(CompletionCallback callback, |
| 83 | const base::Optional<syncer::ModelError>& error); |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 84 | |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 85 | std::unique_ptr<syncer::ModelTypeStore> store_; |
Eric Willigers | 5a71d19 | 2019-10-08 02:36:40 | [diff] [blame] | 86 | AbstractWebAppDatabaseFactory* const database_factory_; |
Alexey Baskakov | 0b50ec6 | 2019-10-01 03:29:23 | [diff] [blame] | 87 | ReportErrorCallback error_callback_; |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 88 | |
| 89 | // Database is opened if store is created and all data read. |
| 90 | bool opened_ = false; |
| 91 | |
| 92 | SEQUENCE_CHECKER(sequence_checker_); |
| 93 | |
| 94 | base::WeakPtrFactory<WebAppDatabase> weak_ptr_factory_{this}; |
| 95 | |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 96 | }; |
| 97 | |
Eric Willigers | d32986ad | 2019-11-04 00:40:04 | [diff] [blame] | 98 | DisplayMode ToMojomDisplayMode(WebAppProto::DisplayMode display_mode); |
Eric Willigers | 1854428 | 2019-10-09 05:59:58 | [diff] [blame] | 99 | |
Eric Willigers | d32986ad | 2019-11-04 00:40:04 | [diff] [blame] | 100 | DisplayMode ToMojomDisplayMode( |
Eric Willigers | 14c5e57 | 2019-10-29 11:39:49 | [diff] [blame] | 101 | ::sync_pb::WebAppSpecifics::UserDisplayMode user_display_mode); |
| 102 | |
Eric Willigers | d32986ad | 2019-11-04 00:40:04 | [diff] [blame] | 103 | WebAppProto::DisplayMode ToWebAppProtoDisplayMode(DisplayMode display_mode); |
Eric Willigers | 1854428 | 2019-10-09 05:59:58 | [diff] [blame] | 104 | |
Alexey Baskakov | ac8c4b0 | 2018-11-07 06:10:02 | [diff] [blame] | 105 | } // namespace web_app |
| 106 | |
| 107 | #endif // CHROME_BROWSER_WEB_APPLICATIONS_WEB_APP_DATABASE_H_ |