blob: 419bcb1c6952086a9669d4bd33007daa211df0d1 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
/*
* Copyright (C) 2008-2010 Manjeet Dahiya
*
* Author:
* Manjeet Dahiya
*
* Source:
* http://code.google.com/p/qxmpp
*
* This file is a part of QXmpp library.
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
*/
#ifndef QXMPPSTREAM_H
#define QXMPPSTREAM_H
#include <QObject>
#include <QSslSocket>
#include "QXmppClient.h"
#include "QXmppConfiguration.h"
#include "QXmppLogger.h"
#include "QXmppStanza.h"
class QDomElement;
class QTimer;
class QXmppClient;
class QXmppPacket;
class QXmppPresence;
class QXmppIq;
class QXmppBind;
class QXmppRosterIq;
class QXmppVCard;
class QXmppMessage;
class QXmppRpcResponseIq;
class QXmppRpcErrorIq;
class QXmppArchiveChatIq;
class QXmppArchiveListIq;
class QXmppArchivePrefIq;
class QXmppByteStreamIq;
class QXmppDiscoveryIq;
class QXmppIbbCloseIq;
class QXmppIbbDataIq;
class QXmppIbbOpenIq;
class QXmppJingleIq;
class QXmppMucAdminIq;
class QXmppMucOwnerIq;
class QXmppStreamInitiationIq;
class QXmppVersionIq;
class QXmppStream : public QObject
{
Q_OBJECT
public:
QXmppStream(QObject *parent);
~QXmppStream();
void connect();
void acceptSubscriptionRequest(const QString& from, bool accept = true);
void sendSubscriptionRequest(const QString& to);
void disconnect();
bool isConnected() const;
bool sendPacket(const QXmppPacket&);
QAbstractSocket::SocketError socketError();
QXmppStanza::Error::Condition xmppStreamError();
QXmppConfiguration& configuration();
QXmppLogger *logger();
void setLogger(QXmppLogger *logger);
QXmppElementList presenceExtensions() const;
signals:
// socket host found
void hostFound();
// socket connected
void connected();
// socket disconnected
void disconnected();
// xmpp connected
void xmppConnected();
/// This signal is emitted to send logging messages.
void logMessage(QXmppLogger::MessageType type, const QString &msg);
void error(QXmppClient::Error);
void elementReceived(const QDomElement &element, bool &handled);
void presenceReceived(const QXmppPresence&);
void messageReceived(const QXmppMessage&);
void iqReceived(const QXmppIq&);
void rosterIqReceived(const QXmppRosterIq&);
void vCardIqReceived(const QXmppVCard&);
void rpcCallInvoke(const QXmppRpcInvokeIq &invoke);
void rpcCallResponse(const QXmppRpcResponseIq& result);
void rpcCallError(const QXmppRpcErrorIq &err);
void archiveChatIqReceived(const QXmppArchiveChatIq&);
void archiveListIqReceived(const QXmppArchiveListIq&);
void archivePrefIqReceived(const QXmppArchivePrefIq&);
void discoveryIqReceived(const QXmppDiscoveryIq&);
void byteStreamIqReceived(const QXmppByteStreamIq&);
void ibbCloseIqReceived(const QXmppIbbCloseIq&);
void ibbDataIqReceived(const QXmppIbbDataIq&);
void ibbOpenIqReceived(const QXmppIbbOpenIq&);
void streamInitiationIqReceived(const QXmppStreamInitiationIq&);
// XEP-0045: Multi-User Chat
void mucAdminIqReceived(const QXmppMucAdminIq&);
void mucOwnerIqReceived(const QXmppMucOwnerIq&);
// XEP-0166: Jingle
void jingleIqReceived(const QXmppJingleIq&);
private slots:
void socketHostFound();
void socketReadReady();
void socketEncrypted();
void socketConnected();
void socketDisconnected();
void socketError(QAbstractSocket::SocketError);
void socketSslErrors(const QList<QSslError>&);
void pingStart();
void pingStop();
void pingSend();
void pingTimeout();
private:
QXmppConfiguration m_config; ///< This object provides the configuration
///< required for connecting to the XMPP server.
QXmppLogger* m_logger;
QString m_sessionId;
QString m_bindId;
QByteArray m_dataBuffer;
QSslSocket m_socket;
bool m_sessionAvailable;
QAbstractSocket::SocketError m_socketError;
QString m_streamId;
QString m_nonSASLAuthId;
QString m_XMPPVersion;
QXmppStanza::Error::Condition m_xmppStreamError;
QTimer *m_pingTimer;
QTimer *m_timeoutTimer;
int m_authStep;
QXmppDiscoveryIq capabilities() const;
void debug(const QString&);
void info(const QString&);
void warning(const QString&);
void parser(const QByteArray&);
void sendStartStream();
void sendEndStream();
void sendStartTls();
void sendNonSASLAuth(bool);
void sendNonSASLAuthQuery( const QString &to );
void sendAuthPlain();
void sendAuthDigestMD5();
void sendAuthDigestMD5ResponseStep1(const QString& challenge);
void sendAuthDigestMD5ResponseStep2();
void sendBindIQ();
void sendSessionIQ();
void sendRosterRequest();
bool sendToServer(const QByteArray&);
bool hasStartStreamElement(const QByteArray&);
bool hasEndStreamElement(const QByteArray&);
void flushDataBuffer();
};
#endif // QXMPPSTREAM_H
|
