Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Warnings
- This test gets skipped with pattern: os == 'win' && socketprocess_networking && fission OR msix OR os == 'android' && !fission
- Manifest: toolkit/components/extensions/test/xpcshell/xpcshell-remote.toml
"use strict";
AddonTestUtils.init(this);
AddonTestUtils.overrideCertDB();
AddonTestUtils.createAppInfo(
"xpcshell@tests.mozilla.org",
"XPCShell",
"1",
"43"
);
let { promiseShutdownManager, promiseStartupManager } = AddonTestUtils;
function readFile(file) {
let fstream = Cc["@mozilla.org/network/file-input-stream;1"].createInstance(
Ci.nsIFileInputStream
);
fstream.init(file, -1, 0, 0);
let data = NetUtil.readInputStreamToString(fstream, fstream.available());
fstream.close();
return data;
}
function addCertFromFile(certdb, filename, trustString) {
let certFile = do_get_file(filename, false);
let pem = readFile(certFile)
.replace(/-----BEGIN CERTIFICATE-----/, "")
.replace(/-----END CERTIFICATE-----/, "")
.replace(/[\r\n]/g, "");
certdb.addCertFromBase64(pem, trustString);
}
let proxyHost;
let proxyPort;
/**
* Sets up HTTP3 proxy configuration for extension tests
*/
add_setup(async function setup() {
Services.prefs.setBoolPref("network.proxy.allow_hijacking_localhost", true);
Services.prefs.setBoolPref("network.dns.disableIPv6", true);
Services.prefs.setIntPref("network.webtransport.datagram_size", 1500);
Services.prefs.setCharPref("network.dns.localDomains", "foo.example.com");
let certdb = Cc["@mozilla.org/security/x509certdb;1"].getService(
Ci.nsIX509CertDB
);
addCertFromFile(
certdb,
"../../../../../netwerk/test/unit/proxy-ca.pem",
"CTu,u,u"
);
addCertFromFile(
certdb,
"../../../../../netwerk/test/unit/http2-ca.pem",
"CTu,u,u"
);
proxyHost = "foo.example.com";
proxyPort = Services.env.get("MOZHTTP3_PORT_MASQUE");
// A dummy request to make sure AltSvcCache::mStorage is ready.
// It doesn't really matter if it succeeds or fails.
try {
} catch (e) {}
// In case the prefs have a different value by default.
Services.prefs.setBoolPref(
"extensions.webextensions.early_background_wakeup_on_request",
false
);
registerCleanupFunction(() => {
Services.prefs.clearUserPref("network.proxy.allow_hijacking_localhost");
});
});
add_task(async function test_connect_udp() {
await promiseStartupManager();
let h3Port = Services.env.get("MOZHTTP3_PORT");
ok(h3Port, `MOZHTTP3_PORT should be set: ${h3Port}`);
function background(proxyInfo) {
browser.proxy.onRequest.addListener(
details => {
browser.test.log(`onRequest: ${JSON.stringify(details)}`);
browser.test.sendMessage("onRequest", details.url);
return proxyInfo;
},
{ urls: ["<all_urls>"] }
);
}
let proxyInfo = {
host: proxyHost,
port: proxyPort,
type: "masque",
pathTemplate: "/.well-known/masque/udp/{target_host}/{target_port}/",
connectionIsolationKey: "masque-udp",
};
let extension = ExtensionTestUtils.loadExtension({
useAddonManager: "permanent",
manifest: {
permissions: ["proxy", "<all_urls>"],
},
background: `(${background})(${JSON.stringify(proxyInfo)})`,
});
await extension.startup();
Services.prefs.setCharPref(
"network.http.http3.alt-svc-mapping-for-testing",
`alt1.example.com;h3=:${h3Port}`
);
// Test the HTTP3 connection through the extension proxy
let response = await ExtensionTestUtils.fetch(
);
Assert.equal(response, "Hello World", "HTTP3 proxy request succeeded");
equal(
await extension.awaitMessage("onRequest"),
"Observed proxy.onRequest for speculative document request"
);
equal(
await extension.awaitMessage("onRequest"),
"Observed proxy.onRequest for document request"
);
equal(
await extension.awaitMessage("onRequest"),
"Observed proxy.onRequest for fetch() call"
);
await extension.unload();
await promiseShutdownManager();
});