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
|
/* Any copyright is dedicated to the Public Domain.
http://creativecommons.org/publicdomain/zero/1.0/
*/
const { TelemetryController } = ChromeUtils.importESModule(
"resource://gre/modules/TelemetryController.sys.mjs"
);
const { TelemetrySession } = ChromeUtils.importESModule(
"resource://gre/modules/TelemetrySession.sys.mjs"
);
function tick(aHowMany) {
for (let i = 0; i < aHowMany; i++) {
Services.obs.notifyObservers(null, "user-interaction-active");
}
}
function checkSessionTicks(aExpected) {
let payload = TelemetrySession.getPayload();
Assert.equal(
payload.simpleMeasurements.activeTicks,
aExpected,
"Should record the expected number of active ticks for the session."
);
}
function checkSubsessionTicks(aExpected, aClearSubsession) {
let payload = TelemetrySession.getPayload("main", aClearSubsession);
Assert.equal(
payload.simpleMeasurements.activeTicks,
aExpected,
"Should record the expected number of active ticks for the subsession."
);
if (aExpected > 0) {
Assert.equal(
payload.processes.parent.scalars["browser.engagement.active_ticks"],
aExpected,
"Should record the expected number of active ticks for the subsession, in a scalar."
);
}
}
add_task(async function test_setup() {
do_get_profile();
// Make sure we don't generate unexpected pings due to pref changes.
await setEmptyPrefWatchlist();
// Ensure FOG's init
Services.fog.initializeFOG();
});
add_task(async function test_record_activeTicks() {
await TelemetryController.testSetup();
let checkActiveTicks = expected => {
// Scalars are only present in subsession payloads.
let payload = TelemetrySession.getPayload("main");
Assert.equal(
payload.simpleMeasurements.activeTicks,
expected,
"TelemetrySession must record the expected number of active ticks (in simpleMeasurements)."
);
// Subsessions are not yet supported on Android.
if (!gIsAndroid) {
Assert.equal(
payload.processes.parent.scalars["browser.engagement.active_ticks"],
expected,
"TelemetrySession must record the expected number of active ticks (in scalars)."
);
}
Assert.equal(Glean.browserEngagement.activeTicks.testGetValue(), expected);
};
for (let i = 0; i < 3; i++) {
Services.obs.notifyObservers(null, "user-interaction-active");
}
checkActiveTicks(3);
// Now send inactive. This must not increment the active ticks.
Services.obs.notifyObservers(null, "user-interaction-inactive");
checkActiveTicks(3);
// If we send active again, this should be counted as inactive.
Services.obs.notifyObservers(null, "user-interaction-active");
checkActiveTicks(3);
// If we send active again, this should be counted as active.
Services.obs.notifyObservers(null, "user-interaction-active");
checkActiveTicks(4);
Services.obs.notifyObservers(null, "user-interaction-active");
checkActiveTicks(5);
await TelemetryController.testShutdown();
});
add_task(
{
skip_if: () => gIsAndroid,
},
async function test_subsession_activeTicks() {
await TelemetryController.testReset();
Telemetry.clearScalars();
tick(5);
checkSessionTicks(5);
checkSubsessionTicks(5, true);
// After clearing the subsession, subsession ticks should be 0 but session
// ticks should still be 5.
checkSubsessionTicks(0);
checkSessionTicks(5);
tick(1);
checkSessionTicks(6);
checkSubsessionTicks(1, true);
checkSubsessionTicks(0);
checkSessionTicks(6);
tick(2);
checkSessionTicks(8);
checkSubsessionTicks(2);
await TelemetryController.testShutdown();
}
);
|
