Source code
Revision control
Copy as Markdown
Other Tools
/* 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
import { ContextDescriptorType } from "chrome://remote/content/shared/messagehandler/MessageHandler.sys.mjs";
import { Module } from "chrome://remote/content/shared/messagehandler/Module.sys.mjs";
class RootOnlyModule extends Module {
#sessionDataReceived;
#subscribedEvents;
constructor(messageHandler) {
super(messageHandler);
this.#sessionDataReceived = [];
this.#subscribedEvents = new Set();
}
destroy() {}
/**
* Commands
*/
getSessionDataReceived() {
return this.#sessionDataReceived;
}
testCommand(params = {}) {
return params;
}
_applySessionData(params) {
const added = [];
const removed = [];
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.#subscribedEvents.delete(event);
removed.push(event);
}
}
// Subscribe to all events, which have an item in SessionData
for (const { value } of filteredSessionData) {
if (!this.#subscribedEvents.has(value)) {
this.#subscribedEvents.add(value);
added.push(value);
}
}
this.#sessionDataReceived.push({
category: params.category,
added,
removed,
contextDescriptor: {
type: ContextDescriptorType.All,
},
});
}
}
export const rootOnly = RootOnlyModule;