Revision control
Copy as Markdown
Other Tools
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
var { NntpChannel } = ChromeUtils.importESModule(
);
var { PromiseTestUtils } = ChromeUtils.importESModule(
);
let server;
add_setup(function setup() {
const daemon = setupNNTPDaemon();
server = new nsMailServer(() => {
const handler = new NNTP_RFC977_handler(daemon);
// Test NntpClient works with 201 response.
handler.onStartup = () => {
return "201 posting prohibited";
};
return handler;
}, daemon);
server.start(NNTP_PORT);
registerCleanupFunction(() => {
server.stop();
});
setupLocalServer(NNTP_PORT);
});
/**
* Test a ?list-ids news url will trigger LISTGROUP request.
*/
add_task(async function test_listIds() {
// Init the uri and streamListener.
const uri = Services.io.newURI(
);
const streamListener = new PromiseTestUtils.PromiseStreamListener();
// Run the uri with NntpChannel.
const channel = new NntpChannel(uri);
channel.asyncOpen(streamListener);
await streamListener.promise;
// Test LISTGROUP request was sent correctly.
const transaction = server.playTransaction();
do_check_transaction(transaction, ["MODE READER", "LISTGROUP test.filter"]);
});
/**
* Test a ?group=name&key=x news url will trigger ARTICLE request.
*/
add_task(async function test_fetchArticle() {
_server.closeCachedConnections();
// Init the uri and streamListener.
const uri = Services.io.newURI(
);
const streamListener = new PromiseTestUtils.PromiseStreamListener();
// Run the uri with NntpChannel.
const channel = new NntpChannel(uri);
channel.asyncOpen(streamListener);
await streamListener.promise;
// Test ARTICLE request was sent correctly.
const transaction = server.playTransaction();
do_check_transaction(transaction, [
"MODE READER",
"GROUP test.filter",
"ARTICLE 1",
]);
});