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
|
/*
** Copyright 2002, Double Precision Inc.
**
** See COPYING for distribution information.
*/
#ifndef libmail_copymessage_H
#define libmail_copymessage_H
#include "libmail_config.h"
#include "mail.H"
#include "objectmonitor.H"
#include "runlater.H"
#include <vector>
#include <queue>
////////////////////////////////////////////////////////////////////////////
//
// This class copies a single message between two servers
//
LIBMAIL_START
class addMessage;
class copyMessage : public runLater {
mail::callback &callback;
ptr<mail::account> from;
ptr<mail::folder> to;
addMessage *addMessagePtr;
size_t messageNum;
mail::messageInfo messageInfo;
time_t arrivalDate;
copyMessage(mail::account *fromArg,
size_t messageNumArg,
mail::folder *toArg,
mail::callback &callbackArg);
virtual ~copyMessage();
void go();
void fetchText();
class FetchCallback : public mail::callback::message {
public:
copyMessage *me;
void (copyMessage::*successCallback)();
FetchCallback();
~FetchCallback();
void messageArrivalDateCallback(size_t messageNumber,
time_t datetime);
void messageTextCallback(size_t n, std::string text);
void success(std::string);
void fail(std::string);
void reportProgress(size_t bytesCompleted,
size_t bytesEstimatedTotal,
size_t messagesCompleted,
size_t messagesEstimatedTotal);
} fetch_callback;
class AddCallback : public mail::callback {
public:
copyMessage *me;
AddCallback();
~AddCallback();
void success(std::string);
void fail(std::string);
void reportProgress(size_t bytesCompleted,
size_t bytesEstimatedTotal,
size_t messagesCompleted,
size_t messagesEstimatedTotal);
} add_callback;
size_t fetchCompletedCnt;
size_t fetchEstimatedCnt;
size_t addCompleted;
size_t addEstimated;
void reportProgress();
void fetchCompleted();
void RunningLater();
void success(mail::callback &callback, std::string msg);
public:
size_t completedCount;
friend class FetchCallback;
friend class AddCallback;
static void copy(mail::account *copyFrom, size_t messageNum,
mail::folder *copyTo,
mail::callback &callback,
size_t completedCount=0);
};
///////////////////////////////////////////////////////////////////////////
//
// A helper class for copying a range of messages. This is done by
// instantiating multiple mail::copyMessage object. We'll try to keep
// two instances going at a time, hopefully at all times one instance
// reads from the source server, and the second instance is uploading
// to the desintation server
class copyMessages : public runLater {
mail::callback &callback;
// To make sure that the source folder doesn't change, we'll
// keep track of each message's UID.
std::queue< std::pair<size_t, std::string> > todo;
ptr<mail::account> copyFrom;
ptr<mail::folder> copyTo;
size_t inProgress; // # of copies in progress, at most 2.
size_t copiedCount;
size_t totalCount;
size_t progressUpdateCount;
std::string failMessage;
// Helper
class Callback : public mail::callback {
public:
copyMessages *me;
Callback();
~Callback();
void success(std::string message);
void fail(std::string message);
void reportProgress(size_t bytesCompleted,
size_t bytesEstimatedTotal,
size_t messagesCompleted,
size_t messagesEstimatedTotal);
} copy_callback;
copyMessages(mail::account *copyFrom,
const std::vector<size_t> &messages,
mail::folder *copyTo,
mail::callback &callback);
~copyMessages();
void RunningLater();
void doSomething(std::string message);
void success(mail::callback &callback, std::string message);
public:
static void copy(mail::account *copyFrom,
const std::vector<size_t> &messages,
mail::folder *copyTo,
mail::callback &callback);
};
LIBMAIL_END
#endif
|
