popaccount.h

#ifndef KMAcctExpPop_h
#define KMAcctExpPop_h
 
#include "networkaccount.h"
 
#include <tqvaluelist.h>
#include <tqstringlist.h>
#include <tqvaluevector.h>
#include <tqtimer.h>
#include <tqdict.h>
 
class KMPopHeaders;
class KMMessage;
class TQDataStream;
namespace TDEIO {
  class MetaData;
  class Slave;
  class SimpleJob;
  class Job;
}
 
namespace KMail {
class PopAccount: public NetworkAccount {
  TQ_OBJECT
  
 
public:
  virtual ~PopAccount();
  virtual void init(void);
 
  virtual TDEIO::MetaData slaveConfig() const;
 
  virtual void pseudoAssign( const KMAccount * a );
 
  virtual TQString protocol() const;
  virtual unsigned short int defaultPort() const;
 
  bool usePipelining(void) const { return mUsePipelining; }
  virtual void setUsePipelining(bool);
 
  bool leaveOnServer(void) const { return mLeaveOnServer; }
  virtual void setLeaveOnServer(bool);
 
  int leaveOnServerDays(void) const { return mLeaveOnServerDays; }
  virtual void setLeaveOnServerDays(int);
 
  int leaveOnServerCount(void) const { return mLeaveOnServerCount; }
  virtual void setLeaveOnServerCount(int);
 
  int leaveOnServerSize(void) const { return mLeaveOnServerSize; }
  virtual void setLeaveOnServerSize(int);
 
  bool filterOnServer(void) const { return mFilterOnServer; }
  virtual void setFilterOnServer(bool);
 
  unsigned int filterOnServerCheckSize(void) const { return mFilterOnServerCheckSize; }
  virtual void setFilterOnServerCheckSize(unsigned int);
 
  virtual TQString type(void) const;
  virtual void readConfig(TDEConfig&);
  virtual void writeConfig(TDEConfig&);
  virtual void processNewMail(bool _interactive);
 
  virtual void killAllJobs( bool disconnectSlave=false ); // NOOP currently
 
protected:
  enum Stage { Idle, List, Uidl, Head, Retr, Dele, Quit };
  friend class ::AccountManager;
  PopAccount(AccountManager* owner, const TQString& accountName, uint id);
 
  void startJob();
 
  void connectJob();
 
  void processRemainingQueuedMessages();
 
  void saveUidList();
 
  bool    mUsePipelining;
  bool    mLeaveOnServer;
  int     mLeaveOnServerDays;
  int     mLeaveOnServerCount;
  int     mLeaveOnServerSize;
  bool    gotMsgs;
  bool    mFilterOnServer;
  unsigned int mFilterOnServerCheckSize;
 
  TDEIO::SimpleJob *job;
  //Map of ID's vs. sizes of messages which should be downloaded
  TQMap<TQString, int> mMsgsPendingDownload;
 
  TQPtrList<KMPopHeaders> headersOnServer;
  TQPtrListIterator<KMPopHeaders> headerIt;
  bool headers;
 
  TQMap<TQString, bool> mHeaderDeleteUids;
  TQMap<TQString, bool> mHeaderDownUids;
  TQMap<TQString, bool> mHeaderLaterUids;
 
  TQStringList idsOfMsgs; //used for ids and for count
  TQValueList<int> lensOfMsgs;
  TQMap<TQString, TQString> mUidForIdMap; // maps message ID (i.e. index on the server) to UID
  TQDict<int> mUidsOfSeenMsgsDict; // set of UIDs of previously seen messages (for fast lookup)
  TQDict<int> mUidsOfNextSeenMsgsDict; // set of UIDs of seen messages (for the next check)
  TQValueVector<int> mTimeOfSeenMsgsVector; // list of times of previously seen messages
  TQMap<TQString, int> mTimeOfNextSeenMsgsMap; // map of uid to times of seen messages
  TQDict<int> mSizeOfNextSeenMsgsDict;
  TQStringList idsOfMsgsToDelete;
  TQStringList idsOfForcedDeletes;
  int indexOfCurrentMsg;
 
  TQValueList<KMMessage*> msgsAwaitingProcessing;
  TQStringList msgIdsAwaitingProcessing;
  TQStringList msgUidsAwaitingProcessing;
 
  TQByteArray curMsgData;
  TQDataStream *curMsgStrm;
 
  int curMsgLen;
  Stage stage;
  TQTimer processMsgsTimer;
  int processingDelay;
  int numMsgs, numBytes, numBytesToRead, numBytesRead, numMsgBytesRead;
  bool interactive;
  bool mProcessing;
  bool mUidlFinished;
  int dataCounter;
 
protected slots:
  void slotProcessPendingMsgs();
 
  void slotGetNextMsg();
 
  void slotMsgRetrieved(TDEIO::Job*, const TQString &);
 
  void slotData( TDEIO::Job*, const TQByteArray &);
 
  void slotResult( TDEIO::Job* );
 
  void slotCancel();
 
  void slotAbortRequested();
 
  void slotJobFinished();
 
  void slotSlaveError(TDEIO::Slave *, int, const TQString &);
 
  void slotGetNextHdr();
};
 
} // namespace KMail
 
 
 
#endif /*KMAcctExpPop_h*/