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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef CHROME_UPDATER_IPC_UPDATE_SERVICE_PROXY_POSIX_H_
#define CHROME_UPDATER_IPC_UPDATE_SERVICE_PROXY_POSIX_H_
#include <memory>
#include <optional>
#include "base/functional/callback_forward.h"
#include "base/memory/ref_counted.h"
#include "base/memory/weak_ptr.h"
#include "base/sequence_checker.h"
#include "base/types/expected.h"
#include "chrome/updater/mojom/updater_service.mojom.h"
#include "chrome/updater/update_service.h"
#include "chrome/updater/updater_scope.h"
#include "mojo/public/cpp/bindings/remote.h"
namespace base {
class FilePath;
class Version;
} // namespace base
namespace policy {
enum class PolicyFetchReason;
} // namespace policy
namespace mojo {
class IsolatedConnection;
class PlatformChannelEndpoint;
} // namespace mojo
namespace updater {
using RpcError = int;
struct RegistrationRequest;
// UpdateServiceProxyImpl connects to the active updater instance server and
// runs its implementation of UpdateService methods. All functions and
// callbacks must be called on the same sequence.
class UpdateServiceProxyImpl
: public base::RefCountedThreadSafe<UpdateServiceProxyImpl> {
public:
// Create an UpdateServiceProxyImpl which is not bound to a remote. It will
// search for and establish a connection in a background sequence.
UpdateServiceProxyImpl(UpdaterScope scope, base::TimeDelta timeout);
// Create an UpdateServiceProxyImpl bound to the provided Mojo remote. The
// lifetime of the connection to the remote process is handled by
// `connection` and is bound to the lifetime of this instance.
UpdateServiceProxyImpl(UpdaterScope scope,
std::unique_ptr<mojo::IsolatedConnection> connection,
mojo::Remote<mojom::UpdateService> remote);
// Note: Provided OnceCallbacks are wrapped with
// `mojo::WrapCallbackWithDefaultInvokeIfNotRun` to avoid deadlock if
// connection to the remote is broken, and UpdateServiceProxyImpl will not be
// destroyed while these calls are outstanding; the caller need not retain a
// ref.
void GetVersion(
base::OnceCallback<void(base::expected<base::Version, RpcError>)>
callback);
void FetchPolicies(
policy::PolicyFetchReason reason,
base::OnceCallback<void(base::expected<int, RpcError>)> callback);
void RegisterApp(
const RegistrationRequest& request,
base::OnceCallback<void(base::expected<int, RpcError>)> callback);
void GetAppStates(
base::OnceCallback<void(
base::expected<std::vector<UpdateService::AppState>, RpcError>)>);
void RunPeriodicTasks(
base::OnceCallback<void(base::expected<int, RpcError>)> callback);
void CheckForUpdate(
const std::string& app_id,
UpdateService::Priority priority,
UpdateService::PolicySameVersionUpdate policy_same_version_update,
const std::string& language,
base::RepeatingCallback<void(const UpdateService::UpdateState&)>
state_update,
base::OnceCallback<void(base::expected<UpdateService::Result, RpcError>)>
callback);
void Update(
const std::string& app_id,
const std::string& install_data_index,
UpdateService::Priority priority,
UpdateService::PolicySameVersionUpdate policy_same_version_update,
const std::string& language,
base::RepeatingCallback<void(const UpdateService::UpdateState&)>
state_update,
base::OnceCallback<void(base::expected<UpdateService::Result, RpcError>)>
callback);
void UpdateAll(
base::RepeatingCallback<void(const UpdateService::UpdateState&)>
state_update,
base::OnceCallback<void(base::expected<UpdateService::Result, RpcError>)>
callback);
void Install(
const RegistrationRequest& registration,
const std::string& client_install_data,
const std::string& install_data_index,
UpdateService::Priority priority,
const std::string& language,
base::RepeatingCallback<void(const UpdateService::UpdateState&)>
state_update,
base::OnceCallback<void(base::expected<UpdateService::Result, RpcError>)>
callback);
void CancelInstalls(const std::string& app_id);
void RunInstaller(
const std::string& app_id,
const base::FilePath& installer_path,
const std::string& install_args,
const std::string& install_data,
const std::string& install_settings,
const std::string& language,
base::RepeatingCallback<void(const UpdateService::UpdateState&)>
state_update,
base::OnceCallback<void(base::expected<UpdateService::Result, RpcError>)>
callback);
private:
friend class base::RefCountedThreadSafe<UpdateServiceProxyImpl>;
~UpdateServiceProxyImpl();
void OnConnected(mojo::PendingReceiver<mojom::UpdateService> pending_receiver,
std::optional<mojo::PlatformChannelEndpoint> endpoint);
void OnDisconnected();
void EnsureConnecting();
SEQUENCE_CHECKER(sequence_checker_);
const UpdaterScope scope_;
base::TimeDelta get_version_timeout_;
std::unique_ptr<mojo::IsolatedConnection> connection_
GUARDED_BY_CONTEXT(sequence_checker_);
mojo::Remote<mojom::UpdateService> remote_
GUARDED_BY_CONTEXT(sequence_checker_);
base::WeakPtrFactory<UpdateServiceProxyImpl> weak_factory_{this};
};
} // namespace updater
#endif // CHROME_UPDATER_IPC_UPDATE_SERVICE_PROXY_POSIX_H_
|
