diff options
Diffstat (limited to 'src/coap/qcoapresourcediscoveryreply.cpp')
| -rw-r--r-- | src/coap/qcoapresourcediscoveryreply.cpp | 168 |
1 files changed, 168 insertions, 0 deletions
diff --git a/src/coap/qcoapresourcediscoveryreply.cpp b/src/coap/qcoapresourcediscoveryreply.cpp new file mode 100644 index 0000000..c709331 --- /dev/null +++ b/src/coap/qcoapresourcediscoveryreply.cpp @@ -0,0 +1,168 @@ +/**************************************************************************** +** +** Copyright (C) 2017 Witekio. +** Copyright (C) 2018 The Qt Company Ltd. +** Contact: https://www.qt.io/licensing/ +** +** This file is part of the QtCoap module. +** +** $QT_BEGIN_LICENSE:GPL$ +** Commercial License Usage +** Licensees holding valid commercial Qt licenses may use this file in +** accordance with the commercial license agreement provided with the +** Software or, alternatively, in accordance with the terms contained in +** a written agreement between you and The Qt Company. For licensing terms +** and conditions see https://www.qt.io/terms-conditions. For further +** information use the contact form at https://www.qt.io/contact-us. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU +** General Public License version 3 or (at your option) any later version +** approved by the KDE Free Qt Foundation. The licenses are as published by +** the Free Software Foundation and appearing in the file LICENSE.GPL3 +** included in the packaging of this file. Please review the following +** information to ensure the GNU General Public License requirements will +** be met: https://www.gnu.org/licenses/gpl-3.0.html. +** +** $QT_END_LICENSE$ +** +****************************************************************************/ + +#include "qcoapresourcediscoveryreply_p.h" +#include "qcoapinternalreply_p.h" +#include "qcoapnamespace_p.h" + +QT_BEGIN_NAMESPACE + +QCoapResourceDiscoveryReplyPrivate::QCoapResourceDiscoveryReplyPrivate(const QCoapRequest &request) : + QCoapReplyPrivate(request) +{ +} + +/*! + \internal + + Updates the QCoapResourceDiscoveryReply object, its message and list of resources + with data of the internal reply \a internalReply. +*/ +void QCoapResourceDiscoveryReplyPrivate::_q_setContent(const QHostAddress &sender, + const QCoapMessage &msg, + QtCoap::ResponseCode code) +{ + Q_Q(QCoapResourceDiscoveryReply); + + if (q->isFinished()) + return; + + message = msg; + responseCode = code; + + if (QtCoap::isError(responseCode)) { + _q_setError(responseCode); + } else { + auto res = QCoapResourceDiscoveryReplyPrivate::resourcesFromCoreLinkList(sender, + message.payload()); + resources.append(res); + emit q->discovered(q, res); + } +} + +/*! + \class QCoapResourceDiscoveryReply + \inmodule QtCoap + + \brief The QCoapResourceDiscoveryReply class holds the data of a CoAP reply + for a resource discovery request. + + \reentrant + + This class is used for discovery requests. It emits the discovered() + signal if and when resources are discovered. When using a multicast + address for discovery, the discovered() signal will be emitted once + for each response received. + + \note A QCoapResourceDiscoveryReply is a QCoapReply that stores also a list + of QCoapResources. + + \sa QCoapClient, QCoapRequest, QCoapReply, QCoapResource +*/ + +/*! + \fn void QCoapResourceDiscoveryReply::discovered(QCoapResourceDiscoveryReply *reply, + QVector<QCoapResource> resources); + + This signal is emitted whenever a CoAP resource is discovered. + + The \a reply parameter contains a pointer to the reply that has just been + received, and \a resources contains a list of resources that were discovered. + + \sa QCoapReply::finished() +*/ + +/*! + \internal + + Constructs a new CoAP discovery reply from the \a request and sets \a parent + as its parent. +*/ +QCoapResourceDiscoveryReply::QCoapResourceDiscoveryReply(const QCoapRequest &request, QObject *parent) : + QCoapReply(*new QCoapResourceDiscoveryReplyPrivate(request), parent) +{ +} + +/*! + Returns the list of resources. +*/ +QVector<QCoapResource> QCoapResourceDiscoveryReply::resources() const +{ + Q_D(const QCoapResourceDiscoveryReply); + return d->resources; +} + +/*! + \internal + + Decodes the \a data received from the \a sender to a list of QCoapResource + objects. The \a data byte array contains the frame returned by the + discovery request. +*/ +QVector<QCoapResource> +QCoapResourceDiscoveryReplyPrivate::resourcesFromCoreLinkList(const QHostAddress &sender, + const QByteArray &data) +{ + QVector<QCoapResource> resourceList; + + QLatin1String quote = QLatin1String("\""); + const QList<QByteArray> links = data.split(','); + for (QByteArray link : links) { + QCoapResource resource; + resource.setHost(sender); + + const QList<QByteArray> parameterList = link.split(';'); + for (QByteArray parameter : parameterList) { + QString parameterString = QString::fromUtf8(parameter); + int length = parameterString.length(); + if (parameter.startsWith('<')) + resource.setPath(parameterString.mid(1, length - 2)); + else if (parameter.startsWith("title=")) + resource.setTitle(parameterString.mid(6).remove(quote)); + else if (parameter.startsWith("rt=")) + resource.setResourceType(parameterString.mid(3).remove(quote)); + else if (parameter.startsWith("if=")) + resource.setInterface(parameterString.mid(3).remove(quote)); + else if (parameter.startsWith("sz=")) + resource.setMaximumSize(parameterString.mid(3).remove(quote).toInt()); + else if (parameter.startsWith("ct=")) + resource.setContentFormat(parameterString.mid(3).remove(quote).toUInt()); + else if (parameter == "obs") + resource.setObservable(true); + } + + if (!resource.path().isEmpty()) + resourceList.push_back(resource); + } + + return resourceList; +} + +QT_END_NAMESPACE |