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
|
// Copyright 2020 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "components/reporting/storage/storage_module.h"
#include <memory>
#include <utility>
#include "base/containers/span.h"
#include "base/functional/bind.h"
#include "base/functional/callback.h"
#include "base/logging.h"
#include "base/memory/ptr_util.h"
#include "base/types/expected.h"
#include "components/reporting/compression/compression_module.h"
#include "components/reporting/encryption/encryption_module_interface.h"
#include "components/reporting/proto/synced/record.pb.h"
#include "components/reporting/proto/synced/record_constants.pb.h"
#include "components/reporting/storage/storage.h"
#include "components/reporting/storage/storage_configuration.h"
#include "components/reporting/storage/storage_module_interface.h"
#include "components/reporting/storage/storage_uploader_interface.h"
#include "components/reporting/util/status.h"
#include "components/reporting/util/statusor.h"
namespace reporting {
StorageModule::StorageModule() = default;
StorageModule::~StorageModule() = default;
void StorageModule::AddRecord(Priority priority,
Record record,
EnqueueCallback callback) {
storage_->Write(priority, std::move(record), std::move(callback));
}
void StorageModule::Flush(Priority priority, FlushCallback callback) {
storage_->Flush(priority, std::move(callback));
}
void StorageModule::ReportSuccess(SequenceInformation sequence_information,
bool force) {
storage_->Confirm(std::move(sequence_information), force,
base::BindOnce([](Status status) {
LOG_IF(ERROR, !status.ok())
<< "Unable to confirm record deletion: " << status;
}));
}
void StorageModule::UpdateEncryptionKey(
SignedEncryptionInfo signed_encryption_key) {
storage_->UpdateEncryptionKey(std::move(signed_encryption_key));
}
// static
void StorageModule::Create(
const StorageOptions& options,
UploaderInterface::AsyncStartUploaderCb async_start_upload_cb,
scoped_refptr<EncryptionModuleInterface> encryption_module,
scoped_refptr<CompressionModule> compression_module,
base::OnceCallback<void(StatusOr<scoped_refptr<StorageModule>>)> callback) {
scoped_refptr<StorageModule> instance =
// Cannot base::MakeRefCounted, since constructor is protected.
base::WrapRefCounted(new StorageModule());
Storage::Create(
options, async_start_upload_cb, encryption_module, compression_module,
base::BindOnce(
[](scoped_refptr<StorageModule> instance,
base::OnceCallback<void(StatusOr<scoped_refptr<StorageModule>>)>
callback,
StatusOr<scoped_refptr<Storage>> storage) {
if (!storage.has_value()) {
std::move(callback).Run(
base::unexpected(std::move(storage).error()));
return;
}
instance->storage_ = std::move(storage.value());
std::move(callback).Run(std::move(instance));
},
std::move(instance), std::move(callback)));
}
} // namespace reporting
|
