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
|
/* Any copyright is dedicated to the Public Domain.
http://creativecommons.org/publicdomain/zero/1.0/ */
"use strict";
/**
* Check that the resource command is still properly watching for new targets
* after unwatching one resource, if there is still another watched resource.
*/
add_task(async function () {
// We will create a main process target list here in order to monitor
// resources from new tabs as they get created.
await pushPref("devtools.browsertoolbox.scope", "everything");
// Open a test tab
const tab = await addTab("data:text/html,Root Node tests");
const { client, resourceCommand, targetCommand } =
await initMultiProcessResourceCommand();
const { CONSOLE_MESSAGE, ROOT_NODE } = resourceCommand.TYPES;
// We are only interested in console messages as a resource, the ROOT_NODE one
// is here to test the ResourceCommand::unwatchResources API with several resources.
const receivedMessages = [];
const onAvailable = resources => {
for (const resource of resources) {
if (resource.resourceType === CONSOLE_MESSAGE) {
receivedMessages.push(resource);
}
}
};
info("Call watchResources([CONSOLE_MESSAGE, ROOT_NODE], ...)");
await resourceCommand.watchResources([CONSOLE_MESSAGE, ROOT_NODE], {
onAvailable,
});
info("Use console.log in the content page");
logInTab(tab, "test from data-url");
info(
"Wait until onAvailable received the CONSOLE_MESSAGE resource emitted from the data-url tab"
);
await waitUntil(() =>
receivedMessages.find(
resource => resource.message.arguments[0] === "test from data-url"
)
);
// Check that the resource command captures resources from new targets.
info("Open a first tab on the example.com domain");
const comTab = await addTab(
"https://example.com/document-builder.sjs?html=com"
);
info("Use console.log in the example.com page");
logInTab(comTab, "test-from-example-com");
info(
"Wait until onAvailable received the CONSOLE_MESSAGE resource emitted from the example.com tab"
);
await waitUntil(() =>
receivedMessages.find(
resource => resource.message.arguments[0] === "test-from-example-com"
)
);
info("Stop watching ROOT_NODE resources");
await resourceCommand.unwatchResources([ROOT_NODE], { onAvailable });
// Check that messages from new targets are still captured after calling
// unwatch for another resource.
info("Open a second tab on the example.org domain");
const orgTab = await addTab(
"https://example.org/document-builder.sjs?html=org"
);
info("Use console.log in the example.org page");
logInTab(orgTab, "test-from-example-org");
info(
"Wait until onAvailable received the CONSOLE_MESSAGE resource emitted from the example.org tab"
);
await waitUntil(() =>
receivedMessages.find(
resource => resource.message.arguments[0] === "test-from-example-org"
)
);
info("Stop watching CONSOLE_MESSAGE resources");
await resourceCommand.unwatchResources([CONSOLE_MESSAGE], { onAvailable });
await logInTab(tab, "test-again");
// We don't have a specific event to wait for here, so allow some time for
// the message to be received.
await wait(1000);
is(
receivedMessages.find(
resource => resource.message.arguments[0] === "test-again"
),
undefined,
"The resource command should not watch CONSOLE_MESSAGE anymore"
);
// Cleanup
targetCommand.destroy();
await client.close();
});
function logInTab(tab, message) {
return ContentTask.spawn(tab.linkedBrowser, message, function (_message) {
content.console.log(_message);
});
}
|
