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
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
/*
* Copyright (C) 2015 Christian Mollekopf <chrigi_1@fastmail.fm>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the
* Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#pragma once
#include <Async/Async>
#include <KMime/KMime/KMimeMessage>
#include <KIMAP2/ListJob>
#include <KIMAP2/Session>
#include <KIMAP2/FetchJob>
#include <KIMAP2/SearchJob>
namespace Imap {
namespace Flags
{
/// The flag for a message being seen (i.e. opened by user).
extern const char* Seen;
/// The flag for a message being deleted by the user.
extern const char* Deleted;
/// The flag for a message being replied to by the user.
extern const char* Answered;
/// The flag for a message being marked as flagged.
extern const char* Flagged;
}
namespace FolderFlags
{
extern const char* Noinferiors;
extern const char* Noselect;
extern const char* Marked;
extern const char* Unmarked;
}
struct Message {
qint64 uid;
qint64 size;
KIMAP2::MessageAttributes attributes;
KIMAP2::MessageFlags flags;
KMime::Message::Ptr msg;
};
struct Folder {
Folder() = default;
Folder(const QString &path, const QChar &separator, bool noselect_)
: noselect(noselect_),
mPath(path),
pathParts(path.split(separator)),
mSeparator(separator)
{
}
Folder(const QString &path_)
: mPath(path_)
{
}
QString normalizedPath() const
{
return path('/');
}
QString path(const QChar &s) const
{
Q_ASSERT(!s.isNull());
return pathParts.join(s);
}
QString path() const
{
Q_ASSERT(!mPath.isEmpty());
return mPath;
}
QString parentPath() const
{
Q_ASSERT(!mSeparator.isNull());
auto parts = pathParts;
parts.removeLast();
return parts.join(mSeparator);
}
QString normalizedParentPath() const
{
Q_ASSERT(!pathParts.isEmpty());
auto parts = pathParts;
parts.removeLast();
return parts.join('/');
}
QString name() const
{
Q_ASSERT(!pathParts.isEmpty());
return pathParts.last();
}
bool noselect = false;
private:
QString mPath;
QList<QString> pathParts;
QChar mSeparator;
};
struct SelectResult {
qint64 uidValidity;
qint64 uidNext;
quint64 highestModSequence;
};
class ImapServerProxy {
KIMAP2::Session *mSession;
QStringList mCapabilities;
QSet<QString> mPersonalNamespaces;
QChar mPersonalNamespaceSeparator;
QSet<QString> mSharedNamespaces;
QChar mSharedNamespaceSeparator;
QSet<QString> mUserNamespaces;
QChar mUserNamespaceSeparator;
public:
ImapServerProxy(const QString &serverUrl, int port);
//Standard IMAP calls
KAsync::Job<void> login(const QString &username, const QString &password);
KAsync::Job<SelectResult> select(const QString &mailbox);
KAsync::Job<qint64> append(const QString &mailbox, const QByteArray &content, const QList<QByteArray> &flags = QList<QByteArray>(), const QDateTime &internalDate = QDateTime());
KAsync::Job<void> store(const KIMAP2::ImapSet &set, const QList<QByteArray> &flags);
KAsync::Job<void> storeFlags(const KIMAP2::ImapSet &set, const QList<QByteArray> &flags);
KAsync::Job<void> addFlags(const KIMAP2::ImapSet &set, const QList<QByteArray> &flags);
KAsync::Job<void> removeFlags(const KIMAP2::ImapSet &set, const QList<QByteArray> &flags);
KAsync::Job<void> create(const QString &mailbox);
KAsync::Job<void> rename(const QString &mailbox, const QString &newMailbox);
KAsync::Job<void> remove(const QString &mailbox);
KAsync::Job<void> expunge();
KAsync::Job<void> expunge(const KIMAP2::ImapSet &set);
KAsync::Job<void> copy(const KIMAP2::ImapSet &set, const QString &newMailbox);
KAsync::Job<QVector<qint64>> search(const KIMAP2::ImapSet &set);
KAsync::Job<QVector<qint64>> search(const KIMAP2::Term &term);
typedef std::function<void(const KIMAP2::FetchJob::Result &)> FetchCallback;
KAsync::Job<void> fetch(const KIMAP2::ImapSet &set, KIMAP2::FetchJob::FetchScope scope, FetchCallback callback);
KAsync::Job<void> fetch(const KIMAP2::ImapSet &set, KIMAP2::FetchJob::FetchScope scope, const std::function<void(const Message &)> &callback);
KAsync::Job<void> list(KIMAP2::ListJob::Option option, const std::function<void(const KIMAP2::MailBoxDescriptor &mailboxes,const QList<QByteArray> &flags)> &callback);
QStringList getCapabilities() const;
//Composed calls that do login etc.
KAsync::Job<QVector<qint64>> fetchHeaders(const QString &mailbox, qint64 minUid = 1);
KAsync::Job<void> remove(const QString &mailbox, const KIMAP2::ImapSet &set);
KAsync::Job<void> remove(const QString &mailbox, const QByteArray &imapSet);
KAsync::Job<void> move(const QString &mailbox, const KIMAP2::ImapSet &set, const QString &newMailbox);
KAsync::Job<QString> createSubfolder(const QString &parentMailbox, const QString &folderName);
KAsync::Job<QString> renameSubfolder(const QString &mailbox, const QString &newName);
KAsync::Job<QVector<qint64>> fetchUids(const QString &mailbox);
KAsync::Job<QVector<qint64>> fetchUidsSince(const QString &mailbox, const QDate &since);
QString mailboxFromFolder(const Folder &) const;
KAsync::Job<void> fetchFolders(std::function<void(const Folder &)> callback);
KAsync::Job<void> fetchMessages(const Folder &folder, std::function<void(const Message &)> callback, std::function<void(int, int)> progress = std::function<void(int, int)>());
KAsync::Job<void> fetchMessages(const Folder &folder, qint64 uidNext, std::function<void(const Message &)> callback, std::function<void(int, int)> progress = std::function<void(int, int)>());
KAsync::Job<void> fetchMessages(const Folder &folder, const QVector<qint64> &uidsToFetch, std::function<void(const Message &)> callback, std::function<void(int, int)> progress);
KAsync::Job<SelectResult> fetchFlags(const Folder &folder, const KIMAP2::ImapSet &set, qint64 changedsince, std::function<void(const Message &)> callback);
KAsync::Job<QVector<qint64>> fetchUids(const Folder &folder);
private:
QObject mGuard;
};
}
|
