blob: 55dc7967e37c8b711f3a1136a1fc9b220694ff44 (
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
|
// SPDX-FileCopyrightText: 2009 Manjeet Dahiya <manjeetdahiya@gmail.com>
// SPDX-FileCopyrightText: 2010 Jeremy Lainé <jeremy.laine@m4x.org>
//
// SPDX-License-Identifier: LGPL-2.1-or-later
#ifndef QXMPPSTREAM_H
#define QXMPPSTREAM_H
#include "QXmppLogger.h"
#include "QXmppSendResult.h"
#include <memory>
#include <variant>
#include <QAbstractSocket>
#include <QObject>
class QDomElement;
template<typename T>
class QXmppTask;
template<typename T>
class QFuture;
template<typename T>
class QFutureInterface;
class QSslSocket;
class QXmppIq;
class QXmppNonza;
class QXmppPacket;
class QXmppStanza;
class QXmppStreamPrivate;
///
/// \brief The QXmppStream class is the base class for all XMPP streams.
///
class QXMPP_EXPORT QXmppStream : public QXmppLoggable
{
Q_OBJECT
public:
QXmppStream(QObject *parent);
~QXmppStream() override;
virtual bool isConnected() const;
bool sendPacket(const QXmppNonza &);
QXmppTask<QXmpp::SendResult> send(QXmppNonza &&);
QXmppTask<QXmpp::SendResult> send(QXmppPacket &&);
using IqResult = std::variant<QDomElement, QXmppError>;
QXmppTask<IqResult> sendIq(QXmppIq &&);
QXmppTask<IqResult> sendIq(QXmppPacket &&, const QString &id, const QString &to);
void cancelOngoingIqs();
bool hasIqId(const QString &id) const;
void resetPacketCache();
Q_SIGNALS:
/// This signal is emitted when the stream is connected.
void connected();
/// This signal is emitted when the stream is disconnected.
void disconnected();
protected:
// Access to underlying socket
QSslSocket *socket() const;
void setSocket(QSslSocket *socket);
// Overridable methods
virtual void handleStart();
/// Handles an incoming XMPP stanza.
///
/// \param element
virtual void handleStanza(const QDomElement &element) = 0;
/// Handles an incoming XMPP stream start.
///
/// \param element
virtual void handleStream(const QDomElement &element) = 0;
// XEP-0198: Stream Management
void enableStreamManagement(bool resetSequenceNumber);
unsigned int lastIncomingSequenceNumber() const;
void setAcknowledgedSequenceNumber(unsigned int sequenceNumber);
public Q_SLOTS:
virtual void disconnectFromHost();
virtual bool sendData(const QByteArray &);
private Q_SLOTS:
void _q_socketConnected();
void _q_socketEncrypted();
void _q_socketError(QAbstractSocket::SocketError error);
void _q_socketReadyRead();
private:
friend class QXmppStreamManager;
friend class tst_QXmppStream;
friend class TestClient;
QXmppTask<QXmpp::SendResult> send(QXmppPacket &&, bool &);
void processData(const QString &data);
bool handleIqResponse(const QDomElement &);
QXmppStreamPrivate *const d;
};
#endif // QXMPPSTREAM_H
|
