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
|
import {PressureManager, PressureManagerReceiver, PressureStatus} from '/gen/services/device/public/mojom/pressure_manager.mojom.m.js'
import {PressureSource, PressureState} from '/gen/services/device/public/mojom/pressure_update.mojom.m.js'
class MockPressureService {
constructor() {
this.receiver_ = new PressureManagerReceiver(this);
this.interceptor_ =
new MojoInterfaceInterceptor(PressureManager.$interfaceName);
this.interceptor_.oninterfacerequest = e => {
this.receiver_.$.bindHandle(e.handle);
};
this.reset();
this.mojomSourceType_ = new Map([['cpu', PressureSource.kCpu]]);
this.mojomStateType_ = new Map([
['nominal', PressureState.kNominal], ['fair', PressureState.kFair],
['serious', PressureState.kSerious], ['critical', PressureState.kCritical]
]);
this.pressureServiceReadingTimerId_ = null;
}
start() {
this.interceptor_.start();
}
stop() {
this.stopPlatformCollector();
this.receiver_.$.close();
this.interceptor_.stop();
// Wait for an event loop iteration to let any pending mojo commands in
// the pressure service finish.
return new Promise(resolve => setTimeout(resolve, 0));
}
reset() {
this.observers_ = [];
this.pressureUpdate_ = null;
this.pressureServiceReadingTimerId_ = null;
this.pressureStatus_ = PressureStatus.kOk;
this.updatesDelivered_ = 0;
}
async addClient(observer, source) {
if (this.observers_.indexOf(observer) >= 0)
throw new Error('addClient() has already been called');
// TODO(crbug.com/1342184): Consider other sources.
// For now, "cpu" is the only source.
if (source !== PressureSource.kCpu)
throw new Error('Call addClient() with a wrong PressureSource');
observer.onConnectionError.addListener(() => {
// Remove this observer from observer array.
this.observers_.splice(this.observers_.indexOf(observer), 1);
});
this.observers_.push(observer);
return {status: this.pressureStatus_};
}
startPlatformCollector(sampleInterval) {
if (sampleInterval === 0)
return;
if (this.pressureServiceReadingTimerId_ != null)
this.stopPlatformCollector();
this.pressureServiceReadingTimerId_ = self.setInterval(() => {
if (this.pressureUpdate_ === null || this.observers_.length === 0)
return;
// Because we cannot retrieve directly the timeOrigin internal in
// TimeTicks from Chromium, we need to create a timestamp that
// would help to test basic functionality.
// by multiplying performance.timeOrigin by 10 we make sure that the
// origin is higher than the internal time origin in TimeTicks.
// performance.now() allows us to have an increase matching the TimeTicks
// that would be read from the platform collector.
this.pressureUpdate_.timestamp = {
internalValue:
Math.round((performance.timeOrigin * 10) + performance.now()) * 1000
};
for (let observer of this.observers_)
observer.onPressureUpdated(this.pressureUpdate_);
this.updatesDelivered_++;
}, sampleInterval);
}
stopPlatformCollector() {
if (this.pressureServiceReadingTimerId_ != null) {
self.clearInterval(this.pressureServiceReadingTimerId_);
this.pressureServiceReadingTimerId_ = null;
}
this.updatesDelivered_ = 0;
}
updatesDelivered() {
return this.updatesDelivered_;
}
setPressureUpdate(source, state) {
if (!this.mojomSourceType_.has(source))
throw new Error(`PressureSource '${source}' is invalid`);
if (!this.mojomStateType_.has(state))
throw new Error(`PressureState '${state}' is invalid`);
this.pressureUpdate_ = {
source: this.mojomSourceType_.get(source),
state: this.mojomStateType_.get(state),
};
}
setExpectedFailure(expectedException) {
assert_true(
expectedException instanceof DOMException,
'setExpectedFailure() expects a DOMException instance');
if (expectedException.name === 'NotSupportedError') {
this.pressureStatus_ = PressureStatus.kNotSupported;
} else {
throw new TypeError(
`Unexpected DOMException '${expectedException.name}'`);
}
}
}
export const mockPressureService = new MockPressureService();
|
