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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
"use strict";
const pushNotifier = Cc["@mozilla.org/push/Notifier;1"].getService(
Ci.nsIPushNotifier
);
add_task(async function test_observer_remoting() {
do_get_profile();
if (isParent) {
await testInParent();
} else {
await testInChild();
}
});
const childTests = [
{
text: "Hello from child!",
principal: Services.scriptSecurityManager.getSystemPrincipal(),
},
];
const parentTests = [
{
text: "Hello from parent!",
principal: Services.scriptSecurityManager.getSystemPrincipal(),
},
];
async function testInParent() {
setPrefs();
// Register observers for notifications from the child, then run the test in
// the child and wait for the notifications.
let promiseNotifications = childTests.reduce(
(p, test) =>
p.then(_ => waitForNotifierObservers(test, /* shouldNotify = */ false)),
Promise.resolve()
);
let promiseFinished = run_test_in_child("./test_observer_remoting.js");
await promiseNotifications;
// Wait until the child is listening for notifications from the parent.
await do_await_remote_message("push_test_observer_remoting_child_ready");
// Fire an observer notification in the parent that should be forwarded to
// the child.
await parentTests.reduce(
(p, test) =>
p.then(_ => waitForNotifierObservers(test, /* shouldNotify = */ true)),
Promise.resolve()
);
// Wait for the child to exit.
await promiseFinished;
}
async function testInChild() {
// Fire an observer notification in the child that should be forwarded to
// the parent.
await childTests.reduce(
(p, test) =>
p.then(_ => waitForNotifierObservers(test, /* shouldNotify = */ true)),
Promise.resolve()
);
// Register observers for notifications from the parent, let the parent know
// we're ready, and wait for the notifications.
let promiseNotifierObservers = parentTests.reduce(
(p, test) =>
p.then(_ => waitForNotifierObservers(test, /* shouldNotify = */ false)),
Promise.resolve()
);
do_send_remote_message("push_test_observer_remoting_child_ready");
await promiseNotifierObservers;
}
var waitForNotifierObservers = async function (
{ text, principal },
shouldNotify = false
) {
let notifyPromise = promiseObserverNotification(
PushServiceComponent.pushTopic
);
let subChangePromise = promiseObserverNotification(
PushServiceComponent.subscriptionChangeTopic
);
let subModifiedPromise = promiseObserverNotification(
PushServiceComponent.subscriptionModifiedTopic
);
let scope = "chrome://test-scope";
let data = new TextEncoder().encode(text);
if (shouldNotify) {
pushNotifier.notifyPushWithData(scope, principal, "", data);
pushNotifier.notifySubscriptionChange(scope, principal);
pushNotifier.notifySubscriptionModified(scope, principal);
}
let { data: notifyScope, subject: notifySubject } = await notifyPromise;
equal(
notifyScope,
scope,
"Should fire push notifications with the correct scope"
);
let message = notifySubject.QueryInterface(Ci.nsIPushMessage);
equal(
message.principal,
principal,
"Should include the principal in the push message"
);
strictEqual(message.data.text(), text, "Should include data");
let { data: subChangeScope, subject: subChangePrincipal } =
await subChangePromise;
equal(
subChangeScope,
scope,
"Should fire subscription change notifications with the correct scope"
);
equal(
subChangePrincipal,
principal,
"Should pass the principal as the subject of a change notification"
);
let { data: subModifiedScope, subject: subModifiedPrincipal } =
await subModifiedPromise;
equal(
subModifiedScope,
scope,
"Should fire subscription modified notifications with the correct scope"
);
equal(
subModifiedPrincipal,
principal,
"Should pass the principal as the subject of a modified notification"
);
};
|
