blob: c86954c5e0eafa2d13d63054d8b82118c7e4a130 (
plain)
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
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
import { Module } from "chrome://remote/content/shared/messagehandler/Module.sys.mjs";
class EventEmitterModule extends Module {
#isSubscribed;
#subscribedEvents;
constructor(messageHandler) {
super(messageHandler);
this.#isSubscribed = false;
this.#subscribedEvents = new Set();
}
destroy() {}
/**
* Commands
*/
emitTestEvent() {
if (this.#isSubscribed) {
const text = `event from ${this.messageHandler.contextId}`;
this.emitEvent("eventemitter.testEvent", { text });
}
// Emit another event consistently for monitoring during the test.
this.emitEvent("eventemitter.monitoringEvent", {});
}
isSubscribed() {
return this.#isSubscribed;
}
_applySessionData(params) {
const { category } = params;
if (category === "event") {
const filteredSessionData = params.sessionData.filter(item =>
this.messageHandler.matchesContext(item.contextDescriptor)
);
for (const event of this.#subscribedEvents.values()) {
const hasSessionItem = filteredSessionData.some(
item => item.value === event
);
// If there are no session items for this context, we should unsubscribe from the event.
if (!hasSessionItem) {
this.#unsubscribeEvent(event);
}
}
// Subscribe to all events, which have an item in SessionData
for (const { value } of filteredSessionData) {
this.#subscribeEvent(value);
}
}
}
#subscribeEvent(event) {
if (event === "eventemitter.testEvent") {
if (this.#isSubscribed) {
throw new Error("Already subscribed to eventemitter.testEvent");
}
this.#isSubscribed = true;
this.#subscribedEvents.add(event);
}
}
#unsubscribeEvent(event) {
if (event === "eventemitter.testEvent") {
if (!this.#isSubscribed) {
throw new Error("Not subscribed to eventemitter.testEvent");
}
this.#isSubscribed = false;
this.#subscribedEvents.delete(event);
}
}
}
export const eventemitter = EventEmitterModule;
|
