Reset the MessageProcessor on disconnect
[quassel.git] / src / qtui / qtuimessageprocessor.h
1 /***************************************************************************
2 *   Copyright (C) 2005-08 by the Quassel Project                          *
3 *   devel@quassel-irc.org                                                 *
4 *                                                                         *
5 *   This program is free software; you can redistribute it and/or modify  *
6 *   it under the terms of the GNU General Public License as published by  *
7 *   the Free Software Foundation; either version 2 of the License, or     *
8 *   (at your option) version 3.                                           *
9 *                                                                         *
10 *   This program is distributed in the hope that it will be useful,       *
11 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
12 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
13 *   GNU General Public License for more details.                          *
14 *                                                                         *
15 *   You should have received a copy of the GNU General Public License     *
16 *   along with this program; if not, write to the                         *
17 *   Free Software Foundation, Inc.,                                       *
18 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
19 ***************************************************************************/
20
21 #ifndef QTUIMESSAGEPROCESSOR_H_
22 #define QTUIMESSAGEPROCESSOR_H_
23
24 #include <QTimer>
25
26 #include "abstractmessageprocessor.h"
27
28 class QtUiMessageProcessor : public AbstractMessageProcessor {
29   Q_OBJECT
30
31   public:
32     enum Mode {
33       TimerBased,
34       Concurrent
35     };
36
37     QtUiMessageProcessor(QObject *parent);
38
39     inline bool isProcessing() const { return _processing; }
40     inline Mode processMode() const { return _processMode; }
41
42     void reset();
43
44   public slots:
45     void process(Message &msg);
46     void process(QList<Message> &msgs);
47
48   private slots:
49     void processNextMessage();
50
51   private:
52     void checkForHighlight(Message &msg);
53     void startProcessing();
54
55     QList<QList<Message> > _processQueue;
56     QList<Message> _currentBatch;
57     QTimer _processTimer;
58     bool _processing;
59     Mode _processMode;
60 };
61
62 #endif