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
/*
* Test that an unknown untagged X response sent while the connection is
* idling, when no url is running, is ignored:
*
* * XFOO bar<CR><LF>
*/
const { IMAPServer } = ChromeUtils.importESModule(
);
const { TestUtils } = ChromeUtils.importESModule(
);
let incomingServer;
let server;
let inbox;
async function updateInbox() {
const listener = new PromiseTestUtils.PromiseUrlListener();
inbox.updateFolderWithListener(null, listener);
await listener.promise;
}
add_setup(async function () {
server = new IMAPServer({ extensions: ["RFC2177"] });
const account = MailServices.accounts.createAccount();
account.addIdentity(MailServices.accounts.createIdentity());
incomingServer = MailServices.accounts.createIncomingServer(
"user",
"localhost",
"imap"
);
incomingServer.password = "password";
incomingServer.port = server.port;
incomingServer.QueryInterface(Ci.nsIImapIncomingServer).useIdle = true;
account.incomingServer = incomingServer;
const listener = new PromiseTestUtils.PromiseUrlListener();
MailServices.imap.discoverAllFolders(
incomingServer.rootFolder,
listener,
null
);
await listener.promise;
inbox = incomingServer.rootFolder
.getChildNamed("INBOX")
.QueryInterface(Ci.nsIMsgImapMailFolder);
await updateInbox();
registerCleanupFunction(() => {
incomingServer.closeCachedConnections();
MailServices.accounts.removeIncomingServer(incomingServer, false);
});
});
add_task(async function unsolicitedXResponseWhileIdle() {
await TestUtils.waitForCondition(
() => server.daemon.getConnections("INBOX").some(h => h.idling),
"INBOX connection should enter IDLE"
);
await server.addMessages("INBOX", [gMessageGenerator.makeMessage()], false);
const messageAdded = PromiseTestUtils.promiseFolderNotification(
inbox,
"msgAdded"
);
Assert.equal(
server.daemon.sendUnsolicited("INBOX", ["* XFOO bar", "* 1 EXISTS"]),
1,
"the idling connection should receive the X response"
);
// The message is fetched in response to the EXISTS, so the X response
// before it was handled while idling.
await messageAdded;
Assert.equal(inbox.getTotalMessages(false), 1, "the message should arrive");
});