ETM-Schurig
/
powersync-plugins
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
powersync-plugins/bosswerk/integrationpluginbosswerk.cpp

261 lines
11 KiB
C++
Raw Permalink Blame History

// SPDX-License-Identifier: GPL-3.0-or-later
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
*
* Copyright (C) 2013 - 2024, nymea GmbH
* Copyright (C) 2024 - 2025, chargebyte austria GmbH
*
* This file is part of nymea-plugins.
*
* nymea-plugins is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* nymea-plugins 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
* General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with nymea-plugins. If not, see <https://www.gnu.org/licenses/>.
*
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
#include "integrationpluginbosswerk.h"
#include "plugininfo.h"
#include <plugintimer.h>
#include <types/param.h>
#include <network/networkdevicediscovery.h>
#include <network/networkaccessmanager.h>
#include <network/networkdevicediscoveryreply.h>
#include <QNetworkReply>
#include <QAuthenticator>
#include <QUrlQuery>
#include <QJsonDocument>
#include <QMetaEnum>
IntegrationPluginBosswerk::IntegrationPluginBosswerk()
{
}
IntegrationPluginBosswerk::~IntegrationPluginBosswerk()
{
}
void IntegrationPluginBosswerk::discoverThings(ThingDiscoveryInfo *info)
{
m_discoveryCache.clear();
NetworkDeviceDiscoveryReply *discoveryReply = hardwareManager()->networkDeviceDiscovery()->discover();
// This device doesn't give much information without login credentials. In order to identify it we'll
// do an unauthorized GET call on it and compare the server header "HTTPD" as well as the static
// Unauthorized page which looks unique enough.
// If this proves to not be reliable enough, one more option would be to connect to TCP port 8899 which is open
// and responds to a proprietary binary protocol which would need to be reverse engineered first.
connect(discoveryReply, &NetworkDeviceDiscoveryReply::finished, discoveryReply, &NetworkDeviceDiscoveryReply::deleteLater);
connect(discoveryReply, &NetworkDeviceDiscoveryReply::hostAddressDiscovered, info, [this, info](const QHostAddress &address){
qCDebug(dcBosswerk()) << "Probing device" << address.toString();
QUrl url("http://" + address.toString() + "/status.html");
QNetworkRequest request(url);
QNetworkReply *probeReply = hardwareManager()->networkManager()->get(request);
connect(probeReply, &QNetworkReply::finished, probeReply, &QNetworkReply::deleteLater);
connect(probeReply, &QNetworkReply::finished, info, [probeReply, address, this](){
QByteArray data = probeReply->readAll();
qCDebug(dcBosswerk()) << "Probe reply from" << address.toString() << ":" << probeReply->rawHeaderPairs() << data;
if (probeReply->header(QNetworkRequest::ServerHeader) == "HTTPD" && data == "<HTML><HEAD><TITLE>401 Unauthorized</TITLE></HEAD>\n<BODY BGCOLOR=\"#cc9999\"><H4>401 Unauthorized</H4>\nAuthorization required.\n</BODY></HTML>\n") {
qCDebug(dcBosswerk()) << "Found bosswerk MI-300/600:" << address.toString();
// We get the discovery info once the network device discovery is finished.
m_discoveryCache.append(address);
}
});
});
connect(discoveryReply, &NetworkDeviceDiscoveryReply::finished, info, [this, info, discoveryReply](){
foreach (const QHostAddress &address, m_discoveryCache) {
NetworkDeviceInfo networkDeviceInfo = discoveryReply->networkDeviceInfos().get(address);
ThingDescriptor descriptor(mix00ThingClassId, "MI-300/600", networkDeviceInfo.hostName());
ParamList params;
params.append(Param(mix00ThingMacAddressParamTypeId, networkDeviceInfo.thingParamValueMacAddress()));
params.append(Param(mix00ThingHostNameParamTypeId, networkDeviceInfo.thingParamValueHostName()));
params.append(Param(mix00ThingAddressParamTypeId, networkDeviceInfo.thingParamValueAddress()));
Thing *existingThing = myThings().findByParams(params);
if (existingThing)
descriptor.setThingId(existingThing->id());
info->addThingDescriptor(descriptor);
}
m_discoveryCache.clear();
});
QTimer *timeout = new QTimer(info);
timeout->start(28000);
connect(timeout, &QTimer::timeout, info, [=](){
info->finish(Thing::ThingErrorNoError);
});
}
void IntegrationPluginBosswerk::startPairing(ThingPairingInfo *info)
{
info->finish(Thing::ThingErrorNoError, QT_TR_NOOP("Please enter your login credentials."));
}
void IntegrationPluginBosswerk::confirmPairing(ThingPairingInfo *info, const QString &username, const QString &secret)
{
MacAddress macAddress(info->params().paramValue(mix00ThingMacAddressParamTypeId).toString());
QString hostName(info->params().paramValue(mix00ThingHostNameParamTypeId).toString());
QHostAddress address(info->params().paramValue(mix00ThingAddressParamTypeId).toString());
NetworkDeviceInfos cache = hardwareManager()->networkDeviceDiscovery()->cache();
NetworkDeviceInfo networkDeviceInfo;
if (!macAddress.isNull()) {
networkDeviceInfo = cache.at(cache.indexFromMacAddress(macAddress).first());
} else if (!hostName.isEmpty()) {
networkDeviceInfo = cache.at(cache.indexFromHostName(hostName));
} else if (!address.isNull()) {
networkDeviceInfo = cache.get(address);
} else {
qCWarning(dcBosswerk()) << info->params() << "not found in network device cache.";
info->finish(Thing::ThingErrorItemNotFound, QT_TR_NOOP("An error happened in the network communication."));
return;
}
QUrl url("http://" + username + ":" + secret + "@" + networkDeviceInfo.address().toString() + "/status.html");
QNetworkRequest request(url);
qCDebug(dcBosswerk) << "Requesting" << request.url();
QNetworkReply *reply = hardwareManager()->networkManager()->get(request);
connect(reply, &QNetworkReply::finished, reply, &QNetworkReply::deleteLater);
connect(reply, &QNetworkReply::finished, info, [=](){
if (reply->error() != QNetworkReply::NoError) {
qCWarning(dcBosswerk()) << "Error logging in at inverter" << reply->error();
info->finish(Thing::ThingErrorAuthenticationFailure, QT_TR_NOOP("Failed to log in at the inverter."));
return;
}
QByteArray payload = reply->readAll();
qCDebug(dcBosswerk()) << "Reply data:" << payload;
pluginStorage()->beginGroup(info->thingId().toString());
pluginStorage()->setValue("username", username);
pluginStorage()->setValue("password", secret);
pluginStorage()->endGroup();
info->finish(Thing::ThingErrorNoError);
});
}
void IntegrationPluginBosswerk::setupThing(ThingSetupInfo *info)
{
Thing *thing = info->thing();
NetworkDeviceMonitor *monitor = m_deviceMonitors.take(thing);
if (monitor) {
hardwareManager()->networkDeviceDiscovery()->unregisterMonitor(monitor);
}
PluginTimer *timer = m_timers.take(thing);
if (timer) {
hardwareManager()->pluginTimerManager()->unregisterTimer(timer);
}
monitor = hardwareManager()->networkDeviceDiscovery()->registerMonitor(thing);
m_deviceMonitors.insert(thing, monitor);
timer = hardwareManager()->pluginTimerManager()->registerTimer(5);
m_timers.insert(thing, timer);
connect(monitor, &NetworkDeviceMonitor::reachableChanged, thing, [this, timer, thing](bool reachable) {
thing->setStateValue(mix00ConnectedStateTypeId, reachable);
if (reachable) {
timer->start();
pollDevice(thing);
} else {
timer->stop();
thing->setStateValue(mix00CurrentPowerStateTypeId, 0);
}
});
connect(timer, &PluginTimer::timeout, thing, [this, thing](){
if (m_deviceMonitors.value(thing)->reachable()) {
pollDevice(thing);
}
});
pollDevice(thing);
info->finish(Thing::ThingErrorNoError);
}
void IntegrationPluginBosswerk::thingRemoved(Thing *thing)
{
hardwareManager()->networkDeviceDiscovery()->unregisterMonitor(m_deviceMonitors.take(thing));
hardwareManager()->pluginTimerManager()->unregisterTimer(m_timers.take(thing));
}
void IntegrationPluginBosswerk::pollDevice(Thing *thing)
{
NetworkDeviceMonitor *monitor = m_deviceMonitors.value(thing);
pluginStorage()->beginGroup(thing->id().toString());
QString username = pluginStorage()->value("username").toString();
QString password = pluginStorage()->value("password").toString();
pluginStorage()->endGroup();
QUrl url("http://" + username + ":" + password + "@" + monitor->networkDeviceInfo().address().toString() + "/status.html");
qCDebug(dcBosswerk()) << "Requesting" << url.toString();
QNetworkRequest request(url);
QNetworkReply *statusReply = hardwareManager()->networkManager()->get(request);
connect(statusReply, &QNetworkReply::finished, statusReply, &QNetworkReply::deleteLater);
connect(statusReply, &QNetworkReply::finished, thing, [=](){
if (statusReply->error() != QNetworkReply::NoError) {
qCWarning(dcBosswerk) << "Error polling" << thing->name() << ":" << statusReply->error() << statusReply->errorString();
return;
}
QByteArray data = statusReply->readAll();
// qCDebug(dcBosswerk) << "Status:" << qUtf8Printable(data);
foreach (const QString &line, QString(data).split("\n")) {
if (line.startsWith("var ")) {
qCDebug(dcBosswerk()) << "Data line:" << line;
}
if (line.startsWith("var webdata_now_p")) {
bool ok;
double currentPower = line.split("\"").at(1).toDouble(&ok);
if (ok) {
thing->setStateValue(mix00CurrentPowerStateTypeId, -currentPower);
}
}
if (line.startsWith("var webdata_total_e")) {
bool ok;
double totalEnergyProduced = line.split("\"").at(1).toDouble(&ok);
if (ok && totalEnergyProduced != 0) { // When it's not producing anything, it will also give 0 for the total. Ignoring that...
thing->setStateValue(mix00TotalEnergyProducedStateTypeId, totalEnergyProduced);
}
}
if (line.startsWith("var cover_sta_rssi")) {
bool ok;
QString rssiString = line.split("\"").at(1);
rssiString.remove("%");
int rssi = rssiString.toInt(&ok);
if (ok) {
thing->setStateValue(mix00SignalStrengthStateTypeId, rssi);
}
}
}
});
}
Reference in New Issue View Git Blame Copy Permalink