blob: f3e90e45388ca0ed3eb454e3df510220bebe148c (
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
|
/*
* 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 "QXmppConfiguration.h"
#include "QXmppRoster.h"
#include "QXmppStanza.h"
#include "QXmppVCardManager.h"
#include "QXmppArchiveManager.h"
#include "QXmppTransferManager.h"
class QDomElement;
class QXmppRoster;
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 QXmppVersionIq;
class QXmppStream : public QObject
{
Q_OBJECT
public:
QXmppStream(QXmppClient* client);
~QXmppStream();
void connect();
void acceptSubscriptionRequest(const QString& from, bool accept = true);
void sendSubscriptionRequest(const QString& to);
void disconnect();
QXmppArchiveManager& getArchiveManager();
QXmppRoster& getRoster();
QXmppTransferManager& getTransferManager();
QXmppVCardManager& getVCardManager();
void sendPacket(const QXmppPacket&);
QAbstractSocket::SocketError getSocketError();
QXmppClient::StreamError getXmppStreamError();
signals:
// socket host found
void hostFound();
// socket connected
void connected();
// socket disconnected
void disconnected();
// xmpp connected
void xmppConnected();
void error(QXmppClient::Error);
void subscriptionRequestReceived(const QString& from);
void presenceReceived(const QXmppPresence&);
void messageReceived(const QXmppMessage&);
void iqReceived(const QXmppIq&);
void rosterIqReceived(const QXmppRosterIq&);
void rosterRequestIqReceived(const QXmppRosterIq&);
void vCardIqReceived(const QXmppVCard&);
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 versionIqReceived(const QXmppVersionIq&);
void byteStreamIqReceived(const QXmppByteStreamIq&);
void ibbCloseIqReceived(const QXmppIbbCloseIq&);
void ibbDataIqReceived(const QXmppIbbDataIq&);
void ibbOpenIqReceived(const QXmppIbbOpenIq&);
void streamInitiationIqReceived(const QXmppStreamInitiationIq&);
private slots:
void socketHostFound();
void socketReadReady();
void socketEncrypted();
void socketConnected();
void socketDisconnected();
void socketError(QAbstractSocket::SocketError);
void socketSslErrors(const QList<QSslError>&);
private:
QXmppClient* m_client; // reverse pointer
QXmppRoster m_roster;
QString m_sessionId;
QString m_bindId;
QString m_rosterReqId;
QByteArray m_dataBuffer;
QSslSocket m_socket;
bool m_sessionAvaliable;
QAbstractSocket::SocketError m_socketError;
QString m_streamId;
QString m_nonSASLAuthId;
QString m_XMPPVersion;
QXmppClient::StreamError m_xmppStreamError;
// m_xmppStanzaError;
QXmppArchiveManager m_archiveManager;
QXmppTransferManager m_transferManager;
QXmppVCardManager m_vCardManager;
int m_authStep;
QXmppConfiguration& getConfiguration();
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 sendInitialPresence();
void sendRosterRequest();
void sendToServer(const QByteArray&);
bool hasStartStreamElement(const QByteArray&);
bool hasEndStreamElement(const QByteArray&);
void processPresence(const QXmppPresence&);
void processMessage(const QXmppMessage&);
void processIq(const QXmppIq&);
void processBindIq(const QXmppBind&);
void processRosterIq(const QXmppRosterIq&);
void flushDataBuffer();
};
#endif // QXMPPSTREAM_H
|
