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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
package tests
import (
"io"
"strconv"
"testing"
"time"
goimap "github.com/emersion/go-imap"
"github.com/emersion/go-imap/client"
"github.com/stretchr/testify/require"
)
func TestRemoteCopy(t *testing.T) {
runOneToOneTestWithAuth(t, defaultServerOptions(t), func(c *testConnection, s *testSession) {
s.setFolderPrefix("user", "Folders")
s.setLabelsPrefix("user", "Labels")
// Create two exclusive mailboxes, one with 100 messages.
s.mailboxCreated("user", []string{"Folders", "mbox1"}, "testdata/dovecot-crlf")
s.mailboxCreated("user", []string{"Folders", "mbox2"})
// Create two non-exclusive mailboxes, one with 100 messages.
s.mailboxCreated("user", []string{"Labels", "mbox1"}, "testdata/dovecot-crlf")
s.mailboxCreated("user", []string{"Labels", "mbox2"})
// Copy everything from Folders/mbox1 to Folders/mbox2.
c.C(`A001 select Folders/mbox1`).Sxe(`100 EXISTS`).OK(`A001`)
c.C(`A002 copy 1:* Folders/mbox2`).OK(`A002`)
// Copy everything from Labels/mbox1 to Labels/mbox2.
c.C(`A001 select Labels/mbox1`).Sxe(`100 EXISTS`).OK(`A001`)
c.C(`A002 copy 1:* Labels/mbox2`).OK(`A002`)
// The folders are exclusive and so the remote will remove them automatically from the origin.
// The labels are non-exclusive and so they will not be modified by the remote.
s.flush("user")
// Check that the message counts are expected.
c.C(`A003 noop`).OK(`A003`)
c.C(`A004 status Folders/mbox1 (messages)`).Sx(`MESSAGES 0`).OK(`A004`)
c.C(`A005 status Folders/mbox2 (messages)`).Sx(`MESSAGES 100`).OK(`A005`)
c.C(`A004 status Labels/mbox1 (messages)`).Sx(`MESSAGES 100`).OK(`A004`)
c.C(`A005 status Labels/mbox2 (messages)`).Sx(`MESSAGES 100`).OK(`A005`)
})
}
func TestAppendDuplicate(t *testing.T) {
const messagePath = "testdata/afternoon-meeting.eml"
runOneToOneTestClientWithAuth(t, defaultServerOptions(t), func(client *client.Client, s *testSession) {
s.setFolderPrefix("user", "Folders")
s.setLabelsPrefix("user", "Labels")
// Create exclusive mailboxes to be the origin and destination.
s.mailboxCreated("user", []string{"Folders", "origin"})
s.mailboxCreated("user", []string{"Folders", "destination"})
// Put the message in origin.
require.NoError(t, doAppendWithClientFromFile(t, client, "Folders/origin", messagePath, time.Now(), goimap.SeenFlag))
// Copy the message to destination.
status, err := client.Select("Folders/origin", false)
require.NoError(t, err)
require.Equal(t, uint32(1), status.Messages)
section, err := goimap.ParseBodySectionName("BODY[]")
require.NoError(t, err)
messages := newFetchCommand(t, client).withItems(section.FetchItem()).fetch(strconv.Itoa(1)).messages
require.Len(t, messages, 1)
body, err := io.ReadAll(messages[0].GetBody(section))
require.NoError(t, err)
require.NoError(t, doAppendWithClient(client, "Folders/destination", string(body), time.Now(), goimap.SeenFlag))
// Check that the message is in destination.
status, err = client.Select("Folders/destination", false)
require.NoError(t, err)
require.Equal(t, uint32(1), status.Messages)
// The folders are exclusive and so the remote will remove them automatically from the origin.
s.flush("user")
// Check that the message is no longer in origin.
status, err = client.Select("Folders/origin", false)
require.NoError(t, err)
require.Equal(t, uint32(0), status.Messages)
})
}
func TestRemoteDeletionPool(t *testing.T) {
runManyToOneTestWithAuth(t, defaultServerOptions(t), []int{1, 2}, func(c map[int]*testConnection, s *testSession) {
// Create a mailbox for the test to run in.
mboxID1 := s.mailboxCreated("user", []string{"mbox1"})
mboxID2 := s.mailboxCreated("user", []string{"mbox2"})
// Create some messages externally.
messageID1 := s.messageCreatedFromFile("user", mboxID1, "testdata/afternoon-meeting.eml")
messageID2 := s.messageCreatedFromFile("user", mboxID1, "testdata/afternoon-meeting.eml")
// Add the messages to a second mailbox.
s.messageAdded("user", messageID1, mboxID2)
s.messageAdded("user", messageID2, mboxID2)
// Select in the mailbox.
c[1].C("tag select mbox1").OK("tag")
c[2].C("tag select mbox1").OK("tag")
// First client expunges the messages.
c[1].C(`tag store 1:* +flags (\deleted)`).OK("tag")
c[1].C(`tag expunge`).OK("tag")
// Second client has not been notified of the expunge.
// The messages are in the deletion pool.
c[2].C(`tag fetch 1:* (uid)`)
c[2].Se(`* 1 FETCH (UID 1)`, `* 2 FETCH (UID 2)`)
c[2].OK("tag")
// Put the messages back in the mailbox.
// They'll get new UIDs.
s.messageAdded("user", messageID1, mboxID1)
s.messageAdded("user", messageID2, mboxID1)
// Flush the updates.
s.flush("user")
// Receive updates.
c[2].C(`tag noop`).OK(`tag`)
// Second client sees the messages have new UIDs.
c[2].C(`tag fetch 1:* (uid)`)
c[2].Se(`* 1 FETCH (UID 3)`, `* 2 FETCH (UID 4)`)
c[2].OK("tag")
})
}
|
