← Back to branch summary

~ubuntu-branches/ubuntu/quantal/psi/quantal

« back to all changes in this revision

Viewing changes to src/jabstream.h

  • Committer: Bazaar Package Importer
  • Author(s): Jan Niehusmann
  • Date: 2005-01-10 17:41:43 UTC
  • mfrom: (1.2.1 upstream) (2.1.2 hoary)
  • Revision ID: james.westby@ubuntu.com-20050110174143-ltocv5zapl6blf5d
Tags: 0.9.3-1
* New upstream release
* Cleaned up debian/rules (some things are done by upstream Makefiles now)
* Fixed some lintian warnings:
  - removed executable bit from some .png files
  - moved psi.desktop to /usr/share/applications
* Updated menu files

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/jabstream.h
1
 
/****************************************************************************
2
 
** jabstream.h - handles a Jabber XML stream
3
 
** Copyright (C) 2001, 2002  Justin Karneges
4
 
**
5
 
** This program is free software; you can redistribute it and/or
6
 
** modify it under the terms of the GNU General Public License
7
 
** as published by the Free Software Foundation; either version 2
8
 
** of the License, or (at your option) any later version.
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 Free Software
17
 
** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.
18
 
**
19
 
****************************************************************************/
20
 
 
21
 
#ifndef JABSTREAM_H
22
 
#define JABSTREAM_H
23
 
 
24
 
#include<qxml.h>
25
 
#include<qdom.h>
26
 
#include<qobject.h>
27
 
#include<qstring.h>
28
 
#include<qtimer.h>
29
 
#include<qptrstack.h>
30
 
#include<qptrqueue.h>
31
 
#include<qsocket.h>
32
 
#include"sslfilter.h"
33
 
 
34
 
 
35
 
#define JABSTREAM_ERR_DNS         0
36
 
#define JABSTREAM_ERR_CONNREFUSED 1
37
 
#define JABSTREAM_ERR_CONNTIMEOUT 2
38
 
#define JABSTREAM_ERR_DISC        3
39
 
#define JABSTREAM_ERR_SOCKET      4
40
 
#define JABSTREAM_ERR_HANDSHAKE   5
41
 
 
42
 
 
43
 
/****************************************************************************
44
 
  JabStream
45
 
 
46
 
  This class handles a Jabber XML stream.  It collects XML data into
47
 
  QDomElements and signals the chunks back to the caller.  There is no
48
 
  actual Jabber logic in this class.  It simply takes care of XML and
49
 
  a socket connection.
50
 
 
51
 
  HOWTO:
52
 
 
53
 
    JabStream stream;
54
 
    stream.connectToHost("jabber.org", 5222");
55
 
 
56
 
  The class communicates back to you via signals:
57
 
 
58
 
    connected()                       - connection success
59
 
    error(int)                        - connection/stream error
60
 
    packetReady(const QDomElement &)  - new XML chunk ready
61
 
 
62
 
****************************************************************************/
63
 
 
64
 
class JabXmlHandler : public QObject, public QXmlDefaultHandler
65
 
{
66
 
        Q_OBJECT
67
 
public:
68
 
        JabXmlHandler(QDomDocument *);
69
 
 
70
 
        // Xml functions (reimplemented)
71
 
        bool startDocument();
72
 
        bool startElement(const QString &, const QString &, const QString &, const QXmlAttributes &);
73
 
        bool endElement(const QString &, const QString &, const QString &);
74
 
        bool characters(const QString &);
75
 
 
76
 
        QString toLower(QString s);
77
 
 
78
 
signals:
79
 
        void packetReady(const QDomElement &);
80
 
        void handshake(bool, const QString &);
81
 
 
82
 
private:
83
 
        QString indent, characterData;
84
 
        int depth;
85
 
        QDomDocument *doc;
86
 
        QDomElement chunk, current;
87
 
};
88
 
 
89
 
 
90
 
class JabStream : public QObject
91
 
{
92
 
        Q_OBJECT
93
 
public:
94
 
        JabStream();
95
 
        ~JabStream();
96
 
 
97
 
        void connectToHost(const QString &host, int port);
98
 
        void disc();
99
 
        bool isConnected() { return v_isHandShaken; }
100
 
        QString id() { return v_id; }
101
 
 
102
 
        void setNoop(int);
103
 
 
104
 
        bool isSSLSupported();
105
 
        bool isSSLEnabled() { return use_ssl; }
106
 
        void setSSLEnabled(bool);
107
 
 
108
 
        static QCString encodeXML(QString);
109
 
        static QCString elemToString(const QDomElement &);
110
 
 
111
 
signals:
112
 
        void connected();
113
 
        void error(int);
114
 
        void receivePacket(const QDomElement &);
115
 
 
116
 
public slots:
117
 
        void sendPacket(const QDomElement &);
118
 
        void sendString(const QCString &);
119
 
 
120
 
private slots:
121
 
        // QSocket slots
122
 
        void sock_connected();
123
 
        void sock_disconnected();
124
 
        void sock_readyRead();
125
 
        void sock_error(int);
126
 
 
127
 
        // SSLFilter
128
 
        void ssl_outgoingReady();
129
 
        void ssl_readyRead();
130
 
        void ssl_error();
131
 
 
132
 
        // delayed functions so we can "get out" of a QSocket slot before continuing
133
 
        void delayedProcessError();
134
 
        void delayedProcessReceived();
135
 
        void delayedProcessHandShake();
136
 
 
137
 
        // prevent NAT/connection timeouts
138
 
        void doNoop();
139
 
 
140
 
        // JabXmlHandler slots
141
 
        void packetReady(const QDomElement &);
142
 
        void handshake(bool, const QString &);
143
 
 
144
 
private:
145
 
        QSocket *sock;
146
 
        SSLFilter *ssl;
147
 
        QDomDocument *doc;
148
 
        QXmlInputSource *src;
149
 
        QXmlSimpleReader *reader;
150
 
        JabXmlHandler *handler;
151
 
 
152
 
        QTimer *t;
153
 
        bool v_isConnected, v_isHandShaken, first_time;
154
 
        QString host;
155
 
        int port;
156
 
        bool use_ssl;
157
 
 
158
 
        int errType;
159
 
        int noop_time;
160
 
 
161
 
        QString v_id;
162
 
 
163
 
        QPtrQueue<QDomElement> in;
164
 
 
165
 
        void processIncomingData(const QByteArray &);
166
 
};
167
 
 
168
 
#endif