267 lines
11 KiB
C++
267 lines
11 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
* *
|
|
* Copyright (C) 2019 Bernhard Trinnes <bernhard.trinnes@nymea.io> *
|
|
* Copyright (C) 2018 Simon Stürz <simon.stuerz@nymea.io> *
|
|
* *
|
|
* This file is part of nymea. *
|
|
* *
|
|
* 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. *
|
|
* *
|
|
* You should have received a copy of the GNU Lesser General Public *
|
|
* License along with this library; If not, see *
|
|
* <http://www.gnu.org/licenses/>. *
|
|
* *
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#include "devicepluginhttpcommander.h"
|
|
#include "network/networkaccessmanager.h"
|
|
#include "plugininfo.h"
|
|
#include <QNetworkInterface>
|
|
|
|
DevicePluginHttpCommander::DevicePluginHttpCommander()
|
|
{
|
|
}
|
|
|
|
void DevicePluginHttpCommander::setupDevice(DeviceSetupInfo *info)
|
|
{
|
|
Device *device = info->device();
|
|
qDebug(dcHttpCommander()) << "Setup device" << device->name() << device->params();
|
|
|
|
if(!m_pluginTimer) {
|
|
m_pluginTimer = hardwareManager()->pluginTimerManager()->registerTimer(60);
|
|
connect(m_pluginTimer, &PluginTimer::timeout, this, &DevicePluginHttpCommander::onPluginTimer);
|
|
}
|
|
|
|
if (device->deviceClassId() == httpGetCommanderDeviceClassId) {
|
|
QUrl url = device->paramValue(httpGetCommanderDeviceUrlParamTypeId).toUrl();
|
|
if (!url.isValid()) {
|
|
qDebug(dcHttpCommander()) << "Given URL is not valid";
|
|
//: Error setting up device
|
|
return info->finish(Device::DeviceErrorInvalidParameter, QT_TR_NOOP("The given url is not valid."));
|
|
}
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
|
|
if (device->deviceClassId() == httpPutCommanderDeviceClassId) {
|
|
QUrl url = device->paramValue(httpPutCommanderDeviceUrlParamTypeId).toUrl();
|
|
if (!url.isValid()) {
|
|
qDebug(dcHttpCommander()) << "Given URL is not valid";
|
|
//: Error setting up device
|
|
return info->finish(Device::DeviceErrorInvalidParameter, QT_TR_NOOP("The given url is not valid."));
|
|
}
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
|
|
if (device->deviceClassId() == httpPostCommanderDeviceClassId) {
|
|
QUrl url = device->paramValue(httpPostCommanderDeviceUrlParamTypeId).toUrl();
|
|
if (!url.isValid()) {
|
|
qDebug(dcHttpCommander()) << "Given URL is not valid";
|
|
//: Error setting up device
|
|
return info->finish(Device::DeviceErrorInvalidParameter, QT_TR_NOOP("The given url is not valid."));
|
|
}
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
|
|
if (device->deviceClassId() == httpServerDeviceClassId) {
|
|
|
|
HttpSimpleServer *httpSimpleServer = new HttpSimpleServer(this);
|
|
connect(httpSimpleServer, &HttpSimpleServer::requestReceived, this, &DevicePluginHttpCommander::onHttpSimpleServerRequestReceived);
|
|
m_httpSimpleServer.insert(device, httpSimpleServer);
|
|
|
|
QString interfaces;
|
|
foreach (const QNetworkInterface &interface, QNetworkInterface::allInterfaces()) {
|
|
foreach (QNetworkAddressEntry entry, interface.addressEntries()) {
|
|
if (entry.ip().protocol() == QAbstractSocket::IPv4Protocol && entry.ip().toString() != "127.0.0.1") {
|
|
interfaces.append(entry.ip().toString());
|
|
}
|
|
}
|
|
}
|
|
device->setStateValue(httpServerServerAddressStateTypeId, interfaces);
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
|
|
|
|
void DevicePluginHttpCommander::postSetupDevice(Device *device)
|
|
{
|
|
if (device->deviceClassId() == httpGetCommanderDeviceClassId) {
|
|
makeGetCall(device);
|
|
}
|
|
}
|
|
|
|
|
|
void DevicePluginHttpCommander::executeAction(DeviceActionInfo *info)
|
|
{
|
|
Device *device = info->device();
|
|
Action action = info->action();
|
|
|
|
if (device->deviceClassId() == httpPostCommanderDeviceClassId) {
|
|
|
|
if (action.actionTypeId() == httpPostCommanderPostActionTypeId) {
|
|
QUrl url = device->paramValue(httpPostCommanderDeviceUrlParamTypeId).toUrl();
|
|
url.setPort(device->paramValue(httpPostCommanderDevicePortParamTypeId).toInt());
|
|
QByteArray payload = action.param(httpPostCommanderPostActionDataParamTypeId).value().toByteArray();
|
|
|
|
QNetworkReply *reply = hardwareManager()->networkManager()->post(QNetworkRequest(url), payload);
|
|
connect(reply, &QNetworkReply::finished, this, &DevicePluginHttpCommander::onPostRequestFinished);
|
|
|
|
m_httpRequests.insert(reply, device);
|
|
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
return info->finish(Device::DeviceErrorActionTypeNotFound);
|
|
}
|
|
|
|
if (device->deviceClassId() == httpPutCommanderDeviceClassId) {
|
|
|
|
// check if this is the "press" action
|
|
if (action.actionTypeId() == httpPutCommanderPutActionTypeId) {
|
|
QUrl url = device->paramValue(httpPutCommanderDeviceUrlParamTypeId).toUrl();
|
|
url.setPort(device->paramValue(httpPutCommanderDevicePortParamTypeId).toInt());
|
|
QByteArray payload = action.param(httpPutCommanderPutActionDataParamTypeId).value().toByteArray();
|
|
|
|
QNetworkReply *reply = hardwareManager()->networkManager()->put(QNetworkRequest(url), payload);
|
|
connect(reply, &QNetworkReply::finished, this, &DevicePluginHttpCommander::onPutRequestFinished);
|
|
|
|
m_httpRequests.insert(reply, device);
|
|
|
|
return info->finish(Device::DeviceErrorNoError);
|
|
}
|
|
}
|
|
return info->finish(Device::DeviceErrorDeviceClassNotFound);
|
|
}
|
|
|
|
void DevicePluginHttpCommander::makeGetCall(Device *device)
|
|
{
|
|
QUrl url = device->paramValue(httpGetCommanderDeviceUrlParamTypeId).toUrl();
|
|
url.setPort(device->paramValue(httpGetCommanderDevicePortParamTypeId).toInt());
|
|
QNetworkRequest request;
|
|
request.setUrl(url);
|
|
request.setRawHeader("User-Agent", "nymea http commander");
|
|
|
|
QNetworkReply *reply = hardwareManager()->networkManager()->get(request);
|
|
connect(reply, &QNetworkReply::finished, this, &DevicePluginHttpCommander::onGetRequestFinished);
|
|
|
|
m_httpRequests.insert(reply, device);
|
|
}
|
|
|
|
void DevicePluginHttpCommander::onPluginTimer()
|
|
{
|
|
foreach (Device *device, myDevices()) {
|
|
if (device->deviceClassId() == httpGetCommanderDeviceClassId) {
|
|
makeGetCall(device);
|
|
}
|
|
}
|
|
}
|
|
|
|
void DevicePluginHttpCommander::onGetRequestFinished()
|
|
{
|
|
QNetworkReply *reply = static_cast<QNetworkReply *>(sender());
|
|
qDebug(dcHttpCommander()) << "GET reply finished";
|
|
QByteArray data = reply->readAll();
|
|
int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
|
|
|
if (!m_httpRequests.contains(reply)) {
|
|
reply->deleteLater();
|
|
return;
|
|
}
|
|
|
|
Device *device = m_httpRequests.take(reply);
|
|
device->setStateValue(httpGetCommanderResponseStateTypeId, data);
|
|
device->setStateValue(httpGetCommanderStatusStateTypeId, true);
|
|
|
|
// Check HTTP status code
|
|
if (status != 200 || reply->error() != QNetworkReply::NoError) {
|
|
qCWarning(dcHttpCommander()) << "Request error:" << status << reply->errorString();
|
|
}
|
|
reply->deleteLater();
|
|
}
|
|
|
|
void DevicePluginHttpCommander::onPostRequestFinished()
|
|
{
|
|
QNetworkReply *reply = static_cast<QNetworkReply *>(sender());
|
|
qDebug(dcHttpCommander()) << "POST reply finished";
|
|
QByteArray data = reply->readAll();
|
|
int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
|
|
|
if (!m_httpRequests.contains(reply)) {
|
|
reply->deleteLater();
|
|
return;
|
|
}
|
|
|
|
Device *device = m_httpRequests.take(reply);
|
|
device->setStateValue(httpPostCommanderResponseStateTypeId, data);
|
|
device->setStateValue(httpPostCommanderStatusStateTypeId, status);
|
|
|
|
// Check HTTP status code
|
|
if (status != 200 || reply->error() != QNetworkReply::NoError) {
|
|
qCWarning(dcHttpCommander()) << "Request error:" << status << reply->errorString();
|
|
}
|
|
reply->deleteLater();
|
|
}
|
|
|
|
void DevicePluginHttpCommander::onPutRequestFinished()
|
|
{
|
|
QNetworkReply *reply = static_cast<QNetworkReply *>(sender());
|
|
qDebug(dcHttpCommander()) << "PUT reply finished";
|
|
QByteArray data = reply->readAll();
|
|
int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
|
|
|
if (!m_httpRequests.contains(reply)) {
|
|
reply->deleteLater();
|
|
return;
|
|
}
|
|
|
|
Device *device = m_httpRequests.take(reply);
|
|
device->setStateValue(httpPutCommanderResponseStateTypeId, data);
|
|
device->setStateValue(httpPutCommanderStatusStateTypeId, status);
|
|
|
|
// Check HTTP status code
|
|
if (status != 200 || reply->error() != QNetworkReply::NoError) {
|
|
qCWarning(dcHttpCommander()) << "Request error:" << status << reply->errorString();
|
|
}
|
|
reply->deleteLater();
|
|
}
|
|
|
|
void DevicePluginHttpCommander::onHttpSimpleServerRequestReceived(const QString &type, const QString &path, const QString &body)
|
|
{
|
|
//qCDebug(dcHttpCommander()) << "Request recieved" << type << body;
|
|
HttpSimpleServer *httpServer = static_cast<HttpSimpleServer *>(sender());
|
|
Device *device = m_httpSimpleServer.key(httpServer);
|
|
Event ev = Event(httpServerTriggeredEventTypeId, device->id());
|
|
ParamList params;
|
|
params.append(Param(httpServerTriggeredEventRequestTypeParamTypeId, type));
|
|
params.append(Param(httpServerTriggeredEventPathParamTypeId, path));
|
|
params.append(Param(httpServerTriggeredEventBodyParamTypeId, body));
|
|
ev.setParams(params);
|
|
emit emitEvent(ev);
|
|
}
|
|
|
|
|
|
void DevicePluginHttpCommander::deviceRemoved(Device *device)
|
|
{
|
|
if ((device->deviceClassId() == httpPostCommanderDeviceClassId) ||
|
|
(device->deviceClassId() == httpPutCommanderDeviceClassId) ||
|
|
(device->deviceClassId() == httpGetCommanderDeviceClassId)) {
|
|
|
|
while (m_httpRequests.values().contains(device)) {
|
|
QNetworkReply *reply = m_httpRequests.key(device);
|
|
m_httpRequests.remove(reply);
|
|
reply->deleteLater();
|
|
}
|
|
}
|
|
|
|
if (myDevices().empty()) {
|
|
hardwareManager()->pluginTimerManager()->unregisterTimer(m_pluginTimer);
|
|
}
|
|
}
|