Source code
Revision control
Copy as Markdown
Other Tools
Test Info:
/* Any copyright is dedicated to the Public Domain.
"use strict";
// Test the TargetCommand API getAllTargets.
const FISSION_TEST_URL = URL_ROOT_SSL + "fission_document.html";
const CHROME_WORKER_URL = CHROME_URL_ROOT + "test_worker.js";
add_task(async function () {
// Disable the preloaded process as it creates processes intermittently
// which forces the emission of RDP requests we aren't correctly waiting for.
await pushPref("dom.ipc.processPrelaunch.enabled", false);
info("Setup the test page with workers of all types");
const tab = await addTab(FISSION_TEST_URL);
// Instantiate a worker in the parent process
// eslint-disable-next-line no-unused-vars
const worker = new Worker(CHROME_WORKER_URL + "#simple-worker");
// eslint-disable-next-line no-unused-vars
const sharedWorker = new SharedWorker(CHROME_WORKER_URL + "#shared-worker");
info("Create a target list for the main process target");
const commands = await CommandsFactory.forMainProcess();
const targetCommand = commands.targetCommand;
const { TYPES } = targetCommand;
await targetCommand.startListening();
info("Check getAllTargets will throw when providing invalid arguments");
Assert.throws(
() => targetCommand.getAllTargets(),
e => e.message === "getAllTargets expects a non-empty array of types"
);
Assert.throws(
() => targetCommand.getAllTargets([]),
e => e.message === "getAllTargets expects a non-empty array of types"
);
info("Check getAllTargets returns consistent results with several types");
const workerTargets = targetCommand.getAllTargets([TYPES.WORKER]);
const serviceWorkerTargets = targetCommand.getAllTargets([
TYPES.SERVICE_WORKER,
]);
const sharedWorkerTargets = targetCommand.getAllTargets([
TYPES.SHARED_WORKER,
]);
const processTargets = targetCommand.getAllTargets([TYPES.PROCESS]);
const frameTargets = targetCommand.getAllTargets([TYPES.FRAME]);
const allWorkerTargetsReference = [
...workerTargets,
...serviceWorkerTargets,
...sharedWorkerTargets,
];
const allWorkerTargets = targetCommand.getAllTargets([
TYPES.WORKER,
TYPES.SERVICE_WORKER,
TYPES.SHARED_WORKER,
]);
is(
allWorkerTargets.length,
allWorkerTargetsReference.length,
"getAllTargets([worker, service, shared]) returned the expected number of targets"
);
ok(
allWorkerTargets.every(t => allWorkerTargetsReference.includes(t)),
"getAllTargets([worker, service, shared]) returned the expected targets"
);
const allTargetsReference = [
...allWorkerTargets,
...processTargets,
...frameTargets,
];
const allTargets = targetCommand.getAllTargets(targetCommand.ALL_TYPES);
is(
allTargets.length,
allTargetsReference.length,
"getAllTargets(ALL_TYPES) returned the expected number of targets"
);
ok(
allTargets.every(t => allTargetsReference.includes(t)),
"getAllTargets(ALL_TYPES) returned the expected targets"
);
for (const target of allTargets) {
is(
target.commands,
commands,
"Each target front has a `commands` attribute - " + target
);
}
// Wait for all the targets to be fully attached so we don't have pending requests.
await waitForAllTargetsToBeAttached(targetCommand);
ok(
!targetCommand.isDestroyed(),
"TargetCommand isn't destroyed before calling commands.destroy()"
);
await commands.destroy();
ok(
targetCommand.isDestroyed(),
"TargetCommand is destroyed after calling commands.destroy()"
);
await SpecialPowers.spawn(tab.linkedBrowser, [], async () => {
// registrationPromise is set by the test page.
const registration = await content.wrappedJSObject.registrationPromise;
registration.unregister();
});
});