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
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
"use strict";
let h3Route;
let httpsOrigin;
let h3AltSvc;
let prefs;
let tests = [test_https_alt_svc, test_response_421, testsDone];
let current_test = 0;
function run_next_test() {
if (current_test < tests.length) {
dump("starting test number " + current_test + "\n");
tests[current_test]();
current_test++;
}
}
function run_test() {
let h2Port = Services.env.get("MOZHTTP2_PORT");
Assert.notEqual(h2Port, null);
Assert.notEqual(h2Port, "");
let h3Port = Services.env.get("MOZHTTP3_PORT");
Assert.notEqual(h3Port, null);
Assert.notEqual(h3Port, "");
h3AltSvc = ":" + h3Port;
h3Route = "foo.example.com:" + h3Port;
do_get_profile();
prefs = Services.prefs;
prefs.setBoolPref("network.http.http3.enable", true);
prefs.setCharPref("network.dns.localDomains", "foo.example.com");
// We always resolve elements of localDomains as it's hardcoded without the
// following pref:
prefs.setBoolPref("network.proxy.allow_hijacking_localhost", true);
// The certificate for the http3server server is for foo.example.com and
// is signed by http2-ca.pem so add that cert to the trust list as a
// signing cert.
let certdb = Cc["@mozilla.org/security/x509certdb;1"].getService(
Ci.nsIX509CertDB
);
addCertFromFile(certdb, "http2-ca.pem", "CTu,u,u");
httpsOrigin = "https://foo.example.com:" + h2Port + "/";
run_next_test();
}
function makeChan(uri) {
let chan = NetUtil.newChannel({
uri,
loadUsingSystemPrincipal: true,
}).QueryInterface(Ci.nsIHttpChannel);
chan.loadFlags = Ci.nsIChannel.LOAD_INITIAL_DOCUMENT_URI;
return chan;
}
let Http3Listener = function () {};
Http3Listener.prototype = {
onDataAvailableFired: false,
buffer: "",
routed: "",
httpVersion: "",
onStartRequest: function testOnStartRequest(request) {
Assert.ok(request instanceof Ci.nsIHttpChannel);
Assert.equal(request.status, Cr.NS_OK);
Assert.equal(request.responseStatus, 200);
},
onDataAvailable: function testOnDataAvailable(request, stream, off, cnt) {
this.onDataAvailableFired = true;
this.buffer = this.buffer.concat(read_stream(stream, cnt));
},
onStopRequest: function testOnStopRequest(request, status) {
Assert.equal(status, Cr.NS_OK);
Assert.equal(this.onDataAvailableFired, true);
this.routed = "NA";
try {
this.routed = request.getRequestHeader("Alt-Used");
} catch (e) {}
dump("routed is " + this.routed + "\n");
this.httpVersion = "";
try {
this.httpVersion = request.protocolVersion;
} catch (e) {}
dump("httpVersion is " + this.httpVersion + "\n");
},
};
let WaitForHttp3Listener = function () {};
WaitForHttp3Listener.prototype = new Http3Listener();
WaitForHttp3Listener.prototype.uri = "";
WaitForHttp3Listener.prototype.onStopRequest = function testOnStopRequest(
request,
status
) {
Http3Listener.prototype.onStopRequest.call(this, request, status);
if (this.routed == h3Route) {
Assert.equal(this.httpVersion, "h3-29");
run_next_test();
} else {
dump("poll later for alt svc mapping\n");
do_test_pending();
do_timeout(500, () => {
doTest(this.uri);
});
}
do_test_finished();
};
function doTest(uri) {
let chan = makeChan(uri);
let listener = new WaitForHttp3Listener();
listener.uri = uri;
chan.setRequestHeader("x-altsvc", h3AltSvc, false);
chan.asyncOpen(listener);
}
// Test Alt-Svc for http3.
// H2 server returns alt-svc=h3-29=:h3port
function test_https_alt_svc() {
dump("test_https_alt_svc()\n");
do_test_pending();
doTest(httpsOrigin + "http3-test");
}
let Resp421Listener = function () {};
Resp421Listener.prototype = new Http3Listener();
Resp421Listener.prototype.onStopRequest = function testOnStopRequest(
request,
status
) {
Http3Listener.prototype.onStopRequest.call(this, request, status);
Assert.equal(this.routed, "0");
Assert.equal(this.httpVersion, "h2");
Assert.ok(this.buffer.match("You Win! [(]by requesting/Response421[)]"));
run_next_test();
do_test_finished();
};
function test_response_421() {
dump("test_response_421()\n");
let listener = new Resp421Listener();
let chan = makeChan(httpsOrigin + "Response421");
chan.asyncOpen(listener);
do_test_pending();
}
function testsDone() {
prefs.clearUserPref("network.http.http3.enable");
prefs.clearUserPref("network.dns.localDomains");
prefs.clearUserPref("network.proxy.allow_hijacking_localhost");
dump("testDone\n");
do_test_pending();
do_test_finished();
}
|
