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
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
|
/*
* kmfoldercachedimap.cpp
*
* Copyright (c) 2002-2004 Bo Thorsen <bo@sonofthor.dk>
* Copyright (c) 2002-2003 Steffen Hansen <steffen@klaralvdalens-datakonsult.se>
*
* 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; version 2 of the License
*
* 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.
*
* In addition, as a special exception, the copyright holders give
* permission to link the code of this program with any edition of
* the Qt library by Trolltech AS, Norway (or with modified versions
* of Qt that use the same license as Qt), and distribute linked
* combinations including the two. You must obey the GNU General
* Public License in all respects for all of the code used other than
* Qt. If you modify this file, you may extend this exception to
* your version of the file, but you are not obligated to do so. If
* you do not wish to do so, delete this exception statement from
* your version.
*/
#ifndef kmfoldercachedimap_h
#define kmfoldercachedimap_h
#include <kdialogbase.h>
#include <kstandarddirs.h>
#include <tqvaluelist.h>
#include <tqvaluevector.h>
#include <tqptrlist.h>
#include <tqdialog.h>
#include "kmfoldermaildir.h"
#include "kmfolderimap.h"
#include "kmacctcachedimap.h"
#include "kmfoldertype.h"
#include "folderjob.h"
#include "cachedimapjob.h"
#include "quotajobs.h"
using KMail::FolderJob;
using KMail::QuotaInfo;
class KMCommand;
class TQComboBox;
class TQRadioButton;
namespace KMail {
class AttachmentStrategy;
class ImapAccountBase;
struct ACLListEntry;
}
using KMail::AttachmentStrategy;
class DImapTroubleShootDialog : public KDialogBase
{
Q_OBJECT
public:
enum SelectedOperation {
None = -1,
ReindexCurrent = 0,
ReindexRecursive = 1,
ReindexAll = 2,
RefreshCache
};
DImapTroubleShootDialog( TQWidget* parent=0, const char* name=0 );
static int run();
private slots:
void slotDone();
private:
TQRadioButton *mIndexButton, *mCacheButton;
TQComboBox *mIndexScope;
int rc;
};
class KMFolderCachedImap : public KMFolderMaildir
{
Q_OBJECT
public:
static TQString cacheLocation() {
return locateLocal("data", "kmail/dimap" );
}
/** Usually a parent is given. But in some cases there is no
fitting parent object available. Then the name of the folder
is used as the absolute path to the folder file. */
KMFolderCachedImap(KMFolder* folder, const char* name=0);
virtual ~KMFolderCachedImap();
/** @reimpl */
void reallyDoClose(const char* owner);
/** Initialize this storage from another one. Used when creating a child folder */
void initializeFrom( KMFolderCachedImap* parent );
virtual void readConfig();
virtual void writeConfig();
void writeConfigKeysWhichShouldNotGetOverwrittenByReadConfig();
/** Returns the type of this folder */
virtual KMFolderType folderType() const { return KMFolderTypeCachedImap; }
/** @reimpl */
virtual int create();
/** Remove this folder */
virtual void remove();
/** Synchronize this folder and it's subfolders with the server */
virtual void serverSync( bool recurse );
/** Force the sync state to be done. */
void resetSyncState( );
/** Block this folder from generating alarms, even if the annotations
* on it say otherwise. Used to override alarms for read-only folders.
* (Only useful for resource folders) */
void setAlarmsBlocked( bool blocked );
/** Should alarms for this folder be blocked? (Only useful for resource folders) */
bool alarmsBlocked() const;
void checkUidValidity();
enum imapState { imapNoInformation=0, imapInProgress=1, imapFinished=2 };
virtual imapState getContentState() { return mContentState; }
virtual void setContentState(imapState state) { mContentState = state; }
virtual imapState getSubfolderState() { return mSubfolderState; }
virtual void setSubfolderState(imapState state);
/** The path to the imap folder on the server */
void setImapPath(const TQString &path);
TQString imapPath() const { return mImapPath; }
/** The highest UID in the folder */
void setLastUid( ulong uid );
ulong lastUid();
/** Find message by UID. Returns NULL if it doesn't exist */
KMMsgBase* findByUID( ulong uid );
/** The uidvalidity of the last update */
void setUidValidity(const TQString &validity) { mUidValidity = validity; }
TQString uidValidity() const { return mUidValidity; }
/** Forget which mails are considered locally present. Needed when uidvalidity
* changes. */
void clearUidMap() { uidMap.clear(); }
/** The imap account associated with this folder */
void setAccount(KMAcctCachedImap *acct);
KMAcctCachedImap* account() const;
/** Returns the filename of the uidcache file */
TQString uidCacheLocation() const;
/** Read the uidValitidy and lastUid values from disk */
int readUidCache();
/** Write the uidValitidy and lastUid values to disk */
int writeUidCache();
/** Current progress status (between 0 and 100) */
int progress() const { return mProgress; }
/* Reimplemented from KMFolder. Moving is not supported, so aParent must be 0 */
virtual int rename(const TQString& aName, KMFolderDir *aParent=0);
/**
* Reimplemented from KMFolderMaildir
* This deletes the message permanently, also from the server. For this, rememberDeletion() is
* called, so that the message can be deleted from the server on the next sync.
*/
virtual KMMessage* take(int idx);
/**
* Like take(), only that the deletion is not remembered, i.e. the message will not be deleted
* from the server.
* Calling this can cause inconsistencies, so make sure you re-add the message later!
*/
void takeTemporarily( int idx );
/* Reimplemented from KMFolderMaildir */
virtual int addMsg(KMMessage* msg, int* index_return = 0);
/* internal version that doesn't remove the X-UID header */
virtual int addMsgInternal(KMMessage* msg, bool, int* index_return = 0);
virtual int addMsgKeepUID(KMMessage* msg, int* index_return = 0) {
return addMsgInternal(msg, false, index_return);
}
/* Reimplemented from KMFolderMaildir */
virtual void removeMsg(int i, bool imapQuiet = false);
virtual void removeMsg(TQPtrList<KMMessage> msgList, bool imapQuiet = false)
{ FolderStorage::removeMsg(msgList, imapQuiet); }
/// Is the folder readonly?
bool isReadOnly() const { return KMFolderMaildir::isReadOnly() || mReadOnly; }
/**
* Emit the folderComplete signal
*/
void sendFolderComplete(bool success)
{ emit folderComplete(this, success); }
/**
* The silentUpload can be set to remove the folder upload error dialog
*/
void setSilentUpload( bool silent ) { mSilentUpload = silent; }
bool silentUpload() { return mSilentUpload; }
virtual int createIndexFromContents() {
const int result = KMFolderMaildir::createIndexFromContents();
reloadUidMap();
return result;
}
int createIndexFromContentsRecursive();
//virtual void holdSyncs( bool hold ) { mHoldSyncs = hold; }
/**
* List a directory and add the contents to kmfoldermgr
* It uses a ListJob to get the folders
* returns false if the connection failed
*/
virtual bool listDirectory();
virtual void listNamespaces();
/** Return the trash folder. */
KMFolder* trashFolder() const;
/**
* The user's rights on this folder - see bitfield in ACLJobs namespace.
* @return 0 when not known yet, -1 if there was an error fetching them
*/
int userRights() const { return mUserRights; }
/// Set the user's rights on this folder - called by getUserRights
void setUserRights( unsigned int userRights );
/**
* The quota information for this folder.
* @return an invalid info if we haven't synced yet, or the server
* doesn't support quota. The difference can be figured out by
* asking the account whether it supports quota. If we have
* synced, the account supports quota, but there is no quota
* on the folder, the return info will be valid, but empty.
* @see QuotaInfo::isEmpty(), QuotaInfo::isValid()
*/
const QuotaInfo quotaInfo() const { return mQuotaInfo; }
void setQuotaInfo( const QuotaInfo & );
/// Return the list of ACL for this folder
typedef TQValueVector<KMail::ACLListEntry> ACLList;
const ACLList& aclList() const { return mACLList; }
/// Set the list of ACL for this folder (for FolderDiaACLTab)
void setACLList( const ACLList& arr );
// Reimplemented so the mStatusChangedLocally bool can be set
virtual void setStatus( int id, KMMsgStatus status, bool toggle );
virtual void setStatus( TQValueList<int>& ids, KMMsgStatus status, bool toggle );
TQString annotationFolderType() const { return mAnnotationFolderType; }
// For kmailicalifaceimpl only
void updateAnnotationFolderType();
/// Free-busy and alarms relevance of this folder, i.e. for whom should
/// events in this calendar lead to "busy" periods in their freebusy lists,
/// and who should get alarms for the incidences in this folder.
/// Applies to Calendar and Task folders only.
///
/// IncForNobody: not relevant for free-busy and alarms to anybody
/// IncForAdmins: apply to persons with admin permissions on this calendar
/// IncForReaders: apply to all readers of this calendar
enum IncidencesFor { IncForNobody, IncForAdmins, IncForReaders };
IncidencesFor incidencesFor() const { return mIncidencesFor; }
/// For the folder properties dialog
void setIncidencesFor( IncidencesFor incfor );
/** Returns true if this folder can be moved */
virtual bool isMoveable() const;
/**
* List of namespaces that need to be queried
* Is set by the account for the root folder when the listing starts
*/
TQStringList namespacesToList() { return mNamespacesToList; }
void setNamespacesToList( TQStringList list ) { mNamespacesToList = list; }
/**
* Specify an imap path that is used to create the folder on the server
* Otherwise the parent folder is used to construct the path
*/
const TQString& imapPathForCreation() { return mImapPathCreation; }
void setImapPathForCreation( const TQString& path ) { mImapPathCreation = path; }
/** \reimp */
bool isCloseToQuota() const;
/** Flags that can be permanently stored on the server. */
int permanentFlags() const { return mPermanentFlags; }
TQString folderAttributes() const { return mFolderAttributes; }
protected slots:
void slotGetMessagesData(KIO::Job * job, const TQByteArray & data);
void getMessagesResult(KMail::FolderJob *, bool lastSet);
void slotGetLastMessagesResult(KMail::FolderJob *);
void slotProgress(unsigned long done, unsigned long total);
void slotPutProgress( unsigned long, unsigned long );
//virtual void slotCheckValidityResult(KIO::Job * job);
void slotSubFolderComplete(KMFolderCachedImap*, bool);
// Connected to the imap account
void slotConnectionResult( int errorCode, const TQString& errorMsg );
void slotCheckUidValidityResult( KMail::FolderJob* job );
void slotPermanentFlags( int flags );
void slotTestAnnotationResult(KIO::Job *job);
void slotGetAnnotationResult( KIO::Job* );
void slotMultiUrlGetAnnotationResult( KIO::Job* );
void slotSetAnnotationResult(KIO::Job *job);
void slotReceivedUserRights( KMFolder* );
void slotReceivedACL( KMFolder*, KIO::Job*, const KMail::ACLList& );
void slotMultiSetACLResult(KIO::Job *);
void slotACLChanged( const TQString&, int );
void slotAnnotationResult(const TQString& entry, const TQString& value, bool found);
void slotAnnotationChanged( const TQString& entry, const TQString& attribute, const TQString& value );
void slotDeleteMessagesResult(KMail::FolderJob *);
void slotImapStatusChanged(KMFolder* folder, const TQString&, bool);
void slotStorageQuotaResult( const QuotaInfo& );
void slotQuotaResult( KIO::Job* job );
protected:
/* returns true if there were messages to delete
on the server */
bool deleteMessages();
void listMessages();
void uploadNewMessages();
void uploadFlags();
void uploadSeenFlags();
void createNewFolders();
void listDirectory2();
void createFoldersNewOnServerAndFinishListing( const TQValueVector<int> foldersNewOnServer );
/** Utility methods for syncing. Finds new messages
in the local cache that must be uploaded */
virtual TQValueList<unsigned long> findNewMessages();
/** Utility methods for syncing. Finds new subfolders
in the local cache that must be created in the server */
virtual TQValueList<KMFolderCachedImap*> findNewFolders();
/** This returns false if we have subfolders. Otherwise it returns ::canRemoveFolder() */
virtual bool canRemoveFolder() const;
/** Reimplemented from KMFolder */
virtual FolderJob* doCreateJob( KMMessage *msg, FolderJob::JobType jt, KMFolder *folder,
TQString partSpecifier, const AttachmentStrategy *as ) const;
virtual FolderJob* doCreateJob( TQPtrList<KMMessage>& msgList, const TQString& sets,
FolderJob::JobType jt, KMFolder *folder ) const;
virtual void timerEvent( TQTimerEvent* );
/* update progress status */
void newState( int progress, const TQString& syncStatus );
/** See if there is a better parent then this folder */
KMFolderCachedImap* findParent( const TQString& path, const TQString& name );
public slots:
/**
* Add the data a KIO::Job retrieves to the buffer
*/
void slotSimpleData(KIO::Job * job, const TQByteArray & data);
/**
* Troubleshoot the IMAP cache
*/
void slotTroubleshoot();
/**
* Connected to ListJob::receivedFolders
* creates/removes folders
*/
void slotListResult( const TQStringList&, const TQStringList&,
const TQStringList&, const TQStringList&, const ImapAccountBase::jobData& );
/**
* Connected to ListJob::receivedFolders
* creates namespace folders
*/
void slotCheckNamespace( const TQStringList&, const TQStringList&,
const TQStringList&, const TQStringList&, const ImapAccountBase::jobData& );
private slots:
void serverSyncInternal();
void slotIncreaseProgress();
void slotUpdateLastUid();
void slotFolderDeletionOnServerFinished();
void slotRescueDone( KMCommand* command );
signals:
void folderComplete(KMFolderCachedImap *folder, bool success);
void listComplete( KMFolderCachedImap* );
/** emitted when we enter the state "state" and
have to process "number" items (for example messages
*/
void syncState( int state, int number );
private:
void setReadOnly( bool readOnly );
TQString state2String( int state ) const;
void rememberDeletion( int );
/** Rescue not yet synced messages to a lost+found folder in case
syncing is not possible because the folder has been deleted on the
server or write access to this folder has been revoked.
*/
KMCommand* rescueUnsyncedMessages();
/** Recursive helper function calling the above method. */
void rescueUnsyncedMessagesAndDeleteFolder( KMFolder *folder, bool root = true );
/** State variable for the synchronization mechanism */
enum {
SYNC_STATE_INITIAL,
SYNC_STATE_TEST_ANNOTATIONS,
SYNC_STATE_PUT_MESSAGES,
SYNC_STATE_UPLOAD_FLAGS,
SYNC_STATE_CREATE_SUBFOLDERS,
SYNC_STATE_LIST_NAMESPACES,
SYNC_STATE_LIST_SUBFOLDERS,
SYNC_STATE_LIST_SUBFOLDERS2,
SYNC_STATE_DELETE_SUBFOLDERS,
SYNC_STATE_LIST_MESSAGES,
SYNC_STATE_DELETE_MESSAGES,
SYNC_STATE_EXPUNGE_MESSAGES,
SYNC_STATE_GET_MESSAGES,
SYNC_STATE_HANDLE_INBOX,
SYNC_STATE_GET_USERRIGHTS,
SYNC_STATE_GET_ANNOTATIONS,
SYNC_STATE_SET_ANNOTATIONS,
SYNC_STATE_GET_ACLS,
SYNC_STATE_SET_ACLS,
SYNC_STATE_GET_QUOTA,
SYNC_STATE_FIND_SUBFOLDERS,
SYNC_STATE_SYNC_SUBFOLDERS,
SYNC_STATE_CHECK_UIDVALIDITY,
SYNC_STATE_RENAME_FOLDER
} mSyncState;
int mProgress;
int mStatusFlagsJobs;
TQString mUidValidity;
TQString mImapPath;
imapState mContentState, mSubfolderState;
TQStringList mSubfolderNames, mSubfolderPaths,
mSubfolderMimeTypes, mSubfolderAttributes;
TQString mFolderAttributes;
TQString mAnnotationFolderType;
IncidencesFor mIncidencesFor;
bool mHasInbox;
bool mIsSelected;
bool mCheckFlags;
bool mReadOnly;
mutable TQGuardedPtr<KMAcctCachedImap> mAccount;
TQIntDict<int> uidsOnServer;
TQValueList<ulong> uidsForDeletionOnServer;
TQValueList<KMail::CachedImapJob::MsgForDownload> mMsgsForDownload;
TQValueList<ulong> mUidsForDownload;
TQStringList foldersForDeletionOnServer;
TQValueList<KMFolderCachedImap*> mSubfoldersForSync;
KMFolderCachedImap* mCurrentSubfolder;
/** Mapping uid -> index
Keep updated in addMsg, take and removeMsg. This is used to lookup
whether a mail is present locally or not. */
TQMap<ulong,int> uidMap;
bool uidMapDirty;
void reloadUidMap();
int uidWriteTimer;
/** This is the last uid that we have seen from the server on the last
sync. It is crucially important that this is correct at all times
and not bumped up permaturely, as it is the watermark which is used
to discern message which are not present locally, because they were
deleted locally and now need to be deleted from the server,
from those which are new and need to be downloaded. Sucessfull
downloading of all pending mail from the server sets this. Between
invocations it is stored on disk in the uidcache file. It must not
change during a sync. */
ulong mLastUid;
/** The highest id encountered while syncing. Once the sync process has
successfully downloaded all pending mail and deleted on the server
all messages that were removed locally, this will become the new
mLastUid. See above for details. */
ulong mTentativeHighestUid;
/** Used to determine whether listing messages yielded a sensible result.
* Only then is the deletion o messages (which relies on succesful
* listing) attempted, during the sync. */
bool mFoundAnIMAPDigest;
int mUserRights, mOldUserRights;
ACLList mACLList;
bool mSilentUpload;
bool mFolderRemoved;
//bool mHoldSyncs;
bool mRecurse;
/** Set to true by setStatus. Indicates that the client has changed
the status of at least one mail. The mail flags will therefore be
uploaded to the server, overwriting the server's notion of the status
of the mails in this folder. */
bool mStatusChangedLocally;
/// Set to true when the foldertype annotation needs to be set on the next sync
bool mAnnotationFolderTypeChanged;
/// Set to true when the "incidences-for" annotation needs to be set on the next sync
bool mIncidencesForChanged;
TQStringList mNamespacesToList;
int mNamespacesToCheck;
bool mPersonalNamespacesCheckDone;
TQString mImapPathCreation;
QuotaInfo mQuotaInfo;
TQMap<ulong,void*> mDeletedUIDsSinceLastSync;
bool mAlarmsBlocked;
TQValueList<KMFolder*> mToBeDeletedAfterRescue;
int mRescueCommandCount;
int mPermanentFlags;
};
#endif /*kmfoldercachedimap_h*/
|