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
|
/* Any copyright is dedicated to the Public Domain.
http://creativecommons.org/publicdomain/zero/1.0/ */
"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();
});
});
|
