1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
|
// Copyright 2024 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef COMPONENTS_PLUS_ADDRESSES_WEBDATA_PLUS_ADDRESS_WEBDATA_SERVICE_H_
#define COMPONENTS_PLUS_ADDRESSES_WEBDATA_PLUS_ADDRESS_WEBDATA_SERVICE_H_
#include <memory>
#include "base/memory/ref_counted_delete_on_sequence.h"
#include "base/memory/scoped_refptr.h"
#include "base/memory/weak_ptr.h"
#include "base/observer_list.h"
#include "base/observer_list_types.h"
#include "base/task/sequenced_task_runner.h"
#include "components/plus_addresses/plus_address_types.h"
#include "components/webdata/common/web_data_service_base.h"
#include "components/webdata/common/web_data_service_consumer.h"
class WebDatabaseService;
namespace syncer {
class DataTypeControllerDelegate;
}
namespace plus_addresses {
class PlusAddressSyncBridge;
class PlusAddressDataChange;
// `PlusAddressWebDataService` acts as the bridge between code on the UI
// sequence (`PlusAddressService`) and code on the DB sequence (
// `PlusAddressTable` and `PlusAddressSyncBridge`). It should only be called
// from the UI sequence.
//
// It mirrors a subset of `PlusAddressTable`'s API and is responsible for
// posting tasks from the UI sequence to the DB sequence, invoking the relevant
// function on `PlusAddressTable`.
//
// Owned by `WebDataServiceWrapper`.
class PlusAddressWebDataService : public WebDataServiceBase {
public:
class Observer : public base::CheckedObserver {
public:
// Called whenever `PlusAddressTable` was modified directly on the DB
// sequence by `PlusAddressSyncBridge`. `change` represents an addition or
// removal operation triggered on the `PlusAddressTable`. Notably, update
// operations are emulated as a remove operation of the old value followed
// by an addition of the updated value.
virtual void OnWebDataChangedBySync(
const std::vector<PlusAddressDataChange>& changes) = 0;
};
PlusAddressWebDataService(
scoped_refptr<WebDatabaseService> wdbs,
scoped_refptr<base::SequencedTaskRunner> ui_task_runner);
void AddObserver(Observer* o) { observers_.AddObserver(o); }
void RemoveObserver(Observer* o) { observers_.RemoveObserver(o); }
// `PlusAddressTable`'s API, for the subset of functions needed on the UI
// sequence.
void GetPlusProfiles(WebDataServiceRequestCallback consumer);
void AddOrUpdatePlusProfile(const PlusProfile& profile);
// Returns a controller delegate for the `sync_bridge` owned this service.
std::unique_ptr<syncer::DataTypeControllerDelegate>
GetSyncControllerDelegate();
protected:
~PlusAddressWebDataService() override;
private:
// `PlusAddressWebDataService` owns the `PlusAddressSyncBridge`. However, the
// bridge itself lives on the `db_task_runner_`. `SyncBridgeDBSequenceWrapper`
// is a wrapper around the bridge, to ensure destruction happens on
// `db_task_runner_`.
struct SyncBridgeDBSequenceWrapper
: public base::RefCountedDeleteOnSequence<SyncBridgeDBSequenceWrapper> {
explicit SyncBridgeDBSequenceWrapper(
scoped_refptr<base::SequencedTaskRunner> db_task_runner);
// Should only be accessed through the `db_task_runner_`.
std::unique_ptr<PlusAddressSyncBridge> sync_bridge;
private:
friend class base::RefCountedDeleteOnSequence<SyncBridgeDBSequenceWrapper>;
friend class base::DeleteHelper<SyncBridgeDBSequenceWrapper>;
~SyncBridgeDBSequenceWrapper();
};
// Notifies all `observers_` about `OnWebDataChangedBySync()`.
void NotifyOnWebDataChangedBySync(std::vector<PlusAddressDataChange> changes);
scoped_refptr<base::SequencedTaskRunner> ui_task_runner_;
// `scoped_refptr<>`, because the destruction order of
// `PlusAddressWebDataService` and `db_task_runner_` is unclear.
// `PlusAddressWebDataService` is the primary owner.
scoped_refptr<SyncBridgeDBSequenceWrapper> sync_bridge_wrapper_;
base::ObserverList<Observer> observers_;
base::WeakPtrFactory<PlusAddressWebDataService> weak_factory_{this};
};
} // namespace plus_addresses
#endif // COMPONENTS_PLUS_ADDRESSES_WEBDATA_PLUS_ADDRESS_WEBDATA_SERVICE_H_
|
