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
|
// Copyright 2023 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_BROWSER_CHROMEOS_EXTENSIONS_TELEMETRY_API_EVENTS_FAKE_EVENTS_SERVICE_H_
#define CHROME_BROWSER_CHROMEOS_EXTENSIONS_TELEMETRY_API_EVENTS_FAKE_EVENTS_SERVICE_H_
#include "base/functional/callback_forward.h"
#include "chromeos/crosapi/mojom/telemetry_event_service.mojom.h"
#include "chromeos/crosapi/mojom/telemetry_extension_exception.mojom.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver.h"
#include "mojo/public/cpp/bindings/remote_set.h"
namespace chromeos {
class FakeEventsService : public crosapi::mojom::TelemetryEventService {
public:
FakeEventsService();
FakeEventsService(const FakeEventsService&) = delete;
FakeEventsService& operator=(const FakeEventsService&) = delete;
~FakeEventsService() override;
void BindPendingReceiver(
mojo::PendingReceiver<crosapi::mojom::TelemetryEventService> receiver);
mojo::PendingRemote<crosapi::mojom::TelemetryEventService>
BindNewPipeAndPassRemote();
// TelemetryEventService:
void AddEventObserver(
crosapi::mojom::TelemetryEventCategoryEnum category,
mojo::PendingRemote<crosapi::mojom::TelemetryEventObserver> observer)
override;
void IsEventSupported(crosapi::mojom::TelemetryEventCategoryEnum category,
IsEventSupportedCallback callback) override;
// Sets the response for a call to `IsEventSupported`.
void SetIsEventSupportedResponse(
crosapi::mojom::TelemetryExtensionSupportStatusPtr status);
// Emits an `info` for all observers subscribed to `category`.
void EmitEventForCategory(crosapi::mojom::TelemetryEventCategoryEnum category,
crosapi::mojom::TelemetryEventInfoPtr info);
// Returns the remotes that are observing a certain category, returns nullptr
// if no remote is observing a certain category.
mojo::RemoteSet<crosapi::mojom::TelemetryEventObserver>*
GetObserversByCategory(crosapi::mojom::TelemetryEventCategoryEnum category);
// Sets a callback that is invoked in two cases:
// - A new subscription is added (`AddEventObserver` was called).
// - A subscription is removed (the mojo connection was cut).
// This is useful since in tests we usually want to perform a certain action
// as soon as an observation is registered or removed.
void SetOnSubscriptionChange(base::RepeatingClosure callback);
private:
mojo::Receiver<crosapi::mojom::TelemetryEventService> receiver_{this};
// Collection of registered general observers grouped by category.
std::map<crosapi::mojom::TelemetryEventCategoryEnum,
mojo::RemoteSet<crosapi::mojom::TelemetryEventObserver>>
event_observers_;
// Called when a new subscription is opened or an existing one is closed.
base::RepeatingClosure on_subscription_change_;
// Used as the response to any IsEventSupported IPCs received.
crosapi::mojom::TelemetryExtensionSupportStatusPtr
is_event_supported_response_{
crosapi::mojom::TelemetryExtensionSupportStatus::
NewUnmappedUnionField(0)};
};
} // namespace chromeos
#endif // CHROME_BROWSER_CHROMEOS_EXTENSIONS_TELEMETRY_API_EVENTS_FAKE_EVENTS_SERVICE_H_
|
