blob: de5a04a50cffdc2c5765ea95f0f9b756cb7ab3ae (
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
|
// SPDX-FileCopyrightText: 2016 Niels Ole Salscheider <niels_ole@salscheider-online.de>
//
// SPDX-License-Identifier: LGPL-2.1-or-later
#include "QXmppMamManager.h"
#include "QXmppClient.h"
#include "QXmppConstants_p.h"
#include "QXmppDataForm.h"
#include "QXmppMamIq.h"
#include "QXmppMessage.h"
#include "QXmppUtils.h"
#include <QDomElement>
/// \cond
QStringList QXmppMamManager::discoveryFeatures() const
{
// XEP-0313: Message Archive Management
return QStringList() << ns_mam;
}
bool QXmppMamManager::handleStanza(const QDomElement &element)
{
if (element.tagName() == "message") {
QDomElement resultElement = element.firstChildElement("result");
if (!resultElement.isNull() && resultElement.namespaceURI() == ns_mam) {
QDomElement forwardedElement = resultElement.firstChildElement("forwarded");
QString queryId = resultElement.attribute("queryid");
if (!forwardedElement.isNull() && forwardedElement.namespaceURI() == ns_forwarding) {
QDomElement messageElement = forwardedElement.firstChildElement("message");
QDomElement delayElement = forwardedElement.firstChildElement("delay");
if (!messageElement.isNull()) {
QXmppMessage message;
message.parse(messageElement);
if (!delayElement.isNull() && delayElement.namespaceURI() == ns_delayed_delivery) {
const QString stamp = delayElement.attribute("stamp");
message.setStamp(QXmppUtils::datetimeFromString(stamp));
}
emit archivedMessageReceived(queryId, message);
}
}
return true;
}
} else if (QXmppMamResultIq::isMamResultIq(element)) {
QXmppMamResultIq result;
result.parse(element);
emit resultsRecieved(result.id(), result.resultSetReply(), result.complete());
return true;
}
return false;
}
/// \endcond
/// Retrieves archived messages. For each received message, the
/// archiveMessageReceived() signal is emitted. Once all messages are received,
/// the resultsRecieved() signal is emitted. It returns a result set that can
/// be used to page through the results.
/// The number of results may be limited by the server.
///
/// \param to Optional entity that should be queried. Leave this empty to query
/// the local archive.
/// \param node Optional node that should be queried. This is used when querying
/// a pubsub node.
/// \param jid Optional JID to filter the results.
/// \param start Optional start time to filter the results.
/// \param end Optional end time to filter the results.
/// \param resultSetQuery Optional Result Set Management query. This can be used
/// to limit the number of results and to page through the
/// archive.
/// \return query id of the request. This can be used to associate the
/// corresponding resultsRecieved signal.
///
QString QXmppMamManager::retrieveArchivedMessages(const QString &to,
const QString &node,
const QString &jid,
const QDateTime &start,
const QDateTime &end,
const QXmppResultSetQuery &resultSetQuery)
{
QList<QXmppDataForm::Field> fields;
QXmppDataForm::Field hiddenField(QXmppDataForm::Field::HiddenField);
hiddenField.setKey("FORM_TYPE");
hiddenField.setValue(ns_mam);
fields << hiddenField;
if (!jid.isEmpty()) {
QXmppDataForm::Field jidField;
jidField.setKey("with");
jidField.setValue(jid);
fields << jidField;
}
if (start.isValid()) {
QXmppDataForm::Field startField;
startField.setKey("start");
startField.setValue(QXmppUtils::datetimeToString(start));
fields << startField;
}
if (end.isValid()) {
QXmppDataForm::Field endField;
endField.setKey("end");
endField.setValue(QXmppUtils::datetimeToString(end));
fields << endField;
}
QXmppDataForm form;
form.setType(QXmppDataForm::Submit);
form.setFields(fields);
QXmppMamQueryIq queryIq;
QString queryId = queryIq.id(); /* reuse the IQ id as query id */
queryIq.setTo(to);
queryIq.setNode(node);
queryIq.setQueryId(queryId);
queryIq.setForm(form);
queryIq.setResultSetQuery(resultSetQuery);
client()->sendPacket(queryIq);
return queryId;
}
|
