Revision control
Copy as Markdown
Other Tools
/* -*- Mode: JavaScript; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* ***** BEGIN LICENSE BLOCK *****
*
* Any copyright is dedicated to the Public Domain.
*
* ***** END LICENSE BLOCK ***** */
/**
* This test checks pseudo-offline message copies (which is triggered
* by allowUndo == true in copyMessages).
*/
var { PromiseTestUtils } = ChromeUtils.importESModule(
);
/* import-globals-from ../../../test/resources/logHelper.js */
load("../../../resources/logHelper.js");
var gMsgFile1 = do_get_file("../../../data/bugmail10");
var gMsgId1 = "200806061706.m56H6RWT004933@mrapp54.mozilla.org";
var gMsgFile2 = do_get_file("../../../data/image-attach-test");
var gMsgId2 = "4A947F73.5030709@example.com";
var gMsgFile3 = do_get_file("../../../data/SpamAssassinYes");
var gMsg3Id = "bugmail7.m47LtAEf007543@mrapp51.mozilla.org";
var gMsg4Id = "foo.12345@example";
var gFolder1;
// Adds some messages directly to a mailbox (eg new mail)
function addMessagesToServer(messages, mailbox) {
messages.forEach(function (message) {
const URI = Services.io
.newFileURI(message.file)
.QueryInterface(Ci.nsIFileURL);
// Create the ImapMessage and store it on the mailbox.
mailbox.addMessage(new ImapMessage(URI.spec, mailbox.uidnext++, []));
});
}
var tests = [
async function setup() {
// Turn off autosync_offline_stores because
// fetching messages is invoked after copying the messages.
// (i.e. The fetching process will be invoked after OnStopCopy)
// It will cause crash with an assertion
// (ASSERTION: tried to add duplicate listener: 'index == -1') on teardown.
Services.prefs.setBoolPref(
"mail.server.default.autosync_offline_stores",
false
);
setupIMAPPump();
const promiseFolderAdded = PromiseTestUtils.promiseFolderAdded("folder 1");
IMAPPump.incomingServer.rootFolder.createSubfolder("folder 1", null);
await promiseFolderAdded;
gFolder1 = IMAPPump.incomingServer.rootFolder.getChildNamed("folder 1");
Assert.ok(gFolder1 instanceof Ci.nsIMsgFolder);
// these hacks are required because we've created the inbox before
// running initial folder discovery, and adding the folder bails
// out before we set it as verified online, so we bail out, and
// then remove the INBOX folder since it's not verified.
IMAPPump.inbox.hierarchyDelimiter = "/";
IMAPPump.inbox.verifiedAsOnlineFolder = true;
// Add messages to the INBOX
// this is synchronous, afaik
addMessagesToServer(
[
{ file: gMsgFile1, messageId: gMsgId1 },
{ file: gMsgFile2, messageId: gMsgId2 },
],
IMAPPump.daemon.getMailbox("INBOX")
);
},
async function updateFolder() {
const promiseUrlListener = new PromiseTestUtils.PromiseUrlListener();
IMAPPump.inbox.updateFolderWithListener(null, promiseUrlListener);
await promiseUrlListener.promise;
},
async function downloadAllForOffline() {
const promiseUrlListener = new PromiseTestUtils.PromiseUrlListener();
IMAPPump.inbox.downloadAllForOffline(promiseUrlListener, null);
await promiseUrlListener.promise;
},
async function copyMessagesToInbox() {
let promiseCopyListener = new PromiseTestUtils.PromiseCopyListener();
MailServices.copy.copyFileMessage(
gMsgFile3,
IMAPPump.inbox,
null,
false,
0,
"",
promiseCopyListener,
null
);
await promiseCopyListener.promise;
promiseCopyListener = new PromiseTestUtils.PromiseCopyListener();
MailServices.copy.copyFileMessage(
gMsgFile4,
IMAPPump.inbox,
null,
false,
0,
"",
promiseCopyListener,
null
);
await promiseCopyListener.promise;
const promiseUrlListener = new PromiseTestUtils.PromiseUrlListener();
IMAPPump.inbox.updateFolderWithListener(null, promiseUrlListener);
await promiseUrlListener.promise;
const db = IMAPPump.inbox.msgDatabase;
// test the headers in the inbox
let count = 0;
for (const message of db.enumerateMessages()) {
count++;
message instanceof Ci.nsIMsgDBHdr;
dump(
"message <" +
message.subject +
"> storeToken: <" +
message.getStringProperty("storeToken") +
"> offset: <" +
message.messageOffset +
"> id: <" +
message.messageId +
">\n"
);
// are copied are not visible in pre-pluggableStores versions of TB (pre TB 12)
if (IMAPPump.inbox.msgStore.storeType == "mbox") {
Assert.equal(
message.messageOffset,
parseInt(message.getStringProperty("storeToken"))
);
}
}
Assert.equal(count, 4);
},
function copyMessagesToSubfolder() {
// a message created from IMAP download
let db = IMAPPump.inbox.msgDatabase;
const msg1 = db.getMsgHdrForMessageID(gMsgId1);
// this is sync, I believe?
MailServices.copy.copyMessages(
IMAPPump.inbox,
[msg1],
gFolder1,
false,
null,
null,
true
);
// two messages originally created from file copies (like in Send)
const msg3 = db.getMsgHdrForMessageID(gMsg3Id);
Assert.ok(msg3 instanceof Ci.nsIMsgDBHdr);
MailServices.copy.copyMessages(
IMAPPump.inbox,
[msg3],
gFolder1,
false,
null,
null,
true
);
const msg4 = db.getMsgHdrForMessageID(gMsg4Id);
Assert.ok(msg4 instanceof Ci.nsIMsgDBHdr);
msg4.messageOffset = 0;
MailServices.copy.copyMessages(
IMAPPump.inbox,
[msg4],
gFolder1,
false,
null,
null,
true
);
// test the db headers in folder1
db = gFolder1.msgDatabase;
let count = 0;
for (const message of db.enumerateMessages()) {
count++;
message instanceof Ci.nsIMsgDBHdr;
dump(
"message <" +
message.subject +
"> storeToken: <" +
message.getStringProperty("storeToken") +
"> offset: <" +
message.messageOffset +
"> id: <" +
message.messageId +
">\n"
);
if (gFolder1.msgStore.storeType == "mbox") {
Assert.equal(
message.messageOffset,
parseInt(message.getStringProperty("storeToken"))
);
}
}
Assert.equal(count, 3);
},
async function test_headers() {
const msgIds = [gMsgId1, gMsg3Id, gMsg4Id];
for (const msgId of msgIds) {
const newMsgHdr = gFolder1.msgDatabase.getMsgHdrForMessageID(msgId);
Assert.ok(newMsgHdr.flags & Ci.nsMsgMessageFlags.Offline);
const msgURI = newMsgHdr.folder.getUriForMsg(newMsgHdr);
const msgServ = MailServices.messageServiceFromURI(msgURI);
const promiseStreamListener =
new PromiseTestUtils.PromiseStreamListener();
msgServ.streamHeaders(msgURI, promiseStreamListener, null, true);
const data = await promiseStreamListener.promise;
dump("\nheaders for messageId " + msgId + "\n" + data + "\n\n");
Assert.ok(data.includes(msgId));
}
},
function moveMessagesToSubfolder() {
const db = IMAPPump.inbox.msgDatabase;
const messages = [...db.enumerateMessages()];
Assert.ok(messages.length > 0);
// this is sync, I believe?
MailServices.copy.copyMessages(
IMAPPump.inbox,
messages,
gFolder1,
true,
null,
null,
true
);
// the inbox should now be empty
Assert.ok([...db.enumerateMessages()].length == 0);
// maildir should also delete the files.
if (IMAPPump.inbox.msgStore.storeType == "maildir") {
const curDir = IMAPPump.inbox.filePath.clone();
curDir.append("cur");
Assert.ok(curDir.exists());
Assert.ok(curDir.isDirectory());
const curEnum = curDir.directoryEntries;
Assert.ok(!curEnum.hasMoreElements());
}
},
teardownIMAPPump,
];
function run_test() {
tests.forEach(x => add_task(x));
run_next_test();
}