You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
143 lines
3.8 KiB
143 lines
3.8 KiB
/*
|
|
KNode, the KDE newsreader
|
|
Copyright (c) 1999-2005 the KNode authors.
|
|
See file AUTHORS for details
|
|
|
|
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.
|
|
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, US
|
|
*/
|
|
|
|
#ifndef KNJOBDATA_H
|
|
#define KNJOBDATA_H
|
|
|
|
#include <tqobject.h>
|
|
#include <tqvaluelist.h>
|
|
|
|
#include <libtdepim/progressmanager.h>
|
|
|
|
namespace TDEIO {
|
|
class Job;
|
|
}
|
|
|
|
class KNJobData;
|
|
class KNServerInfo;
|
|
|
|
|
|
class KNJobConsumer {
|
|
|
|
public:
|
|
KNJobConsumer();
|
|
virtual ~KNJobConsumer();
|
|
|
|
/** Send the job to KNNetAccess and append it to the
|
|
joblist */
|
|
void emitJob(KNJobData *j);
|
|
|
|
/** Remove the job from the joblist and process it by
|
|
calling @ref processJob */
|
|
void jobDone(KNJobData *j);
|
|
|
|
/** Returns true if we are waiting for at least one job
|
|
to be completed */
|
|
bool jobsPending() const { return !mJobs.isEmpty(); }
|
|
|
|
protected:
|
|
/** The actual work is done here */
|
|
virtual void processJob(KNJobData *j);
|
|
TQValueList<KNJobData*> mJobs;
|
|
|
|
};
|
|
|
|
|
|
class KNJobItem {
|
|
|
|
public:
|
|
KNJobItem() {}
|
|
virtual ~KNJobItem() {}
|
|
|
|
virtual bool isLocked() { return false; }
|
|
virtual void setLocked(bool) { }
|
|
|
|
virtual TQString prepareForExecution() { return TQString(); }
|
|
|
|
};
|
|
|
|
|
|
class KNJobData : public TQObject
|
|
{
|
|
TQ_OBJECT
|
|
|
|
|
|
public:
|
|
|
|
friend class KNJobConsumer;
|
|
|
|
enum jobType { JTLoadGroups=1,
|
|
JTFetchGroups,
|
|
JTCheckNewGroups,
|
|
JTfetchNewHeaders,
|
|
JTsilentFetchNewHeaders,
|
|
JTfetchArticle,
|
|
JTpostArticle,
|
|
JTmail,
|
|
JTfetchSource };
|
|
|
|
KNJobData(jobType t, KNJobConsumer *c, KNServerInfo *a, KNJobItem *i);
|
|
~KNJobData();
|
|
|
|
jobType type() const { return t_ype; }
|
|
|
|
bool net() const { return (t_ype!=JTLoadGroups); }
|
|
KNServerInfo* account() const { return a_ccount; }
|
|
KNJobItem* data() const { return d_ata; }
|
|
|
|
const TQString& errorString() const { return e_rrorString; }
|
|
bool success() const { return e_rrorString.isEmpty(); }
|
|
bool canceled() const { return c_anceled; }
|
|
bool authError() const { return a_uthError; }
|
|
|
|
void setErrorString(const TQString& s) { e_rrorString=s; }
|
|
void cancel();
|
|
void setAuthError(bool b) { a_uthError=b; }
|
|
|
|
void prepareForExecution() { e_rrorString = d_ata->prepareForExecution(); }
|
|
void notifyConsumer();
|
|
|
|
TDEIO::Job* job() const { return mJob; }
|
|
void setJob( TDEIO::Job *job );
|
|
|
|
KPIM::ProgressItem* progressItem() const { return mProgressItem; }
|
|
void createProgressItem();
|
|
|
|
// safe forwards to the progress item
|
|
void setStatus( const TQString &msg ) { if ( mProgressItem ) mProgressItem->setStatus( msg ); }
|
|
void setProgress( unsigned int progress ) { if ( mProgressItem ) mProgressItem->setProgress( progress ); }
|
|
void setComplete() { if ( mProgressItem ) { mProgressItem->setComplete(); mProgressItem = 0; } }
|
|
|
|
protected:
|
|
jobType t_ype;
|
|
KNJobItem *d_ata;
|
|
KNServerInfo *a_ccount;
|
|
TQString e_rrorString;
|
|
bool c_anceled;
|
|
bool a_uthError;
|
|
KNJobConsumer *c_onsumer;
|
|
|
|
private slots:
|
|
void slotJobPercent( TDEIO::Job *job, unsigned long percent );
|
|
void slotJobInfoMessage( TDEIO::Job *job, const TQString &msg );
|
|
|
|
private:
|
|
TDEIO::Job *mJob;
|
|
KPIM::ProgressItem *mProgressItem;
|
|
|
|
};
|
|
|
|
|
|
#endif
|