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
|
/* 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 file,
* You can obtain one at http://mozilla.org/MPL/2.0/. */
/* Test that the message failed to move to a local folder remains on IMAP
* server. */
var { MailServices } = ChromeUtils.import(
"resource:///modules/MailServices.jsm"
);
var { MessageGenerator } = ChromeUtils.import(
"resource://testing-common/mailnews/MessageGenerator.jsm"
);
var { PromiseTestUtils } = ChromeUtils.import(
"resource://testing-common/mailnews/PromiseTestUtils.jsm"
);
function stop_server() {
IMAPPump.incomingServer.closeCachedConnections();
IMAPPump.server.stop();
let thread = gThreadManager.currentThread;
while (thread.hasPendingEvents()) {
thread.processNextEvent(true);
}
}
add_setup(function () {
setupIMAPPump();
Services.prefs.setBoolPref(
"mail.server.default.autosync_offline_stores",
false
);
});
add_setup(async function () {
let messageGenerator = new MessageGenerator();
let messageString = messageGenerator.makeMessage().toMessageString();
let dataUri = Services.io.newURI(
"data:text/plain;base64," + btoa(messageString)
);
let imapMsg = new ImapMessage(dataUri.spec, IMAPPump.mailbox.uidnext++, []);
IMAPPump.mailbox.addMessage(imapMsg);
let listener = new PromiseTestUtils.PromiseUrlListener();
IMAPPump.inbox.updateFolderWithListener(null, listener);
await listener.promise;
});
add_task(async function move_messages() {
let msg = IMAPPump.inbox.msgDatabase.getMsgHdrForKey(
IMAPPump.mailbox.uidnext - 1
);
let copyListener = new PromiseTestUtils.PromiseCopyListener({
OnProgress(aProgress, aProgressMax) {
stop_server();
},
});
MailServices.copy.copyMessages(
IMAPPump.inbox,
[msg],
localAccountUtils.inboxFolder,
true,
copyListener,
null,
false
);
await copyListener.promise;
});
add_task(function check_messages() {
Assert.equal(IMAPPump.inbox.getTotalMessages(false), 1);
Assert.equal(localAccountUtils.inboxFolder.getTotalMessages(false), 0);
});
add_task(function endTest() {
// IMAPPump.server.performTest() brings this test to a halt,
// so we need teardownIMAPPump() without IMAPPump.server.performTest().
IMAPPump.inbox = null;
IMAPPump.server.resetTest();
try {
IMAPPump.incomingServer.closeCachedConnections();
let serverSink = IMAPPump.incomingServer.QueryInterface(
Ci.nsIImapServerSink
);
serverSink.abortQueuedUrls();
} catch (ex) {
dump(ex);
}
IMAPPump.server.stop();
let thread = gThreadManager.currentThread;
while (thread.hasPendingEvents()) {
thread.processNextEvent(true);
}
});
|
