/*
    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 KNNETACCESS_H
#define KNNETACCESS_H

#include <tqobject.h>
#include <tqmutex.h>
#include <tqvaluelist.h>

class TQSocketNotifier;

namespace TDEIO {
  class Job;
}

namespace KPIM {
  class ProgressItem;
}
using KPIM::ProgressItem;

class KNJobData;
class KNNntpClient;


class KNNetAccess : public TQObject  {

  Q_OBJECT
  

  public:

    KNNetAccess(TQObject *parent=0, const char *name=0);
    ~KNNetAccess();

    void addJob(KNJobData *job);
    /** type==0 => all jobs */
    void stopJobsNntp(int type);
    /** type==0 => all jobs */
    void stopJobsSmtp(int type);
    void cancelAllJobs();

    /** current statusbar message */
    TQString currentMsg() const        { return currMsg; }

    TQMutex& nntpMutex() { return nntp_Mutex; }

  protected:
    /** passes a signal through the ipc-pipe to the net-thread */
    void triggerAsyncThread(int pipeFd);
    void startJobNntp();
    void startJobSmtp();
    void threadDoneNntp();
    void threadDoneSmtp();

    /** stores the current status message,
        so that it can be restored by the mainwindow */
    TQString currMsg;

    KNNntpClient *nntpClient;
    TQValueList<KNJobData*> nntpJobQueue, smtpJobQueue;
    KNJobData *currentNntpJob, *currentSmtpJob;
    TQMutex nntp_Mutex;
    int nntpInPipe[2], nntpOutPipe[2];
    TQSocketNotifier *nntpNotifier;

  protected slots:
    void slotThreadSignal(int i);

  signals:
    void netActive(bool);

  private:
    void cancelCurrentNntpJob( int type = 0 );
    void cancelCurrentSmtpJob( int type = 0 );
    /** Update activitiy status, i.e. emit netActive signal. */
    void updateStatus();

  private slots:
    void slotJobResult( TDEIO::Job *job );

    void slotCancelJob( KPIM::ProgressItem *item );

    void slotPasswordsChanged();

  private:
    /// jobs waiting for async wallet loading
    TQValueList<KNJobData*> mWalletQueue;

};

#endif