blob: ddfe9d9e03e28cf294dfef9d9b814598aaa28691 (
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
|
/*
* Copyright (C) 2008-2010 The QXmpp developers
*
* 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 "QXmppLogger.h"
#include "QXmppStanza.h"
class QDomElement;
class QXmppClient;
class QXmppConfiguration;
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 QXmppStreamPrivate;
class QXmppVersionIq;
class QXmppStream : public QObject
{
Q_OBJECT
public:
QXmppStream(QSslSocket *socket, QObject *parent);
~QXmppStream();
void connectToHost();
void disconnectFromHost();
bool isConnected() const;
bool sendData(const QByteArray&);
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&);
protected:
// Logging helpers
void debug(const QString&);
void info(const QString&);
void warning(const QString&);
// Overridable methods
virtual void handleStanza(const QDomElement &element);
virtual void handleStream(const QDomElement &element);
virtual bool sendStartStream();
virtual bool sendEndStream();
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:
QXmppDiscoveryIq capabilities() const;
void flushDataBuffer();
void parser(const QByteArray&);
void sendNonSASLAuth(bool plaintext);
void sendNonSASLAuthQuery();
void sendAuthDigestMD5ResponseStep1(const QString& challenge);
void sendAuthDigestMD5ResponseStep2();
void sendBindIQ();
void sendSessionIQ();
QXmppStreamPrivate * const d;
};
#endif // QXMPPSTREAM_H
|
